xuyangzhong commented on code in PR #26668: URL: https://github.com/apache/flink/pull/26668#discussion_r2153939397
########## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AsyncLookupJoinITCase.scala: ########## @@ -19,34 +19,39 @@ package org.apache.flink.table.planner.runtime.stream.sql import org.apache.flink.core.testutils.FlinkAssertions.anyCauseMatches import org.apache.flink.table.api._ -import org.apache.flink.table.api.bridge.scala._ +import org.apache.flink.table.api.bridge.scala.tableConversions import org.apache.flink.table.api.config.{ExecutionConfigOptions, OptimizerConfigOptions} import org.apache.flink.table.api.config.ExecutionConfigOptions.AsyncOutputMode import org.apache.flink.table.connector.source.lookup.LookupOptions import org.apache.flink.table.data.GenericRowData import org.apache.flink.table.data.binary.BinaryStringData import org.apache.flink.table.planner.factories.TestValuesTableFactory -import org.apache.flink.table.planner.runtime.utils.{StreamingWithStateTestBase, TestingAppendSink, TestingRetractSink} +import org.apache.flink.table.planner.factories.TestValuesTableFactory.changelogRow +import org.apache.flink.table.planner.runtime.utils.{StreamingWithStateTestBase, TestingRetractSink} import org.apache.flink.table.planner.runtime.utils.StreamingWithStateTestBase.{HEAP_BACKEND, ROCKSDB_BACKEND, StateBackendMode} import org.apache.flink.table.planner.runtime.utils.UserDefinedFunctionTestUtils._ import org.apache.flink.table.runtime.functions.table.lookup.LookupCacheManager import org.apache.flink.testutils.junit.extensions.parameterized.{ParameterizedTestExtension, Parameters} import org.apache.flink.types.Row import org.assertj.core.api.Assertions.{assertThat, assertThatIterable, assertThatThrownBy} +import org.junit.Assume.assumeTrue Review Comment: use junit 5 ########## flink-table/flink-table-runtime/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 Review Comment: revert these changes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org