You are viewing a plain text version of this content. The canonical link for it is here.
- (flink) branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions created (now e49564a2e36) - posted by fh...@apache.org on 2024/11/01 10:27:30 UTC, 0 replies.
- (flink) 01/01: [FLINK-36642][table] Fix SQL names of built-in functions - posted by fh...@apache.org on 2024/11/01 10:27:31 UTC, 0 replies.
- (flink) branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions updated (e49564a2e36 -> e81232e7dda) - posted by fh...@apache.org on 2024/11/01 10:46:48 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36460] Refactoring the CI matrix - posted by gy...@apache.org on 2024/11/01 13:05:35 UTC, 0 replies.
- (flink) branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions updated (e81232e7dda -> 8a1be872847) - posted by fh...@apache.org on 2024/11/01 15:19:45 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36332] Fix okhttp dependency handling - posted by gy...@apache.org on 2024/11/02 08:43:28 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36599] Correct the metric config name in the doc to reduce confusing - posted by gy...@apache.org on 2024/11/02 09:00:05 UTC, 0 replies.
- (flink-benchmarks) branch master updated: [FLINK-36622] Remove the dependency on RocksDBKeyedStateBackend APIs. (#98) - posted by za...@apache.org on 2024/11/04 02:26:01 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated: [FLINK-35862][docs] Fix an incorrect configuration option name in the Chinese documentation - posted by gu...@apache.org on 2024/11/04 06:26:52 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36544][OLM ] Ensure file permissions are preserved on the CSV during bundle creation - posted by gy...@apache.org on 2024/11/04 06:34:47 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36551][OLM] Ensure that docker-entry.sh actually replaces the keystore pod volume - posted by gy...@apache.org on 2024/11/04 06:36:11 UTC, 0 replies.
- (flink-ml) branch master updated (44f71f27 -> 583a6199) - posted by zh...@apache.org on 2024/11/04 07:58:00 UTC, 0 replies.
- (flink-ml) 01/02: [FLINK-36653] Fix OnlineLogisticRegressionModel updating logic - posted by zh...@apache.org on 2024/11/04 07:58:01 UTC, 0 replies.
- (flink-ml) 02/02: [hotfix] Fix macOS version in Actions to stable version - posted by zh...@apache.org on 2024/11/04 07:58:02 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36639] Use table aliases in Table API asSerializableString (#25597) - posted by dw...@apache.org on 2024/11/04 08:11:08 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36644] TIMESTAMPDIFF can not be string serialized (#25599) - posted by dw...@apache.org on 2024/11/04 08:12:12 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36644] TIMESTAMPDIFF can not be string serialized (#25599) - posted by dw...@apache.org on 2024/11/04 08:13:06 UTC, 0 replies.
- (flink) branch master updated: [FLINK-33722] Fix events ordering in MATCH_RECOGNIZE in batch mode (#24699) - posted by dw...@apache.org on 2024/11/04 08:14:38 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36011][runtime] Improved logging in StateTransitionManager - posted by ma...@apache.org on 2024/11/04 08:38:26 UTC, 0 replies.
- (flink) branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions updated (8a1be872847 -> 097d4982959) - posted by fh...@apache.org on 2024/11/04 09:02:45 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35544][docs][deploy] Add deployment documentations for Kubernetes Operator - posted by le...@apache.org on 2024/11/04 11:10:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36642][table] Fix SQL names of built-in functions (#25601) - posted by fh...@apache.org on 2024/11/04 11:21:52 UTC, 0 replies.
- (flink) branch fhueske-FLINK-36642-backport created (now 1c51e884ff5) - posted by fh...@apache.org on 2024/11/04 11:25:59 UTC, 0 replies.
- (flink) 01/01: [FLINK-36642][table] Fix SQL names of built-in functions (#25601) - posted by fh...@apache.org on 2024/11/04 11:26:00 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36618][cdc-connector][postgres] Improve PostgresDialect.discoverDataCollections to reduce the bootstrap time - posted by le...@apache.org on 2024/11/04 11:52:43 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36052][docs][cdc-pipeline-connector/es] Add flink cdc pipeline elasticsearch connector docs - posted by le...@apache.org on 2024/11/04 12:13:26 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36510][rpc] Bump Pekko to 1.1.2, remove Netty 3 - posted by fc...@apache.org on 2024/11/04 12:49:23 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36642][table] Fix SQL names of built-in functions (#25605) - posted by fh...@apache.org on 2024/11/04 14:20:28 UTC, 0 replies.
- (flink-connector-aws) branch main updated (30d32fd -> da74232) - posted by ho...@apache.org on 2024/11/04 15:44:13 UTC, 0 replies.
- (flink-connector-aws) 01/02: [FLINK-31980][Connectors/Kinesis] Abstract away base SplitReader logic from PollingKinesisShardSplitReader to set up for FanOutKinesisShardSplitReader - posted by ho...@apache.org on 2024/11/04 15:44:14 UTC, 0 replies.
- (flink-connector-aws) 02/02: [FLINK-31980][Connectors/Kinesis] Implement EFO subscription - posted by ho...@apache.org on 2024/11/04 15:44:15 UTC, 0 replies.
- (flink) branch master updated (a86d23f7a98 -> 96bb45d1f7f) - posted by pn...@apache.org on 2024/11/04 17:03:38 UTC, 0 replies.
- (flink) 01/02: [FLINK-36624][checkpointing] Expose JobID to the OperatorCoordinators - posted by pn...@apache.org on 2024/11/04 17:03:39 UTC, 0 replies.
- (flink) 02/02: [FLINK-36624][checkpointing] Log JobID from the SourceCoordinator - posted by pn...@apache.org on 2024/11/04 17:03:40 UTC, 0 replies.
- (flink-connector-aws) annotated tag v5.0.0-rc1 updated (74ab10d -> 36f68e4) - posted by ho...@apache.org on 2024/11/04 19:20:36 UTC, 0 replies.
- svn commit: r72784 - in /dev/flink/flink-connector-aws-5.0.0-rc1: ./ flink-connector-aws-5.0.0-src.tgz flink-connector-aws-5.0.0-src.tgz.asc flink-connector-aws-5.0.0-src.tgz.sha512 - posted by ho...@apache.org on 2024/11/04 19:21:46 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-35401] Add Sqs Table API connector - posted by ho...@apache.org on 2024/11/04 22:32:47 UTC, 0 replies.
- (flink-connector-aws) annotated tag v5.0.0-rc1 deleted (was 36f68e4) - posted by ho...@apache.org on 2024/11/04 22:35:21 UTC, 0 replies.
- (flink-connector-aws) annotated tag v5.0.0-rc1 updated (329169f -> bef1920) - posted by ho...@apache.org on 2024/11/04 22:36:19 UTC, 0 replies.
- (flink-connector-aws) annotated tag v5.0.0-rc2 updated (329169f -> 5e403d5) - posted by ho...@apache.org on 2024/11/04 22:37:24 UTC, 0 replies.
- svn commit: r72786 - in /dev/flink/flink-connector-aws-5.0.0-rc2: ./ flink-connector-aws-5.0.0-src.tgz flink-connector-aws-5.0.0-src.tgz.asc flink-connector-aws-5.0.0-src.tgz.sha512 - posted by ho...@apache.org on 2024/11/04 22:37:56 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36583] Add Slow Request Kube Client Metrics (#908) - posted by mo...@apache.org on 2024/11/04 23:41:25 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36615] Support LEAD/LAG functions in Table API (#25582) - posted by dw...@apache.org on 2024/11/05 07:47:34 UTC, 0 replies.
- (flink-connector-gcp-pubsub) branch main updated: [hotfix] Replace System.out.println with logger for better log management (#31) - posted by sn...@apache.org on 2024/11/05 07:53:50 UTC, 0 replies.
- (flink-connector-gcp-pubsub) branch main updated: [FLINK-36077][Connectors/Google PubSub] Implement table api support for SinkV2 - posted by sn...@apache.org on 2024/11/05 07:54:13 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36002] Add CompiledPlan annotations to BatchExecMatch (#25171) - posted by dw...@apache.org on 2024/11/05 07:58:36 UTC, 0 replies.
- (flink) branch fhueske-hotfix-add-lead_lag-table-api-agg-functions-to-docs created (now cb22534b7d4) - posted by fh...@apache.org on 2024/11/05 08:35:20 UTC, 0 replies.
- (flink) 01/01: [hotfix] [docs] Add lead()/lag() Table API agg functions to docs - posted by fh...@apache.org on 2024/11/05 08:35:21 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated: Set up archunit tests and violations - posted by ho...@apache.org on 2024/11/05 09:40:14 UTC, 0 replies.
- (flink) branch master updated: [hotfix] [docs] Add lead()/lag() Table API agg functions to docs (#25608) - posted by fh...@apache.org on 2024/11/05 11:26:27 UTC, 0 replies.
- (flink-connector-elasticsearch) branch v3.1 created (now da2ef1f) - posted by da...@apache.org on 2024/11/05 13:02:39 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36099][task] Log jobID in TaskExecutor#failTask - posted by pn...@apache.org on 2024/11/05 14:18:31 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36623] Improve logging in DefaultStateTransitionManager (#25610) - posted by ma...@apache.org on 2024/11/05 15:19:01 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated: [FLINK-33137][Connectors/Prometheus][docs] Connector docs - posted by ho...@apache.org on 2024/11/05 16:15:15 UTC, 0 replies.
- [I] MySqlChunkSplitter对varchar进行分块时排序问题 [flink-cdc] - posted by "MilesLuo (via GitHub)" <gi...@apache.org> on 2024/11/06 02:52:08 UTC, 4 replies.
- [I] MySqlChunkSplitter分片排序问题 [flink-cdc] - posted by "MilesLuo (via GitHub)" <gi...@apache.org> on 2024/11/06 02:59:58 UTC, 3 replies.
- (flink) branch master updated (21eea0d2dde -> 13fe0e641cd) - posted by ar...@apache.org on 2024/11/06 08:55:13 UTC, 0 replies.
- (flink) 01/03: [FLINK-36455] Sinks retry synchronously - posted by ar...@apache.org on 2024/11/06 08:55:14 UTC, 0 replies.
- (flink) 02/03: [FLINK-36455] Fix PendingCommittable metric in sink - posted by ar...@apache.org on 2024/11/06 08:55:15 UTC, 0 replies.
- (flink) 03/03: [FLINK-36455] Deprecate async parts of committable summary - posted by ar...@apache.org on 2024/11/06 08:55:16 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36474][route] Support merging timestamp columns when routing - posted by le...@apache.org on 2024/11/06 11:53:53 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36514][cdc-cli] Fix unable to override exclude schema types in lenient mode - posted by le...@apache.org on 2024/11/06 11:58:15 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35332][yarn] Do not set "rest.address" to the actual IP address of the YARN NM to support dual network envs - posted by fc...@apache.org on 2024/11/06 12:23:56 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [hotfix] Update NOTICE files to reflect the packaged dependencies - posted by ho...@apache.org on 2024/11/06 16:18:32 UTC, 0 replies.
- (flink-connector-aws) annotated tag v5.0.0-rc3 updated (b4047bc -> d61bf6f) - posted by ho...@apache.org on 2024/11/06 16:27:29 UTC, 0 replies.
- (flink-connector-aws) branch v5.0 created (now b4047bc) - posted by ho...@apache.org on 2024/11/06 16:28:00 UTC, 0 replies.
- svn commit: r72818 - in /dev/flink/flink-connector-aws-5.0.0-rc3: ./ flink-connector-aws-5.0.0-src.tgz flink-connector-aws-5.0.0-src.tgz.asc flink-connector-aws-5.0.0-src.tgz.sha512 - posted by ho...@apache.org on 2024/11/06 16:28:20 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated (08dd161 -> e41a4aa) - posted by ho...@apache.org on 2024/11/06 16:59:57 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated: [FLINK-36667][Connectors/Prometheus] remove redundant proto files - posted by ho...@apache.org on 2024/11/06 17:00:13 UTC, 0 replies.
- (flink-connector-prometheus) branch v1.0 created (now b4366ad) - posted by ho...@apache.org on 2024/11/06 17:01:41 UTC, 1 replies.
- svn commit: r72821 - /release/flink/KEYS - posted by mb...@apache.org on 2024/11/06 19:28:44 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36221][docs] Add CAST function documentations (#3596) - posted by ru...@apache.org on 2024/11/07 08:21:22 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35982][transform] Fix transform metadata failure when projection block is missed - posted by le...@apache.org on 2024/11/07 09:58:25 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35985][transform] Correct the substring function in transform rule - posted by le...@apache.org on 2024/11/07 10:03:05 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36105][flink-cdc-cli] Fix unable to restore from checkpoint with Flink 1.20 (#3564) - posted by ru...@apache.org on 2024/11/07 10:13:47 UTC, 0 replies.
- (flink) branch master updated: [hotfix][metrics] fix default value of endTsMillis in SpanBuilder - posted by pn...@apache.org on 2024/11/07 10:16:32 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36662][table-planner] Port CALCITE-6317 to fix the incorrectly constant pullup when group keys in aggregate are NULL - posted by li...@apache.org on 2024/11/07 10:35:14 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36266][table] Insert into as select * behaves incorrect - posted by sn...@apache.org on 2024/11/07 11:18:42 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36592][state/forst] Support file cache for ForStStateBackend (#25561) - posted by le...@apache.org on 2024/11/07 11:48:58 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36221][docs] Add `CAST ... AS ...` documentations (#3694) - posted by ru...@apache.org on 2024/11/08 03:09:12 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36247][cdc-connector][mysql] Fix potential transaction leak during MySQL snapshot phase (#3602) - posted by ru...@apache.org on 2024/11/08 05:46:54 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][transform][minor] Fix potential code conflict that SUBSTR built-in function is 1-based index now - posted by le...@apache.org on 2024/11/08 05:57:14 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36654][table-planner] Fix incorrect cast when dividing decimals by integers - posted by li...@apache.org on 2024/11/08 06:22:49 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36649][cdc-connector][oracle] Fix oracle connection close error (#3678) - posted by ru...@apache.org on 2024/11/08 06:57:10 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36417][table] Add support for hints in WatermarkAssigner - posted by sn...@apache.org on 2024/11/08 07:16:06 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36417][table] Add support for hints in WatermarkAssigner - posted by sn...@apache.org on 2024/11/08 07:17:08 UTC, 0 replies.
- (flink) branch master updated (bd6f292ad7f -> b4bcde53b0c) - posted by sh...@apache.org on 2024/11/08 07:40:47 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36247][cdc-connector][mysql] Fix potential transaction leak during MySQL snapshot phase (#3602) (#3699) - posted by ru...@apache.org on 2024/11/08 07:41:44 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36649][cdc-connector][oracle] Fix oracle connection close error (#3678) (#3700) - posted by ru...@apache.org on 2024/11/08 09:32:29 UTC, 0 replies.
- (flink-connector-aws) branch main updated (e0e1b30 -> 3abc1c5) - posted by ho...@apache.org on 2024/11/08 09:41:02 UTC, 0 replies.
- (flink-connector-aws) 01/03: [FLINK-31989][docs] Update english docs for KinesisStreamsSource - posted by ho...@apache.org on 2024/11/08 09:41:03 UTC, 1 replies.
- (flink-connector-aws) 02/03: [FLINK-31989][docs] Update english docs for DynamoDbStreamsSource - posted by ho...@apache.org on 2024/11/08 09:41:04 UTC, 1 replies.
- (flink-connector-aws) 03/03: [FLINK-31989][docs] Update english docs for Kinesis Table API - posted by ho...@apache.org on 2024/11/08 09:41:05 UTC, 1 replies.
- (flink-connector-prometheus) annotated tag v1.0.0 updated (b4366ad -> c3b4ca9) - posted by ho...@apache.org on 2024/11/08 11:27:15 UTC, 0 replies.
- svn commit: r72877 - /dev/flink/flink-connector-prometheus-1.0.0-rc1/ /release/flink/flink-connector-prometheus-1.0.0/ - posted by da...@apache.org on 2024/11/08 12:50:51 UTC, 0 replies.
- (flink-connector-prometheus) branch v1.0 deleted (was b4366ad) - posted by ho...@apache.org on 2024/11/08 13:00:52 UTC, 0 replies.
- (flink-connector-prometheus) branch v1.0 updated (b4366ad -> 5ce59e5) - posted by ho...@apache.org on 2024/11/08 13:02:02 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36289][Connectors/Prometheus][docs] Integrate Prometheus connector docs into Flink website - posted by ho...@apache.org on 2024/11/08 14:14:04 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated: [FLINK-33142][Connectors/Prometheus] Copy over english docs into chinese docs - posted by ho...@apache.org on 2024/11/08 14:37:24 UTC, 0 replies.
- (flink-connector-prometheus) branch v1.0 updated: [FLINK-33142][Connectors/Prometheus] Copy over english docs into chinese docs - posted by ho...@apache.org on 2024/11/08 14:44:23 UTC, 0 replies.
- (flink-connector-prometheus) branch v1.0 updated: [hotfix][build] Standardize snapshot version naming to follow other connectors - posted by ho...@apache.org on 2024/11/08 14:46:03 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated: [hotfix][build] Bump to 1.1-SNAPSHOT after v1.0 release - posted by ho...@apache.org on 2024/11/08 14:48:42 UTC, 0 replies.
- (flink-connector-hbase) branch v4.0 updated: [hotfix] Bump version to 4.0.0 in "docs/data" - posted by fc...@apache.org on 2024/11/08 14:48:46 UTC, 0 replies.
- (flink-web) branch asf-site updated: Adding Prometheus Connector v1.0.0 - posted by ho...@apache.org on 2024/11/08 14:52:04 UTC, 0 replies.
- (flink-connector-hbase) branch v4.0 updated (91f085b -> a267e9f) - posted by fc...@apache.org on 2024/11/08 15:00:23 UTC, 0 replies.
- (flink-connector-hbase) 01/01: [hotfix] Bump version to 4.0.0 in "docs/data" - posted by fc...@apache.org on 2024/11/08 15:00:24 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36289][Connectors/Prometheus][docs] Integrate Prometheus connector docs into Flink website - posted by ho...@apache.org on 2024/11/08 15:01:16 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36289][Connectors/Prometheus][docs] Integrate Prometheus connector docs into Flink website - posted by ho...@apache.org on 2024/11/08 15:02:19 UTC, 0 replies.
- (flink-connector-hbase) branch main updated: [hotfix] Bump version to 4.0.0 in "docs/data" - posted by fc...@apache.org on 2024/11/08 15:08:06 UTC, 0 replies.
- (flink-connector-prometheus) branch v1.0 updated: [FLINK-33137][Connectors/Prometheus][docs] Connector docs - posted by ho...@apache.org on 2024/11/08 15:27:48 UTC, 0 replies.
- (flink-connector-hbase) annotated tag v4.0.0-rc1 updated (4dd8505 -> 68e3c39) - posted by fc...@apache.org on 2024/11/08 15:54:28 UTC, 0 replies.
- svn commit: r72883 - in /dev/flink/flink-connector-hbase-4.0.0-rc1: ./ flink-connector-hbase-4.0.0-src.tgz flink-connector-hbase-4.0.0-src.tgz.asc flink-connector-hbase-4.0.0-src.tgz.sha512 - posted by fc...@apache.org on 2024/11/08 15:57:33 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: Flink v1.20 is supported - posted by fa...@apache.org on 2024/11/10 03:24:55 UTC, 0 replies.
- (flink-kubernetes-operator) branch release-1.10 updated: Flink v1.20 is supported - posted by fa...@apache.org on 2024/11/10 03:27:05 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36572][pipeline-connector][starrocks] Fix the issue that the local time zone is wrongly set - posted by le...@apache.org on 2024/11/11 05:55:08 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36407][runtime] Shut down coordinatorExecutor upon closing SchemaRegistry (#3624) - posted by ru...@apache.org on 2024/11/11 06:01:59 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36560][pipeline-connector][paimon] Fix the issue that timestamp_ltz field is not correctly converted - posted by le...@apache.org on 2024/11/11 06:46:54 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36408][pipeline-connector][mysql] Fix MySQL pipeline connector failed to parse FLOAT type with precision (#3625) - posted by ru...@apache.org on 2024/11/11 07:09:13 UTC, 0 replies.
- (flink-kubernetes-operator) branch release-1.10 updated: [FLINK-36332] Fix okhttp dependency handling - posted by gy...@apache.org on 2024/11/11 08:01:05 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36375][cdc-runtime] Fix missed default value in AddColumnEvent/RenameColunEvent - posted by le...@apache.org on 2024/11/11 09:41:48 UTC, 0 replies.
- (flink-connector-aws) annotated tag v5.0.0 updated (b4047bc -> e1afc83) - posted by ho...@apache.org on 2024/11/11 10:08:12 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated: [hotfix][build] Add docs data file for v1.1-SNAPSHOT - posted by ho...@apache.org on 2024/11/11 10:31:48 UTC, 0 replies.
- (flink-connector-prometheus) branch v1.0 updated: [hotfix][build] Add docs data file for v1.0.0 - posted by ho...@apache.org on 2024/11/11 10:32:09 UTC, 0 replies.
- (flink-web) branch asf-site updated: Adding AWS Connectors v5.0.0 - posted by ho...@apache.org on 2024/11/11 11:12:01 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36474][route] Support merging timestamp columns when routing - posted by le...@apache.org on 2024/11/11 11:17:55 UTC, 0 replies.
- (flink-connector-aws) branch v5.0 updated: [hotfix][docs] Set up release versions for AWS connectors - posted by ho...@apache.org on 2024/11/11 11:22:15 UTC, 0 replies.
- (flink-connector-aws) branch v5.0 updated: [hotfix][docs] Set up release versions for SQS connector - posted by ho...@apache.org on 2024/11/11 11:23:40 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36214][build] Downgrade scala-maven-plugin version to 4.8.0 to keep compatibility with Java 8 - posted by le...@apache.org on 2024/11/11 11:31:30 UTC, 0 replies.
- svn commit: r72958 - /dev/flink/flink-connector-aws-5.0.0-rc3/ /release/flink/flink-connector-aws-5.0.0/ - posted by da...@apache.org on 2024/11/11 11:53:11 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36517][pipeline-connector][paimon] Use filterAndCommit API to avoid committing the same datafile twice - posted by le...@apache.org on 2024/11/11 11:57:27 UTC, 0 replies.
- svn commit: r72959 - in /dev/flink: flink-connector-aws-5.0.0-rc1/ flink-connector-aws-5.0.0-rc2/ - posted by da...@apache.org on 2024/11/11 11:57:45 UTC, 0 replies.
- svn commit: r72960 - /release/flink/flink-connector-aws-4.2.0/ - posted by da...@apache.org on 2024/11/11 11:58:36 UTC, 0 replies.
- (flink-web) branch asf-site updated: Rebuild website - posted by ho...@apache.org on 2024/11/11 12:31:20 UTC, 5 replies.
- (flink-connector-aws) branch main updated: [FLINK-36668][build] Update AWS build for v5.0 - posted by ho...@apache.org on 2024/11/11 14:05:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36668][docs] Update AWS docs for v5.0 - posted by ho...@apache.org on 2024/11/11 14:06:22 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36668][docs] Update AWS docs for v5.0 - posted by ho...@apache.org on 2024/11/11 14:06:34 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36668][docs] Update AWS docs for v5.0 - posted by ho...@apache.org on 2024/11/11 14:06:56 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36678][docs][deploy] Fix the typo in Flink CDC YARN deployment documentation - posted by le...@apache.org on 2024/11/12 06:51:16 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36375][cdc-runtime] Fix missed default value in AddColumnEvent/RenameColumnEvent - posted by le...@apache.org on 2024/11/12 07:20:46 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36541][pipeline-connector][paimon] Pass checkpointId to StoreSinkWrite#prepareCommit correctly - posted by le...@apache.org on 2024/11/12 09:51:52 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36678][docs][deploy] Fix the typo in Flink CDC YARN deployment documentation - posted by le...@apache.org on 2024/11/12 11:56:12 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36609][pipeline-connector][paimon] Add partition columns to primary keys - posted by le...@apache.org on 2024/11/12 12:00:18 UTC, 0 replies.
- (flink-connector-aws) branch v5.0 updated (89aec61 -> 8569206) - posted by ho...@apache.org on 2024/11/12 13:15:14 UTC, 0 replies.
- (flink-connector-aws) branch v5.0 updated: [hotfix][docs] Fix typo in docs - posted by ho...@apache.org on 2024/11/12 13:22:20 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36635][runtime] Remove PhysicalSlotRequestBulkImpl as it is not used - posted by ju...@apache.org on 2024/11/12 14:10:38 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36560][pipeline-connector][paimon] Fix the issue that timestamp_ltz field is not correctly converted - posted by le...@apache.org on 2024/11/12 15:16:09 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [hotfix][e2e] Temporarily disable TransformE2eITCase in multiple parallelism - posted by le...@apache.org on 2024/11/12 16:07:33 UTC, 0 replies.
- (flink-connector-aws) branch v5.0 updated: [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch - posted by ho...@apache.org on 2024/11/12 17:18:25 UTC, 0 replies.
- (flink-connector-prometheus) branch v1.0 updated: [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch - posted by ho...@apache.org on 2024/11/12 17:20:17 UTC, 0 replies.
- (flink-connector-aws) branch v5.0 updated: [hotfix][docs] Remove buggy doc reference - posted by ho...@apache.org on 2024/11/12 17:32:20 UTC, 0 replies.
- (flink) branch master updated (584dc46b45d -> 6fe39c65581) - posted by za...@apache.org on 2024/11/13 02:33:43 UTC, 0 replies.
- (flink) branch release-1.20 updated (54994fc8892 -> 1a5e4dca23d) - posted by ar...@apache.org on 2024/11/13 06:59:07 UTC, 0 replies.
- (flink) 01/08: [hotfix] Fix UnifiedSinkMigrationITCase - posted by ar...@apache.org on 2024/11/13 06:59:08 UTC, 1 replies.
- (flink) 02/08: [FLINK-25920] Straighten EOI handling in CommittableCollector - posted by ar...@apache.org on 2024/11/13 06:59:09 UTC, 1 replies.
- (flink) 03/08: [FLINK-25920] Improve sink test assertions - posted by ar...@apache.org on 2024/11/13 06:59:10 UTC, 1 replies.
- (flink) 04/08: [FLINK-25920] Only process complete batches of committables - posted by ar...@apache.org on 2024/11/13 06:59:11 UTC, 1 replies.
- (flink) 05/08: [FLINK-25920] Refactor & Revise SinkWriterOperatorTestBase - posted by ar...@apache.org on 2024/11/13 06:59:12 UTC, 1 replies.
- (flink) 06/08: [FLINK-25920] Handle duplicate EOI in Sink - posted by ar...@apache.org on 2024/11/13 06:59:13 UTC, 1 replies.
- (flink) 07/08: [FLINK-25920] Improve logging in committable handling of the sink - posted by ar...@apache.org on 2024/11/13 06:59:14 UTC, 1 replies.
- (flink) 08/08: [FLINK-25920] Fix AbstractStreamingWriter sending after EOI - posted by ar...@apache.org on 2024/11/13 06:59:15 UTC, 1 replies.
- (flink-cdc) branch master updated: [FLINK-36699][cdc-common] fix nullability when converting cdc data type to flink data type (#3713) - posted by ru...@apache.org on 2024/11/13 07:07:45 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36598][state/ForSt] Provide FileSystem instance in initialization (#25638) - posted by za...@apache.org on 2024/11/13 11:45:11 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35592][cdc-connector][mysql] Fix MysqlDebeziumTimeConverter miss timezone when convert to timestamp - posted by le...@apache.org on 2024/11/14 03:24:25 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36093][transform] Fix preTransformoperator wrongly filters columns belong to different transforms - posted by le...@apache.org on 2024/11/14 03:42:02 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36596][transform] Fix unable to schema evolve with project-less transform rules - posted by le...@apache.org on 2024/11/14 04:04:58 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-35592][cdc-connector][mysql] Fix MysqlDebeziumTimeConverter miss timezone when convert to timestamp (#3731) - posted by ru...@apache.org on 2024/11/14 05:50:07 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36681][mysql-cdc][docs] Fix the wrong chunks splitting query in incremental snapshot reading section - posted by le...@apache.org on 2024/11/14 06:20:47 UTC, 0 replies.
- (flink) branch release-1.19 updated (6cad12ad412 -> 3c968e9a845) - posted by ar...@apache.org on 2024/11/14 07:58:48 UTC, 0 replies.
- (flink) branch release-1.20 updated (1a5e4dca23d -> 5dea94b9599) - posted by ar...@apache.org on 2024/11/14 07:59:19 UTC, 0 replies.
- (flink) 01/02: [FLINK-36287] Migrate SinkITCase to AssertJ - posted by ar...@apache.org on 2024/11/14 07:59:20 UTC, 1 replies.
- (flink) 02/02: [FLINK-36287] Disallow UC for inner sink channels - posted by ar...@apache.org on 2024/11/14 07:59:21 UTC, 1 replies.
- (flink-connector-kafka) branch main updated: [FLINK-34466] Lineage interfaces for kafka connector (#130) - posted by ar...@apache.org on 2024/11/14 08:40:24 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36565][transform] Route allows merging Decimals with various precisions - posted by le...@apache.org on 2024/11/14 08:41:00 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36285][doris] Fix unable to alter column type without default value specified - posted by le...@apache.org on 2024/11/14 08:43:44 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36709][parquet] fix parquet can not read row with last column is array. (#25651) - posted by xc...@apache.org on 2024/11/14 17:05:30 UTC, 0 replies.
- (flink-connector-kafka) annotated tag v3.4.0-rc1 updated (e93b300d -> 0a16ecd6) - posted by ar...@apache.org on 2024/11/14 17:18:44 UTC, 0 replies.
- 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 - posted by ar...@apache.org on 2024/11/14 17:22:05 UTC, 0 replies.
- (flink) branch release-1.19 updated (3c968e9a845 -> a79a649eaa6) - posted by ar...@apache.org on 2024/11/14 17:33:19 UTC, 0 replies.
- [I] Postgres table have chinese like "my_table_的“ ，flink cdc task-flow failed [flink-cdc] - posted by "zjb48000 (via GitHub)" <gi...@apache.org> on 2024/11/15 06:17:02 UTC, 3 replies.
- (flink) branch master updated: [FLINK-16155][docs] Translate "Operator/Process Function" into Chinese (#25624) - posted by re...@apache.org on 2024/11/15 09:15:12 UTC, 0 replies.
- (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 - posted by da...@apache.org on 2024/11/15 11:32:33 UTC, 0 replies.
- (flink) branch master updated (5bea35ebb65 -> 77e7ac076c3) - posted by sn...@apache.org on 2024/11/15 12:47:12 UTC, 0 replies.
- (flink) 01/02: [hotfix] Add missing Flink modification comment - posted by sn...@apache.org on 2024/11/15 12:47:13 UTC, 0 replies.
- (flink) 02/02: [FLINK-31362][table] Upgrade Calcite to 1.33.0 - posted by sn...@apache.org on 2024/11/15 12:47:14 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36368] Do not prematurely merge CommittableManager (#25405) - posted by ar...@apache.org on 2024/11/15 15:01:11 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36517][pipeline-connector][paimon] Use filterAndCommit API to avoid committing the same datafile twice - posted by le...@apache.org on 2024/11/18 07:32:31 UTC, 0 replies.
- (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 - posted by le...@apache.org on 2024/11/18 09:05:17 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36509][pipeline-connector][paimon] Add partition columns to primary key - posted by le...@apache.org on 2024/11/18 09:25:06 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36326][source-connector/mysql] Fix auto scan newly-added table failure - posted by le...@apache.org on 2024/11/18 11:13:17 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-35985][transform] Correct the substring function in transform rule - posted by le...@apache.org on 2024/11/18 11:59:09 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated (670bfcf8 -> c89f4312) - posted by gy...@apache.org on 2024/11/18 18:22:06 UTC, 0 replies.
- (flink-kubernetes-operator) 01/02: [FLINK-36646][helm] Add required Java Opts to allow Java 17 based job images. - posted by gy...@apache.org on 2024/11/18 18:22:07 UTC, 0 replies.
- (flink-kubernetes-operator) 02/02: [FLINK-36646] add tests of the various different Java versions as the job images. - posted by gy...@apache.org on 2024/11/18 18:22:08 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated (bd2aa0aaa -> 1bf40f09c) - posted by le...@apache.org on 2024/11/19 02:03:54 UTC, 0 replies.
- (flink-cdc) 01/09: [FLINK-36408][source-connector/mysql] Fix MySQL pipeline connector failed to parse FLOAT type with precision - posted by le...@apache.org on 2024/11/19 02:03:55 UTC, 0 replies.
- (flink-cdc) 02/09: [FLINK-36541][pipeline-connector][paimon] Pass checkpointId to StoreSinkWrite#prepareCommit correctly - posted by le...@apache.org on 2024/11/19 02:03:56 UTC, 0 replies.
- (flink-cdc) 03/09: [FLINK-36105][flink-cdc-cli] Fix unable to restore from checkpoint with Flink 1.20 - posted by le...@apache.org on 2024/11/19 02:03:57 UTC, 0 replies.
- (flink-cdc) 04/09: [FLINK-36407][runtime] Shut down coordinatorExecutor upon closing SchemaRegistry - posted by le...@apache.org on 2024/11/19 02:03:58 UTC, 0 replies.
- (flink-cdc) 05/09: [FLINK-35980][tests] Add transform-related test cases - posted by le...@apache.org on 2024/11/19 02:03:59 UTC, 0 replies.
- (flink-cdc) 06/09: [FLINK-35982][transform] Fix unable to transform metadata without projections - posted by le...@apache.org on 2024/11/19 02:04:00 UTC, 0 replies.
- (flink-cdc) 07/09: [FLINK-36461][transform] Fix schema evolution failure with un-transformed tables - posted by le...@apache.org on 2024/11/19 02:04:01 UTC, 0 replies.
- (flink-cdc) 08/09: [FLINK-36596][transform] Fix unable to schema evolve with project-less transform rules - posted by le...@apache.org on 2024/11/19 02:04:02 UTC, 0 replies.
- (flink-cdc) 09/09: [FLINK-36093][transform] Fix preTransformoperator wrongly filters columns belong to different transforms - posted by le...@apache.org on 2024/11/19 02:04:03 UTC, 0 replies.
- (flink) branch master updated (77e7ac076c3 -> 25b729246e0) - posted by fa...@apache.org on 2024/11/19 06:27:15 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36586][build] Update flink version to 1.19 (#3660) - posted by ru...@apache.org on 2024/11/19 07:17:48 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Log batch size in FlinkS3FileSystem instead of total - posted by pn...@apache.org on 2024/11/19 08:28:25 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36711][runtime] Add tips when System out and err are redirected to LOG or discarded (#25653) - posted by fa...@apache.org on 2024/11/19 10:42:03 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Use Tag to replace some incorrectly used Category annotation for skipping adaptvie-scheduler test - posted by gu...@apache.org on 2024/11/19 11:02:32 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36693][state/forst] Implement checkpoint/restore for ForStSyncKeyedStateBackend (#25643) - posted by le...@apache.org on 2024/11/19 12:13:16 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36192][log] instruct how to change log level dynamically (#911) - posted by mx...@apache.org on 2024/11/19 14:19:34 UTC, 0 replies.
- (flink-playgrounds) branch dependabot/maven/docker/data-generator/org.apache.kafka-kafka-clients-3.7.1 created (now da2bbcd) - posted by gi...@apache.org on 2024/11/19 18:09:52 UTC, 0 replies.
- (flink-connector-kafka) branch dependabot/maven/org.apache.kafka-kafka-clients-3.7.1 created (now 724f3dc8) - posted by gi...@apache.org on 2024/11/19 18:10:14 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36565][transform] Route allows merging Decimals with various precisions (#3743) - posted by ru...@apache.org on 2024/11/20 05:57:09 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36052][docs][cdc-pipeline-connector/es] Add flink cdc pipeline elasticsearch connector docs (#3686) - posted by ru...@apache.org on 2024/11/20 06:03:05 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36710] Log job ID in RecreateOnResetOperatorCoordinator - posted by pn...@apache.org on 2024/11/20 07:23:22 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36714][state] Ignore interrupted in sstmerge.CompactionScheduler#stop - posted by pn...@apache.org on 2024/11/20 07:30:00 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36656][mysql] Fix type conversion failure for newly-added sharding table with mysql boolean type (#3684) - posted by ru...@apache.org on 2024/11/20 07:32:31 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36656][mysql] Fix type conversion failure for newly-added sharding table with mysql boolean type (#3683) - posted by ru...@apache.org on 2024/11/20 07:36:15 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-35291][runtime] Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme (#3289) (#3670) - posted by ru...@apache.org on 2024/11/20 07:38:01 UTC, 0 replies.
- svn commit: r73162 - /release/flink/KEYS - posted by le...@apache.org on 2024/11/20 09:11:44 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][source-connector/mysql] Fix conflicts after flink version bumped to 1.19 (#3748) - posted by ru...@apache.org on 2024/11/20 11:00:31 UTC, 0 replies.
- (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) - posted by mx...@apache.org on 2024/11/20 16:48:48 UTC, 0 replies.
- 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] - posted by "qzztf (via GitHub)" <gi...@apache.org> on 2024/11/21 01:40:32 UTC, 1 replies.
- (flink-cdc) branch release-3.2 updated: [FLINK-36572][pipeline-connector][starrocks] Fix the issue that the local time zone is wrongly set - posted by le...@apache.org on 2024/11/21 02:04:13 UTC, 0 replies.
- 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 - posted by ru...@apache.org on 2024/11/21 08:51:43 UTC, 0 replies.
- (flink-cdc) annotated tag release-3.2.1-rc1 updated (c703d18d1 -> 5b867fa09) - posted by ru...@apache.org on 2024/11/21 08:53:19 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36686] add operatorPod.webhook.container.env in helm chart to allow customizating of flink-webhook container envs - posted by gy...@apache.org on 2024/11/21 10:25:44 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36685] allow CREATE/UPDATE operation on flinkdeployments resource on webhook mutation endpoint - posted by gy...@apache.org on 2024/11/21 10:25:59 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36772][mysql][cdc-base] Fix error placeholder for errorMessageTemplate of Preconditions - posted by le...@apache.org on 2024/11/22 08:02:29 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][docs][pipeline-connector/es] Add missed supported flink versions and Elasticsearch versions - posted by le...@apache.org on 2024/11/22 09:57:58 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [hotfix][docs][pipeline-connector/es] Add missed supported flink versions and Elasticsearch versions - posted by le...@apache.org on 2024/11/22 09:58:13 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated (958cfcb06 -> d52e54f52) - posted by le...@apache.org on 2024/11/22 09:58:47 UTC, 0 replies.
- (flink-cdc) 01/02: [hotfix][docs] Add missed supported flink versions - posted by le...@apache.org on 2024/11/22 09:58:48 UTC, 0 replies.
- (flink-cdc) 02/02: [hotfix][docs][pipeline-connector/vitess] Fix dead links - posted by le...@apache.org on 2024/11/22 09:58:49 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34600][table] Migrate PushLimitIntoLegacyTableSourceScanRule to java - posted by sn...@apache.org on 2024/11/24 14:32:46 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34599][table] Migrate BatchPhysicalConstantTableFunctionScanRule to Java - posted by sn...@apache.org on 2024/11/24 15:31:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35751][table] Migrate SplitPythonConditionFromCorrelateRule to java - posted by sn...@apache.org on 2024/11/24 17:57:03 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35977][docs] Add missing imports in examples in docs - posted by sn...@apache.org on 2024/11/24 20:13:04 UTC, 0 replies.
- [I] flink-cdc3.x版本不支持同步MySQL含有联合主键的表到doris中，任务会报异常并且停止 [flink-cdc] - posted by "BambooJWB (via GitHub)" <gi...@apache.org> on 2024/11/25 08:37:50 UTC, 6 replies.
- (flink) branch master updated (ced02ce25a2 -> 44da52d0964) - posted by sh...@apache.org on 2024/11/25 11:11:52 UTC, 0 replies.
- (flink) 01/02: [FLINK-36755][k8s] Relax the limitation that kubernetes application require a main jar - posted by sh...@apache.org on 2024/11/25 11:11:53 UTC, 0 replies.
- (flink) 02/02: [FLINK-36755][yarn] Relax the limitation that yarn application require a main jar - posted by sh...@apache.org on 2024/11/25 11:11:54 UTC, 0 replies.
- (flink) branch master updated: [hotfix][tests] Remove space from junit Extension file name - posted by sn...@apache.org on 2024/11/25 11:43:16 UTC, 0 replies.
- (flink) branch master updated: [FLINK-31836][table] Upgrade Calcite version to 1.34.0 - posted by sn...@apache.org on 2024/11/25 11:54:04 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36704][table-common] Update TypeInference with StaticArgument and StateTypeStrategy - posted by tw...@apache.org on 2024/11/25 15:09:55 UTC, 0 replies.
- svn commit: r73241 - /dev/flink/flink-connector-kafka-3.4.0-rc1/ /release/flink/flink-connector-kafka-3.4.0/ - posted by ar...@apache.org on 2024/11/25 15:40:22 UTC, 0 replies.
- (flink-connector-kafka) annotated tag v3.4.0 updated (4d3c1022 -> bafdba80) - posted by ar...@apache.org on 2024/11/25 15:45:50 UTC, 0 replies.
- (flink-connector-kafka) tag v3.4.0 updated (bafdba80 -> e93b300d) - posted by ar...@apache.org on 2024/11/25 15:49:22 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-35109] Update weekly CI to verify 3.4 release branch - posted by ar...@apache.org on 2024/11/25 16:11:14 UTC, 0 replies.
- (flink-connector-kafka) branch v3.4 created (now e93b300d) - posted by ar...@apache.org on 2024/11/25 16:14:18 UTC, 0 replies.
- (flink) branch master updated (3ac109b0b4f -> 0c338ae6d21) - posted by ro...@apache.org on 2024/11/25 16:54:57 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36751] Fix PausableRelativeClock does not pause when the source only has one split - posted by ro...@apache.org on 2024/11/25 16:57:16 UTC, 0 replies.
- (flink-web) branch asf-site updated: Add blogpost for new KinesisStreamsSource and DynamoDbStreamsSource - posted by ho...@apache.org on 2024/11/25 17:49:11 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35977][docs] Add missing imports in examples in docs - posted by sn...@apache.org on 2024/11/25 19:29:56 UTC, 0 replies.
- (flink) branch master updated (0c338ae6d21 -> 59dc491f87e) - posted by gu...@apache.org on 2024/11/26 01:45:58 UTC, 0 replies.
- Re: [I] Failed to deserialize data of EventHeaderV4 [flink-cdc] - posted by "NullHunt (via GitHub)" <gi...@apache.org> on 2024/11/26 07:45:31 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36525][transform] Support for AI Model Integration for Data Processing (#3753) - posted by ru...@apache.org on 2024/11/26 08:40:50 UTC, 0 replies.
- (flink) branch master updated (59dc491f87e -> 0580924bf06) - posted by tw...@apache.org on 2024/11/26 09:26:17 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36545] Fix uid/gid mixup when generating the OLM bundle - posted by gy...@apache.org on 2024/11/26 09:30:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36720][table-planner] Add CompiledPlan annotations to BatchExecWindowTableFunction - posted by tw...@apache.org on 2024/11/26 11:30:42 UTC, 0 replies.
- (flink-connector-aws) branch v5.0 updated: [hotfix][docs] Fix description of new configuration table - posted by ho...@apache.org on 2024/11/26 11:42:36 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36047] Add CompiledPlan annotations to BatchExecOverAggregate - posted by sn...@apache.org on 2024/11/26 13:04:22 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36714][state] Ignore interrupted in sstmerge.CompactionScheduler#stop - posted by ro...@apache.org on 2024/11/26 14:00:07 UTC, 0 replies.
- (flink) branch release-1.20 updated: [hotfix] Correct Guava version - posted by ro...@apache.org on 2024/11/26 14:14:01 UTC, 0 replies.
- svn commit: r73286 - /dev/flink/flink-connector-hbase-4.0.0-rc1/ /release/flink/flink-connector-hbase-4.0.0/ - posted by mb...@apache.org on 2024/11/26 17:13:34 UTC, 0 replies.
- (flink-connector-hbase) annotated tag v updated (4dd8505 -> ae84cd3) - posted by fc...@apache.org on 2024/11/26 17:30:02 UTC, 0 replies.
- (flink-connector-hbase) annotated tag v deleted (was ae84cd3) - posted by fc...@apache.org on 2024/11/26 17:31:05 UTC, 0 replies.
- (flink-connector-hbase) annotated tag v4.0.0 updated (4dd8505 -> cc62d8a) - posted by fc...@apache.org on 2024/11/26 17:34:16 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-33571][table] Upgrade json-path from 2.7.0 to 2.9.0 - posted by sn...@apache.org on 2024/11/26 18:30:11 UTC, 0 replies.
- (flink-shaded) branch master updated: [FLINK-33571] Update json-path from 2.7.0 to 2.9.0 (#140) - posted by sn...@apache.org on 2024/11/26 18:37:15 UTC, 0 replies.
- (flink-web) branch asf-site updated: Upgrade Kafka connector to 3.4.0 - posted by ar...@apache.org on 2024/11/26 20:49:00 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36048][table-planner] Add CompiledPlan annotations to BatchExecRank - posted by sn...@apache.org on 2024/11/26 21:18:28 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35334][flink-table] Split constructor of generated code if it is too large - posted by sn...@apache.org on 2024/11/26 21:23:38 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35334][flink-table] Split constructor of generated code if it is too large - posted by sn...@apache.org on 2024/11/26 21:24:16 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35334][flink-table] Split constructor of generated code if it is too large - posted by sn...@apache.org on 2024/11/26 21:25:10 UTC, 0 replies.
- (flink-shaded) branch master updated: [FLINK-35003] Update zookeeper to 3.8.4 - posted by sn...@apache.org on 2024/11/26 21:40:46 UTC, 0 replies.
- [I] paimon sync table CreateTableEvent hold [flink-cdc] - posted by "boerzi (via GitHub)" <gi...@apache.org> on 2024/11/27 03:28:15 UTC, 1 replies.
- svn commit: r73300 - /dev/flink/flink-cdc-3.2.1-rc1/ /release/flink/flink-cdc-3.2.1/ - posted by le...@apache.org on 2024/11/27 06:20:30 UTC, 0 replies.
- (flink-cdc) annotated tag release-3.2.1 updated (c703d18d1 -> 86acf60d7) - posted by ru...@apache.org on 2024/11/27 06:34:01 UTC, 0 replies.
- Re: [I] 请问出现这个错误(io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4{timestamp=1627541881000,)是什么原因? [flink-cdc] - posted by "danzhewuju (via GitHub)" <gi...@apache.org> on 2024/11/27 06:46:44 UTC, 0 replies.
- Re: [I] cdc sync mysql to paimon Schema Registry is busy now, waiting for next request... [flink-cdc] - posted by "boerzi (via GitHub)" <gi...@apache.org> on 2024/11/27 06:49:31 UTC, 1 replies.
- (flink-web) branch asf-site updated: Add release announcement for Flink CDC 3.2.1 (#764) - posted by ru...@apache.org on 2024/11/27 07:25:14 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [hotfix] Fix incorrect `messageKey` passed in `ScalingLimited` event - posted by gy...@apache.org on 2024/11/27 07:48:39 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][Doc] fix spelling error in Al model docs. (#3764) - posted by ru...@apache.org on 2024/11/27 09:18:59 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Do skip distributing maxAllowedWatermark if there are no subtasks - posted by pn...@apache.org on 2024/11/27 10:46:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36764] Add checkpoint type and unaligned flag to the checkpoint trace - posted by pn...@apache.org on 2024/11/27 10:48:00 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36718][table-planner] Add CompiledPlan annotations to BatchExecLookupJoin - posted by sn...@apache.org on 2024/11/27 13:46:12 UTC, 0 replies.
- (flink-web) branch asf-site updated: Update blogpost for new KinesisStreamsSource and DynamoDbStreamsSource - posted by ho...@apache.org on 2024/11/27 14:12:02 UTC, 0 replies.
- (flink-web) branch asf-site updated (c09af3ab9 -> fcad0bfb2) - posted by fc...@apache.org on 2024/11/27 15:05:12 UTC, 0 replies.
- (flink-web) branch asf-site updated (fcad0bfb2 -> 744ec4195) - posted by fc...@apache.org on 2024/11/27 15:12:20 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35136][docs] Bump HBase connector docs version to v4.0 - posted by fc...@apache.org on 2024/11/27 19:11:58 UTC, 0 replies.
- (flink-connector-hbase) branch v4.0 updated: [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch - posted by fc...@apache.org on 2024/11/27 19:33:08 UTC, 0 replies.
- (flink-connector-hbase) branch main updated: [hotfix][docs] Explicitly set connector compatibility as string to prevent version comparison mismatch - posted by fc...@apache.org on 2024/11/27 19:38:17 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36751] Fix PausableRelativeClock does not pause when the source only has one split - posted by ro...@apache.org on 2024/11/27 21:54:52 UTC, 0 replies.
- [I] Caused by: java.sql.SQLException: ORA-01435: user does not exist ORA-06512: at "SYS.DBMS_LOGMNR", line 72 [flink-cdc] - posted by "yhai1596 (via GitHub)" <gi...@apache.org> on 2024/11/28 09:43:45 UTC, 4 replies.
- (flink) branch release-1.19 updated: [FLINK-35136][docs] Bump HBase connector docs version to v4.0 - posted by fc...@apache.org on 2024/11/28 09:57:56 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36529] Allow Flink version configs to be set to greater than given version - posted by gy...@apache.org on 2024/11/28 13:47:40 UTC, 0 replies.
- (flink) branch master updated (b9c92371dba -> a8f51944be3) - posted by sn...@apache.org on 2024/11/28 17:00:22 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34194] Update CI to Ubuntu 22.04 (Jammy) - posted by ch...@apache.org on 2024/11/28 20:52:03 UTC, 0 replies.
- Re: [I] update operation does not take effect [flink-cdc] - posted by "GlassesCXY (via GitHub)" <gi...@apache.org> on 2024/11/29 03:18:08 UTC, 0 replies.
- (flink) branch master updated (ea7425b8b77 -> d7bfa77bcab) - posted by ar...@apache.org on 2024/11/29 08:11:16 UTC, 0 replies.
- (flink) 01/03: [FLINK-36788] Move GlobalCommitter to flink-runtime - posted by ar...@apache.org on 2024/11/29 08:11:17 UTC, 0 replies.
- (flink) 02/03: [FLINK-36788] Add InitContext to GlobalCommitter factory - posted by ar...@apache.org on 2024/11/29 08:11:18 UTC, 0 replies.
- (flink) 03/03: [FLINK-36788] Fix GlobalCommitter expansion - posted by ar...@apache.org on 2024/11/29 08:11:19 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36705][table-common] Add initial ProcessTableFunction class and annotations - posted by tw...@apache.org on 2024/11/29 09:15:37 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36809][table] Support ignoreIfExists param for createTable - posted by tw...@apache.org on 2024/11/29 17:03:21 UTC, 0 replies.
- (flink) branch master updated (02510f1116d -> 4998907331a) - posted by sn...@apache.org on 2024/11/30 15:35:35 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36643][filesystems] Update aws-java-sdk-core to 1.12.779 - posted by sn...@apache.org on 2024/11/30 15:37:28 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36643][filesystems] Update aws-java-sdk-core to 1.12.779 - posted by sn...@apache.org on 2024/11/30 15:38:59 UTC, 0 replies.