[inlong] branch master updated: [INLONG-8217][Sort] Sort-core should support running on flink-1.15 (#8230)

[yunqing]

This is an automated email from the ASF dual-hosted git repository.

yunqing pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 5a789fe7fe [INLONG-8217][Sort] Sort-core should support running on 
flink-1.15 (#8230)
5a789fe7fe is described below

commit 5a789fe7fe43f2f7faab4cd4fa0fadbcd730ba15
Author: Sting <zpen...@connect.ust.hk>
AuthorDate: Wed Jun 14 21:31:15 2023 +0800

    [INLONG-8217][Sort] Sort-core should support running on flink-1.15 (#8230)
---
 .../sort-core/src/main/java/org/apache/inlong/sort/Entrance.java       | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java 
b/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java
index ae3ebc842d..ea3f3f95be 100644
--- a/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java
+++ b/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java
@@ -50,8 +50,7 @@ public class Entrance {
                 config.getInteger(Constants.MIN_PAUSE_BETWEEN_CHECKPOINTS_MS));
         
env.getCheckpointConfig().setCheckpointTimeout(config.getInteger(Constants.CHECKPOINT_TIMEOUT_MS));
         env.getCheckpointConfig().setMaxConcurrentCheckpoints(1);
-        EnvironmentSettings settings = 
EnvironmentSettings.newInstance().useBlinkPlanner()
-                .inStreamingMode().build();
+        EnvironmentSettings settings = 
EnvironmentSettings.newInstance().inStreamingMode().build();
         StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, 
settings);
         
tableEnv.getConfig().getConfiguration().setString(Constants.PIPELINE_NAME,
                 config.getString(Constants.JOB_NAME));