fixup: address review

apache · Feb 23, 2021 · 9b596a1 · 9b596a1
1 parent aa8dede
commit 9b596a1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../src/test/scala/org/apache/flink/table/planner/runtime/stream/table/TableSinkITCase.scala b/.../src/test/scala/org/apache/flink/table/planner/runtime/stream/table/TableSinkITCase.scala
@@ -892,7 +892,8 @@ class TableSinkITCase extends StreamingTestBase {
  tEnv.createTemporaryView("MyTable", t)
 
  expectedEx.expect(classOf[ValidationException])
- expectedEx.expectMessage("Column 'a' has no default value and does not allow NULLs")
+ expectedEx.expectMessage("Column 'a' does not allow NULL value, " +
+ "thus it can not be used in partial insert")
 
  tEnv.executeSql(
  s"""