Skip to content

Commit 3626b6b

Browse files
committed
Fix based on cr
1 parent 51300d9 commit 3626b6b

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/utils/FactoryDiscoveryUtils.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,10 +20,11 @@
2020
import org.apache.flink.cdc.common.annotation.Internal;
2121
import org.apache.flink.cdc.common.factories.Factory;
2222

23-
import org.codehaus.commons.nullanalysis.NotNull;
2423
import org.slf4j.Logger;
2524
import org.slf4j.LoggerFactory;
2625

26+
import javax.annotation.Nonnull;
27+
2728
import java.net.URL;
2829
import java.nio.file.Files;
2930
import java.nio.file.Paths;
@@ -43,7 +44,7 @@ public class FactoryDiscoveryUtils {
4344
private FactoryDiscoveryUtils() {}
4445

4546
/** Returns the {@link Factory} for the given identifier. */
46-
@NotNull
47+
@Nonnull
4748
@SuppressWarnings("unchecked")
4849
public static <T extends Factory> T getFactoryByIdentifier(
4950
String identifier, Class<T> factoryClass) {

0 commit comments

Comments
 (0)