diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java index 78340b246ee1..9662a3bb477f 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalIndexAssigner.java @@ -23,6 +23,7 @@ import org.apache.paimon.data.BinaryRow; import org.apache.paimon.data.InternalRow; import org.apache.paimon.data.serializer.RowCompactedSerializer; +import org.apache.paimon.flink.RocksDBOptions; import org.apache.paimon.flink.lookup.RocksDBStateFactory; import org.apache.paimon.flink.lookup.RocksDBValueState; import org.apache.paimon.options.Options; @@ -106,14 +107,13 @@ public void open(File tmpDir, int numAssigners, int assignId, BiConsumer(BinaryRow::copy); this.bucketAssigner = new BucketAssigner(); diff --git a/paimon-flink/paimon-flink-common/src/test/resources/log4j2-test.properties b/paimon-flink/paimon-flink-common/src/test/resources/log4j2-test.properties index 1b3980d15104..e27922dad60b 100644 --- a/paimon-flink/paimon-flink-common/src/test/resources/log4j2-test.properties +++ b/paimon-flink/paimon-flink-common/src/test/resources/log4j2-test.properties @@ -18,7 +18,7 @@ # Set root logger level to OFF to not flood build logs # set manually to INFO for debugging purposes -rootLogger.level = OFF +rootLogger.level = INFO rootLogger.appenderRef.test.ref = TestLogger appender.testlogger.name = TestLogger