(flink) 02/02: [FLINK-33777] Fix ParquetTimestampITCase>FsStreamingSinkITCaseBase failing

[dwysakowicz]

This is an automated email from the ASF dual-hosted git repository.

dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 0e515dce78832dbbbf5fce9c8cdd113bbb62cdf0
Author: Sergey Nuyanzin <snuyan...@gmail.com>
AuthorDate: Fri Dec 8 08:51:38 2023 +0100

    [FLINK-33777] Fix ParquetTimestampITCase>FsStreamingSinkITCaseBase failing
---
 .../apache/flink/formats/parquet/ParquetTimestampITCase.java |  4 ++--
 .../planner/runtime/stream/FsStreamingSinkITCaseBase.scala   | 12 +-----------
 2 files changed, 3 insertions(+), 13 deletions(-)

diff --git 
a/flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java
 
b/flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java
index ed267d329d0..90c130e22f5 100644
--- 
a/flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java
+++ 
b/flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTimestampITCase.java
@@ -181,7 +181,7 @@ public class ParquetTimestampITCase extends 
FsStreamingSinkITCaseBase {
                                             Types.STRING,
                                             Types.STRING
                                         },
-                                        new String[] {"a", "b", "c", "d", 
"e"})));
+                                        new String[] {"f0", "f1", "f2", "f3", 
"f4"})));
     }
 
     @Override
@@ -198,7 +198,7 @@ public class ParquetTimestampITCase extends 
FsStreamingSinkITCaseBase {
                                             Types.STRING,
                                             Types.STRING
                                         },
-                                        new String[] {"a", "b", "c", "d", 
"e"})));
+                                        new String[] {"f0", "f1", "f2", "f3", 
"f4"})));
     }
 
     @Override
diff --git 
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/FsStreamingSinkITCaseBase.scala
 
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/FsStreamingSinkITCaseBase.scala
index c4f3c2c1764..d772d8ace77 100644
--- 
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/FsStreamingSinkITCaseBase.scala
+++ 
b/flink-table/flink-table-planner/src/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(