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 ed267d329d0fc..90c130e22f528 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 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/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 c4f3c2c1764b6..d772d8ace77fc 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(