Skip to content

Commit 51dda35

Browse files
author
shuo.cs
committed
rebase
1 parent fa464fd commit 51dda35

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -318,7 +318,7 @@ class CalcITCase extends StreamingTestBase {
318318

319319
val ddl =
320320
s"""
321-
|CREATE TABLE SimpleTable (
321+
|CREATE TABLE CustomTable (
322322
| a bigint,
323323
| b map<bigint, bigint>
324324
|) WITH (
@@ -331,7 +331,7 @@ class CalcITCase extends StreamingTestBase {
331331

332332
env.getConfig.disableObjectReuse()
333333
tEnv.executeSql(ddl)
334-
val result = tEnv.executeSql( "select a, b from SimpleTable")
334+
val result = tEnv.executeSql( "select a, b from CustomTable")
335335

336336
val expected = List("1,{1=2}", "2,{4=5}")
337337
val actual = CollectionUtil.iteratorToList(result.collect()).map(r => r.toString)

0 commit comments

Comments
 (0)