(flink-connector-kafka) branch main updated: [FLINK-35228][Connectors/Kafka] Fix: DynamicKafkaSource does not read re-added topic for the same cluster (#97)

2024-04-29 Thread masc
This is an automated email from the ASF dual-hosted git repository. masc pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git The following commit(s) were added to refs/heads/main by this push: new 00c9c8c7

(flink) branch release-1.19 updated: [FLINK-32622][table-planner] Optimize mini-batch assignment (#23470)

2024-04-29 Thread jingge
This is an automated email from the ASF dual-hosted git repository. jingge pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new c370b20c8e2

(flink) branch master updated: [FLINK-35191][table-api] Support alter materialized table related syntax: suspend, resume, refresh, set and reset

2024-04-29 Thread ron
This is an automated email from the ASF dual-hosted git repository. ron pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 330f524d185 [FLINK-35191][table-api] Support alter

(flink) branch master updated: [FLINK-35184][table-runtime] Fix mini-batch join hash collision when use InputSideHasNoUniqueKeyBundle

2024-04-29 Thread ron
This is an automated email from the ASF dual-hosted git repository. ron pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new f543cc543e9 [FLINK-35184][table-runtime] Fix

svn commit: r68873 - in /dev/flink/flink-cdc-3.1.0-rc1: ./ flink-cdc-3.1.0-bin.tar.gz flink-cdc-3.1.0-bin.tar.gz.asc flink-cdc-3.1.0-bin.tar.gz.sha512 flink-cdc-3.1.0-src.tgz flink-cdc-3.1.0-src.tgz.a

2024-04-29 Thread renqs
Author: renqs Date: Tue Apr 30 04:48:23 2024 New Revision: 68873 Log: Apache Flink CDC, version 3.1.0, release candidate 1 Added: dev/flink/flink-cdc-3.1.0-rc1/ dev/flink/flink-cdc-3.1.0-rc1/flink-cdc-3.1.0-bin.tar.gz (with props)

(flink-cdc) annotated tag release-3.1.0-rc1 updated (63b42cb93 -> cdae15dab)

2024-04-29 Thread renqs
This is an automated email from the ASF dual-hosted git repository. renqs pushed a change to annotated tag release-3.1.0-rc1 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git *** WARNING: tag release-3.1.0-rc1 was modified! *** from 63b42cb93 (commit) to cdae15dab (tag)

(flink) branch master updated (f75c5188660 -> 86de622c807)

2024-04-29 Thread fanrui
This is an automated email from the ASF dual-hosted git repository. fanrui pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from f75c5188660 [hotfix][docs] Fix file reference new 5263f9cbf20 [FLINK-35222][rest] Add getJobType for

(flink) 03/03: [FLINK-35224][web] Show the JobType on Flink WebUI

2024-04-29 Thread fanrui
This is an automated email from the ASF dual-hosted git repository. fanrui pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 86de622c807413f2a7a1664113e39798f0fed81d Author: Rui Fan <1996fan...@gmail.com> AuthorDate: Wed Apr 24 17:52:32 2024

(flink-cdc) branch release-3.1 updated: [FLINK-35255][cdc][runtime] DataSinkWriterOperator adds overrides for the snapshotState and processWatermark methods (#3279)

2024-04-29 Thread renqs
This is an automated email from the ASF dual-hosted git repository. renqs pushed a commit to branch release-3.1 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git The following commit(s) were added to refs/heads/release-3.1 by this push: new 759b29449

(flink-cdc) branch release-3.1 updated: [minor][docs] Fix route definition example in core concept docs (#3270)

2024-04-29 Thread renqs
This is an automated email from the ASF dual-hosted git repository. renqs pushed a commit to branch release-3.1 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git The following commit(s) were added to refs/heads/release-3.1 by this push: new a83d0e5d9 [minor][docs] Fix route

(flink) 02/03: [FLINK-35223][rest] Add jobType in JobDetailsInfo related rest api

2024-04-29 Thread fanrui
This is an automated email from the ASF dual-hosted git repository. fanrui pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 917352ed35eff562a032a6e3038aaaf1177d2a8a Author: Rui Fan <1996fan...@gmail.com> AuthorDate: Wed Apr 24 17:47:12 2024

(flink) 01/03: [FLINK-35222][rest] Add getJobType for AccessExecutionGraph

2024-04-29 Thread fanrui
This is an automated email from the ASF dual-hosted git repository. fanrui pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 5263f9cbf20536e9a81a0044f22b033e78a908ea Author: Rui Fan <1996fan...@gmail.com> AuthorDate: Wed Apr 24 17:25:08 2024

(flink-cdc) branch release-3.1 updated (711bc0038 -> 7a1947927)

2024-04-29 Thread renqs
This is an automated email from the ASF dual-hosted git repository. renqs pushed a change to branch release-3.1 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git from 711bc0038 [FLINK-35251][cdc][runtime] Fix bug of serializing derivation mapping in SchemaDerivation new

(flink-cdc) 01/02: [FLINK-35259][cdc][transform] Fix FlinkCDC pipeline transform can't deal timestamp field (#3278)

2024-04-29 Thread renqs
This is an automated email from the ASF dual-hosted git repository. renqs pushed a commit to branch release-3.1 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git commit e022f4d2592dedc6d570948213fd07f47c1e505c Author: Wink <32723967+aiwe...@users.noreply.github.com> AuthorDate: Mon

(flink-cdc) 02/02: [FLINK-34878][cdc][transform] Flink CDC pipeline transform supports CASE WHEN (#3228)

2024-04-29 Thread renqs
This is an automated email from the ASF dual-hosted git repository. renqs pushed a commit to branch release-3.1 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git commit 7a1947927df29cb5c8a78129a5819409b069c602 Author: Wink <32723967+aiwe...@users.noreply.github.com> AuthorDate: Mon

(flink-connector-hbase) branch main updated: [FLINK-35233] Fix lookup cache reuse RowData object problem (#47)

2024-04-29 Thread martijnvisser
This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-hbase.git The following commit(s) were added to refs/heads/main by this push: new b7850a5 [FLINK-35233] Fix

(flink-cdc) branch master updated (23a67dcdb -> f61f0f44b)

2024-04-29 Thread renqs
This is an automated email from the ASF dual-hosted git repository. renqs pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink-cdc.git from 23a67dcdb [FLINK-35255][cdc][runtime] DataSinkWriterOperator adds overrides for the snapshotState and

(flink-cdc) branch release-3.1 updated: [FLINK-35264][cdc][runtime] Fix multiple transform rules do not take effect (#3281)

2024-04-29 Thread renqs
This is an automated email from the ASF dual-hosted git repository. renqs pushed a commit to branch release-3.1 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git The following commit(s) were added to refs/heads/release-3.1 by this push: new 71dfad24d