commits@flink.apache.org, 2024-07

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

- (flink-connector-jdbc) branch main updated: [FLINK-35542] Set the correct class loader to lookup for the class CheckpointedOffset (#130) - posted by fa...@apache.org on 2024/07/01 01:42:36 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-35022][Connectors/DynamoDB] Add Default DynamoDB Element Converter - posted by ho...@apache.org on 2024/07/01 11:06:46 UTC, 0 replies.
- (flink) branch master updated (e7d7db3b6f8 -> 3aa3c48ab19) - posted by ro...@apache.org on 2024/07/01 13:26:18 UTC, 0 replies.
- (flink) 01/02: [FLINK-35734][table] Fix periodic refresh job naming - posted by ro...@apache.org on 2024/07/01 13:26:19 UTC, 1 replies.
- (flink) 02/02: [FLINK-35734][table] Do not override the user-defined checkpoint interval in continuous mode - posted by ro...@apache.org on 2024/07/01 13:26:20 UTC, 1 replies.
- (flink) branch master updated: [FLINK-35498][table] Fix unexpected argument name conflicts when extracting method parameter names from UDF - posted by li...@apache.org on 2024/07/02 01:12:17 UTC, 0 replies.
- (flink) branch release-1.20 updated (7f40c35fc74 -> d147bbf33d2) - posted by ro...@apache.org on 2024/07/02 01:32:15 UTC, 0 replies.
- (flink) branch master updated (84165b23cfc -> cfa09e27041) - posted by lz...@apache.org on 2024/07/02 02:22:16 UTC, 0 replies.
- (flink) branch master updated: [FLINK-33212][core] add job status changed listener for lineage (#24754) - posted by zj...@apache.org on 2024/07/02 05:16:23 UTC, 0 replies.
- (flink) branch master updated (99cb5c7addc -> c226ea938ad) - posted by rm...@apache.org on 2024/07/02 06:12:45 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35728][python] Move conda url from repo.continuum.io to repo.anaconda.com - posted by rm...@apache.org on 2024/07/02 06:13:52 UTC, 0 replies.
- (flink) branch release-1.18 updated: [FLINK-35728][python] Move conda url from repo.continuum.io to repo.anaconda.com (#25007) - posted by rm...@apache.org on 2024/07/02 06:14:46 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35728][python] Move conda url from repo.continuum.io to repo.anaconda.com (#25008) - posted by rm...@apache.org on 2024/07/02 06:15:36 UTC, 0 replies.
- svn commit: r70087 - /dev/flink/flink-kubernetes-operator-1.9.0-rc1/ /release/flink/flink-kubernetes-operator-1.9.0/ - posted by gy...@apache.org on 2024/07/02 06:55:51 UTC, 0 replies.
- svn commit: r70088 - /release/flink/flink-kubernetes-operator-1.6.1/ - posted by gy...@apache.org on 2024/07/02 06:58:03 UTC, 0 replies.
- (flink-kubernetes-operator) annotated tag release-1.9.0 updated (17129ff2 -> 05404db9) - posted by gy...@apache.org on 2024/07/02 07:00:22 UTC, 0 replies.
- (flink-kubernetes-operator) annotated tag release-1.9.0-rc1 deleted (was c06634eb) - posted by gy...@apache.org on 2024/07/02 07:01:01 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35625][cli] Merge "flink run" and "flink run-application" functionality, deprecate "run-application" - posted by ga...@apache.org on 2024/07/02 10:23:04 UTC, 0 replies.
- (flink-web) branch asf-site updated (207acb652 -> e4817ed04) - posted by gy...@apache.org on 2024/07/02 13:56:15 UTC, 0 replies.
- (flink-web) 01/02: Flink Kubernetes Operator 1.9.0 - posted by gy...@apache.org on 2024/07/02 13:56:16 UTC, 0 replies.
- (flink-web) 02/02: Rebuild website - posted by gy...@apache.org on 2024/07/02 13:56:17 UTC, 1 replies.
- (flink) branch master updated (e56b54db40a -> c75248e48f4) - posted by ma...@apache.org on 2024/07/02 15:32:51 UTC, 0 replies.
- (flink) 01/02: [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow - posted by ma...@apache.org on 2024/07/02 15:32:52 UTC, 0 replies.
- (flink) 02/02: [FLINK-34582] Updates cibuildwheel to support cpython 3.11 wheel package - posted by ma...@apache.org on 2024/07/02 15:32:53 UTC, 0 replies.
- Re: [I] [ERROR] Could not execute SQL statement. Reason: java.io.StreamCorruptedException: unexpected block data [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2024/07/02 16:58:09 UTC, 1 replies.
- (flink) branch master updated: [FLINK-33211][table] support flink table lineage (#24618) - posted by zj...@apache.org on 2024/07/03 01:58:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35735][sql-gateway] Don't list all catalogs when closing session (#25010) - posted by sh...@apache.org on 2024/07/03 02:13:09 UTC, 0 replies.
- (flink) branch master updated (af3e39fa4ce -> b782acfb9c0) - posted by fa...@apache.org on 2024/07/03 03:21:51 UTC, 0 replies.
- (flink) 01/02: [FLINK-35733] Change org.jetbrains.annotations.NotNull/Nullable to javax.annotation.Nonnull/Nullable - posted by fa...@apache.org on 2024/07/03 03:21:52 UTC, 0 replies.
- (flink) 02/02: [FLINK-35733][tools] Add the Nonnull & Nullable annotations check rule. - posted by fa...@apache.org on 2024/07/03 03:21:53 UTC, 0 replies.
- (flink) branch master updated: Revert "[FLINK-33211][table] support flink table lineage (#24618)" - posted by ma...@apache.org on 2024/07/03 06:35:00 UTC, 0 replies.
- (flink-web) branch asf-site updated: Rebuild website - posted by gy...@apache.org on 2024/07/03 10:01:30 UTC, 1 replies.
- (flink) branch master updated (0b60bba6715 -> 482969aa24d) - posted by ma...@apache.org on 2024/07/03 12:24:31 UTC, 0 replies.
- (flink) 01/06: [hotfix][runtime] Removes unused method - posted by ma...@apache.org on 2024/07/03 12:24:32 UTC, 0 replies.
- (flink) 02/06: [hotfix][runtime] Remove no longer used CheckpointCoordinator#failUnacknowledgedPendingCheckpointsFor method. - posted by ma...@apache.org on 2024/07/03 12:24:33 UTC, 0 replies.
- (flink) 03/06: [hotfix][runtime] Adds missing @Nullable annotation - posted by ma...@apache.org on 2024/07/03 12:24:34 UTC, 0 replies.
- (flink) 04/06: [hotfix][runtime] Make CheckpointStatsTracker not rely on numberOfTotalSubtasks - posted by ma...@apache.org on 2024/07/03 12:24:35 UTC, 0 replies.
- (flink) 05/06: [hotfix][runtime] Extracts CheckpointStatsTracker into interface - posted by ma...@apache.org on 2024/07/03 12:24:36 UTC, 0 replies.
- (flink) 06/06: [FLINK-35552][runtime] Rework how CheckpointStatsTracker is constructed. - posted by ma...@apache.org on 2024/07/03 12:24:37 UTC, 0 replies.
- svn commit: r70114 - /dev/flink/flink-shaded-19.0-rc1/ /release/flink/flink-shaded-19.0/ - posted by dw...@apache.org on 2024/07/03 12:26:56 UTC, 0 replies.
- (flink-shaded) annotated tag release-19.0 updated (26473c0 -> e686c1a) - posted by dw...@apache.org on 2024/07/03 12:30:04 UTC, 0 replies.
- (flink-web) branch asf-site updated (abf0b0fe8 -> dd795eecb) - posted by dw...@apache.org on 2024/07/03 13:06:09 UTC, 0 replies.
- (flink-web) 01/02: Release flink-shaded 19.0 - posted by dw...@apache.org on 2024/07/03 13:06:10 UTC, 0 replies.
- (flink) branch master updated (482969aa24d -> 0b0158b4df9) - posted by ro...@apache.org on 2024/07/03 13:14:58 UTC, 0 replies.
- (flink) 01/02: [FLINK-35742] Don't create RocksDB Column Families if task cancellation is in progress - posted by ro...@apache.org on 2024/07/03 13:14:59 UTC, 0 replies.
- (flink) 02/02: [hotfix] Propagate cancellation to RocksDBWriteBatchWrapper during recovery - posted by ro...@apache.org on 2024/07/03 13:15:00 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-35357][docs] Add kubernetes.operator.plugins.listeners config (#845) - posted by fa...@apache.org on 2024/07/04 06:14:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35553][runtime] Wire-up RescaleManager with CheckpointStatsListener in Executing state - posted by ma...@apache.org on 2024/07/04 06:55:55 UTC, 0 replies.
- Re: [I] [Bug] io/debezium/connector/mysql/MySqlConnection$MySqlConnectionConfiguration.class 类重复导致异常java.lang.NoSuchMethodError [flink-cdc] - posted by "Tangsonghuai (via GitHub)" <gi...@apache.org> on 2024/07/04 07:49:22 UTC, 0 replies.
- [I] lost data when gtid with Multiple transaction id on mgr cluster [flink-cdc] - posted by "zbingwen (via GitHub)" <gi...@apache.org> on 2024/07/04 08:36:16 UTC, 4 replies.
- (flink) branch master updated: [FLINK-34268] Removing exclusions for FLINK-33676 33805 - posted by ma...@apache.org on 2024/07/04 09:07:50 UTC, 0 replies.
- (flink) branch ngn346 deleted (was 47ce6a97aaf) - posted by pn...@apache.org on 2024/07/04 10:05:54 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35498][table] Fix unexpected argument name conflicts when extracting method parameter names from UDF - posted by li...@apache.org on 2024/07/04 13:13:55 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35498][table] Fix unexpected argument name conflicts when extracting method parameter names from UDF - posted by li...@apache.org on 2024/07/04 13:17:09 UTC, 0 replies.
- Re: [I] oracle-connector实时读取只读备库的问题 [flink-cdc] - posted by "xiaofan2022 (via GitHub)" <gi...@apache.org> on 2024/07/05 02:01:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35731][runtime] Fix incorrect parallelism configured detection for Sink V2. - posted by zh...@apache.org on 2024/07/05 02:24:29 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35281][cdc-common] FlinkEnvironmentUtils#addJar add each jar only once (#3301) - posted by ru...@apache.org on 2024/07/05 06:07:02 UTC, 0 replies.
- (flink) branch master updated (6b08eb15d09 -> 59769b7eaa5) - posted by dw...@apache.org on 2024/07/05 08:27:57 UTC, 0 replies.
- (flink) 01/02: [FLINK-33705] Upgrade to flink-shaded 18.0 - posted by dw...@apache.org on 2024/07/05 08:27:58 UTC, 0 replies.
- (flink) 02/02: [FLINK-35755] Upgrade to flink-shaded 19.0 - posted by dw...@apache.org on 2024/07/05 08:27:59 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35731][runtime] Fix incorrect parallelism configured detection for Sink V2. - posted by zh...@apache.org on 2024/07/05 09:09:52 UTC, 0 replies.
- (flink) branch master updated (59769b7eaa5 -> 90fc679df07) - posted by ro...@apache.org on 2024/07/05 09:55:45 UTC, 0 replies.
- (flink) 01/03: [FLINK-35643][table] Fix incorrect comment in AlterMaterializedTableResumeOperation - posted by ro...@apache.org on 2024/07/05 09:55:46 UTC, 1 replies.
- (flink) 02/03: [FLINK-35643][doc] Add materialized table statement doc - posted by ro...@apache.org on 2024/07/05 09:55:47 UTC, 1 replies.
- (flink) 03/03: [FLINK-35645][doc] Add quickstart for materialized table - posted by ro...@apache.org on 2024/07/05 09:55:48 UTC, 1 replies.
- (flink) branch release-1.20 updated (2b3a47d98bf -> cab08d95a85) - posted by ro...@apache.org on 2024/07/05 09:59:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35696] JSON_VALUE/QUERY functions incorrectly map floating numbers (#25026) - posted by dw...@apache.org on 2024/07/05 13:10:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35641] ParquetSchemaConverter supports required fields (#24956) - posted by lz...@apache.org on 2024/07/05 14:34:14 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Fix merge conflicts in ParquetColumnarRowSplitReaderTest - posted by lz...@apache.org on 2024/07/05 15:12:57 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34130][core] Mark setBytes and getBytes of Configuration as @Internal (#24999) - posted by fa...@apache.org on 2024/07/06 02:54:21 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35750][runtime/metrics] Fix that the latency marker metrics aren't updated after failover. - posted by fa...@apache.org on 2024/07/06 03:04:38 UTC, 0 replies.
- (flink) branch master updated: [FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup (#24917) - posted by le...@apache.org on 2024/07/06 04:34:50 UTC, 0 replies.
- [I] flinkcdc3 [flink-cdc] - posted by "Tangsonghuai (via GitHub)" <gi...@apache.org> on 2024/07/07 02:44:09 UTC, 1 replies.
- (flink) branch master updated: [FLINK-33211][table] support flink table lineage (#25012) - posted by zj...@apache.org on 2024/07/07 12:57:35 UTC, 0 replies.
- (flink) branch release-1.18 updated: [BP-1.18] [FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup (#25032) - posted by le...@apache.org on 2024/07/08 02:11:58 UTC, 0 replies.
- Re: [I] flinkcdc3 official website operation error [flink-cdc] - posted by "Tangsonghuai (via GitHub)" <gi...@apache.org> on 2024/07/08 05:25:20 UTC, 4 replies.
- (flink) branch release-1.19 updated: [FLINK-35731][runtime] Fix incorrect parallelism configured detection for Sink V2. - posted by zh...@apache.org on 2024/07/08 06:21:49 UTC, 0 replies.
- (flink) branch master updated (f41927c5a9b -> 1bf0e347966) - posted by ho...@apache.org on 2024/07/08 07:47:40 UTC, 0 replies.
- (flink) 01/02: FLINK-35657: use parseFloat for metric value - posted by ho...@apache.org on 2024/07/08 07:47:41 UTC, 0 replies.
- (flink) 02/02: FLINK-35657: fix for all loadMetrics with parseFloat - posted by ho...@apache.org on 2024/07/08 07:47:42 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup - posted by ho...@apache.org on 2024/07/08 08:07:54 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup - posted by ho...@apache.org on 2024/07/08 08:08:49 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35750][runtime/metrics] Fix that the latency marker metrics aren't updated after failover. - posted by fa...@apache.org on 2024/07/08 09:46:31 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35750][runtime/metrics] Fix that the latency marker metrics aren't updated after failover. - posted by fa...@apache.org on 2024/07/08 09:46:36 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35778][checkpoint] Escape URI reserved characters when creating file-merging directories (#25030) - posted by za...@apache.org on 2024/07/08 12:36:27 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35778][checkpoint] Escape URI reserved characters when creating file-merging directories (#25031) - posted by za...@apache.org on 2024/07/08 12:37:00 UTC, 0 replies.
- (flink) branch ngn346 created (now 81ea19f5b19) - posted by pn...@apache.org on 2024/07/08 15:14:13 UTC, 1 replies.
- (flink) branch master updated: [FLINK-35707][table] Allow column definition in CREATE TABLE AS (CTAS) (#24987) - posted by tw...@apache.org on 2024/07/08 15:16:48 UTC, 0 replies.
- (flink) branch ngn346 deleted (was 81ea19f5b19) - posted by pn...@apache.org on 2024/07/08 15:17:49 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35786] Fix NPE BlobServer / shutdownHook - posted by ro...@apache.org on 2024/07/09 06:41:49 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35354] Support host mapping in Flink tikv cdc (#3336) - posted by go...@apache.org on 2024/07/09 07:32:48 UTC, 0 replies.
- (flink-shaded) branch master updated: [hoftix] Update 20.0 version (#139) - posted by dw...@apache.org on 2024/07/09 08:25:16 UTC, 0 replies.
- (flink-benchmarks) branch master updated: [hotfix] Update shaded 19.0 - posted by dw...@apache.org on 2024/07/09 09:43:10 UTC, 0 replies.
- (flink) branch release-1.20 updated: [hotfix][checkpoint] Rename file-merging options in documents (#25049) - posted by le...@apache.org on 2024/07/09 10:31:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35784][checkpoint] Fix the missing shared state registration of file-merging directories (#25051) - posted by za...@apache.org on 2024/07/09 12:21:42 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35784][checkpoint] Fix the missing shared state registration of file-merging directories (#25052) - posted by za...@apache.org on 2024/07/09 12:22:02 UTC, 0 replies.
- (flink) branch release-1.20 updated: [hotfix] Fix the broken link of standalone deployment - posted by za...@apache.org on 2024/07/09 12:28:10 UTC, 0 replies.
- (flink) branch release-1.19 updated: [hotfix] Fix the broken link of standalone deployment - posted by za...@apache.org on 2024/07/09 12:28:26 UTC, 0 replies.
- (flink) branch release-1.18 updated: [hotfix] Fix the broken link of standalone deployment - posted by za...@apache.org on 2024/07/09 12:28:35 UTC, 0 replies.
- (flink) branch master updated (3d793876048 -> 4e86d984374) - posted by za...@apache.org on 2024/07/09 12:28:47 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35786] Fix NPE BlobServer / shutdownHook - posted by ro...@apache.org on 2024/07/09 14:40:45 UTC, 0 replies.
- (flink) branch master updated: [hotfix][checkpoint] Rename file-merging options in documents (#25048) - posted by le...@apache.org on 2024/07/10 02:00:34 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35793][tests] Remove hybrid shuffle types from BatchSQLTest temporarily - posted by gu...@apache.org on 2024/07/10 03:28:29 UTC, 0 replies.
- [I] When restoring a task from a savepoint, tables that were previously synchronized but later deleted still exist in a state [flink-cdc] - posted by "zhangkunjie (via GitHub)" <gi...@apache.org> on 2024/07/10 04:56:26 UTC, 3 replies.
- (flink) branch master updated: [hotfix] [docs] Fix broken link to "Anatomy of the Flink distribution" - posted by ho...@apache.org on 2024/07/10 06:54:35 UTC, 0 replies.
- (flink) branch master updated (b95c11803b7 -> 0bf2aaac0e3) - posted by ar...@apache.org on 2024/07/10 07:50:10 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function - posted by sn...@apache.org on 2024/07/10 08:13:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35789][table] Allow defining watermarks & PRIMARY KEY in CREATE TABLE AS (CTAS) - posted by tw...@apache.org on 2024/07/10 10:24:10 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-34341] Initial implementation of DynamoDBStreams Source. Marked as Experimental - posted by ho...@apache.org on 2024/07/10 11:59:03 UTC, 0 replies.
- (flink) branch master updated: [FLINK-33730][doc] Update the Flink upgrade savepoint compatibility table doc for chinese version - posted by fa...@apache.org on 2024/07/10 12:14:30 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [hotfix][ci] Update builds to test against 1.19.1 - posted by ho...@apache.org on 2024/07/10 15:02:07 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-32218][Connector/Kinesis] Add support for parent-child shard ordering - posted by ho...@apache.org on 2024/07/10 16:26:32 UTC, 0 replies.
- (flink) branch master updated (c00fcfb293d -> d04c70fae03) - posted by ro...@apache.org on 2024/07/11 01:22:51 UTC, 0 replies.
- (flink) 01/02: [FLINK-35754][e2e] Fix SqlGatewayE2ECase.testMaterializedTableInFullMode failed due to Internal Server Error - posted by ro...@apache.org on 2024/07/11 01:22:52 UTC, 1 replies.
- (flink) 02/02: [FLINK-35754][doc] Fix typo in materialized table docs - posted by ro...@apache.org on 2024/07/11 01:22:53 UTC, 1 replies.
- (flink) branch master updated: [FLINK-35803][checkpoint] Fix the wrong file reuse in cp file-merging (#25069) - posted by za...@apache.org on 2024/07/11 02:30:36 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35803][checkpoint] Fix the wrong file reuse in cp file-merging (#25070) - posted by za...@apache.org on 2024/07/11 02:30:45 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35717][table] Allow defining partition keys and table distribution in CREATE TABLE AS (CTAS) - posted by tw...@apache.org on 2024/07/11 08:28:51 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35801] Fix SnapshotFileMergingCompatibilityITCase, wait for file deletion before quit (#25066) - posted by za...@apache.org on 2024/07/11 09:35:47 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35801] Fix SnapshotFileMergingCompatibilityITCase, wait for file deletion before quit (#25067) - posted by za...@apache.org on 2024/07/11 09:35:53 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-35749] Kafka sink component will lose data when kafka cluster is unavailable for a while (#107) - posted by ar...@apache.org on 2024/07/11 11:39:50 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-32324][Connectors/AWS] Implement support for watermark alignment in FLIP-27 sources for KDS and DDB streams - posted by ho...@apache.org on 2024/07/11 15:45:50 UTC, 0 replies.
- (flink) branch master updated: [hotfix][table] Apply uppercase for URL_ENCODE/URL_DECODE remove logging from function class - posted by sn...@apache.org on 2024/07/11 19:42:35 UTC, 0 replies.
- (flink) branch release-1.20 updated (c8b46b09087 -> 8244941ed18) - posted by ro...@apache.org on 2024/07/12 01:54:37 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35240][Connectors][format] Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format (#24730) - posted by go...@apache.org on 2024/07/12 02:03:22 UTC, 0 replies.
- (flink) branch master updated: [hotfix][runtime] Avoid duplicating broadcast records redundantly for hybrid shuffle - posted by gu...@apache.org on 2024/07/12 05:53:54 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-33730][doc] Update the Flink upgrade savepoint compatibility table doc for chinese version - posted by fa...@apache.org on 2024/07/12 07:48:42 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-33730][doc] Update the Flink upgrade savepoint compatibility table doc for chinese version - posted by fa...@apache.org on 2024/07/12 07:50:07 UTC, 0 replies.
- (flink) branch master updated (765467f94ee -> a056e0230e8) - posted by pn...@apache.org on 2024/07/12 08:19:32 UTC, 0 replies.
- (flink) 01/08: [hotfix] Create ConfigOptions for s3 access/secret keys and endpoint - posted by pn...@apache.org on 2024/07/12 08:19:33 UTC, 0 replies.
- (flink) 02/08: [hotfix] Move CompressionUtils to flink-core - posted by pn...@apache.org on 2024/07/12 08:19:34 UTC, 0 replies.
- (flink) 03/08: [hotfix] Use newly defined ConfigOptions in MinioTestContainer - posted by pn...@apache.org on 2024/07/12 08:19:35 UTC, 0 replies.
- (flink) 04/08: [FLINK-35767][filesystems] Add PathsCopyingFileSystem - posted by pn...@apache.org on 2024/07/12 08:19:36 UTC, 0 replies.
- (flink) 05/08: [FLINK-35767][s3] Use s5cmd for fast files download from the s3 - posted by pn...@apache.org on 2024/07/12 08:19:37 UTC, 0 replies.
- (flink) 06/08: [FLINK-35768][state,rocksdb] Refactor RocksDBStateDownloader - posted by pn...@apache.org on 2024/07/12 08:19:38 UTC, 0 replies.
- (flink) 07/08: [FLINK-35768][state,rocksdb] Use fast files download in RocksdBStateDownloader - posted by pn...@apache.org on 2024/07/12 08:19:39 UTC, 0 replies.
- (flink) 08/08: [FLINK-35768][tests] Add an ITCase for s5cmd - posted by pn...@apache.org on 2024/07/12 08:19:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-25537][JUnit5 Migration] Module: flink-core (#24939) - posted by go...@apache.org on 2024/07/12 08:32:45 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated: [FLINK-35824] Polish JDBC documentation : fix link and add back to top button (#88) - posted by go...@apache.org on 2024/07/12 09:10:59 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35647][route] Support symbol replacement to enrich routing rules - posted by le...@apache.org on 2024/07/12 09:35:27 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35781][cli] Provide a default parallelism 1 for pipeline jobs - posted by le...@apache.org on 2024/07/12 09:42:29 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35820] Converting Duration to String fails for big values (#25077) - posted by dw...@apache.org on 2024/07/12 11:24:02 UTC, 0 replies.
- (flink-connector-aws) branch main updated (f81473e -> 4258ec4) - posted by ho...@apache.org on 2024/07/12 14:30:48 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35829][table-planner] The requireWatermark property of StreamPhysicalWindowTableFunction needs to check the window's time type - posted by li...@apache.org on 2024/07/12 15:16:04 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35816][table-planner] Non-mergeable proctime tvf window aggregate needs to fallback to group aggregate - posted by li...@apache.org on 2024/07/12 15:18:43 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35816][table-planner] Non-mergeable proctime tvf window aggregate needs to fallback to group aggregate - posted by li...@apache.org on 2024/07/13 03:09:49 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35829][table-planner] The requireWatermark property of StreamPhysicalWindowTableFunction needs to check the window's time type - posted by li...@apache.org on 2024/07/13 12:27:11 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35804][table-planner] Fix incorrect calc merge during decorrelate phase - posted by li...@apache.org on 2024/07/14 13:23:45 UTC, 0 replies.
- (flink) branch release-1.18 updated: [FLINK-35750][runtime/metrics] Fix that the latency marker metrics aren't updated after failover. - posted by fa...@apache.org on 2024/07/15 01:47:17 UTC, 0 replies.
- (flink) branch release-1.17 updated: [FLINK-35750][runtime/metrics] Fix that the latency marker metrics aren't updated after failover. - posted by fa...@apache.org on 2024/07/15 01:47:22 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated: [hotfix][test] Change the modifier visibility of JUnit5. - posted by fa...@apache.org on 2024/07/15 03:11:08 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-35831] Rotate jobId for both savepoint and stateless deploys - posted by gy...@apache.org on 2024/07/15 05:53:39 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-35126] Rework default checkpoint progress check window - posted by gy...@apache.org on 2024/07/15 05:54:37 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35318][table-planner] Use UTC time zone for TIMESTAMP_LTZ type in RexNodeToExpressionConverter - posted by le...@apache.org on 2024/07/15 06:23:18 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][cdc][docs] Optimize markdown formats in doris quickstart doc - posted by le...@apache.org on 2024/07/15 07:13:32 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35804][table-planner] Fix incorrect calc merge during decorrelate phase - posted by li...@apache.org on 2024/07/15 07:18:06 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35095][test] Fix unstable tests in `ExecutionEnvironmentImplTest` - posted by gu...@apache.org on 2024/07/15 12:38:05 UTC, 0 replies.
- [I] java.lang.IllegalStateException: Failed to send request to coordinator: com.ververica.cdc.runtime.operators.schema.event.ReleaseUpstreamRequest@5b433541 [flink-cdc] - posted by "Panlibin2015 (via GitHub)" <gi...@apache.org> on 2024/07/15 13:01:57 UTC, 6 replies.
- (flink) branch master updated (fd4b4005c93 -> 91a11acc2a8) - posted by gu...@apache.org on 2024/07/15 13:16:03 UTC, 0 replies.
- svn commit: r70314 - in /dev/flink/flink-1.20.0-rc1: ./ python/ - posted by gu...@apache.org on 2024/07/15 13:18:11 UTC, 0 replies.
- (flink) annotated tag release-1.20.0-rc1 updated (5328519f36d -> 0bb6592a09e) - posted by gu...@apache.org on 2024/07/15 13:25:22 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35799][table] Add CompiledPlan annotations to BatchExecCalc - posted by tw...@apache.org on 2024/07/15 14:41:23 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34990][cdc-connector][oracle] Oracle cdc support newly add table (#3203) - posted by go...@apache.org on 2024/07/16 01:49:13 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [FLINK-35616][Connectors/MongoDB] Support upsert into sharded collections (#37) - posted by ji...@apache.org on 2024/07/16 01:57:05 UTC, 0 replies.
- (flink) branch release-1.19 updated: [hotfix] Set correct available connector version numbers - posted by ma...@apache.org on 2024/07/16 07:19:18 UTC, 0 replies.
- (flink) branch release-1.18 updated: [hotfix] Set correct available connector version numbers - posted by ma...@apache.org on 2024/07/16 07:22:46 UTC, 0 replies.
- (flink) branch release-1.19 updated: [hotfix] Set latest available connector version for Opensearch - posted by ma...@apache.org on 2024/07/16 07:24:47 UTC, 0 replies.
- (flink) branch release-1.19 updated: [hotfix] Set Opensearch connector version to v1.2 - posted by ma...@apache.org on 2024/07/16 08:06:31 UTC, 0 replies.
- (flink) branch release-1.18 updated: [hotfix] Set Opensearch connector version to v1.2 - posted by ma...@apache.org on 2024/07/16 08:07:01 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][docs][postgres] Remove unsupported erroneous example code - posted by le...@apache.org on 2024/07/16 10:51:01 UTC, 0 replies.
- (flink-cdc) branch master updated: [build][CI] Introduce automated PR governance workflows - posted by le...@apache.org on 2024/07/16 10:53:12 UTC, 0 replies.
- (flink) branch master updated (0050e426bc0 -> 48f352208b5) - posted by za...@apache.org on 2024/07/16 11:45:06 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34883] Fix postgres uuid column as PK (#3282) - posted by go...@apache.org on 2024/07/16 15:22:14 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35812] Move tuple interfaces to flink-core-api (#25074) - posted by za...@apache.org on 2024/07/17 02:20:58 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35154][docs] Update maven-javadoc-plugin to fix render issue - posted by gu...@apache.org on 2024/07/17 06:01:01 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][cdc-connector][postgres] PostgresDialect removes useless code - posted by le...@apache.org on 2024/07/17 09:30:57 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35758][doc][cdc-connector][mysql] Add missed scan.startup.timestamp-millis option for mysql connector - posted by le...@apache.org on 2024/07/17 10:04:03 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][cdc-connector][mysql] Code optimization for constants - posted by le...@apache.org on 2024/07/17 10:07:24 UTC, 0 replies.
- (flink) branch master updated: [FLINK-28984][checkpoint] Fix concurrency issue between close and flushToFile in FsCheckpointStateOutputStream (#25095) - posted by za...@apache.org on 2024/07/17 11:28:17 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][cdc-connector][sqlserver] Fix some typos (#3421) - posted by go...@apache.org on 2024/07/17 11:45:20 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35837][test] InitOutputPathTest.testErrorOccursUnSynchronized failed in JDK21 (#25097) - posted by go...@apache.org on 2024/07/17 16:18:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35227][rest] Remove execution-mode in ExecutionConfigInfo (#25080) - posted by fa...@apache.org on 2024/07/18 02:04:41 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-34543][docs] Add document of full partition processing on non-keyed datastream - posted by gu...@apache.org on 2024/07/18 03:42:00 UTC, 0 replies.
- (flink) branch test-doc created (now e08af201a22) - posted by gu...@apache.org on 2024/07/18 04:05:52 UTC, 0 replies.
- (flink) 01/01: try to downgrade maven-javadoc-plugin to `2.10.4` - posted by gu...@apache.org on 2024/07/18 04:05:53 UTC, 0 replies.
- (flink) branch test-doc updated: fixup! try to downgrade maven-javadoc-plugin to `2.10.4` - posted by gu...@apache.org on 2024/07/18 05:35:21 UTC, 0 replies.
- (flink-cdc) branch master updated: [docs][minor] Specify the lib directory of Flink CDC in quick start docs - posted by le...@apache.org on 2024/07/18 09:59:05 UTC, 0 replies.
- (flink) branch f35860 created (now efeea34eac8) - posted by pn...@apache.org on 2024/07/18 11:26:36 UTC, 0 replies.
- (flink) 01/01: [FLINK-35860][test] Fix S5CmdOnMinioITCase failed due to IllegalAccessError in JDK17/21 - posted by pn...@apache.org on 2024/07/18 11:26:37 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35832][Table SQL / Planner] Fix IFNULL function returns incorrect result - posted by ro...@apache.org on 2024/07/18 11:35:49 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-35808] Let `ConsumerConfig.(KEY|VALUE)_DESERIALIZER_CLASS_CONFIG` be overridable by user in `KafkaSourceBuilder` (#108) - posted by fp...@apache.org on 2024/07/18 13:45:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35860][test] Fix S5CmdOnMinioITCase failed due to IllegalAccessError in JDK17/21 - posted by pn...@apache.org on 2024/07/18 16:18:02 UTC, 0 replies.
- (flink) branch f35860 deleted (was efeea34eac8) - posted by pn...@apache.org on 2024/07/18 16:18:07 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34543][docs] Add document of full partition processing on non-keyed datastream - posted by gu...@apache.org on 2024/07/19 04:16:34 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-35815][autoscaler] Autoscaler standalone load config from yaml file (#853) - posted by fa...@apache.org on 2024/07/19 06:43:40 UTC, 0 replies.
- (flink) branch master updated (9aab300c9f2 -> 999b7a2f2e3) - posted by ro...@apache.org on 2024/07/19 09:32:52 UTC, 0 replies.
- (flink) 01/03: [hotfix][runtime] Remove unnecessary throws clause - posted by ro...@apache.org on 2024/07/19 09:32:53 UTC, 0 replies.
- (flink) 02/03: [FLINK-31261][runtime] Make AdaptiveScheduler aware of local state size - posted by ro...@apache.org on 2024/07/19 09:32:54 UTC, 0 replies.
- (flink) 03/03: fixup: aggregate keyGroupSize in subtask (not across subtasks) - posted by ro...@apache.org on 2024/07/19 09:32:55 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35832][Table SQL / Planner] Fix IFNULL function returns incorrect result (#25106) - posted by ro...@apache.org on 2024/07/19 12:16:11 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35832][Table SQL / Planner] Fix IFNULL function returns incorrect result - posted by ro...@apache.org on 2024/07/19 12:16:47 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34657] extract lineage info for stream API (#25056) - posted by zj...@apache.org on 2024/07/20 14:01:40 UTC, 0 replies.
- (flink-cdc) branch master updated (ec0becd6f -> 26ff6d2a0) - posted by le...@apache.org on 2024/07/22 02:55:45 UTC, 0 replies.
- (flink-cdc) 01/02: [FLINK-35237][cdc-common] Allow Sink to choose HashFunction in PrePartitionOperator - posted by le...@apache.org on 2024/07/22 02:55:46 UTC, 0 replies.
- (flink-cdc) 02/02: [FLINK-35237][cdc-common] Improve the interfaces and reorganize the directory. - posted by le...@apache.org on 2024/07/22 02:55:47 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35871][doc] Add missed "snapshot" mode to mysql connector startup options - posted by le...@apache.org on 2024/07/22 04:25:45 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35872][table] Fix the incorrect partition generation for materialized table period refresh in Full Mode - posted by ro...@apache.org on 2024/07/22 12:09:58 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35872][table] Fix the incorrect partition generation for materialized table period refresh in Full Mode - posted by ro...@apache.org on 2024/07/23 01:26:56 UTC, 0 replies.
- (flink) branch release-1.20 updated: [hotfix] [docs] Fix java doc api - posted by gu...@apache.org on 2024/07/23 01:54:01 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35865][base] Support Byte and Short in ObjectUtils (#3481) - posted by go...@apache.org on 2024/07/23 02:46:23 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][doc][cdc-connector][oracle] Update OracleSchema#getTableSchema doc description - posted by le...@apache.org on 2024/07/23 03:32:47 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [FLINK-35623][Connectors/MongoDB] Bump mongo-driver version from 4.7.2 to 5.1.1 to support MongoDB 7.0 (#36) - posted by ji...@apache.org on 2024/07/23 09:27:42 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-35776] Simplify job status handling - posted by gy...@apache.org on 2024/07/23 13:39:01 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-35292] Set dummy savepoint path during last-state upgrade - posted by gy...@apache.org on 2024/07/23 14:04:01 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35874][cdc-connector][mysql] Check pureBinlogPhaseTables set before call getBinlogPosition method - posted by le...@apache.org on 2024/07/24 03:30:44 UTC, 0 replies.
- (flink-cdc) branch release-3.1 updated: [hotfix][docs] Fix MongoDB Driver version specification - posted by ji...@apache.org on 2024/07/24 03:31:09 UTC, 0 replies.
- (flink-cdc) branch release-3.0 updated: [hotfix][docs] Fix MongoDB Driver version specification - posted by ji...@apache.org on 2024/07/24 03:31:31 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35318][table-planner] Use UTC time zone for TIMESTAMP_LTZ type in RexNodeToExpressionConverter - posted by le...@apache.org on 2024/07/24 08:33:47 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35318][table-planner] Use UTC time zone for TIMESTAMP_LTZ type in RexNodeToExpressionConverter - posted by le...@apache.org on 2024/07/24 08:34:17 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-35857] Fix redeploy failed deployment without latest checkpoint - posted by gy...@apache.org on 2024/07/24 09:58:16 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35740][cdc-connector][mysql] Allow column as chunk key even it's not primary key - posted by le...@apache.org on 2024/07/24 11:22:54 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35835][test] Make file-merging test tolerate the scenario that source does not produce any record (#25116) - posted by za...@apache.org on 2024/07/25 02:31:05 UTC, 0 replies.
- (flink) branch master updated (95c617249c7 -> d4294c59e6f) - posted by za...@apache.org on 2024/07/25 02:31:29 UTC, 0 replies.
- (flink) 01/03: [FLINK-35858][Runtime/State] Add namespace in internal async states - posted by za...@apache.org on 2024/07/25 02:31:30 UTC, 0 replies.
- (flink) 02/03: [FLINK-35858][Runtime/State] Create state with namespaces - posted by za...@apache.org on 2024/07/25 02:31:31 UTC, 0 replies.
- (flink) 03/03: [FLINK-35858][State/ForSt] Support state namespace - posted by za...@apache.org on 2024/07/25 02:31:32 UTC, 0 replies.
- (flink) branch release-1.20 updated (681760de8c6 -> f14546cba1a) - posted by za...@apache.org on 2024/07/25 02:32:04 UTC, 0 replies.
- (flink) 01/02: [FLINK-35843][test] Check only JM acknowledged files in file-merging IT cases (#25090) - posted by za...@apache.org on 2024/07/25 02:32:05 UTC, 0 replies.
- (flink) 02/02: [FLINK-35835][test] Make file-merging test tolerate the scenario that source does not produce any record - posted by za...@apache.org on 2024/07/25 02:32:06 UTC, 0 replies.
- (flink) annotated tag release-1.20.0-rc2 updated (b1fe7b40994 -> 0d8b1f55879) - posted by gu...@apache.org on 2024/07/25 07:15:35 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35095][test] Fix unstable tests in `ExecutionEnvironmentImplTest` - posted by gu...@apache.org on 2024/07/25 08:00:24 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][test] Add Flink CDC 3.1.1 version to migration test version list - posted by le...@apache.org on 2024/07/25 08:27:11 UTC, 0 replies.
- svn commit: r70542 - in /dev/flink/flink-1.20.0-rc2: ./ python/ - posted by fa...@apache.org on 2024/07/25 10:31:53 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35868][cdc-connector][mongodb] Bump dependency version to support MongoDB 7.0 - posted by le...@apache.org on 2024/07/25 11:23:56 UTC, 0 replies.
- (flink) branch master updated (d4294c59e6f -> ea752ff1129) - posted by fa...@apache.org on 2024/07/26 01:48:52 UTC, 0 replies.
- (flink) 01/02: [hotfix][runtime] Migrate the Time to Duration for DefaultScheduler in the minimum impact range - posted by fa...@apache.org on 2024/07/26 01:48:53 UTC, 0 replies.
- (flink) 02/02: [FLINK-33874][runtime] Support resource request wait mechanism at DefaultDeclarativeSlotPool side for Default Scheduler - posted by fa...@apache.org on 2024/07/26 01:48:54 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated (099cda71 -> 39ba942c) - posted by fa...@apache.org on 2024/07/29 01:49:24 UTC, 0 replies.
- (flink-connector-jdbc) 01/14: [FLINK-35370] Add temp module to test backward compatibility - posted by fa...@apache.org on 2024/07/29 01:49:25 UTC, 0 replies.
- (flink-connector-jdbc) 02/14: [FLINK-35364] Create core module and move code - posted by fa...@apache.org on 2024/07/29 01:49:26 UTC, 0 replies.
- (flink-connector-jdbc) 03/14: [FLINK-35365] Reorganize dialect code - posted by fa...@apache.org on 2024/07/29 01:49:27 UTC, 0 replies.
- (flink-connector-jdbc) 04/14: [FLINK-35365] Reorganize catalog code - posted by fa...@apache.org on 2024/07/29 01:49:28 UTC, 0 replies.
- (flink-connector-jdbc) 05/14: [FLINK-35366] Create all database modules - posted by fa...@apache.org on 2024/07/29 01:49:29 UTC, 0 replies.
- (flink-connector-jdbc) 06/14: [FLINK-35366] Reorganize database modules packages - posted by fa...@apache.org on 2024/07/29 01:49:30 UTC, 0 replies.
- (flink-connector-jdbc) 07/14: [FLINK-35366] Bump containers and fix forkCountItCase - posted by fa...@apache.org on 2024/07/29 01:49:31 UTC, 0 replies.
- (flink-connector-jdbc) 08/14: [FLINK-35366] Fix version from release - posted by fa...@apache.org on 2024/07/29 01:49:32 UTC, 0 replies.
- (flink-connector-jdbc) 09/14: [FLINK-35367] Reorganize sinks - posted by fa...@apache.org on 2024/07/29 01:49:33 UTC, 0 replies.
- (flink-connector-jdbc) 10/14: [FLINK-35494] Reorganize sources - posted by fa...@apache.org on 2024/07/29 01:49:34 UTC, 0 replies.
- (flink-connector-jdbc) 11/14: [FLINK-35788] Deprecate JdbcXaSinkFunction - posted by fa...@apache.org on 2024/07/29 01:49:35 UTC, 0 replies.
- (flink-connector-jdbc) 12/14: [FLINK-35368] Reorganize table code - posted by fa...@apache.org on 2024/07/29 01:49:36 UTC, 0 replies.
- (flink-connector-jdbc) 13/14: [FLINK-35363] Fix deprecated documentation - posted by fa...@apache.org on 2024/07/29 01:49:37 UTC, 0 replies.
- (flink-connector-jdbc) 14/14: [FLINK-35363] Modify tests to clean up unused docker images - posted by fa...@apache.org on 2024/07/29 01:49:38 UTC, 0 replies.
- (flink-connector-gcp-pubsub) branch main updated: [FLINK-35779][Connectors/Google PubSub] Update documentation for PubSubSinkV2 (#29) - posted by sn...@apache.org on 2024/07/29 06:55:38 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline connector to 0.8.2 - posted by le...@apache.org on 2024/07/29 08:44:46 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35736][test] Add migration test scripts & CI workflows - posted by le...@apache.org on 2024/07/30 01:41:28 UTC, 0 replies.
- (flink) branch master updated (ea752ff1129 -> 76049d09e40) - posted by fa...@apache.org on 2024/07/30 03:17:45 UTC, 0 replies.
- (flink) 01/03: [Hotfix][runtime] Add '@Internal' annotation for TaskManagerLoadBalanceMode#loadFromConfiguration - posted by fa...@apache.org on 2024/07/30 03:17:46 UTC, 0 replies.
- (flink) 02/03: [Hotfix][runtime] Enrich the toString method of SlotSharingGroup class - posted by fa...@apache.org on 2024/07/30 03:17:47 UTC, 0 replies.
- (flink) 03/03: [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler - posted by fa...@apache.org on 2024/07/30 03:17:48 UTC, 0 replies.
- (flink-cdc) branch master updated: [docs][minor] Add transform piece for pipeline example - posted by le...@apache.org on 2024/07/30 06:22:32 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-35896][autoscaler] Handle exception events in RescaleApiScalingRealizer (#856) - posted by fa...@apache.org on 2024/07/30 08:33:10 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35072][doris] Support applying AlterColumnTypeEvent to Doris pipeline sink - posted by le...@apache.org on 2024/07/30 09:46:53 UTC, 0 replies.
- [I] addSplits only Snapshot，not foud binlog，so, incrementing data don't sync to sink,need help [flink-cdc] - posted by "nph0901 (via GitHub)" <gi...@apache.org> on 2024/07/30 11:21:49 UTC, 3 replies.
- (flink) branch master updated: [hotfix][scheduler] Migrate the Time to Duration for SlotPool in the minimum scope - posted by fa...@apache.org on 2024/07/31 07:59:02 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34877][cdc] Support type cast conversion in pipeline transform - posted by le...@apache.org on 2024/07/31 15:32:44 UTC, 0 replies.
- (flink-connector-elasticsearch) branch dependabot/maven/flink-connector-elasticsearch-base/org.elasticsearch-elasticsearch-7.17.23 created (now 9518d37) - posted by gi...@apache.org on 2024/07/31 20:57:44 UTC, 0 replies.