Skip to content

Commit 986457e

Browse files
committed
fix
1 parent 4c5360f commit 986457e

File tree

1 file changed

+0
-12
lines changed

1 file changed

+0
-12
lines changed

flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/CalcITCase.scala

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -826,18 +826,6 @@ class CalcITCase extends StreamingTestBase {
826826
assertThat(sink.getAppendResults.sorted).isEqualTo(expected.sorted)
827827
}
828828

829-
@Test
830-
def test(): Unit = {
831-
val dt = "ROW<`data` ROW<`nested` ROW<`trId` STRING NOT NULL>>NOT NULL>"
832-
tEnv.executeSql(
833-
"CREATE TABLE t1 (`myf1` " + dt + ", `myf2` AS CAST(`myf1` AS " + dt + ")) WITH ('connector' = 'datagen')");
834-
tEnv.executeSql("SHOW CREATE TABLE t1").print();
835-
val sql = "SELECT " +
836-
"`myf2`, " +
837-
"COALESCE(TRY_CAST(`myf2`.`data`.`nested`.`trId` AS STRING)) AS transactionId FROM t1";
838-
System.out.println(tEnv.explainSql(sql));
839-
}
840-
841829
@Test
842830
def testCastRow(): Unit = {
843831
val testDataId = TestValuesTableFactory.registerData(

0 commit comments

Comments
 (0)