diff --git a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala index 2a61be84becdb6..5b78fee1044a82 100644 --- a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala +++ b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/StreamFileSystemITCaseBase.scala @@ -26,7 +26,7 @@ import org.apache.flink.table.planner.runtime.utils.{StreamingTestBase, TestSink import org.apache.flink.types.Row import org.junit.Assert.assertEquals -import org.junit.Before +import org.junit.{Before, Test} import scala.collection.Seq @@ -55,4 +55,8 @@ abstract class StreamFileSystemITCaseBase extends StreamingTestBase with FileSys expectedResult.map(TestSinkUtil.rowToString(_)).sorted, sink.getAppendResults.sorted) } + + // Streaming mode not support overwrite + @Test + override def testInsertOverwrite(): Unit = {} }