From a7559e51ea05664bfc0cc69cfc82b20b520988c5 Mon Sep 17 00:00:00 2001 From: Kurt Young Date: Sat, 16 May 2020 12:18:29 +0800 Subject: [PATCH] [hotfix] fix e2e test due to removing TableSource & TableSink registration --- .../archetype-resources/src/main/java/SpendReport.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources/src/main/java/SpendReport.java b/flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources/src/main/java/SpendReport.java index 4b9a1433ec0f4..5b892ed44028d 100644 --- a/flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources/src/main/java/SpendReport.java +++ b/flink-walkthroughs/flink-walkthrough-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());