This is an automated email from the ASF dual-hosted git repository.
eskabetxe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git
The following commit(s) were added to refs/heads/master by this push:
new abd9941 [BAHIR-263] Update flink version to 1.11.3 (#112)
abd9941 is described below
commit abd99411b031c0a5ca377698cf5c7812f57e9346
Author: cheegoday <[email protected]>
AuthorDate: Fri Mar 12 01:46:10 2021 +0800
[BAHIR-263] Update flink version to 1.11.3 (#112)
BAHIR-263 - update flink version to 1.11.3
BAHIR-263 - fix netty connector unit test
---
.travis.yml | 4 ++--
flink-connector-netty/pom.xml | 12 ++++++++++++
.../connectors/netty/example/StreamSqlExample.scala | 6 ++++--
pom.xml | 2 +-
4 files changed, 19 insertions(+), 5 deletions(-)
diff --git a/.travis.yml b/.travis.yml
index 4a473f5..f0c3c34 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -34,8 +34,8 @@ jdk:
- openjdk8
env:
- - FLINK_VERSION="1.11.2" SCALA_VERSION="2.11"
- - FLINK_VERSION="1.11.2" SCALA_VERSION="2.12"
+ - FLINK_VERSION="1.11.3" SCALA_VERSION="2.11"
+ - FLINK_VERSION="1.11.3" SCALA_VERSION="2.12"
before_install:
- ./dev/change-scala-version.sh $SCALA_VERSION
diff --git a/flink-connector-netty/pom.xml b/flink-connector-netty/pom.xml
index 5146985..a93a067 100644
--- a/flink-connector-netty/pom.xml
+++ b/flink-connector-netty/pom.xml
@@ -71,6 +71,18 @@
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
+ <version>${flink.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-clients_${scala.binary.version}</artifactId>
+ <version>${flink.version}</version>
+ <scope>test</scope>
+ </dependency>
</dependencies>
<build>
diff --git
a/flink-connector-netty/src/test/scala/org/apache/flink/streaming/connectors/netty/example/StreamSqlExample.scala
b/flink-connector-netty/src/test/scala/org/apache/flink/streaming/connectors/netty/example/StreamSqlExample.scala
index 08b5068..5bca265 100644
---
a/flink-connector-netty/src/test/scala/org/apache/flink/streaming/connectors/netty/example/StreamSqlExample.scala
+++
b/flink-connector-netty/src/test/scala/org/apache/flink/streaming/connectors/netty/example/StreamSqlExample.scala
@@ -19,6 +19,7 @@ package org.apache.flink.streaming.connectors.netty.example
import org.apache.flink.api.java.utils.ParameterTool
import org.apache.flink.api.scala._
import org.apache.flink.streaming.api.scala.{DataStream,
StreamExecutionEnvironment}
+import org.apache.flink.table.api.EnvironmentSettings
import org.apache.flink.table.api.bridge.scala._
/**
@@ -39,8 +40,9 @@ object StreamSqlExample {
val param = ParameterTool.fromArgs(args)
// set up execution environment
+ val envSettings =
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build()
val env = StreamExecutionEnvironment.getExecutionEnvironment
- val tEnv = StreamTableEnvironment.create(env)
+ val tEnv = StreamTableEnvironment.create(env, envSettings)
val spec = if (param.get("tcp") == "true") {
new TcpReceiverSource(7070, Some("http://localhost:9090/cb";))
@@ -59,7 +61,7 @@ object StreamSqlExample {
tEnv.createTemporaryView("OrderA", orderA)
// union the two tables
- val result = tEnv.sqlQuery("SELECT STREAM * FROM OrderA WHERE amount > 2")
+ val result = tEnv.sqlQuery("SELECT * FROM OrderA WHERE amount > 2")
result.toAppendStream[Order].print()
diff --git a/pom.xml b/pom.xml
index 109b528..d45cd2b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -96,7 +96,7 @@
<log4j2.version>2.13.3</log4j2.version>
<!-- Flink version -->
- <flink.version>1.11.2</flink.version>
+ <flink.version>1.11.3</flink.version>
<junit.jupiter.version>5.4.1</junit.jupiter.version>
