This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 1409e8bc2 [flink] Bump flink version of paimon-flink-common to 1.17.0
(#793)
1409e8bc2 is described below
commit 1409e8bc2bc23da87210eab807862e5af40f8937
Author: yuzelin <[email protected]>
AuthorDate: Fri Mar 31 16:15:53 2023 +0800
[flink] Bump flink version of paimon-flink-common to 1.17.0 (#793)
---
paimon-flink/paimon-flink-common/pom.xml | 2 +-
.../src/test/java/org/apache/paimon/flink/LookupJoinITCase.java | 2 +-
pom.xml | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/paimon-flink/paimon-flink-common/pom.xml
b/paimon-flink/paimon-flink-common/pom.xml
index 54214be36..7a174dc63 100644
--- a/paimon-flink/paimon-flink-common/pom.xml
+++ b/paimon-flink/paimon-flink-common/pom.xml
@@ -34,7 +34,7 @@ under the License.
<name>Paimon : Flink : Common</name>
<properties>
- <flink.version>1.16.1</flink.version>
+ <flink.version>1.17.0</flink.version>
<frocksdbjni.version>6.20.3-ververica-2.0</frocksdbjni.version>
</properties>
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LookupJoinITCase.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LookupJoinITCase.java
index 38ad31d40..537d7fad7 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LookupJoinITCase.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/LookupJoinITCase.java
@@ -498,7 +498,7 @@ public class LookupJoinITCase extends CatalogITCaseBase {
sql("INSERT INTO DIM VALUES (1, 11, 111, 1111), (2, 22, 222, 2222)");
String query =
- "SELECT /*+ LOOKUP('table'='DIM',
'retry-predicate'='lookup_miss',"
+ "SELECT /*+ LOOKUP('table'='D',
'retry-predicate'='lookup_miss',"
+ " 'retry-strategy'='fixed_delay',
'fixed-delay'='1s','max-attempts'='60') */"
+ " T.i, D.j, D.k1, D.k2 FROM T LEFT JOIN DIM for
system_time as of T.proctime AS D ON T.i = D.i";
BlockingIterator<Row, Row> iterator =
BlockingIterator.of(sEnv.executeSql(query).collect());
diff --git a/pom.xml b/pom.xml
index 3ba0a8a58..b18f895ca 100644
--- a/pom.xml
+++ b/pom.xml
@@ -123,7 +123,7 @@ under the License.
<findbugs.version>1.3.9</findbugs.version>
<json-smart.version>2.4.9</json-smart.version>
<avro.version>1.11.1</avro.version>
- <kafka.version>2.8.1</kafka.version>
+ <kafka.version>3.2.3</kafka.version>
</properties>
<dependencies>
