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());