[flink] 10/11: [FLINK-24635][examples] Fix deprecations in changelog socket example

[sj...@apache.org]

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 <sj...@gmail.com>
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();
     }