commits@flink.apache.org, 2024-04

You are viewing a plain text version of this content. The canonical link for it is here.

- (flink-cdc) branch master updated: [FLINK-34948][cdc][common] Fix cdc RowType can not convert to Flink type - posted by ji...@apache.org on 2024/04/01 01:55:38 UTC, 0 replies.
- (flink) branch master updated (3841f062255 -> 28762497bdf) - posted by gu...@apache.org on 2024/04/01 06:36:14 UTC, 0 replies.
- (flink) 01/11: [FLINK-34548][API] Initialize the datastream v2 related modules - posted by gu...@apache.org on 2024/04/01 06:36:15 UTC, 0 replies.
- (flink) 02/11: [FLINK-34548][API] Create flink-core-api module and let flink-core depend on it - posted by gu...@apache.org on 2024/04/01 06:36:16 UTC, 0 replies.
- (flink) 03/11: [FLINK-34548][API] Move Function interface to flink-core-api - posted by gu...@apache.org on 2024/04/01 06:36:17 UTC, 0 replies.
- (flink) 04/11: [FLINK-34548][API] Introduce ProcessFunction and RuntimeContext related interfaces - posted by gu...@apache.org on 2024/04/01 06:36:18 UTC, 0 replies.
- (flink) 05/11: [FLINK-34548][API] Introduce variants of ProcessFunction - posted by gu...@apache.org on 2024/04/01 06:36:19 UTC, 0 replies.
- (flink) 06/11: [FLINK-34548][API] Introduce stream interface and move KeySelector to flink-core-api - posted by gu...@apache.org on 2024/04/01 06:36:20 UTC, 0 replies.
- (flink) 07/11: [FLINK-34548][API] Introduce ExecutionEnvironment - posted by gu...@apache.org on 2024/04/01 06:36:21 UTC, 0 replies.
- (flink) 08/11: [FLINK-34548][API] Implement process function's underlying operators - posted by gu...@apache.org on 2024/04/01 06:36:22 UTC, 0 replies.
- (flink) 09/11: [FLINK-34548][API] Implement datastream - posted by gu...@apache.org on 2024/04/01 06:36:23 UTC, 0 replies.
- (flink) 10/11: [FLINK-34548][API] Supports FLIP-27 Source - posted by gu...@apache.org on 2024/04/01 06:36:24 UTC, 0 replies.
- (flink) 11/11: [FLINK-34548][API] Supports sink-v2 Sink - posted by gu...@apache.org on 2024/04/01 06:36:25 UTC, 0 replies.
- (flink-web) branch asf-site updated (8216fcba0 -> 434203cd8) - posted by re...@apache.org on 2024/04/01 08:39:22 UTC, 0 replies.
- (flink-web) 01/02: [FLINK-34946] Flink Website Menu Adjustment - posted by re...@apache.org on 2024/04/01 08:39:23 UTC, 0 replies.
- (flink-web) 02/02: Rebuild website - posted by re...@apache.org on 2024/04/01 08:39:24 UTC, 3 replies.
- (flink) branch master updated: [hotfix] Fix compile error in DataStreamV2SinkTransformation - posted by gu...@apache.org on 2024/04/01 12:12:22 UTC, 0 replies.
- (flink) branch master updated (d271495c5be -> f38d8ca43f6) - posted by ha...@apache.org on 2024/04/02 02:23:39 UTC, 0 replies.
- (flink-web) branch asf-site updated (434203cd8 -> a3f81bcd9) - posted by ta...@apache.org on 2024/04/02 03:28:03 UTC, 0 replies.
- (flink-web) 01/02: [FLINK-34968] Update flink-web copyright to 2024 - posted by ta...@apache.org on 2024/04/02 03:28:04 UTC, 0 replies.
- (flink) branch master updated (f38d8ca43f6 -> ec1311c8eb8) - posted by zh...@apache.org on 2024/04/02 06:20:34 UTC, 0 replies.
- (flink) branch master updated: [FLINK-33985][runtime] Support obtain all partitions existing in cluster through ShuffleMaster. - posted by zh...@apache.org on 2024/04/02 06:23:29 UTC, 0 replies.
- Re: [I] 请问clickhouse支持cdc么 [flink-cdc] - posted by "xleoken (via GitHub)" <gi...@apache.org> on 2024/04/02 06:35:26 UTC, 0 replies.
- (flink) branch master updated (a4470966295 -> 8a18b119c95) - posted by gu...@apache.org on 2024/04/02 07:46:59 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain - posted by ma...@apache.org on 2024/04/02 08:02:14 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][cdc][docs] Improve the indentation of the example yaml in README file - posted by ji...@apache.org on 2024/04/02 11:26:06 UTC, 0 replies.
- (flink) branch master updated (8a18b119c95 -> 163b9cca6d2) - posted by mb...@apache.org on 2024/04/02 13:26:20 UTC, 0 replies.
- (flink-cdc) branch master updated (ed09e8b23 -> 1d05abff8) - posted by le...@apache.org on 2024/04/02 15:39:32 UTC, 0 replies.
- (flink-cdc) 01/05: [cdc-composer] Introduce transform definition and parser - posted by le...@apache.org on 2024/04/02 15:39:33 UTC, 0 replies.
- (flink-cdc) 02/05: [cdc-common] Introduce partitionKeys into schema and add related util classes - posted by le...@apache.org on 2024/04/02 15:39:34 UTC, 0 replies.
- (flink-cdc) 03/05: [cdc-runtime] Introduce TransformSchemaOperator and TransformDataOperator to support transformation - posted by le...@apache.org on 2024/04/02 15:39:35 UTC, 0 replies.
- (flink-cdc) 04/05: [build] Optimize pom to solve the CI error - posted by le...@apache.org on 2024/04/02 15:39:36 UTC, 0 replies.
- (flink-cdc) 05/05: [minor][cdc-common] Improve the java doc of translators - posted by le...@apache.org on 2024/04/02 15:39:37 UTC, 0 replies.
- Re: [I] Error on Postgres-CDC using incremental snapshot with UUID column as PK [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2024/04/03 08:13:08 UTC, 2 replies.
- (flink) branch master updated: [FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner - posted by sn...@apache.org on 2024/04/03 10:24:23 UTC, 0 replies.
- (flink) branch release-1.18 updated: [FLINK-34955] Upgrade commons-compress to 1.26.0. - posted by mb...@apache.org on 2024/04/03 13:07:03 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-34955] Upgrade commons-compress to 1.26.0. - posted by mb...@apache.org on 2024/04/03 13:08:38 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35000][build] Updates link to test code convention in pull request template - posted by ma...@apache.org on 2024/04/03 14:47:16 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35000][build] Updates link to test code convention in pull request template - posted by ma...@apache.org on 2024/04/03 14:48:23 UTC, 0 replies.
- (flink) branch release-1.18 updated: [FLINK-35000][build] Updates link to test code convention in pull request template - posted by ma...@apache.org on 2024/04/03 14:48:28 UTC, 0 replies.
- (flink) branch master updated (d301839dfe2 -> f86c0804121) - posted by ro...@apache.org on 2024/04/03 21:50:36 UTC, 0 replies.
- (flink) 01/02: [FLINK-34994][tests] Ignore unknown task checkpoint confirmation log in JobIDLoggingITCase - posted by ro...@apache.org on 2024/04/03 21:50:37 UTC, 0 replies.
- (flink) 02/02: [hotfix] Log JobID in checkpoint abort message if available - posted by ro...@apache.org on 2024/04/03 21:50:38 UTC, 0 replies.
- (flink-connector-kafka) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 updated (d4d46ad4 -> 57a63919) - posted by ma...@apache.org on 2024/04/04 12:02:23 UTC, 0 replies.
- (flink) branch release-1.18 updated: [hotfix][table] Fix typo in maven shade configuration (#24621) - posted by rm...@apache.org on 2024/04/04 19:11:11 UTC, 0 replies.
- (flink) branch release-1.19 updated: [hotfix][table] Fix typo in maven shade configuration (#24620) - posted by rm...@apache.org on 2024/04/04 19:11:32 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35021] AggregateQueryOperations produces wrong asSerializableString representation (#24624) - posted by dw...@apache.org on 2024/04/05 12:17:59 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34025] Add data skew metric endpoint and UI - posted by ho...@apache.org on 2024/04/05 14:37:56 UTC, 0 replies.
- Re: [I] Oracle problem，sync fail [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2024/04/05 15:38:22 UTC, 0 replies.
- (flink) branch master updated (080efb9c410 -> 54550e3b9b3) - posted by gu...@apache.org on 2024/04/05 15:45:59 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34657] add lineage provider API (#24619) - posted by mb...@apache.org on 2024/04/05 15:49:01 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35011][tests] Change MockDeserializationSchema's visibility back to public to prevent compilation failure in external connectors - posted by ji...@apache.org on 2024/04/06 12:42:28 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Fix YARN ContainerId.getId Deprecated Used. - posted by fa...@apache.org on 2024/04/07 02:14:53 UTC, 0 replies.
- (flink) branch master updated (ad8bbb49a5a -> 739bd337c65) - posted by ha...@apache.org on 2024/04/07 02:16:28 UTC, 0 replies.
- (flink) branch master updated (739bd337c65 -> 0b7f0fded3f) - posted by ha...@apache.org on 2024/04/07 02:32:52 UTC, 0 replies.
- (flink) 01/02: [FLINK-32079][checkpoint] Support to read/write checkpoint metadata of merged files (#24480) - posted by ha...@apache.org on 2024/04/07 02:32:53 UTC, 0 replies.
- (flink) 02/02: [hotfix] Fix collectSizeStats for SegmentFileStateHandle (#24480) - posted by ha...@apache.org on 2024/04/07 02:32:54 UTC, 0 replies.
- (flink) branch master updated: [FLINK-24939][table] Support `SHOW CREATE CATALOG` syntax - posted by jc...@apache.org on 2024/04/07 02:46:25 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0 - posted by li...@apache.org on 2024/04/07 08:22:13 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0 - posted by li...@apache.org on 2024/04/07 08:51:49 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34959][cdc] Update old flink-cdc-connectors artifactId (#3200) - posted by re...@apache.org on 2024/04/07 09:15:33 UTC, 0 replies.
- (flink) branch master updated (5bbcf8de79c -> 32ab253a044) - posted by gu...@apache.org on 2024/04/08 01:38:33 UTC, 0 replies.
- (flink) 01/02: [hotfix] Document the field start from 1 for sortPartition - posted by gu...@apache.org on 2024/04/08 01:38:34 UTC, 0 replies.
- (flink) 02/02: [hotfix] Correct the option key for sortPartition - posted by gu...@apache.org on 2024/04/08 01:38:35 UTC, 0 replies.
- (flink) branch master updated (32ab253a044 -> 558ca75da2f) - posted by zh...@apache.org on 2024/04/08 02:23:32 UTC, 0 replies.
- (flink) 01/03: [hotfix][test] Migrate SplitAssignmentTrackerTest to Junit5 and AssertJ. - posted by zh...@apache.org on 2024/04/08 02:23:33 UTC, 0 replies.
- (flink) 02/03: [FLINK-33984][runtime] Skip maintain subtaskGatewayMap when CheckpointCoordinator is null. - posted by zh...@apache.org on 2024/04/08 02:23:34 UTC, 0 replies.
- (flink) 03/03: [FLINK-33984][runtime] Support batch snapshot for OperatorCoordinator. - posted by zh...@apache.org on 2024/04/08 02:23:35 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Log Job ID when task is failed externally - posted by pn...@apache.org on 2024/04/08 08:29:12 UTC, 0 replies.
- [I] flink mongodb cdc 方式同步数据，mongodb 4.2版本的不支持，update的更新数据同步吗 [flink-cdc] - posted by "Jardinsjian (via GitHub)" <gi...@apache.org> on 2024/04/08 09:06:40 UTC, 6 replies.
- (flink) branch master updated: [FLINK-34162][table] Migrate LogicalUnnestRule to java - posted by sn...@apache.org on 2024/04/08 09:07:35 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34159][table] Migrate ConstantRankNumberColumnRemoveRule to java - posted by sn...@apache.org on 2024/04/08 09:12:10 UTC, 0 replies.
- (flink) branch master updated (3ec9bfb5ba5 -> d9510893004) - posted by sn...@apache.org on 2024/04/08 09:16:29 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34161][table] Migration of RewriteMinusAllRule to java - posted by sn...@apache.org on 2024/04/08 10:12:04 UTC, 0 replies.
- (flink) branch master updated (97a67277c1d -> 82116865b01) - posted by sn...@apache.org on 2024/04/08 10:13:57 UTC, 0 replies.
- (flink) branch master updated (82116865b01 -> 68cc61a8618) - posted by dw...@apache.org on 2024/04/08 11:58:00 UTC, 0 replies.
- (flink) 01/02: [FLINK-33676] Implement RestoreTests for WindowAggregate - posted by dw...@apache.org on 2024/04/08 11:58:01 UTC, 0 replies.
- (flink) 02/02: [FLINK-33676] Deleting WindowAggregateJsonPlanTest.java and WindowAggregateJsonITCase.java - posted by dw...@apache.org on 2024/04/08 11:58:02 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated (7025642d -> ab5d6159) - posted by sn...@apache.org on 2024/04/08 12:06:40 UTC, 0 replies.
- (flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 updated (c2d3f2b7 -> 702d58e8) - posted by sn...@apache.org on 2024/04/08 14:38:02 UTC, 0 replies.
- (flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 updated (702d58e8 -> 85388dbb) - posted by sn...@apache.org on 2024/04/08 14:55:14 UTC, 0 replies.
- (flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 updated (85388dbb -> ba231442) - posted by sn...@apache.org on 2024/04/08 17:43:37 UTC, 0 replies.
- (flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 updated (ba231442 -> eed458bd) - posted by sn...@apache.org on 2024/04/08 18:16:54 UTC, 0 replies.
- (flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 updated (eed458bd -> 2cfa92d8) - posted by sn...@apache.org on 2024/04/08 19:24:59 UTC, 0 replies.
- (flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 updated (2cfa92d8 -> 96caa3cb) - posted by sn...@apache.org on 2024/04/09 05:37:22 UTC, 0 replies.
- Re: [I] Flink OceanBase CDC事务ID获取 [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:52:56 UTC, 1 replies.
- Re: [I] flinksql设置并发后，会报错Database connection failed when starting copy（postgres-cdc） [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:53:12 UTC, 1 replies.
- Re: [I] FlinkCDC3.0的任务cancel之后，怎样启动指定checkpoint [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:53:32 UTC, 1 replies.
- Re: [I] Error due to Flink CDC using deprecated `flink-conf.yaml` in light of Flink's full YAML 1.2 support since version 1.19 [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:53:47 UTC, 1 replies.
- Re: [I] ChunkKeyColumns that synchronize multiple tables without a primary key need to be concatenated a lot. Why not simply pass Map chunkKeys [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:54:03 UTC, 1 replies.
- Re: [I] Flink CDC may occur binlog can't be find when dynamic added table repeatedly [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:08 UTC, 1 replies.
- Re: [I] How to do MySQL to MySQL pipeline [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:12 UTC, 1 replies.
- Re: [I] Data lost after rename table [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:16 UTC, 1 replies.
- Re: [I] mysql to sr pipeline， float value bug [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:19 UTC, 1 replies.
- Re: [I] [Bug]MySqlSource An error occurred when adding a table to the table.include.list attribute [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:23 UTC, 1 replies.
- Re: [I] mysql cdc to doris: TIME type converting fail [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:31 UTC, 1 replies.
- Re: [I] [Feature] Flink CDC Oracle support tables without primary keys and scan newly added tables [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:35 UTC, 1 replies.
- Re: [I] [Bug] Mysql is synchronized to doris, and an error is reported when adding or deleting data after dropping column. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:41 UTC, 1 replies.
- Re: [I] Oracle add data has error [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:45 UTC, 1 replies.
- Re: [I] [Bug] MongoCDC checkpoint error [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:48 UTC, 1 replies.
- Re: [I] [Bug][mysql] Remove all previous table and add new added table will throw Exception. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:52 UTC, 1 replies.
- Re: [I] [Bug] oracle-cdc cannot read oracle multitenant pdb binlog: ORA-00942: table or view does not exist (LOG_MINING_FLUSH) [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:57:57 UTC, 1 replies.
- Re: [I] [Bug] [StarRocks] [cdc master branch] Unsupported CDC data type BYTES/VARBINARY [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:01 UTC, 1 replies.
- Re: [I] [Bug] Meet NoClassDefFoundError when add new table in mysql cdc source [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:05 UTC, 1 replies.
- Re: [I] [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target table? [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:09 UTC, 1 replies.
- Re: [I] [enhancement] [ cdc-connector] [ignore no primary key table] When using regular expressions to synchronize the entire database with Flink CDC, skip tables that do not have a primary key. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:12 UTC, 1 replies.
- Re: [I] Need report metric or other ways to indicate whether the current is Incremental Snapshot Reading or binlog reading [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:16 UTC, 1 replies.
- Re: [I] [Bug] oracle-cdc ORA-01371: Complete LogMiner dictionary not found [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:20 UTC, 1 replies.
- Re: [I] [Bug] Jackson version conflicts among MySQL/TiDB/MongoDB connectors [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:25 UTC, 1 replies.
- Re: [I] [Bug] Oracle cdc in table api does no support server-time-zone option [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:29 UTC, 1 replies.
- Re: [I] Support modifying partition keys and primary keys of Schema. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:33 UTC, 1 replies.
- Re: [I] [Bug] Can't restore from checkpoint because assignedSplits does not equal to splitFinishedOffsets [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:37 UTC, 1 replies.
- Re: [I] [Bug] timeout when Invocating Remote RPC. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:41 UTC, 1 replies.
- Re: [I] [Improve] When using miniCluster, don't check 'FLINK_HOME'. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:45 UTC, 1 replies.
- Re: [I] [3.1][pipeline-connectors] Add pipeline Sink for Pulsar. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:49 UTC, 1 replies.
- Re: [I] [Bug] BinlogSplitReader#pollSplitRecords return finishedSplit when exception occurs [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:54 UTC, 1 replies.
- Re: [I] [cdc-connector][db2] Db2 support incremental source [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:58:57 UTC, 1 replies.
- Re: [I] [3.1][pipeline-connectors] Add jdbc pipeline sink [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:01 UTC, 1 replies.
- Re: [I] [3.1][pipeline-connectors] Add Implementation of DataSink in Iceberg. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:06 UTC, 1 replies.
- Re: [I] Flink CDC 3.1.0 Plan [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:09 UTC, 1 replies.
- Re: [I] [3.1][cdc-e2e] Add end to end test for pipeline. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:14 UTC, 1 replies.
- Re: [I] [3.1][cdc-common] Add metric for DataChangeEvent [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:18 UTC, 1 replies.
- Re: [I] [3.1][pipeline-connectors] Add Implementation of DataSink in Paimon. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:22 UTC, 1 replies.
- Re: [I] [cdc-common] Add default value of pipeline parallelism. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:25 UTC, 1 replies.
- Re: [I] [cdc-pipeline] Apply 'flink-confing' config for pipeline. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:29 UTC, 1 replies.
- Re: [I] [Bug][sqlserver] SqlServer incremental source cannot support exactly-once [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:33 UTC, 1 replies.
- Re: [I] [Bug] BinlogOffset's comparative method may be cause incremental snapshot scan data lose [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:36 UTC, 1 replies.
- Re: [I] [FLINK-CDC-BASE] Reorder dependency flink-table-runtime in pom.xml to avoid dependency conflict. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:41 UTC, 1 replies.
- Re: [I] [3.1][cdc-composer] verify the options of Context for Factory. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:44 UTC, 1 replies.
- Re: [I] When will opengauss or gaussdb be supported? [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:48 UTC, 1 replies.
- Re: [I] sql server Limited date synchronization [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:52 UTC, 1 replies.
- Re: [I] [flink-cdc-pipeline-connectors] Add Implementation of DataSink in Kafka [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 05:59:56 UTC, 1 replies.
- Re: [I] flink-connector-mysql-cdc-2.4.2 when a multi-column primary key index starts with a varchar column, a snapshot chunk can potentially return a large number of rows and cause jvm to OOM. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:00 UTC, 2 replies.
- Re: [I] [flink-cdc-pipeline-connectors] Add Implementation of DataSource in MongoDB [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:03 UTC, 1 replies.
- Re: [I] [Bug] java.lang.NoClassDefFoundError: Could not initialize class org.apache.kafka.connect.json.JsonConverterConfig [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:08 UTC, 1 replies.
- Re: [I] [Bug] Using tidb-cdc to connect to the data source cpu usage is always high [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:12 UTC, 1 replies.
- Re: [I] [Bug] During the snapshot phase, projection is not being performed according to the user defined schema. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:16 UTC, 1 replies.
- Re: [I] [Bug] [sqlserver cdc] the field "snapshot" is always "false" [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:20 UTC, 1 replies.
- Re: [I] [mysql] Add a module to periodically check ip on DNS (for DB Switching) [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:24 UTC, 1 replies.
- Re: [I] [mysql] Add notifications to Slack when the Snapshot phase ends or Binlog stream phase begins [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:28 UTC, 1 replies.
- Re: [I] [Bug] Mysql cdc connector connection pool [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:32 UTC, 1 replies.
- Re: [I] [Feature][mysql] Mysql-cdc source adapts mariadb. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:36 UTC, 1 replies.
- Re: [I] [Feature][Postgres] Support automatically identify newly added tables [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:40 UTC, 1 replies.
- Re: [I] [FLINK-34805][Bug] About PostgresSql snapshot sql [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:45 UTC, 1 replies.
- Re: [I] [Bug] flink cdc missing step to close mysql connection [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:48 UTC, 1 replies.
- Re: [I] Support cdc catalog [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:52 UTC, 1 replies.
- Re: [I] [Bug] Paimon CDC ingestion with mysql-cdc 2.4.1 cannot receive complete Debezium binlog [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:00:56 UTC, 1 replies.
- Re: [I] [Bug] An insufficient number of arguments were supplied for the procedure or function cdc.fn_cdc_get_all_changes_ [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:01 UTC, 1 replies.
- Re: [I] [Bug] Mysql Startup with TIMESTAMP，Restore From Checkpoint Failed：One or more fetchers have encountered exception [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:05 UTC, 1 replies.
- Re: [I] Add docs for the experimental features. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:10 UTC, 1 replies.
- Re: [I] The program encountered a blockage preventing it from reading snapshot data from mysql-cdc [Bug] [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:14 UTC, 1 replies.
- Re: [I] [Bug] DBZ-5589 Mysql connector can't handle the case sensitive of rename/change column statement [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:18 UTC, 1 replies.
- Re: [I] [Bug] Flink CDC Orcale Connection Pool Number settings cannot take effect [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:21 UTC, 1 replies.
- Re: [I] Tidb, please support synchronization of multiple tables at the same time [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:25 UTC, 1 replies.
- Re: [I] [Bug] [tidb cdc]a error:java.lang.IllegalArgumentException: Invalid range: [+INF..{xxx}) at org.apache.flink.shaded.guava30.com.google.common.collect.Range.(Range.java:358) [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:29 UTC, 1 replies.
- Re: [I] [bug] MySQL using utf8_ general_ Ci encoding, splitting will end prematurely [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:33 UTC, 1 replies.
- Re: [I] [Bug] Datetime data inconsistency (off by 8 hours) in snapshot phase [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:37 UTC, 1 replies.
- Re: [I] [Bug] TiDB Flink CDC not support exactly once [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:40 UTC, 1 replies.
- Re: [I] Multiple source read binlogs of the same job are all assigned to SubTask-0, which may have performance problems. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:44 UTC, 1 replies.
- Re: [I] [Bug] [oracle] oracle real-time synchronization is slow [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:48 UTC, 1 replies.
- Re: [I] [Bug] Oracle cdc repeatedly consumes snapshot data and does not consume binlog data [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:52 UTC, 1 replies.
- Re: [I] look forward to adding dameng（dm8） connectors [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:01:56 UTC, 1 replies.
- Re: [I] look forward to adding greenplum connectors [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:00 UTC, 1 replies.
- Re: [I] [Bug] Select mysql cdc table in flink sql client caused java.lang.NoClassDefFoundError: com/fasterxml/jackson/databind/ObjectMapper [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:04 UTC, 1 replies.
- Re: [I] mysql cdc restart from checkpoint failed when some binlog file has been purged [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:07 UTC, 1 replies.
- Re: [I] [Bug] oracle cdc logminer can't catch up the latest records when scn huge increment occured. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:11 UTC, 1 replies.
- Re: [I] Supports synchronizing data from the oracle standby database [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:15 UTC, 1 replies.
- Re: [I] FlinkCDC is incompatible with MariaDB 10.0.24 [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:20 UTC, 1 replies.
- Re: [I] OracleIncrementalSource at Oracle CDB mode [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:23 UTC, 1 replies.
- Re: [I] use earliest-offset or timestamp mode to consume data,flink job always restart [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:27 UTC, 1 replies.
- Re: [I] Support table.exclude.list as Debezium does [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:31 UTC, 1 replies.
- Re: [I] Refactor state serializers in MySQL CDC source [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:34 UTC, 1 replies.
- Re: [I] Can not start FlinkCDC 2.3 with startupOptions = specificOffset [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:38 UTC, 1 replies.
- Re: [I] Caused by: io.debezium.DebeziumException: could not find next log; [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:42 UTC, 1 replies.
- Re: [I] Flink CDC Clinkhouse [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:46 UTC, 1 replies.
- Re: [I] [MySQL-CDC] serverId parameter out of Integer range [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:49 UTC, 1 replies.
- Re: [I] Encountered a problem reading tidb data [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:53 UTC, 1 replies.
- Re: [I] [tidb-cdc]When the task runs for a period of time, there are only Resolved Events [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:02:58 UTC, 1 replies.
- Re: [I] [Feature][Pipeline] SchemeRegistry saves the routing rules used to restore the TransformDataOperator [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:05 UTC, 1 replies.
- Re: [I] [Feature][Pipeline] Flink CDC pipeline transform supports the strategy of schema evolution [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:08 UTC, 1 replies.
- Re: [I] [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:13 UTC, 1 replies.
- Re: [I] [Feature][Pipeline] Flink CDC pipeline transform supports type conversion [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:15 UTC, 1 replies.
- Re: [I] [Feature][Pipeline] Flink CDC pipeline transform supports UDF [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:20 UTC, 1 replies.
- Re: [I] [Feature] CDC Action supports update and delete record (logical deletion) [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:23 UTC, 1 replies.
- Re: [I] [MongoDB] Support initial.snapshotting.pipeline related configs in table api [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:27 UTC, 1 replies.
- Re: [I] [Bug] After starting Streaming ELT from MySQL to StarRocks using Flink CDC 3.0, the newly created tables are not being synchronized. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:30 UTC, 1 replies.
- Re: [I] [Feature] Optimizing the last chunk with a large amount of data to avoid memory overflow. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:35 UTC, 1 replies.
- Re: [I] [Feature] submit Flink CDC pipeline job to k8s cluster. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:39 UTC, 1 replies.
- Re: [I] [Feature][Pipeline] Flink-CDC-Pipeline support database mapper and table add unified prefix or suffix [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:43 UTC, 1 replies.
- Re: [I] [Feature][Pipeline] Flink CDC pipeline supports transform [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:47 UTC, 1 replies.
- Re: [I] [test] Support to execute the (mysql) test cases with custom database deployment [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:50 UTC, 1 replies.
- Re: [I] Flink CDC3.0 Demo Mysql binlog to Starrocks Exception amount of AddColumnEvent is already existed[Bug] [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:54 UTC, 3 replies.
- Re: [I] refactor: some class in flink-connector-mysql-cdc do not inherit from the base class in flink-cdc-base [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:07:58 UTC, 1 replies.
- Re: [I] MySQL database using the compress function, can provide analytic function [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:02 UTC, 1 replies.
- Re: [I] [Bug][cdc-connectors][cdc-base] Transaction log of high_watermark read twice [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:06 UTC, 1 replies.
- Re: [I] [3.1][cdc-composer] Support routing sharding tables with the same primary key into one. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:09 UTC, 1 replies.
- Re: [I] [postgres] Remove unnecessary schema fresh to improve performance. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:13 UTC, 1 replies.
- Re: [I] oracle 19c PDB mode SplitFetcher thread 0 received unexpected exception while polling the records [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:18 UTC, 1 replies.
- Re: [I] Add external listeners to obtain split information [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:22 UTC, 1 replies.
- Re: [I] [Bug] Can't map utf8mb4 given for characterSetResults to a supported MySQL encoding [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:26 UTC, 1 replies.
- Re: [I] Allow custom Configurations for ConnectionPool [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:29 UTC, 1 replies.
- Re: [I] [Bug] Sqlserver transaction hung when get change data. [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:33 UTC, 1 replies.
- Re: [I] SQL server cannot read the correct table[Bug] [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:38 UTC, 1 replies.
- Re: [I] [Bug] flink cdc mysql, use datastream to synchronize multiple tables, read full amount of data in a loop [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:41 UTC, 1 replies.
- Re: [I] [Bug] if splitTable method execute fast than getNext, job will be blocked [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:46 UTC, 1 replies.
- Re: [I] Supports synchronizing data from the postgreSQL standby database? [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:50 UTC, 1 replies.
- Re: [I] [Bug] Incremental source never switches to streaming mode with disabled checkpointing and parallelism > 1 [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:55 UTC, 1 replies.
- Re: [I] [Bug][mysql-cdc] com.ververica.cdc.connectors.mysql.source.utils.StatementUtils#initStatement leads to uncommitted transactions [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:08:58 UTC, 1 replies.
- Re: [I] [Bug] [Critical] cdc-myql-connector snapshot/binlog phase MySQL -> MySQL temporal related field transfer WRONG with/or wrong epoch time across timezone [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:09:02 UTC, 1 replies.
- Re: [I] Flink CDC connector with YugabyteDB [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:09:06 UTC, 1 replies.
- Re: [I] [mysql-cdc] Add upsert changelog mode to avoid UPDATE_BEFORE records push down [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:09:10 UTC, 1 replies.
- Re: [I] simple tidb cdc demo,but caused 'java.lang.IllegalArgumentException: Invalid range: ' [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:09:14 UTC, 1 replies.
- Re: [I] io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource : Failed to start Oracle LogMiner session, retrying-->io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource :.java.sql.SQLException: ORA-01291: missing log file[Bug] [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:14:25 UTC, 1 replies.
- Re: [I] Mysql-connector cdc sourcerecord not have data type information,bug dez record have [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:14:30 UTC, 1 replies.
- Re: [I] [Bug] flink-postgresql-cdc buzy 100% [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:14:34 UTC, 1 replies.
- Re: [I] [Bug] oracle clob [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:14:37 UTC, 1 replies.
- Re: [I] [improve] Alter scan.incremental.close-idle-reader.enabled Default is true [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:14:40 UTC, 1 replies.
- Re: [I] [Bug] Debezium's database.server.name property should not be hard-coded [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:14:45 UTC, 1 replies.
- Re: [I] [Bug] flink cdc has lot of lamda class, it may leaked in flink standalone cluster after task start and stop many times [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:14:48 UTC, 1 replies.
- Re: [I] expected to support flink-connector-db2-cd('scan.startup.mode'='specific_offsets') [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:14:52 UTC, 1 replies.
- Re: [I] flink-sql-connector-mysql-cdc cannot read incremental data in initial mode [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:14:58 UTC, 1 replies.
- Re: [I] Ensure checkpointing is enabled for Postgres connector [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:15:01 UTC, 1 replies.
- Re: [I] Does flink cdc plan to support duckdb sink [flink-cdc] - posted by "PatrickRen (via GitHub)" <gi...@apache.org> on 2024/04/09 06:15:05 UTC, 1 replies.
- (flink-connector-jdbc) branch main updated: [FLINK-35057] Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 - posted by sn...@apache.org on 2024/04/09 06:35:26 UTC, 0 replies.
- (flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was 96caa3cb) - posted by gi...@apache.org on 2024/04/09 06:35:32 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [FLINK-35010][connectors/mongodb] Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 - posted by ji...@apache.org on 2024/04/09 06:36:48 UTC, 0 replies.
- (flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc/org.postgresql-postgresql-42.5.5 updated (7282a5ea -> 16f2a46a) - posted by sn...@apache.org on 2024/04/09 07:01:59 UTC, 0 replies.
- (flink-connector-mongodb) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was 03d7567) - posted by gi...@apache.org on 2024/04/09 07:04:49 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34613][cdc] Support recover from a specific savepoint file (#2959) - posted by re...@apache.org on 2024/04/09 07:25:47 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34952][cdc-composer][sink] Flink CDC pipeline supports SinkFunction (#3204) - posted by re...@apache.org on 2024/04/09 07:27:58 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated: [FLINK-35059] Bump org.postgresql:postgresql to 42.7.3 in flink-connector-jdbc - posted by sn...@apache.org on 2024/04/09 09:04:24 UTC, 0 replies.
- (flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc/org.postgresql-postgresql-42.5.5 deleted (was 16f2a46a) - posted by gi...@apache.org on 2024/04/09 09:04:33 UTC, 0 replies.
- (flink) branch release-1.18 updated: [FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner - posted by sn...@apache.org on 2024/04/09 15:10:19 UTC, 0 replies.
- (flink) branch master updated (68cc61a8618 -> 98bd2659f5b) - posted by pn...@apache.org on 2024/04/09 15:27:51 UTC, 0 replies.
- (flink) 01/02: fixup! [FLINK-19010][metric] Introduce subtask level restore metric - posted by pn...@apache.org on 2024/04/09 15:27:52 UTC, 0 replies.
- (flink) 02/02: [FLINK-35065][metrics] Add numFiredTimers and numFiredTimersPerSecond - posted by pn...@apache.org on 2024/04/09 15:27:53 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner - posted by sn...@apache.org on 2024/04/09 18:02:08 UTC, 0 replies.
- (flink) branch master updated: [FLINK-28440][State/changelog] Increase the materialization Interval of ChangelogRecoveryITCase#testMaterialization - posted by le...@apache.org on 2024/04/10 02:07:08 UTC, 0 replies.
- (flink) branch master updated (10522ff67ec -> ee81c79f899) - posted by ha...@apache.org on 2024/04/10 02:10:58 UTC, 0 replies.
- (flink-ml) branch master updated: [FLINK-35066] Fix the unwrap from IterationRecord during keyBy - posted by zh...@apache.org on 2024/04/10 02:41:33 UTC, 0 replies.
- (flink) branch master updated (ee81c79f899 -> dec5e9e659d) - posted by sn...@apache.org on 2024/04/10 07:32:01 UTC, 0 replies.
- [I] I found flink-cdc supported connectors using YAML definition,its very convenient,i love it.so my question is when other pipeline is supported?for example,i want sync data form oracle to pg or pg to mysql.Thanks! [flink-cdc] - posted by "Leopold-Xu (via GitHub)" <gi...@apache.org> on 2024/04/10 07:55:59 UTC, 2 replies.
- (flink-connector-pulsar) branch main updated: [FLINK-34962] Use client.getPartitionsForTopic instead of lookup.getPartitionedTopicMetadata (#86) - posted by ti...@apache.org on 2024/04/10 08:37:28 UTC, 0 replies.
- (flink-cdc) branch master updated: [MySQL] Fix for DBZ-7037 and #2217 to not clear tableMapEventByTableId for fake Rotates Event (#3065) - posted by re...@apache.org on 2024/04/10 10:17:44 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35015][formats] allow passing hadoop config into parquet reader (#24623) - posted by mb...@apache.org on 2024/04/10 10:48:01 UTC, 0 replies.
- (flink) branch master updated: [hotfix][doc] Generate and use docs of RpcOptions instead of AkkaOptions (#24629) - posted by le...@apache.org on 2024/04/11 02:07:20 UTC, 0 replies.
- (flink) branch master updated (54f789d21ef -> ec2a140daed) - posted by le...@apache.org on 2024/04/11 02:12:48 UTC, 0 replies.
- (flink) 01/03: [FLINK-34986][Runtime/State] Introduce element-control component - posted by le...@apache.org on 2024/04/11 02:12:49 UTC, 0 replies.
- (flink) 02/03: [FLINK-34986][Runtime/State] Basic implementation of AEC, RecordContext and reference counting - posted by le...@apache.org on 2024/04/11 02:12:50 UTC, 0 replies.
- (flink) 03/03: [FLINK-34986][Runtime/State] More tests for reference counting of ContextStateFutureImpl - posted by le...@apache.org on 2024/04/11 02:12:51 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34690] Cast decimal to VARCHAR as primary key in starrocks sink (#3150) - posted by re...@apache.org on 2024/04/11 02:57:54 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34905][cdc-connector][mysql] Fix the default length of CHAR/BINARY data type of Add column DDL (#3145) - posted by re...@apache.org on 2024/04/11 05:42:35 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework - posted by sn...@apache.org on 2024/04/11 07:30:14 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-35007] Add support for Flink 1.19 (#90) - posted by ma...@apache.org on 2024/04/11 08:15:36 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34250][docs] add new option for avro format docs - posted by re...@apache.org on 2024/04/11 08:44:02 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix] run mvn spotless to fix code style violations. (#3219) - posted by re...@apache.org on 2024/04/11 09:15:47 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][cdc-connector][mongo] Fix warning during MongoDB tests (#3210) - posted by ji...@apache.org on 2024/04/11 09:54:15 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [hotfix] Add Java 21 as JDK to test for Flink 1.19.0 weekly runs - posted by ma...@apache.org on 2024/04/11 10:09:30 UTC, 0 replies.
- (flink-connector-kafka) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 updated (57a63919 -> edba5a2b) - posted by ma...@apache.org on 2024/04/11 10:11:43 UTC, 0 replies.
- (flink-connector-kafka) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 updated (edba5a2b -> 0e8bcbec) - posted by ma...@apache.org on 2024/04/11 10:26:40 UTC, 0 replies.
- (flink-connector-kafka) branch dependabot/maven/flink-connector-kafka/org.yaml-snakeyaml-2.0 deleted (was a547a0b7) - posted by gi...@apache.org on 2024/04/11 11:26:25 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-34961] Use dedicated CI name for Kafka connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/11 11:32:41 UTC, 0 replies.
- (flink-connector-kafka) branch v3.1 updated: [FLINK-35007] Add support for Flink 1.19 (#90) - posted by ma...@apache.org on 2024/04/11 11:42:06 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-35008] Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 (#87) - posted by ma...@apache.org on 2024/04/11 11:44:03 UTC, 0 replies.
- (flink-connector-kafka) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was 0e8bcbec) - posted by gi...@apache.org on 2024/04/11 11:44:10 UTC, 0 replies.
- (flink-connector-kafka) branch v3.1 updated (809cb078 -> 4168d0f2) - posted by ma...@apache.org on 2024/04/11 11:45:58 UTC, 0 replies.
- (flink-connector-kafka) 01/02: [hotfix] Add Java 21 as JDK to test for Flink 1.19.0 weekly runs - posted by ma...@apache.org on 2024/04/11 11:45:59 UTC, 0 replies.
- (flink-connector-kafka) 02/02: [FLINK-35008] Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 (#87) - posted by ma...@apache.org on 2024/04/11 11:46:00 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-35038] Bump `org.yaml:snakeyaml` to `2.2` (#93) - posted by ma...@apache.org on 2024/04/11 11:47:50 UTC, 0 replies.
- (flink-connector-kafka) branch v3.1 updated: [FLINK-35038] Bump `org.yaml:snakeyaml` to `2.2` (#93) - posted by ma...@apache.org on 2024/04/11 11:48:20 UTC, 0 replies.
- (flink-cdc) branch master updated (1b0b9f868 -> af7665d33) - posted by re...@apache.org on 2024/04/12 02:13:13 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34634][cdc-base][mysql] Fix that Restarting the job will not read the changelog anymore if it stops before the synchronization of meta information is complete and some table is removed (#3134) - posted by re...@apache.org on 2024/04/12 02:15:50 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35078][ci] Adds flink-cdc-pipeline-connectors to the GHA CI (#3220) - posted by re...@apache.org on 2024/04/12 07:43:04 UTC, 0 replies.
- (flink-connector-kafka) branch v3.1 updated: [FLINK-34961] Use dedicated CI name for Kafka connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/12 08:08:32 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated: [FLINK-34961] Use dedicated CI name for JDBC connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/12 08:56:42 UTC, 0 replies.
- (flink) branch master updated (722fb9b4052 -> c0d889fbb9a) - posted by gu...@apache.org on 2024/04/12 09:08:49 UTC, 0 replies.
- (flink-connector-jdbc) branch v3.1 updated: [FLINK-34961] Use dedicated CI name for JDBC connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/12 09:42:52 UTC, 0 replies.
- (flink-connector-rabbitmq) branch main updated: [FLINK-34961] Use dedicated CI name for Rabbit MQ connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/13 17:56:35 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-34961] Use dedicated CI name for Kubernetes Operator to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/13 18:19:52 UTC, 0 replies.
- (flink-connector-opensearch) branch main updated: [FLINK-34942][connectors/opensearch] Add support for Flink 1.19+ - posted by sn...@apache.org on 2024/04/14 17:13:21 UTC, 0 replies.
- (flink-cdc) branch master updated: [docs] [minor] Optimize styles of the Flink CDC website homepage - posted by le...@apache.org on 2024/04/15 03:07:19 UTC, 0 replies.
- (flink-connector-pulsar) branch main updated: [FLINK-34629][Stream] Fix non-partition topic subscribe lost. (#85) - posted by ti...@apache.org on 2024/04/15 05:47:45 UTC, 0 replies.
- (flink-connector-pulsar) branch main updated (7a5eef2 -> 9f4b902) - posted by ti...@apache.org on 2024/04/15 05:50:39 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController (#24633) - posted by le...@apache.org on 2024/04/15 05:57:03 UTC, 0 replies.
- (flink) branch master updated: [FLINK-32440][checkpoint] Introduce file merging configuration (#22973) - posted by le...@apache.org on 2024/04/15 06:21:48 UTC, 0 replies.
- (flink) branch master updated (c601c70e5c4 -> f74dc57561a) - posted by sn...@apache.org on 2024/04/15 06:28:28 UTC, 0 replies.
- (flink-connector-opensearch) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was d2883c0) - posted by gi...@apache.org on 2024/04/15 06:32:39 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [FLINK-34961] Use dedicated CI name for MongoDB connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/15 06:58:34 UTC, 0 replies.
- (flink-connector-mongodb) branch v1.1 updated: [FLINK-34961] Use dedicated CI name for MongoDB connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/15 07:15:41 UTC, 0 replies.
- (flink-connector-opensearch) branch main updated: [FLINK-34961] Use dedicated CI name for Opensearch connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/15 10:13:33 UTC, 0 replies.
- (flink-connector-opensearch) branch v1.1 updated: [FLINK-34961] Use dedicated CI name for Opensearch connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/15 11:31:28 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-34947] Only scale down JM in Foreground deletion propagation and reduce timeout - posted by gy...@apache.org on 2024/04/15 11:50:30 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-30388] Move Lazy Initialization of AWS element converters to SinkWriter open() method - posted by da...@apache.org on 2024/04/15 11:55:56 UTC, 0 replies.
- (flink-connector-aws) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was 70417e2) - posted by gi...@apache.org on 2024/04/15 12:00:48 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-35108] Do not trigger deployment recovery for finished/failed jobs - posted by gy...@apache.org on 2024/04/15 12:21:11 UTC, 0 replies.
- (flink) branch master updated: [FLINK-31472][connectors/base] Remove external timer service reference from AsyncSinkThrottling Test (#24481) - posted by da...@apache.org on 2024/04/15 12:30:53 UTC, 0 replies.
- (flink-connector-elasticsearch) branch main updated: [FLINK-35094] SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT - posted by sn...@apache.org on 2024/04/15 12:38:48 UTC, 0 replies.
- (flink-web) branch asf-site updated: Fix broken link in CN use-cases.md (#731) - posted by da...@apache.org on 2024/04/15 12:46:26 UTC, 0 replies.
- (flink-web) branch asf-site updated (4c9ef1e57 -> 9aa05781c) - posted by da...@apache.org on 2024/04/15 12:52:57 UTC, 0 replies.
- (flink-web) 01/02: Fix broken link in use-cases.md - posted by da...@apache.org on 2024/04/15 12:52:58 UTC, 0 replies.
- (flink-web) branch asf-site updated: Add missing word (#705) - posted by da...@apache.org on 2024/04/15 13:02:17 UTC, 0 replies.
- (flink-web) branch asf-site updated: Make Flink-specific security page more prominent - posted by da...@apache.org on 2024/04/15 13:04:01 UTC, 0 replies.
- (flink-web) branch asf-site updated: [hotfix][docs] Change how-to-contribute empty link to overview page - posted by da...@apache.org on 2024/04/15 13:08:11 UTC, 0 replies.
- (flink-web) branch asf-site updated (55931515d -> 0f9478d1d) - posted by da...@apache.org on 2024/04/15 13:11:10 UTC, 0 replies.
- (flink-web) 01/02: [hotfix][docs] Change how-to-contribute empty link to overview page (CN) - posted by da...@apache.org on 2024/04/15 13:11:11 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-35113][Connectors/AWS] Bump commons-compress and commons-io dependency versions - posted by da...@apache.org on 2024/04/15 13:20:35 UTC, 0 replies.
- (flink-web) branch asf-site updated: [hotfix] Cannot go to how-to-contribute/contribute-code Chinese page - posted by da...@apache.org on 2024/04/15 13:29:32 UTC, 0 replies.
- (flink-web) branch asf-site updated: Update flink-operations.md 修正错字 - posted by da...@apache.org on 2024/04/15 13:31:41 UTC, 0 replies.
- (flink-connector-gcp-pubsub) branch main updated (4c155b4 -> 952f296) - posted by sn...@apache.org on 2024/04/15 14:33:38 UTC, 0 replies.
- (flink-connector-gcp-pubsub) 01/03: [hotfix] Update dependencies junit5 to 5.10.2 assertj to 3.25.3 testcontainers to 1.19.7 mockito to 3.12.4 hamcrest to 2.2 log4j to 2.23.1 - posted by sn...@apache.org on 2024/04/15 14:33:39 UTC, 0 replies.
- (flink-connector-gcp-pubsub) 02/03: [hotfix] Drop support for Flink 1.16 and add support for 1.19, 1.20 - posted by sn...@apache.org on 2024/04/15 14:33:40 UTC, 0 replies.
- (flink-connector-gcp-pubsub) 03/03: [hotfix] Add jdk 17, 21 to ci, use dedicated name for ci - posted by sn...@apache.org on 2024/04/15 14:33:41 UTC, 0 replies.
- (flink-connector-elasticsearch) branch main updated: [FLINK-34961] Use dedicated CI name for Elasticsearch connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/15 15:15:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-25537][JUnit5 Migration] Module flink-core with package configuration - posted by ji...@apache.org on 2024/04/16 01:09:42 UTC, 0 replies.
- (flink) branch master updated: [hotfix][runtime]Fix the missing methed parameter annotation problem - posted by gu...@apache.org on 2024/04/16 01:34:45 UTC, 0 replies.
- (flink) branch master updated: [FLINK-30081][runtime] Reset unused options like jvm-overhead.min/max for local executor - posted by xt...@apache.org on 2024/04/16 06:24:26 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-34906][autoscaler] Only scale when all tasks are running - posted by fa...@apache.org on 2024/04/16 07:43:35 UTC, 0 replies.
- (flink) branch release-1.18 updated: [FLINK-31472][connectors/base] Remove external timer service reference from AsyncSinkThrottling Test (#24668) - posted by da...@apache.org on 2024/04/16 08:05:27 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-31472][connectors/base] Remove external timer service reference from AsyncSinkThrottling Test (#24669) - posted by da...@apache.org on 2024/04/16 08:05:46 UTC, 0 replies.
- (flink-connector-pulsar) branch main updated: [FLINK-34961] Use dedicated CI name for Pulsar connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/16 08:54:31 UTC, 0 replies.
- (flink-connector-aws) annotated tag v4.3.0-rc1 updated (73a4582 -> 259eeb0) - posted by da...@apache.org on 2024/04/16 10:01:15 UTC, 0 replies.
- svn commit: r68569 - in /dev/flink/flink-connector-aws-4.3.0-rc1: ./ flink-connector-aws-4.3.0-src.tgz flink-connector-aws-4.3.0-src.tgz.asc flink-connector-aws-4.3.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/16 10:02:36 UTC, 0 replies.
- svn commit: r68570 - /dev/flink/flink-connector-aws-4.3.0-rc1/ - posted by da...@apache.org on 2024/04/16 10:07:08 UTC, 0 replies.
- (flink-connector-aws) annotated tag v4.3.0-rc1 deleted (was 259eeb0) - posted by da...@apache.org on 2024/04/16 10:07:44 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [hotfix][Connectors/AWS] Bump default Flink version to minimum support version, 1.18.0 - posted by da...@apache.org on 2024/04/16 10:09:40 UTC, 0 replies.
- (flink-connector-aws) annotated tag v4.3.0-rc1 updated (25f00e4 -> 42e66e4) - posted by da...@apache.org on 2024/04/16 10:12:15 UTC, 0 replies.
- svn commit: r68571 - in /dev/flink/flink-connector-aws-4.3.0-rc1: ./ flink-connector-aws-4.3.0-src.tgz flink-connector-aws-4.3.0-src.tgz.asc flink-connector-aws-4.3.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/16 10:12:50 UTC, 0 replies.
- (flink-connector-hbase) branch main updated: [FLINK-33440] Update Flink version matrix, add 1.19-SNAPSHOT to GH workflows, update flink-connector-parent - posted by sn...@apache.org on 2024/04/16 13:11:49 UTC, 0 replies.
- (flink-connector-hbase) branch main updated: [FLINK-34961] Use dedicated CI name for HBase connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/16 14:14:56 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34653][cdc][route] Support table merging with route rules - posted by le...@apache.org on 2024/04/16 14:48:47 UTC, 0 replies.
- (flink-connector-hbase) branch v3.0 updated: [FLINK-34961] Use dedicated CI name for HBase connector to differentiate it in infra-reports - posted by sn...@apache.org on 2024/04/16 16:09:50 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor (#24663) - posted by ha...@apache.org on 2024/04/17 02:30:39 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35079][cdc-connector][mongo] Fallback to timestamp startup mode when resume token has expired - posted by ji...@apache.org on 2024/04/17 02:31:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35089][runtime] Initialize lastRecordAttributes in AbstractStreamOperator during setup - posted by xt...@apache.org on 2024/04/17 03:54:01 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35089][runtime] Initialize lastRecordAttributes in AbstractStreamOperator during setup - posted by xt...@apache.org on 2024/04/17 03:57:08 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34936][Checkpointing] Register reused shared state handle to FileMergingSnapshotManager - posted by le...@apache.org on 2024/04/17 09:07:46 UTC, 0 replies.
- (flink) branch master updated (31ea1a9358f -> fe8dde4ea48) - posted by le...@apache.org on 2024/04/17 09:34:53 UTC, 0 replies.
- (flink) 01/03: [FLINK-35025][Runtime/State] Erase the type parameter of record within AEC and related components. - posted by le...@apache.org on 2024/04/17 09:34:54 UTC, 0 replies.
- (flink) 02/03: [FLINK-35025][Runtime/State] Abstract stream operators for async state processing - posted by le...@apache.org on 2024/04/17 09:34:55 UTC, 0 replies.
- (flink) 03/03: [FLINK-35025][Runtime/State] Introduce element order for async state processing - posted by le...@apache.org on 2024/04/17 09:34:56 UTC, 0 replies.
- (flink-connector-jdbc) annotated tag v3.2.0-rc1 updated (ba026660 -> 1bb6fede) - posted by da...@apache.org on 2024/04/17 09:41:54 UTC, 0 replies.
- svn commit: r68601 - in /dev/flink/flink-connector-jdbc-3.2.0-rc1: ./ flink-connector-jdbc-3.2.0-src.tgz flink-connector-jdbc-3.2.0-src.tgz.asc flink-connector-jdbc-3.2.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/17 09:42:33 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [FLINK-35139][Connectors/MongoDB] Drop support for Flink 1.17 - posted by ji...@apache.org on 2024/04/17 09:54:48 UTC, 0 replies.
- (flink-connector-mongodb) annotated tag v1.2.0-rc1 updated (7970c25 -> b90b337) - posted by da...@apache.org on 2024/04/17 10:06:50 UTC, 0 replies.
- svn commit: r68602 - in /dev/flink/flink-connector-mongodb-1.2.0-rc1: ./ flink-connector-mongodb-1.2.0-src.tgz flink-connector-mongodb-1.2.0-src.tgz.asc flink-connector-mongodb-1.2.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/17 10:07:20 UTC, 0 replies.
- (flink) branch master updated (fe8dde4ea48 -> 2c5078bc905) - posted by ha...@apache.org on 2024/04/17 14:32:34 UTC, 0 replies.
- (flink) 01/03: [FLINK-34987][state] Introduce new StateDescriptor for Async State API - posted by ha...@apache.org on 2024/04/17 14:32:35 UTC, 0 replies.
- (flink) 02/03: [FLINK-34987][state] Introduce InternalKeyedState for Async State API - posted by ha...@apache.org on 2024/04/17 14:32:36 UTC, 0 replies.
- (flink) 03/03: [FLINK-34987][state] Implement Async Value State (#24651) - posted by ha...@apache.org on 2024/04/17 14:32:37 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated (75eb206e -> 4ec4b319) - posted by mb...@apache.org on 2024/04/17 16:29:43 UTC, 0 replies.
- (flink-kubernetes-operator) 01/02: [FLINK-35116] Bump operator sdk version to 4.8.3 - posted by mb...@apache.org on 2024/04/17 16:29:44 UTC, 0 replies.
- (flink-kubernetes-operator) 02/02: [FLINK-35116] Bump fabric8 version to 6.11.0 - posted by mb...@apache.org on 2024/04/17 16:29:45 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][cdc][docs] Optimize markdown styles in quickstart doc - posted by ji...@apache.org on 2024/04/18 01:18:35 UTC, 0 replies.
- (flink-cdc) branch release-3.0 updated: [minor][cdc][docs] Optimize markdown styles in quickstart doc - posted by ji...@apache.org on 2024/04/18 01:23:33 UTC, 0 replies.
- (flink) branch master updated (2c5078bc905 -> 43a3d50ce39) - posted by jc...@apache.org on 2024/04/18 02:24:05 UTC, 0 replies.
- Re: [I] flinkcdc有可能支持clickhosue或达梦数据库吗？ [flink-cdc] - posted by "louislu007 (via GitHub)" <gi...@apache.org> on 2024/04/18 06:13:08 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-31860] FlinkDeployments never finalize when namespace is deleted - posted by gy...@apache.org on 2024/04/18 06:16:00 UTC, 0 replies.
- [I] Flink Mongodb CDC在遇到DDL操作（eg: db.c.drop()），程序报错, 期待相应功能的支持 [flink-cdc] - posted by "lanse-li (via GitHub)" <gi...@apache.org> on 2024/04/18 07:18:08 UTC, 2 replies.
- (flink-connector-shared-utils) branch release_utils updated: [hotfix] Add optional FLINK_MINOR_VERSION variable for stage_jars script - posted by da...@apache.org on 2024/04/18 09:03:27 UTC, 0 replies.
- (flink-connector-gcp-pubsub) branch main updated: [FLINK-35135][Connectors/Google Cloud PubSub] Drop support for Flink 1.17 (#25) - posted by da...@apache.org on 2024/04/18 09:07:54 UTC, 0 replies.
- (flink-connector-shared-utils) branch release_utils updated: [FLINK-35124] Include Maven build configuration in the pristine source clone - posted by da...@apache.org on 2024/04/18 09:53:49 UTC, 0 replies.
- (flink-connector-gcp-pubsub) annotated tag v3.1.0-rc1 updated (68521e1 -> bfe63f1) - posted by da...@apache.org on 2024/04/18 09:57:10 UTC, 0 replies.
- svn commit: r68621 - in /dev/flink/flink-connector-gcp-pubsub-3.1.0-rc1: ./ flink-connector-gcp-pubsub-3.1.0-src.tgz flink-connector-gcp-pubsub-3.1.0-src.tgz.asc flink-connector-gcp-pubsub-3.1.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/18 09:57:13 UTC, 0 replies.
- (flink-connector-mongodb) annotated tag v1.2.0-rc2 updated (3dd1153 -> e0462b6) - posted by da...@apache.org on 2024/04/18 10:00:06 UTC, 0 replies.
- svn commit: r68622 - in /dev/flink/flink-connector-mongodb-1.2.0-rc2: ./ flink-connector-mongodb-1.2.0-src.tgz flink-connector-mongodb-1.2.0-src.tgz.asc flink-connector-mongodb-1.2.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/18 10:00:09 UTC, 0 replies.
- svn commit: r68623 - in /dev/flink/flink-connector-jdbc-3.2.0-rc2: ./ flink-connector-jdbc-3.2.0-src.tgz flink-connector-jdbc-3.2.0-src.tgz.asc flink-connector-jdbc-3.2.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/18 10:02:10 UTC, 0 replies.
- (flink-connector-jdbc) annotated tag v3.2.0-rc2 updated (b0ff9db2 -> 034fcf8a) - posted by da...@apache.org on 2024/04/18 10:02:11 UTC, 0 replies.
- (flink) branch master updated (43a3d50ce39 -> a312a3bdd25) - posted by ha...@apache.org on 2024/04/18 13:10:49 UTC, 0 replies.
- Re: [I] cause Could not find any factory for identifier 'sqlserver-cdc' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath. [flink-cdc] - posted by "craynic (via GitHub)" <gi...@apache.org> on 2024/04/19 03:37:33 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35127][cdc][values] Remove HybridSource from ValuesSource to avoid CI failure. (#3237) - posted by re...@apache.org on 2024/04/19 07:37:40 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34903][cdc][mysql] Add mysql-pipeline-connector with tables.exclude option to exclude unnecessary tables (#3186) - posted by re...@apache.org on 2024/04/19 07:49:36 UTC, 0 replies.
- (flink) branch master updated (a312a3bdd25 -> 131358b918b) - posted by ch...@apache.org on 2024/04/19 08:19:58 UTC, 0 replies.
- Re: [I] flink-sql-connector-oracle-cdc-2.4.0采集出现异常 [flink-cdc] - posted by "Aiden-Rose (via GitHub)" <gi...@apache.org> on 2024/04/19 09:20:52 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-35115][Connectors/Kinesis] Allow kinesis consumer to snapshotState after cancelling operator - posted by da...@apache.org on 2024/04/19 09:42:47 UTC, 0 replies.
- (flink-connector-aws) annotated tag v4.3.0-rc2 updated (a68f076 -> 009e133) - posted by da...@apache.org on 2024/04/19 09:51:02 UTC, 0 replies.
- svn commit: r68649 - in /dev/flink/flink-connector-aws-4.3.0-rc2: ./ flink-connector-aws-4.3.0-src.tgz flink-connector-aws-4.3.0-src.tgz.asc flink-connector-aws-4.3.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/19 09:51:08 UTC, 0 replies.
- (flink) branch master updated (131358b918b -> 39779829b88) - posted by da...@apache.org on 2024/04/19 09:55:55 UTC, 0 replies.
- (flink-connector-rabbitmq) branch main updated: [hotfix] Bump version to 3.1-SNAPSHOT - posted by da...@apache.org on 2024/04/19 10:10:17 UTC, 0 replies.
- (flink-connector-rabbitmq) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was 107b33c) - posted by da...@apache.org on 2024/04/19 10:15:46 UTC, 0 replies.
- (flink-connector-rabbitmq) branch main updated (1b0e2a8 -> 6b8a906) - posted by da...@apache.org on 2024/04/19 10:34:21 UTC, 0 replies.
- (flink-connector-rabbitmq) 01/02: [hotfix] Update copyright year to 2024 - posted by da...@apache.org on 2024/04/19 10:34:22 UTC, 0 replies.
- (flink-connector-rabbitmq) 02/02: [hotfix] Fix the dependency convergence rule - posted by da...@apache.org on 2024/04/19 10:34:23 UTC, 0 replies.
- (flink-connector-rabbitmq) branch main updated: [FLINK-35142][Connectors/RabbitMQ] Drop support for Flink 1.17 - posted by da...@apache.org on 2024/04/19 10:34:37 UTC, 0 replies.
- (flink-connector-rabbitmq) branch main updated: [FLINK-35174][Connectors/RabbitMQ] Bump commons-compress to 1.26.1 - posted by da...@apache.org on 2024/04/19 10:49:11 UTC, 0 replies.
- Re: [I] The XML dependency of Flink Oracle CDC conflicts with the XML related classes of Java8：ERROR StatusLogger Caught javax.xml.parsers.ParserConfigurationException [flink-cdc] - posted by "Aiden-Rose (via GitHub)" <gi...@apache.org> on 2024/04/19 11:12:25 UTC, 0 replies.
- (flink) branch release-1.18 updated: [FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment - posted by ch...@apache.org on 2024/04/19 13:39:37 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment - posted by ch...@apache.org on 2024/04/19 15:03:25 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-34574] Add CPU and memory size autoscaler quota - posted by gy...@apache.org on 2024/04/19 15:36:28 UTC, 0 replies.
- (flink) branch master updated (39779829b88 -> 7c4dec63eb4) - posted by th...@apache.org on 2024/04/19 16:48:49 UTC, 0 replies.
- (flink) branch master updated: [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode (#24303) - posted by mb...@apache.org on 2024/04/20 18:18:01 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35175][filesystem] Avoid reading with ByteBuffer on hadoop version below 3.3.0 (#24691) - posted by ha...@apache.org on 2024/04/22 01:46:01 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController - posted by le...@apache.org on 2024/04/22 03:01:37 UTC, 0 replies.
- (flink) branch master updated (9336760ace7 -> 68a84fd02fb) - posted by gu...@apache.org on 2024/04/22 03:42:28 UTC, 0 replies.
- (flink) branch master updated (68a84fd02fb -> 51d015b5704) - posted by tw...@apache.org on 2024/04/22 07:29:28 UTC, 0 replies.
- (flink) 01/03: [FLINK-35097][table] Fix 'raw' format deserialization - posted by tw...@apache.org on 2024/04/22 07:29:29 UTC, 0 replies.
- (flink) 02/03: [FLINK-35097][table] Update RawFormatSerDeSchemaTest to validate multiple serializations/deserializations - posted by tw...@apache.org on 2024/04/22 07:29:30 UTC, 0 replies.
- (flink) 03/03: [FLINK-35097][table] Use var-args in RawFormatSerDeSchemaTest - posted by tw...@apache.org on 2024/04/22 07:29:31 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35102][cdc][doris-sink] Correct Doris connector varchar type mapping - posted by le...@apache.org on 2024/04/22 07:53:43 UTC, 0 replies.
- (flink-connector-cassandra) branch main updated: [FLINK-35133][Connectors/Cassandra] Adding support for Flink 1.19 - posted by da...@apache.org on 2024/04/22 09:33:09 UTC, 0 replies.
- (flink-connector-cassandra) branch v3.2 created (now 18e7f7a) - posted by da...@apache.org on 2024/04/22 09:41:37 UTC, 0 replies.
- (flink-connector-cassandra) 01/01: [hotfix] Change development version to 3.2-SNAPSHOT - posted by da...@apache.org on 2024/04/22 09:41:38 UTC, 0 replies.
- (flink-connector-cassandra) branch v3.2 updated: [hotfix] Using SSH for release git submodule - posted by da...@apache.org on 2024/04/22 09:45:54 UTC, 0 replies.
- (flink-connector-cassandra) branch v3.2 updated (8761d7d -> 632aefe) - posted by da...@apache.org on 2024/04/22 12:48:16 UTC, 0 replies.
- (flink-connector-cassandra) 01/01: [hotfix] Using SSH for release git submodule - posted by da...@apache.org on 2024/04/22 12:48:17 UTC, 0 replies.
- (flink-connector-cassandra) annotated tag v3.2.0-rc1 updated (74debf8 -> 28beb69) - posted by da...@apache.org on 2024/04/22 12:48:59 UTC, 0 replies.
- svn commit: r68712 - in /dev/flink/flink-connector-cassandra-3.2.0-rc1: ./ flink-connector-cassandra-3.2.0-src.tgz flink-connector-cassandra-3.2.0-src.tgz.asc flink-connector-cassandra-3.2.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/22 12:49:01 UTC, 0 replies.
- (flink-connector-kafka) branch v3.2 created (now 5232dbe1) - posted by da...@apache.org on 2024/04/22 13:14:55 UTC, 0 replies.
- (flink-connector-kafka) 01/01: [hotfix] Updating development version to 3.2-SNAPSHOT - posted by da...@apache.org on 2024/04/22 13:14:56 UTC, 0 replies.
- (flink) branch master updated (51d015b5704 -> 0b2e9880354) - posted by le...@apache.org on 2024/04/22 13:27:08 UTC, 0 replies.
- (flink-connector-kafka) branch v3.2 updated: [hotfix] Setting default Flink version to 1.18.0 - posted by da...@apache.org on 2024/04/22 13:44:34 UTC, 0 replies.
- (flink-connector-kafka) annotated tag v3.2.0-rc1 updated (d12f73c8 -> ada9e063) - posted by da...@apache.org on 2024/04/22 13:45:08 UTC, 0 replies.
- svn commit: r68714 - in /dev/flink/flink-connector-kafka-3.2.0-rc1: ./ flink-connector-kafka-3.2.0-src.tgz flink-connector-kafka-3.2.0-src.tgz.asc flink-connector-kafka-3.2.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/22 13:45:09 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][cdc][docs] Fix outdated StarRocks quickstart guide - posted by ji...@apache.org on 2024/04/23 01:07:03 UTC, 0 replies.
- (flink-cdc) branch release-3.0 updated: [minor][docs] Fix outdated StarRocks quickstart guide - posted by ji...@apache.org on 2024/04/23 01:07:23 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-34970] Translate architecture documents into Chinese - posted by fa...@apache.org on 2024/04/23 04:38:24 UTC, 0 replies.
- (flink) branch release-1.18 updated: [FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator - posted by gu...@apache.org on 2024/04/23 05:16:15 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator - posted by gu...@apache.org on 2024/04/23 05:17:09 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34969][cdc][cli] Add support for both new and old Flink config files in Flink CDC (#3194) - posted by re...@apache.org on 2024/04/23 09:58:12 UTC, 0 replies.
- (flink-cdc) branch master updated: [pipeline-connector][kafka] Add kafka pipeline data sink connector. (#2938) - posted by re...@apache.org on 2024/04/23 10:00:40 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35055][cdc] Exclude connector dependencies with questionable licenses from fat jar packages (#3212) - posted by re...@apache.org on 2024/04/23 10:05:14 UTC, 0 replies.
- (flink-cdc) branch master updated: [e2e][pipeline-connector][mysql] Add e2e test for mysql pipeline connector - posted by le...@apache.org on 2024/04/23 11:23:30 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35214][runtime] Update result partition id for remote input channel when unknown input channel is updated - posted by gu...@apache.org on 2024/04/23 12:04:25 UTC, 0 replies.
- (flink) branch master updated (ea2eabe7da5 -> 8475d284f2a) - posted by le...@apache.org on 2024/04/23 12:37:05 UTC, 0 replies.
- (flink) branch master updated (8475d284f2a -> d453bafe523) - posted by ma...@apache.org on 2024/04/23 21:01:30 UTC, 0 replies.
- (flink-cdc) branch release-3.0 updated: [hotfix][docs] Use the download link of the release version instead of a snapshot version - posted by le...@apache.org on 2024/04/24 02:42:16 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35166][runtime] Make the SortBufferAccumulator use more buffers when the parallelism is small - posted by gu...@apache.org on 2024/04/24 03:51:52 UTC, 0 replies.
- (flink-cdc) branch master updated: [pipeline-connector][paimon] add paimon pipeline data sink connector. (#2916) - posted by re...@apache.org on 2024/04/24 04:11:10 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][e2e] Fix pipeline e2e test cases failures (#3246) - posted by re...@apache.org on 2024/04/24 06:03:26 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35097][table] Fix 'raw' format deserialization - posted by tw...@apache.org on 2024/04/24 07:28:30 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35077][cdc] Add license checking CI scripts (#3218) - posted by re...@apache.org on 2024/04/24 07:35:32 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34648][cdc] Avoid RPC timeout when applying SchemaChangeEvent to downstream external systems - posted by le...@apache.org on 2024/04/24 07:57:08 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34188][cdc][build] Add scripts in tools/releasing to help release. (#3102) - posted by re...@apache.org on 2024/04/24 08:07:54 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-33506][Connectors/AWS] Add support for jdk17 for AWS connectors (#115) - posted by da...@apache.org on 2024/04/24 08:13:34 UTC, 0 replies.
- (flink-connector-pulsar) annotated tag v4.2.0-rc1 updated (bad8a5f -> cb43feb) - posted by da...@apache.org on 2024/04/24 08:15:02 UTC, 0 replies.
- svn commit: r68743 - in /dev/flink/flink-connector-pulsar-4.2.0-rc1: ./ flink-connector-pulsar-4.2.0-src.tgz flink-connector-pulsar-4.2.0-src.tgz.asc flink-connector-pulsar-4.2.0-src.tgz.sha512 - posted by da...@apache.org on 2024/04/24 08:15:08 UTC, 0 replies.
- (flink-connector-pulsar) annotated tag v4.2.0-rc1 deleted (was cb43feb) - posted by da...@apache.org on 2024/04/24 08:18:53 UTC, 0 replies.
- (flink-cdc) branch master updated (65d670a58 -> 3fe0540df) - posted by re...@apache.org on 2024/04/24 08:42:03 UTC, 0 replies.
- (flink-cdc) branch release-3.1 created (now 3fe0540df) - posted by re...@apache.org on 2024/04/24 08:44:43 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][ci] Polish ci concurrency group to avoid warning message - posted by le...@apache.org on 2024/04/24 08:47:53 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [hotfix][docs] Update documentation config for release-3.1 - posted by re...@apache.org on 2024/04/24 08:52:18 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35148][core] Improve InstantiationUtil for checking nullary public constructor - posted by xt...@apache.org on 2024/04/24 10:01:31 UTC, 0 replies.
- (flink) branch master updated (9cc649898d0 -> 8576178c4c0) - posted by ro...@apache.org on 2024/04/24 15:47:26 UTC, 0 replies.
- (flink) 01/02: [FLINK-35188][table-api] Introduce CatalogMaterializedTable interface to support materialized table - posted by ro...@apache.org on 2024/04/24 15:47:27 UTC, 0 replies.
- (flink) 02/02: [FLINK-35188][table-api] Introduce RefreshHandler interface to support materialized table - posted by ro...@apache.org on 2024/04/24 15:47:28 UTC, 0 replies.
- (flink-cdc) branch master updated (990261da6 -> ddf557c8e) - posted by le...@apache.org on 2024/04/24 16:11:55 UTC, 0 replies.
- (flink-cdc) 01/03: [cdc-connector][db2] Db2 support incremental source - posted by le...@apache.org on 2024/04/24 16:11:56 UTC, 0 replies.
- (flink-cdc) 02/03: [minor][cdc-connector][db2] Fix typos and improve the code style - posted by le...@apache.org on 2024/04/24 16:11:57 UTC, 0 replies.
- (flink-cdc) 03/03: [tests][cdc-connector][db2] Improve the DB2 tests - posted by le...@apache.org on 2024/04/24 16:11:58 UTC, 0 replies.
- (flink) branch FLINK-31223-rest-ssl-fix created (now 05cfbb8b308) - posted by gu...@apache.org on 2024/04/24 16:12:05 UTC, 0 replies.
- (flink) 01/03: [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all flink configurations copy in the form of map. - posted by gu...@apache.org on 2024/04/24 16:12:06 UTC, 1 replies.
- (flink) 02/03: [FLINK-31223][test] Abstract SqlClientTestBase. - posted by gu...@apache.org on 2024/04/24 16:12:07 UTC, 1 replies.
- (flink) 03/03: [FLINK-31223][sqlgateway] Pass all flink parameters to the SqlGatewayRestEndpoint. - posted by gu...@apache.org on 2024/04/24 16:12:08 UTC, 1 replies.
- (flink) branch FLINK-31223-rest-ssl-fix deleted (was 05cfbb8b308) - posted by gu...@apache.org on 2024/04/24 16:14:12 UTC, 0 replies.
- (flink-connector-opensearch) branch main updated (a4367c7 -> 22a2934) - posted by sn...@apache.org on 2024/04/24 20:26:45 UTC, 0 replies.
- (flink-connector-opensearch) 01/03: [FLINK-33859] Support OpenSearch v2 - posted by sn...@apache.org on 2024/04/24 20:26:46 UTC, 0 replies.
- (flink-connector-opensearch) 02/03: [hotfix] Apply for Opensearch 2.13.0 and 1.3.15 - posted by sn...@apache.org on 2024/04/24 20:26:47 UTC, 0 replies.
- (flink-connector-opensearch) 03/03: [hotfix] Introduce profiles for releasing connectors for Opensearch 1 and 2 - posted by sn...@apache.org on 2024/04/24 20:26:48 UTC, 0 replies.
- svn commit: r68749 - in /dev/flink/flink-connector-opensearch-1.2.0-rc1: ./ flink-connector-opensearch-1.2.0-src.tgz flink-connector-opensearch-1.2.0-src.tgz.asc flink-connector-opensearch-1.2.0-src.tgz.sha512 - posted by sn...@apache.org on 2024/04/24 21:28:39 UTC, 0 replies.
- svn commit: r68750 - /dev/flink/flink-connector-opensearch-1.2.0-rc1/ - posted by sn...@apache.org on 2024/04/24 22:02:49 UTC, 0 replies.
- svn commit: r68751 - in /dev/flink/flink-connector-opensearch-1.2.0-rc1: ./ flink-connector-opensearch-1.2.0-src.tgz flink-connector-opensearch-1.2.0-src.tgz.asc flink-connector-opensearch-1.2.0-src.tgz.sha512 - posted by sn...@apache.org on 2024/04/24 22:32:17 UTC, 0 replies.
- (flink-connector-opensearch) branch dependabot/maven/flink-connector-opensearch/org.opensearch-opensearch-2.11.1 deleted (was f0c07d7) - posted by gi...@apache.org on 2024/04/24 22:38:09 UTC, 0 replies.
- (flink-connector-opensearch) branch main updated: [hotfix] Use jdk 1.8 for profile activation (#45) - posted by sn...@apache.org on 2024/04/24 23:06:01 UTC, 0 replies.
- (flink) branch master updated (8576178c4c0 -> 09531994e3c) - posted by fa...@apache.org on 2024/04/25 01:19:31 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated: [FLINK-33460][Connector/JDBC] Support property authentication connection. (#115) - posted by fa...@apache.org on 2024/04/25 01:29:19 UTC, 0 replies.
- (flink) branch master updated (09531994e3c -> 92eef24d4cc) - posted by fa...@apache.org on 2024/04/25 01:31:22 UTC, 0 replies.
- (flink) 01/03: [FLINK-29050][test-utils] Rename AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase with JUnit4 suffix. - posted by fa...@apache.org on 2024/04/25 01:31:23 UTC, 0 replies.
- (flink) 02/03: [FLINK-29050][test-utils] Use JUnit5 to re-write AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase and tag the corresponding old implementation classes as deprecated - posted by fa...@apache.org on 2024/04/25 01:31:24 UTC, 0 replies.
- (flink) 03/03: [FLINK-29050][JUnit5 Migration] Module: flink-hadoop-compatibility - posted by fa...@apache.org on 2024/04/25 01:31:25 UTC, 0 replies.
- (flink) branch release-1.18 updated: [FLINK-35097][table] Fix 'raw' format deserialization - posted by tw...@apache.org on 2024/04/25 05:43:36 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added (#3230) - posted by re...@apache.org on 2024/04/25 06:03:28 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35156][Runtime] Make operators of DataStream V2 integrate with async state processing - posted by le...@apache.org on 2024/04/25 06:15:36 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34639][cdc][oceanbase] Support debezium deserializer in OceanBase source connector (#3124) - posted by re...@apache.org on 2024/04/25 07:17:29 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [hotfix] Update version to 3.1-SNAPSHOT - posted by re...@apache.org on 2024/04/25 07:37:50 UTC, 0 replies.
- (flink) branch master updated: [hotfix][docs] Fix the invalid link in 1.18 release note - posted by gu...@apache.org on 2024/04/25 08:28:29 UTC, 0 replies.
- (flink-connector-elasticsearch) branch main updated: [FLINK-35134][Connectors/Elasticsearch] Drop support for Flink 1.17 - posted by gu...@apache.org on 2024/04/25 08:44:34 UTC, 0 replies.
- (flink-cdc) branch master updated: [release] Update version to 3.2-SNAPSHOT - posted by le...@apache.org on 2024/04/25 09:49:12 UTC, 0 replies.
- (flink) branch master updated: [hotfix][runtime] Make sure run RecordContext#release() in Task thread. (#24705) - posted by le...@apache.org on 2024/04/25 09:59:33 UTC, 0 replies.
- (flink-cdc) branch master updated: [docs][hotfix] Correct shell scripts style in Quickstart document - posted by le...@apache.org on 2024/04/25 10:04:07 UTC, 0 replies.
- (flink) branch master updated (797cb9cd843 -> 259aef0b66b) - posted by gu...@apache.org on 2024/04/25 16:05:48 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35239] [docs] Unset outdated warning - posted by uc...@apache.org on 2024/04/25 16:25:44 UTC, 0 replies.
- (flink) branch master updated (259aef0b66b -> 19577b0da7f) - posted by ha...@apache.org on 2024/04/26 01:48:50 UTC, 0 replies.
- (flink) 01/07: [FLINK-35047][state] Introduce forstjni dependency - posted by ha...@apache.org on 2024/04/26 01:48:51 UTC, 0 replies.
- (flink) 02/07: [FLINK-35047][state] Introduce ForSt related options - posted by ha...@apache.org on 2024/04/26 01:48:52 UTC, 0 replies.
- (flink) 03/07: [FLINK-35047][state] Introduce Metrics for ForStStateBackend - posted by ha...@apache.org on 2024/04/26 01:48:53 UTC, 0 replies.
- (flink) 04/07: [FLINK-35047][state] Introduce ResourceContainer for ForStStateBackend - posted by ha...@apache.org on 2024/04/26 01:48:54 UTC, 0 replies.
- (flink) 05/07: [FLINK-35047][state] Support restoring and building ForSt - posted by ha...@apache.org on 2024/04/26 01:48:55 UTC, 0 replies.
- (flink) 06/07: [FLINK-35047][state] Introduce ForStStateBackend and ForStKeyedStateBackend - posted by ha...@apache.org on 2024/04/26 01:48:56 UTC, 0 replies.
- (flink) 07/07: [FLINK-35047][state] Support FlinkEnv to init ForSt - posted by ha...@apache.org on 2024/04/26 01:48:57 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35190][table-api] Support create materialized table syntax - posted by ro...@apache.org on 2024/04/26 01:54:26 UTC, 0 replies.
- (flink) branch master updated (512f3fbaac8 -> fb5838042cd) - posted by ha...@apache.org on 2024/04/26 02:05:25 UTC, 0 replies.
- (flink) 01/03: [FLINK-35125][state] Implement ValueState for ForStStateBackend - posted by ha...@apache.org on 2024/04/26 02:05:26 UTC, 0 replies.
- (flink) 02/03: [FLINK-35162][state]Support grouping state get and put access - posted by ha...@apache.org on 2024/04/26 02:05:27 UTC, 0 replies.
- (flink) 03/03: [FLINK-35162][state] Attach the keyGroup and payload into RecordContext - posted by ha...@apache.org on 2024/04/26 02:05:28 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated (1b8c73c6a -> 5096dc73a) - posted by re...@apache.org on 2024/04/26 02:19:17 UTC, 0 replies.
- (flink-cdc) 01/02: [cdc-connector][db2] Db2 support incremental source - posted by re...@apache.org on 2024/04/26 02:19:18 UTC, 0 replies.
- (flink-cdc) 02/02: [hotfix][ci] Polish ci concurrency group to avoid warning message - posted by re...@apache.org on 2024/04/26 02:19:19 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added (#3230) (#3257) - posted by re...@apache.org on 2024/04/26 03:29:46 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [FLINK-34639][cdc][oceanbase] Support debezium deserializer in OceanBase source connector (#3124) (#3259) - posted by re...@apache.org on 2024/04/26 03:32:03 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35173][cdc][mysql] Debezium custom time serializer for MySQL connector (#3240) - posted by re...@apache.org on 2024/04/26 06:10:38 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][cdc][docs] Add user guide about providing extra jar package in quickstart docs - posted by ji...@apache.org on 2024/04/26 08:30:53 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [minor][cdc][docs] Add user guide about providing extra jar package in quickstart docs - posted by ji...@apache.org on 2024/04/26 08:34:59 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [FLINK-35173][cdc][mysql] Debezium custom time serializer for MySQL connector (#3240) (#3264) - posted by re...@apache.org on 2024/04/26 08:47:46 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink - posted by ji...@apache.org on 2024/04/26 08:59:53 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink - posted by ji...@apache.org on 2024/04/26 09:00:16 UTC, 0 replies.
- (flink) branch master updated: add HTTP options to java-storage client - posted by da...@apache.org on 2024/04/26 09:08:04 UTC, 0 replies.
- (flink) branch master updated (f64654e9749 -> 714d1cb2e0b) - posted by ro...@apache.org on 2024/04/26 09:41:54 UTC, 0 replies.
- (flink) 01/03: [FLINK-35189][table-common] CatalogPropertiesUtil support serialize and deserialize materialized table - posted by ro...@apache.org on 2024/04/26 09:41:55 UTC, 0 replies.
- (flink) 02/03: [FLINK-35189][connectors/filesystem] Modify the visibility of filesystem connector related methods to protected - posted by ro...@apache.org on 2024/04/26 09:41:56 UTC, 0 replies.
- (flink) 03/03: [FLINK-35189][test-utils] Introduce test-filesystem connector and catalog based on filesystem to support materialized table - posted by ro...@apache.org on 2024/04/26 09:41:57 UTC, 0 replies.
- (flink) branch master updated (714d1cb2e0b -> 3ff2ba43720) - posted by le...@apache.org on 2024/04/26 11:50:12 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest - posted by gu...@apache.org on 2024/04/26 13:17:08 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated (b96ea11cc -> 62fb38b9b) - posted by re...@apache.org on 2024/04/27 07:47:16 UTC, 0 replies.
- (flink-cdc) 01/06: [hotfix] Remove distribution management and add scm infomation in pom - posted by re...@apache.org on 2024/04/27 07:47:17 UTC, 0 replies.
- (flink-cdc) 02/06: [hotfix] Remove test-jar from parent pom and only add to necessary modules - posted by re...@apache.org on 2024/04/27 07:47:18 UTC, 0 replies.
- (flink-cdc) 03/06: [hotfix] Change parent POM's artifact ID to flink-cdc-parent - posted by re...@apache.org on 2024/04/27 07:47:19 UTC, 0 replies.
- (flink-cdc) 04/06: [hotfix] Use apache-release profile instead - posted by re...@apache.org on 2024/04/27 07:47:20 UTC, 0 replies.
- (flink-cdc) 05/06: [hotfix] Include LICENSE in binary release - posted by re...@apache.org on 2024/04/27 07:47:21 UTC, 0 replies.
- (flink-cdc) 06/06: [hotfix] Use flink-cdc as source release prefix - posted by re...@apache.org on 2024/04/27 07:47:22 UTC, 0 replies.
- svn commit: r68816 - in /dev/flink/flink-cdc-3.1.0-rc0: ./ 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.asc flink-cdc-3.1.0-src.tgz.sha512 - posted by re...@apache.org on 2024/04/27 08:02:59 UTC, 0 replies.
- (flink-cdc) annotated tag release-3.1.0-rc0 updated (0685d090a -> 24404c726) - posted by re...@apache.org on 2024/04/27 08:04:14 UTC, 0 replies.
- svn commit: r68829 - /dev/flink/flink-connector-opensearch-1.2.0-rc1/ - posted by sn...@apache.org on 2024/04/27 20:09:34 UTC, 0 replies.
- svn commit: r68830 - in /dev/flink/flink-connector-opensearch-2.0.0-rc1: ./ flink-connector-opensearch-2.0.0-src.tgz flink-connector-opensearch-2.0.0-src.tgz.asc flink-connector-opensearch-2.0.0-src.tgz.sha512 - posted by sn...@apache.org on 2024/04/27 20:10:36 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35251][cdc][runtime] Fix bug of serializing derivation mapping in SchemaDerivation - posted by le...@apache.org on 2024/04/28 00:30:51 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [hotfix] Using Flink ExceptionUtils#findThrowable for exception checking (#818) - posted by fa...@apache.org on 2024/04/28 02:45:34 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35208][python] Respect pipeline.cached-files during handling Python dependencies - posted by di...@apache.org on 2024/04/28 07:39:35 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation (#3276) - posted by re...@apache.org on 2024/04/28 10:08:01 UTC, 0 replies.
- (flink-cdc) branch release-3.0 updated: [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation (#3275) - posted by re...@apache.org on 2024/04/28 10:10:23 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34915][table] Support `DESCRIBE CATALOG` syntax - posted by jc...@apache.org on 2024/04/28 11:58:01 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation (#3274) - posted by re...@apache.org on 2024/04/28 13:12:18 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35256][cdc][runtime] Fix transform node does not respect type nullability (#3272) - posted by re...@apache.org on 2024/04/28 13:16:29 UTC, 0 replies.
- (flink-cdc) annotated tag release-3.1.0-rc0 deleted (was 24404c726) - posted by re...@apache.org on 2024/04/28 14:03:14 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][docs] Fix route definition example in core concept docs (#3269) - posted by re...@apache.org on 2024/04/29 02:22:17 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [FLINK-35256][runtime] Fix transform node does not respect type nullability (#3277) - posted by re...@apache.org on 2024/04/29 02:22:55 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [FLINK-35251][cdc][runtime] Fix bug of serializing derivation mapping in SchemaDerivation - posted by re...@apache.org on 2024/04/29 02:24:54 UTC, 0 replies.
- (flink) branch master updated: [FLINK-32622][table-planner] Optimize mini-batch assignment (#23470) - posted by ji...@apache.org on 2024/04/29 02:46:31 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35259][cdc][transform] Fix FlinkCDC pipeline transform can't deal timestamp field (#3278) - posted by re...@apache.org on 2024/04/29 03:33:07 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34878][cdc][transform] Flink CDC pipeline transform supports CASE WHEN (#3228) - posted by re...@apache.org on 2024/04/29 03:35:32 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35255][cdc][runtime] DataSinkWriterOperator adds overrides for the snapshotState and processWatermark methods (#3271) - posted by re...@apache.org on 2024/04/29 03:52:21 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34379][table] Fix OutOfMemoryError with large queries - posted by ro...@apache.org on 2024/04/29 04:02:51 UTC, 0 replies.
- (flink) branch master updated (cca14d42106 -> 5e924d76250) - posted by fa...@apache.org on 2024/04/29 05:05:17 UTC, 0 replies.
- (flink) branch master updated: [hotfix][docs] Fix file reference - posted by fa...@apache.org on 2024/04/29 05:06:02 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated (711bc0038 -> 7a1947927) - posted by re...@apache.org on 2024/04/29 06:02:49 UTC, 0 replies.
- (flink-cdc) 01/02: [FLINK-35259][cdc][transform] Fix FlinkCDC pipeline transform can't deal timestamp field (#3278) - posted by re...@apache.org on 2024/04/29 06:02:50 UTC, 0 replies.
- (flink-cdc) 02/02: [FLINK-34878][cdc][transform] Flink CDC pipeline transform supports CASE WHEN (#3228) - posted by re...@apache.org on 2024/04/29 06:02:51 UTC, 0 replies.
- (flink) branch master updated (f75c5188660 -> 86de622c807) - posted by fa...@apache.org on 2024/04/29 06:04:01 UTC, 0 replies.
- (flink) 01/03: [FLINK-35222][rest] Add getJobType for AccessExecutionGraph - posted by fa...@apache.org on 2024/04/29 06:04:02 UTC, 0 replies.
- (flink) 02/03: [FLINK-35223][rest] Add jobType in JobDetailsInfo related rest api - posted by fa...@apache.org on 2024/04/29 06:04:03 UTC, 0 replies.
- (flink) 03/03: [FLINK-35224][web] Show the JobType on Flink WebUI - posted by fa...@apache.org on 2024/04/29 06:04:04 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [minor][docs] Fix route definition example in core concept docs (#3270) - posted by re...@apache.org on 2024/04/29 07:23:08 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [FLINK-35255][cdc][runtime] DataSinkWriterOperator adds overrides for the snapshotState and processWatermark methods (#3279) - posted by re...@apache.org on 2024/04/29 07:24:09 UTC, 0 replies.
- (flink-cdc) branch master updated (23a67dcdb -> f61f0f44b) - posted by re...@apache.org on 2024/04/29 12:23:48 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [FLINK-35264][cdc][runtime] Fix multiple transform rules do not take effect (#3281) - posted by re...@apache.org on 2024/04/29 12:23:58 UTC, 0 replies.
- (flink-connector-hbase) branch main updated: [FLINK-35233] Fix lookup cache reuse RowData object problem (#47) - posted by ma...@apache.org on 2024/04/29 14:35:28 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-35228][Connectors/Kafka] Fix: DynamicKafkaSource does not read re-added topic for the same cluster (#97) - posted by ma...@apache.org on 2024/04/29 23:13:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35191][table-api] Support alter materialized table related syntax: suspend, resume, refresh, set and reset - posted by ro...@apache.org on 2024/04/30 01:29:44 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35184][table-runtime] Fix mini-batch join hash collision when use InputSideHasNoUniqueKeyBundle - posted by ro...@apache.org on 2024/04/30 02:14:54 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-34379][table] Fix OutOfMemoryError with large queries - posted by ro...@apache.org on 2024/04/30 02:19:41 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-32622][table-planner] Optimize mini-batch assignment (#23470) - posted by ji...@apache.org on 2024/04/30 04:40:05 UTC, 0 replies.
- 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.asc flink-cdc-3.1.0-src.tgz.sha512 - posted by re...@apache.org on 2024/04/30 04:48:24 UTC, 0 replies.
- (flink-cdc) annotated tag release-3.1.0-rc1 updated (63b42cb93 -> cdae15dab) - posted by re...@apache.org on 2024/04/30 04:49:11 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35194][table] Support describe job statement for SqlGateway - posted by ro...@apache.org on 2024/04/30 06:41:05 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34902][table] Fix IndexOutOfBoundsException for VALUES - posted by tw...@apache.org on 2024/04/30 08:51:44 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722) - posted by sr...@apache.org on 2024/04/30 11:36:18 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722) (#24751) - posted by sr...@apache.org on 2024/04/30 20:25:35 UTC, 0 replies.
- (flink) branch release-1.18 updated: [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722) (#24752) - posted by sr...@apache.org on 2024/04/30 20:25:45 UTC, 0 replies.