You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/11/19 01:20:28 UTC
[rocketmq-flink] branch main updated: [upgrade flink version] upgrade flink version to 1.14 (#23)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git
The following commit(s) were added to refs/heads/main by this push:
new e303ea9 [upgrade flink version] upgrade flink version to 1.14 (#23)
e303ea9 is described below
commit e303ea95aaca24360aa6093c1a7a6c58ca20e4a5
Author: yiduwangkai <16...@users.noreply.github.com>
AuthorDate: Fri Nov 19 09:20:22 2021 +0800
[upgrade flink version] upgrade flink version to 1.14 (#23)
Co-authored-by: wangkai9 <wa...@tuhu.cn>
---
pom.xml | 12 +++---------
.../flink/source/reader/RocketMQRecordEmitterTest.java | 3 +++
2 files changed, 6 insertions(+), 9 deletions(-)
diff --git a/pom.xml b/pom.xml
index 2e0ad44..c0b1090 100644
--- a/pom.xml
+++ b/pom.xml
@@ -34,7 +34,7 @@
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
<rocketmq.version>4.7.1</rocketmq.version>
- <flink.version>1.13.1</flink.version>
+ <flink.version>1.14.0</flink.version>
<commons-lang.version>2.5</commons-lang.version>
<scala.binary.version>2.11</scala.binary.version>
<spotless.version>2.4.2</spotless.version>
@@ -76,18 +76,12 @@
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
- <artifactId>flink-table-runtime-blink_2.11</artifactId>
+ <artifactId>flink-table-runtime_${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-queryable-state-runtime_${scala.binary.version}</artifactId>
+ <artifactId>flink-queryable-state-runtime</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
diff --git a/src/test/java/org/apache/rocketmq/flink/source/reader/RocketMQRecordEmitterTest.java b/src/test/java/org/apache/rocketmq/flink/source/reader/RocketMQRecordEmitterTest.java
index 83c1c4b..cd54e71 100644
--- a/src/test/java/org/apache/rocketmq/flink/source/reader/RocketMQRecordEmitterTest.java
+++ b/src/test/java/org/apache/rocketmq/flink/source/reader/RocketMQRecordEmitterTest.java
@@ -88,6 +88,9 @@ public class RocketMQRecordEmitterTest {
throw new UnsupportedOperationException();
}
+ @Override
+ public void markActive() {}
+
public SourceOutput<E> createOutputForSplit(String splitId) {
return this;
}