File tree 2 files changed +3
-2
lines changed
2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -297,6 +297,7 @@ under the License.
297
297
<properties >
298
298
<test .flink.main.version>1.19</test .flink.main.version>
299
299
<test .flink.version>1.19.1</test .flink.version>
300
+ <test .flink.connector.kafka.version>3.2.0-${test.flink.main.version} </test .flink.connector.kafka.version>
300
301
<flink .sql.connector.hive>flink-sql-connector-hive-2.3.9_${scala.binary.version} </flink .sql.connector.hive>
301
302
</properties >
302
303
</profile >
@@ -306,6 +307,7 @@ under the License.
306
307
<properties >
307
308
<test .flink.main.version>1.18</test .flink.main.version>
308
309
<test .flink.version>1.18.1</test .flink.version>
310
+ <test .flink.connector.kafka.version>3.0.1-${test.flink.main.version} </test .flink.connector.kafka.version>
309
311
<flink .sql.connector.hive>flink-sql-connector-hive-2.3.9_${scala.binary.version} </flink .sql.connector.hive>
310
312
</properties >
311
313
</profile >
Original file line number Diff line number Diff line change @@ -112,8 +112,7 @@ under the License.
112
112
<test .unit.pattern>**/*Test.*</test .unit.pattern>
113
113
<test .flink.main.version>1.20</test .flink.main.version>
114
114
<test .flink.version>1.20.0</test .flink.version>
115
- <!-- TODO upgrade after connector releases x-1.19 version -->
116
- <test .flink.connector.kafka.version>3.0.1-1.18</test .flink.connector.kafka.version>
115
+ <test .flink.connector.kafka.version>3.4.0-1.20</test .flink.connector.kafka.version>
117
116
<test .mysql.connector.java.version>8.0.27</test .mysql.connector.java.version>
118
117
119
118
<!-- spark profile properties-->
You can’t perform that action at this time.
0 commit comments