[hotfix] fix e2e test due to removing TableSource & TableSink registr…

…ation
silenceland · May 16, 2020 · a7559e5 · a7559e5
1 parent d17a2e0
commit a7559e5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...kthrough-table-java/src/main/resources/archetype-resources/src/main/java/SpendReport.java b/...kthrough-table-java/src/main/resources/archetype-resources/src/main/java/SpendReport.java
@@ -33,9 +33,9 @@ public static void main(String[] args) throws Exception {
 		ExecutionEnvironment env   = ExecutionEnvironment.getExecutionEnvironment();
 		BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);
 
-		((TableEnvironmentInternal) tEnv).registerTableSource(
+		((TableEnvironmentInternal) tEnv).registerTableSourceInternal(
 				"transactions", new BoundedTransactionTableSource());
-		((TableEnvironmentInternal) tEnv).registerTableSink(
+		((TableEnvironmentInternal) tEnv).registerTableSinkInternal(
 				"spend_report", new SpendReportTableSink());
 		tEnv.registerFunction("truncateDateToHour", new TruncateDateToHour());