This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit b00bfaa66db90df7797be6c2003ceaf257e0309f Author: sjwiesman <[email protected]> AuthorDate: Mon Nov 15 15:17:43 2021 -0600 [FLINK-24635][examples] Fix deprecations in changelog socket example --- .../flink/table/examples/java/connectors/ChangelogSocketExample.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogSocketExample.java b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogSocketExample.java index 741903c..63fe6d8 100644 --- a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogSocketExample.java +++ b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogSocketExample.java @@ -26,7 +26,6 @@ import org.apache.flink.table.api.bridge.java.StreamTableEnvironment; import org.apache.flink.table.connector.format.DecodingFormat; import org.apache.flink.table.connector.source.DynamicTableSource; import org.apache.flink.table.factories.FactoryUtil; -import org.apache.flink.types.Row; /** * Example for implementing a custom {@link DynamicTableSource} and a {@link DecodingFormat}. @@ -96,7 +95,7 @@ public final class ChangelogSocketExample { final Table result = tEnv.sqlQuery("SELECT name, SUM(score) FROM UserScores GROUP BY name"); // print the result to the console - tEnv.toRetractStream(result, Row.class).print(); + tEnv.toChangelogStream(result).print(); env.execute(); }
