[FLINK-33777] Fix ParquetTimestampITCase>FsStreamingSinkITCaseBase fa…

…iling
apache · Dec 8, 2023 · 0e515dc · 0e515dc
1 parent ca72f63
commit 0e515dc
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 13 deletions.
diff --git a/.../flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java b/.../flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java
@@ -181,7 +181,7 @@ public DataStream<Row> getDataStream2(Function1<Row, Object> fun) {
                                             Types.STRING,
                                             Types.STRING
                                         },
-                                        new String[] {"a", "b", "c", "d", "e"})));
+                                        new String[] {"f0", "f1", "f2", "f3", "f4"})));
     }
 
     @Override
@@ -198,7 +198,7 @@ public DataStream<Row> getDataStream(Function1<Row, Object> fun) {
                                             Types.STRING,
                                             Types.STRING
                                         },
-                                        new String[] {"a", "b", "c", "d", "e"})));
+                                        new String[] {"f0", "f1", "f2", "f3", "f4"})));
     }
 
     @Override

diff --git a/.../test/scala/org/apache/flink/table/planner/runtime/stream/FsStreamingSinkITCaseBase.scala b/.../test/scala/org/apache/flink/table/planner/runtime/stream/FsStreamingSinkITCaseBase.scala
@@ -25,8 +25,6 @@ import org.apache.flink.streaming.api.CheckpointingMode
 import org.apache.flink.streaming.api.functions.source.SourceFunction
 import org.apache.flink.streaming.api.scala.DataStream
 import org.apache.flink.streaming.api.watermark.Watermark
-import org.apache.flink.table.api.{DataTypes, Schema}
-import org.apache.flink.table.api.Expressions.$
 import org.apache.flink.table.data.TimestampData
 import org.apache.flink.table.planner.runtime.utils.{StreamingTestBase, TestSinkUtil}
 import org.apache.flink.testutils.junit.utils.TempDirUtils
@@ -176,15 +174,7 @@ abstract class FsStreamingSinkITCaseBase extends StreamingTestBase {
 
     tEnv.createTemporaryView(
       "my_table",
-      dataStream,
-      Schema
-        .newBuilder()
-        .column("f0", DataTypes.INT())
-        .column("f1", DataTypes.STRING())
-        .column("f2", DataTypes.STRING())
-        .column("f3", DataTypes.STRING())
-        .column("f4", DataTypes.STRING())
-        .build()
+      dataStream
     )
 
     val ddl: String = getDDL(