commits  

Messages by Thread

• [I] Caused by: java.sql.SQLException: ORA-01435: user does not exist ORA-06512: at "SYS.DBMS_LOGMNR", line 72 [flink-cdc] via GitHub
  • Re: [I] Caused by: java.sql.SQLException: ORA-01435: user does not exist ORA-06512: at "SYS.DBMS_LOGMNR", line 72 [flink-cdc] via GitHub
  • Re: [I] Caused by: java.sql.SQLException: ORA-01435: user does not exist ORA-06512: at "SYS.DBMS_LOGMNR", line 72 [flink-cdc] via GitHub
  • Re: [I] Caused by: java.sql.SQLException: ORA-01435: user does not exist ORA-06512: at "SYS.DBMS_LOGMNR", line 72 [flink-cdc] via GitHub
  • Re: [I] Caused by: java.sql.SQLException: ORA-01435: user does not exist ORA-06512: at "SYS.DBMS_LOGMNR", line 72 [flink-cdc] via GitHub
• (flink) branch release-1.19 updated: [FLINK-35136][docs] Bump HBase connector docs version to v4.0 fcsaky
• (flink) branch release-1.19 updated: [FLINK-36751] Fix PausableRelativeClock does not pause when the source only has one split roman
• (flink-connector-hbase) branch main updated: [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch fcsaky
• (flink-connector-hbase) branch v4.0 updated: [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch fcsaky
• (flink) branch master updated: [FLINK-35136][docs] Bump HBase connector docs version to v4.0 fcsaky
• (flink-web) branch asf-site updated (c09af3ab9 -> fcad0bfb2) fcsaky
• (flink-web) branch asf-site updated (fcad0bfb2 -> 744ec4195) fcsaky
• (flink-web) branch asf-site updated: Update blogpost for new KinesisStreamsSource and DynamoDbStreamsSource hong
• (flink) branch master updated: [FLINK-36718][table-planner] Add CompiledPlan annotations to BatchExecLookupJoin snuyanzin
• (flink) branch master updated: [FLINK-36764] Add checkpoint type and unaligned flag to the checkpoint trace pnowojski
• (flink) branch master updated: [hotfix] Do skip distributing maxAllowedWatermark if there are no subtasks pnowojski
• (flink-cdc) branch master updated: [hotfix][Doc] fix spelling error in Al model docs. (#3764) ruanhang1993
• (flink-kubernetes-operator) branch main updated: [hotfix] Fix incorrect `messageKey` passed in `ScalingLimited` event gyfora
• (flink-web) branch asf-site updated: Add release announcement for Flink CDC 3.2.1 (#764) ruanhang1993
• Re: [I] 请问出现这个错误(io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4{timestamp=1627541881000,)是什么原因? [flink-cdc] via GitHub
  • Re: [I] 请问出现这个错误(io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4{timestamp=1627541881000,)是什么原因? [flink-cdc] via GitHub
• Re: [I] cdc sync mysql to paimon Schema Registry is busy now, waiting for next request... [flink-cdc] via GitHub
  • Re: [I] cdc sync mysql to paimon Schema Registry is busy now, waiting for next request... [flink-cdc] via GitHub
• (flink-cdc) annotated tag release-3.2.1 updated (c703d18d1 -> 86acf60d7) ruanhang1993
• svn commit: r73300 - /dev/flink/flink-cdc-3.2.1-rc1/ /release/flink/flink-cdc-3.2.1/ leonard
• [I] paimon sync table CreateTableEvent hold [flink-cdc] via GitHub
  • Re: [I] paimon sync table CreateTableEvent hold [flink-cdc] via GitHub
• (flink-shaded) branch master updated: [FLINK-35003] Update zookeeper to 3.8.4 snuyanzin
• (flink) branch release-1.19 updated: [FLINK-35334][flink-table] Split constructor of generated code if it is too large snuyanzin
• (flink) branch release-1.20 updated: [FLINK-35334][flink-table] Split constructor of generated code if it is too large snuyanzin
• (flink) branch master updated: [FLINK-35334][flink-table] Split constructor of generated code if it is too large snuyanzin
• (flink) branch master updated: [FLINK-36048][table-planner] Add CompiledPlan annotations to BatchExecRank snuyanzin
• (flink-web) branch asf-site updated: Upgrade Kafka connector to 3.4.0 arvid
• (flink-shaded) branch master updated: [FLINK-33571] Update json-path from 2.7.0 to 2.9.0 (#140) snuyanzin
• (flink) branch release-1.20 updated: [FLINK-33571][table] Upgrade json-path from 2.7.0 to 2.9.0 snuyanzin
• (flink-connector-hbase) annotated tag v4.0.0 updated (4dd8505 -> cc62d8a) fcsaky
• (flink-connector-hbase) annotated tag v deleted (was ae84cd3) fcsaky
• (flink-connector-hbase) annotated tag v updated (4dd8505 -> ae84cd3) fcsaky
• svn commit: r73286 - /dev/flink/flink-connector-hbase-4.0.0-rc1/ /release/flink/flink-connector-hbase-4.0.0/ mbalassi
• (flink) branch release-1.20 updated: [hotfix] Correct Guava version roman
• (flink) branch release-1.20 updated: [FLINK-36714][state] Ignore interrupted in sstmerge.CompactionScheduler#stop roman
• (flink) branch master updated: [FLINK-36047] Add CompiledPlan annotations to BatchExecOverAggregate snuyanzin
• (flink-connector-aws) branch v5.0 updated: [hotfix][docs] Fix description of new configuration table hong
• (flink) branch master updated: [FLINK-36720][table-planner] Add CompiledPlan annotations to BatchExecWindowTableFunction twalthr
• (flink-kubernetes-operator) branch main updated: [FLINK-36545] Fix uid/gid mixup when generating the OLM bundle gyfora
• (flink) branch master updated (59dc491f87e -> 0580924bf06) twalthr
• (flink-cdc) branch master updated: [FLINK-36525][transform] Support for AI Model Integration for Data Processing (#3753) ruanhang1993
• Re: [I] Failed to deserialize data of EventHeaderV4 [flink-cdc] via GitHub
  • Re: [I] Failed to deserialize data of EventHeaderV4 [flink-cdc] via GitHub
  • Re: [I] Failed to deserialize data of EventHeaderV4 [flink-cdc] via GitHub
• (flink) branch master updated (0c338ae6d21 -> 59dc491f87e) guoweijie
• (flink) branch release-1.19 updated: [FLINK-35977][docs] Add missing imports in examples in docs snuyanzin
• (flink-web) branch asf-site updated: Rebuild website hong
  • (flink-web) branch asf-site updated: Rebuild website tangyun
• (flink-web) branch asf-site updated: Add blogpost for new KinesisStreamsSource and DynamoDbStreamsSource hong
• (flink) branch release-1.20 updated: [FLINK-36751] Fix PausableRelativeClock does not pause when the source only has one split roman
• (flink) branch master updated (3ac109b0b4f -> 0c338ae6d21) roman
• (flink-connector-kafka) branch v3.4 created (now e93b300d) arvid
• (flink-connector-kafka) branch main updated: [FLINK-35109] Update weekly CI to verify 3.4 release branch arvid
• (flink-connector-kafka) tag v3.4.0 updated (bafdba80 -> e93b300d) arvid
• (flink-connector-kafka) annotated tag v3.4.0 updated (4d3c1022 -> bafdba80) arvid
• svn commit: r73241 - /dev/flink/flink-connector-kafka-3.4.0-rc1/ /release/flink/flink-connector-kafka-3.4.0/ arvid
• (flink) branch master updated: [FLINK-36704][table-common] Update TypeInference with StaticArgument and StateTypeStrategy twalthr
• (flink) branch master updated: [FLINK-31836][table] Upgrade Calcite version to 1.34.0 snuyanzin
• (flink) branch master updated: [hotfix][tests] Remove space from junit Extension file name snuyanzin
• (flink) branch master updated (ced02ce25a2 -> 44da52d0964) shengkai
  • (flink) 02/02: [FLINK-36755][yarn] Relax the limitation that yarn application require a main jar shengkai
  • (flink) 01/02: [FLINK-36755][k8s] Relax the limitation that kubernetes application require a main jar shengkai
• [I] flink-cdc3.x版本不支持同步MySQL含有联合主键的表到doris中，任务会报异常并且停止 [flink-cdc] via GitHub
  • Re: [I] flink-cdc3.x版本不支持同步MySQL含有联合主键的表到doris中，任务会报异常并且停止 [flink-cdc] via GitHub
  • Re: [I] flink-cdc3.x版本不支持同步MySQL含有联合主键的表到doris中，任务会报异常并且停止 [flink-cdc] via GitHub
  • Re: [I] flink-cdc3.x版本不支持同步MySQL含有联合主键的表到doris中，任务会报异常并且停止 [flink-cdc] via GitHub
  • Re: [I] flink-cdc3.x版本不支持同步MySQL含有联合主键的表到doris中，任务会报异常并且停止 [flink-cdc] via GitHub
  • Re: [I] flink-cdc3.x版本不支持同步MySQL含有联合主键的表到doris中，任务会报异常并且停止 [flink-cdc] via GitHub
  • Re: [I] flink-cdc3.x版本不支持同步MySQL含有联合主键的表到doris中，任务会报异常并且停止 [flink-cdc] via GitHub
• (flink) branch master updated: [FLINK-35977][docs] Add missing imports in examples in docs snuyanzin
• (flink) branch master updated: [FLINK-35751][table] Migrate SplitPythonConditionFromCorrelateRule to java snuyanzin
• (flink) branch master updated: [FLINK-34599][table] Migrate BatchPhysicalConstantTableFunctionScanRule to Java snuyanzin
• (flink) branch master updated: [FLINK-34600][table] Migrate PushLimitIntoLegacyTableSourceScanRule to java snuyanzin
• (flink-cdc) branch release-3.1 updated (958cfcb06 -> d52e54f52) leonard
  • (flink-cdc) 01/02: [hotfix][docs] Add missed supported flink versions leonard
  • (flink-cdc) 02/02: [hotfix][docs][pipeline-connector/vitess] Fix dead links leonard
• (flink-cdc) branch release-3.2 updated: [hotfix][docs][pipeline-connector/es] Add missed supported flink versions and Elasticsearch versions leonard
• (flink-cdc) branch master updated: [hotfix][docs][pipeline-connector/es] Add missed supported flink versions and Elasticsearch versions leonard
• (flink-cdc) branch master updated: [FLINK-36772][mysql][cdc-base] Fix error placeholder for errorMessageTemplate of Preconditions leonard
• (flink-kubernetes-operator) branch main updated: [FLINK-36685] allow CREATE/UPDATE operation on flinkdeployments resource on webhook mutation endpoint gyfora
• (flink-kubernetes-operator) branch main updated: [FLINK-36686] add operatorPod.webhook.container.env in helm chart to allow customizating of flink-webhook container envs gyfora
• svn commit: r73179 - in /dev/flink/flink-cdc-3.2.1-rc1: ./ flink-cdc-3.2.1-bin.tar.gz flink-cdc-3.2.1-bin.tar.gz.asc flink-cdc-3.2.1-bin.tar.gz.sha512 flink-cdc-3.2.1-src.tgz flink-cdc-3.2.1-src.tgz.asc flink-cdc-3.2.1-src.tgz.sha512 ruanhang1993
• (flink-cdc) annotated tag release-3.2.1-rc1 updated (c703d18d1 -> 5b867fa09) ruanhang1993
• (flink-cdc) branch release-3.2 updated: [FLINK-36572][pipeline-connector][starrocks] Fix the issue that the local time zone is wrongly set leonard
• Re: [I] Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.doris.flink.cfg.DorisOptions to field org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier.dorisOptions of type org.apache.doris.flink.cfg.DorisOptions in instance of org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier [flink-cdc] via GitHub
  • Re: [I] Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.doris.flink.cfg.DorisOptions to field org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier.dorisOptions of type org.apache.doris.flink.cfg.DorisOptions in instance of org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier [flink-cdc] via GitHub
  • Re: [I] Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.doris.flink.cfg.DorisOptions to field org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier.dorisOptions of type org.apache.doris.flink.cfg.DorisOptions in instance of org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier [flink-cdc] via GitHub
  • Re: [I] Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.doris.flink.cfg.DorisOptions to field org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier.dorisOptions of type org.apache.doris.flink.cfg.DorisOptions in instance of org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier [flink-cdc] via GitHub
  • Re: [I] Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.doris.flink.cfg.DorisOptions to field org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier.dorisOptions of type org.apache.doris.flink.cfg.DorisOptions in instance of org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier [flink-cdc] via GitHub
  • Re: [I] Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.doris.flink.cfg.DorisOptions to field org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier.dorisOptions of type org.apache.doris.flink.cfg.DorisOptions in instance of org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier [flink-cdc] via GitHub
• (flink-kubernetes-operator) branch main updated: [FLINK-36527][autoscaler] Introduce a parameter to support autoscaler adopt a more radical strategy when source vertex or upstream shuffle is keyBy (#904) mxm
• (flink-cdc) branch master updated: [hotfix][source-connector/mysql] Fix conflicts after flink version bumped to 1.19 (#3748) ruanhang1993
• svn commit: r73162 - /release/flink/KEYS leonard
• (flink) branch master updated: [FLINK-36710] Log job ID in RecreateOnResetOperatorCoordinator pnowojski
• (flink-cdc) branch release-3.2 updated: [FLINK-35291][runtime] Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme (#3289) (#3670) ruanhang1993
• (flink-cdc) branch master updated: [FLINK-36656][mysql] Fix type conversion failure for newly-added sharding table with mysql boolean type (#3683) ruanhang1993
• (flink-cdc) branch release-3.2 updated: [FLINK-36656][mysql] Fix type conversion failure for newly-added sharding table with mysql boolean type (#3684) ruanhang1993
• (flink) branch master updated: [FLINK-36714][state] Ignore interrupted in sstmerge.CompactionScheduler#stop pnowojski
• (flink-cdc) branch release-3.2 updated: [FLINK-36052][docs][cdc-pipeline-connector/es] Add flink cdc pipeline elasticsearch connector docs (#3686) ruanhang1993
• (flink-cdc) branch release-3.2 updated: [FLINK-36565][transform] Route allows merging Decimals with various precisions (#3743) ruanhang1993
• (flink-playgrounds) branch dependabot/maven/docker/data-generator/org.apache.kafka-kafka-clients-3.7.1 created (now da2bbcd) github-bot
• (flink-connector-kafka) branch dependabot/maven/org.apache.kafka-kafka-clients-3.7.1 created (now 724f3dc8) github-bot
• (flink-kubernetes-operator) branch main updated: [FLINK-36192][log] instruct how to change log level dynamically (#911) mxm
• (flink) branch master updated: [FLINK-36693][state/forst] Implement checkpoint/restore for ForStSyncKeyedStateBackend (#25643) leiyanfei
• (flink) branch master updated: [FLINK-36711][runtime] Add tips when System out and err are redirected to LOG or discarded (#25653) fanrui
• (flink) branch master updated: [hotfix] Use Tag to replace some incorrectly used Category annotation for skipping adaptvie-scheduler test guoweijie
• (flink) branch master updated: [hotfix] Log batch size in FlinkS3FileSystem instead of total pnowojski
• (flink-cdc) branch master updated: [FLINK-36586][build] Update flink version to 1.19 (#3660) ruanhang1993
• (flink) branch master updated (77e7ac076c3 -> 25b729246e0) fanrui
• (flink-cdc) branch release-3.2 updated (bd2aa0aaa -> 1bf40f09c) leonard
  • (flink-cdc) 02/09: [FLINK-36541][pipeline-connector][paimon] Pass checkpointId to StoreSinkWrite#prepareCommit correctly leonard
  • (flink-cdc) 09/09: [FLINK-36093][transform] Fix preTransformoperator wrongly filters columns belong to different transforms leonard
  • (flink-cdc) 06/09: [FLINK-35982][transform] Fix unable to transform metadata without projections leonard
  • (flink-cdc) 03/09: [FLINK-36105][flink-cdc-cli] Fix unable to restore from checkpoint with Flink 1.20 leonard
  • (flink-cdc) 04/09: [FLINK-36407][runtime] Shut down coordinatorExecutor upon closing SchemaRegistry leonard
  • (flink-cdc) 05/09: [FLINK-35980][tests] Add transform-related test cases leonard
  • (flink-cdc) 08/09: [FLINK-36596][transform] Fix unable to schema evolve with project-less transform rules leonard
  • (flink-cdc) 07/09: [FLINK-36461][transform] Fix schema evolution failure with un-transformed tables leonard
  • (flink-cdc) 01/09: [FLINK-36408][source-connector/mysql] Fix MySQL pipeline connector failed to parse FLOAT type with precision leonard
• (flink-kubernetes-operator) branch main updated (670bfcf8 -> c89f4312) gyfora
  • (flink-kubernetes-operator) 02/02: [FLINK-36646] add tests of the various different Java versions as the job images. gyfora
  • (flink-kubernetes-operator) 01/02: [FLINK-36646][helm] Add required Java Opts to allow Java 17 based job images. gyfora
• (flink-cdc) branch release-3.2 updated: [FLINK-35985][transform] Correct the substring function in transform rule leonard
• (flink-cdc) branch release-3.2 updated: [FLINK-36326][source-connector/mysql] Fix auto scan newly-added table failure leonard
• (flink-cdc) branch release-3.2 updated: [FLINK-36509][pipeline-connector][paimon] Add partition columns to primary key leonard
• (flink-cdc) branch release-3.2 updated: [FLINK-36211][pipeline-connector/kafka] Shade org.apache.flink.streaming.connectors.kafka to avoid conflict with flink-connector-kafka jar leonard
• (flink-cdc) branch release-3.2 updated: [FLINK-36517][pipeline-connector][paimon] Use filterAndCommit API to avoid committing the same datafile twice leonard
• (flink) branch release-1.20 updated: [FLINK-36368] Do not prematurely merge CommittableManager (#25405) arvid
• (flink) branch master updated (5bea35ebb65 -> 77e7ac076c3) snuyanzin
  • (flink) 01/02: [hotfix] Add missing Flink modification comment snuyanzin
• (flink-connector-elasticsearch) branch main updated: [FLINK-36651][Connectors/Elasticsearch] Fix IT test not compatible with 1.20, drop main branch tests for 1.18 dannycranmer
• (flink) branch master updated: [FLINK-16155][docs] Translate "Operator/Process Function" into Chinese (#25624) renqs
• [I] Postgres table have chinese like "my_table_的“ ，flink cdc task-flow failed [flink-cdc] via GitHub
  • Re: [I] Postgres table have chinese like "my_table_的“ ，flink cdc task-flow failed [flink-cdc] via GitHub
  • Re: [I] Postgres table have chinese like "my_table_的“ ，flink cdc task-flow failed [flink-cdc] via GitHub
  • Re: [I] Postgres table have chinese like "my_table_的“ ，flink cdc task-flow failed [flink-cdc] via GitHub
• svn commit: r73085 - in /dev/flink/flink-connector-kafka-3.4.0-rc1: ./ flink-connector-kafka-3.4.0-src.tgz flink-connector-kafka-3.4.0-src.tgz.asc flink-connector-kafka-3.4.0-src.tgz.sha512 arvid
• (flink) branch release-1.19 updated (3c968e9a845 -> a79a649eaa6) arvid
  • (flink) 02/02: [FLINK-36287] Disallow UC for inner sink channels arvid
  • (flink) 01/02: [FLINK-36287] Migrate SinkITCase to AssertJ arvid
• (flink-connector-kafka) annotated tag v3.4.0-rc1 updated (e93b300d -> 0a16ecd6) arvid
• (flink) branch master updated: [FLINK-36709][parquet] fix parquet can not read row with last column is array. (#25651) xccui
• (flink-cdc) branch master updated: [FLINK-36285][doris] Fix unable to alter column type without default value specified leonard
• (flink-cdc) branch master updated: [FLINK-36565][transform] Route allows merging Decimals with various precisions leonard
• (flink-connector-kafka) branch main updated: [FLINK-34466] Lineage interfaces for kafka connector (#130) arvid
• (flink) branch release-1.20 updated (1a5e4dca23d -> 5dea94b9599) arvid
  • (flink) 02/02: [FLINK-36287] Disallow UC for inner sink channels arvid
  • (flink) 01/02: [FLINK-36287] Migrate SinkITCase to AssertJ arvid
• (flink) branch release-1.19 updated (6cad12ad412 -> 3c968e9a845) arvid
  • (flink) 01/08: [hotfix] Fix UnifiedSinkMigrationITCase arvid
  • (flink) 08/08: [FLINK-25920] Fix AbstractStreamingWriter sending after EOI arvid
  • (flink) 07/08: [FLINK-25920] Improve logging in committable handling of the sink arvid
  • (flink) 05/08: [FLINK-25920] Refactor & Revise SinkWriterOperatorTestBase arvid
  • (flink) 06/08: [FLINK-25920] Handle duplicate EOI in Sink arvid
  • (flink) 04/08: [FLINK-25920] Only process complete batches of committables arvid
  • (flink) 03/08: [FLINK-25920] Improve sink test assertions arvid
• (flink-cdc) branch release-3.2 updated: [FLINK-36681][mysql-cdc][docs] Fix the wrong chunks splitting query in incremental snapshot reading section leonard
• (flink-cdc) branch release-3.2 updated: [FLINK-35592][cdc-connector][mysql] Fix MysqlDebeziumTimeConverter miss timezone when convert to timestamp (#3731) ruanhang1993
• (flink-cdc) branch master updated: [FLINK-36093][transform] Fix preTransformoperator wrongly filters columns belong to different transforms leonard
• (flink-cdc) branch master updated: [FLINK-36596][transform] Fix unable to schema evolve with project-less transform rules leonard
• (flink-cdc) branch master updated: [FLINK-35592][cdc-connector][mysql] Fix MysqlDebeziumTimeConverter miss timezone when convert to timestamp leonard
• (flink) branch master updated: [FLINK-36598][state/ForSt] Provide FileSystem instance in initialization (#25638) zakelly
• (flink-cdc) branch master updated: [FLINK-36699][cdc-common] fix nullability when converting cdc data type to flink data type (#3713) ruanhang1993
• (flink) branch release-1.20 updated (54994fc8892 -> 1a5e4dca23d) arvid
  • (flink) 04/08: [FLINK-25920] Only process complete batches of committables arvid
  • (flink) 05/08: [FLINK-25920] Refactor & Revise SinkWriterOperatorTestBase arvid
  • (flink) 07/08: [FLINK-25920] Improve logging in committable handling of the sink arvid
  • (flink) 02/08: [FLINK-25920] Straighten EOI handling in CommittableCollector arvid
  • (flink) 01/08: [hotfix] Fix UnifiedSinkMigrationITCase arvid
  • (flink) 08/08: [FLINK-25920] Fix AbstractStreamingWriter sending after EOI arvid
  • (flink) 06/08: [FLINK-25920] Handle duplicate EOI in Sink arvid
  • (flink) 03/08: [FLINK-25920] Improve sink test assertions arvid
• (flink) branch master updated (584dc46b45d -> 6fe39c65581) zakelly
• (flink-connector-aws) branch v5.0 updated: [hotfix][docs] Remove buggy doc reference hong
• (flink-connector-prometheus) branch v1.0 updated: [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch hong
• (flink-connector-aws) branch v5.0 updated: [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch hong
• (flink-cdc) branch release-3.2 updated: [hotfix][e2e] Temporarily disable TransformE2eITCase in multiple parallelism leonard
• (flink-cdc) branch release-3.2 updated: [FLINK-36560][pipeline-connector][paimon] Fix the issue that timestamp_ltz field is not correctly converted leonard
• (flink) branch master updated: [FLINK-36635][runtime] Remove PhysicalSlotRequestBulkImpl as it is not used junrui
• (flink-connector-aws) branch v5.0 updated: [hotfix][docs] Fix typo in docs hong
• (flink-connector-aws) branch v5.0 updated (89aec61 -> 8569206) hong
  • (flink-connector-aws) 02/03: [FLINK-31989][docs] Update english docs for DynamoDbStreamsSource hong
  • (flink-connector-aws) 01/03: [FLINK-31989][docs] Update english docs for KinesisStreamsSource hong
  • (flink-connector-aws) 03/03: [FLINK-31989][docs] Update english docs for Kinesis Table API hong
• (flink-cdc) branch master updated: [FLINK-36609][pipeline-connector][paimon] Add partition columns to primary keys leonard
• (flink-cdc) branch release-3.2 updated: [FLINK-36678][docs][deploy] Fix the typo in Flink CDC YARN deployment documentation leonard
• (flink-cdc) branch master updated: [FLINK-36541][pipeline-connector][paimon] Pass checkpointId to StoreSinkWrite#prepareCommit correctly leonard
• (flink-cdc) branch release-3.2 updated: [FLINK-36375][cdc-runtime] Fix missed default value in AddColumnEvent/RenameColumnEvent leonard
• (flink-cdc) branch master updated: [FLINK-36678][docs][deploy] Fix the typo in Flink CDC YARN deployment documentation leonard
• (flink) branch release-1.19 updated: [FLINK-36668][docs] Update AWS docs for v5.0 hong
• (flink) branch master updated: [FLINK-36668][docs] Update AWS docs for v5.0 hong
• (flink) branch release-1.20 updated: [FLINK-36668][docs] Update AWS docs for v5.0 hong
• (flink-connector-aws) branch main updated: [FLINK-36668][build] Update AWS build for v5.0 hong
• svn commit: r72960 - /release/flink/flink-connector-aws-4.2.0/ dannycranmer

• Later messages