You are viewing a plain text version of this content. The canonical link for it is here.
- (flink) branch master updated: [FLINK-36191][tests] FsMergingCheckpointStorageLocationTest generates test data not in tmp folder - posted by sn...@apache.org on 2024/09/02 05:32:36 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36179] bump log4j version - posted by gy...@apache.org on 2024/09/02 12:32:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36011] [runtime] Generalize RescaleManager to become StateTransitionManager - posted by ma...@apache.org on 2024/09/02 14:43:22 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated: [FLINK-36051] Re-prepare invalid statement even if connection is valid (#138) - posted by ji...@apache.org on 2024/09/03 01:22:56 UTC, 0 replies.
- (flink) branch master updated (c869326d089 -> 2c16d884abd) - posted by za...@apache.org on 2024/09/03 09:22:08 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36125][checkpoint] Fix concurrent duplicated discard of logical file in cp file-merging (#25279) - posted by za...@apache.org on 2024/09/03 09:22:16 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35389][State/ForSt] Async list state (#25126) - posted by za...@apache.org on 2024/09/03 09:33:55 UTC, 0 replies.
- (flink) branch master updated (c58a6ebbae5 -> 13cd826b51d) - posted by gu...@apache.org on 2024/09/03 12:20:52 UTC, 0 replies.
- (flink) 01/03: [FLINK-36198][network] Remove code of legacy hybrid shuffle mode. - posted by gu...@apache.org on 2024/09/03 12:20:53 UTC, 0 replies.
- (flink) 02/03: [FLINK-36198][network] Remove deprecated config options related to legacy hybrid shuffle - posted by gu...@apache.org on 2024/09/03 12:20:54 UTC, 0 replies.
- (flink) 03/03: [FLINK-36198][network] Change document related to hybrid shuffle - posted by gu...@apache.org on 2024/09/03 12:20:55 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-35660][dynamodb] Adding parent-child shard ordering for DDB Streams source and add MillisBehindLatest metric - posted by ho...@apache.org on 2024/09/03 16:10:01 UTC, 0 replies.
- (flink) branch master updated (13cd826b51d -> 3f39a7b0822) - posted by za...@apache.org on 2024/09/04 02:17:05 UTC, 0 replies.
- (flink) branch master updated (3f39a7b0822 -> 57bc16948be) - posted by dm...@apache.org on 2024/09/04 06:46:49 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36201][Coordination] Don't use StateLocalitySlotAssigner when local recovery is disabled - posted by fa...@apache.org on 2024/09/04 08:32:35 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36215][dynamodb][BugFix] Removing dependency on ordering of splits - posted by ho...@apache.org on 2024/09/04 10:42:28 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36206][Connectors/AWS] Adding support for custom override configuration - posted by ho...@apache.org on 2024/09/04 12:43:46 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36191][tests] FsMergingCheckpointStorageLocationTest generates test data not in tmp folder - posted by sn...@apache.org on 2024/09/04 21:17:25 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36191][tests] FsMergingCheckpointStorageLocationTest generates test data not in tmp folder - posted by sn...@apache.org on 2024/09/04 21:57:10 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level. (#25257) - posted by za...@apache.org on 2024/09/05 03:22:44 UTC, 0 replies.
- svn commit: r71341 - /dev/flink/flink-cdc-3.2.0-rc1/ /release/flink/flink-cdc-3.2.0/ - posted by re...@apache.org on 2024/09/05 06:58:34 UTC, 0 replies.
- svn commit: r71342 - /dev/flink/flink-cdc-3.2.0-rc0/ - posted by re...@apache.org on 2024/09/05 06:59:51 UTC, 0 replies.
- svn commit: r71343 - /release/flink/flink-cdc-3.1.0/ - posted by re...@apache.org on 2024/09/05 07:01:37 UTC, 0 replies.
- (flink-cdc) annotated tag release-3.2.0 updated (6b9dda39c -> bef72641e) - posted by re...@apache.org on 2024/09/05 07:03:16 UTC, 0 replies.
- (flink-web) branch asf-site updated: Add release announcement for Flink CDC 3.2.0 (#753) - posted by re...@apache.org on 2024/09/05 07:25:51 UTC, 0 replies.
- (flink-web) branch asf-site updated: Rebuild website - posted by re...@apache.org on 2024/09/05 07:27:13 UTC, 1 replies.
- (flink-cdc) branch master updated: [FLINK-36226][cdc][docs] Build 3.2 docs and mark it as stable (#3597) - posted by re...@apache.org on 2024/09/05 09:59:24 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36187][Connectors/Kinesis] Implement UniformShardAssigner using Kinesis shard hashes in the KinesisStreamsSource - posted by ho...@apache.org on 2024/09/05 12:36:11 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36229][Connectors/AWS] Port SingleThreadMultiplexSourceReaderBase to new undeprecated interfaces - posted by ho...@apache.org on 2024/09/05 14:48:11 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36018][autoscaler] Support lazy scale down to avoid frequent rescaling (#875) - posted by fa...@apache.org on 2024/09/06 08:55:23 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-22748] Allow dynamic target topic selection in SQL Kafka sinks (#109) - posted by ar...@apache.org on 2024/09/06 14:38:24 UTC, 0 replies.
- (flink) branch FLINK-35580 created (now 4f058c8f221) - posted by sr...@apache.org on 2024/09/06 15:21:34 UTC, 0 replies.
- (flink) 01/08: [FLINK-35580] Prevent potential JVM crashes from async compaction when RocksDB is already closed. - posted by sr...@apache.org on 2024/09/06 15:21:35 UTC, 1 replies.
- (flink) 02/08: [FLINK-35580] Register async compact task with the backend's lifecycle instead of the restore lifecycle. - posted by sr...@apache.org on 2024/09/06 15:21:36 UTC, 1 replies.
- (flink) 03/08: [FLINK-35580] Introduce artificial map key for RegisteredStateMetaInfoBase for safe deduplication in RocksDBIncrementalRestoreOperation. - posted by sr...@apache.org on 2024/09/06 15:21:37 UTC, 1 replies.
- (flink) 04/08: [FLINK-35580] Handle async compaction exceptions in RocksDB restore. - posted by sr...@apache.org on 2024/09/06 15:21:38 UTC, 1 replies.
- (flink) 05/08: [FLINK-35580] Improve logging and problem analysis in RockDBHandle. - posted by sr...@apache.org on 2024/09/06 15:21:39 UTC, 1 replies.
- (flink) 06/08: [FLINK-35580] Fix synchronization issue when closing RocksDBWriteBatchWrapper - posted by sr...@apache.org on 2024/09/06 15:21:40 UTC, 1 replies.
- (flink) 07/08: [FLINK-35580] Ensure RocksDB working directory is created before opening DB. - posted by sr...@apache.org on 2024/09/06 15:21:41 UTC, 1 replies.
- (flink) 08/08: [FLINK-35580] Improve logging for IngestDB to make key range checks more observable. - posted by sr...@apache.org on 2024/09/06 15:21:42 UTC, 1 replies.
- (flink) branch master updated: [FLINK-35049][state] Implement Map Async State API for ForStStateBackend (#24812) - posted by le...@apache.org on 2024/09/06 15:37:37 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36217][tests] Remove powermock usage (#25287) - posted by go...@apache.org on 2024/09/09 07:03:49 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36239][Connectors/DynamoDB][BugFix] Making the shard retention period to 48h instead of 24h - posted by ho...@apache.org on 2024/09/09 15:10:03 UTC, 0 replies.
- (flink) branch flink-36241 created (now 4450ccaf7b6) - posted by dw...@apache.org on 2024/09/09 15:47:01 UTC, 0 replies.
- (flink) 01/01: [FLINK-36241] Table API .plus should support string concatenation - posted by dw...@apache.org on 2024/09/09 15:47:02 UTC, 0 replies.
- (flink) branch flink-36241 deleted (was 4450ccaf7b6) - posted by dw...@apache.org on 2024/09/09 15:47:59 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34510][Runtime/State]Rename RestoreMode to RecoveryClaimMode (#25192) - posted by le...@apache.org on 2024/09/10 02:32:14 UTC, 0 replies.
- (flink) branch config-2.0 created (now ef57966dd23) - posted by sx...@apache.org on 2024/09/10 04:23:51 UTC, 0 replies.
- (flink) 01/07: [FLINK-34079][config] Refactor callers that use get/setBoolean - posted by sx...@apache.org on 2024/09/10 04:23:52 UTC, 0 replies.
- (flink) 02/07: [FLINK-34079][config] Refactor callers that use get/setClass - posted by sx...@apache.org on 2024/09/10 04:23:53 UTC, 0 replies.
- (flink) 03/07: [FLINK-34079][config] Refactor callers that use get/setDouble - posted by sx...@apache.org on 2024/09/10 04:23:54 UTC, 0 replies.
- (flink) 04/07: [FLINK-34079][config] Refactor callers that use get/setFloat - posted by sx...@apache.org on 2024/09/10 04:23:55 UTC, 0 replies.
- (flink) 05/07: [FLINK-34079][config] Refactor callers that use get/setInt - posted by sx...@apache.org on 2024/09/10 04:23:56 UTC, 0 replies.
- (flink) 06/07: [FLINK-34079][config] Refactor callers that use get/setLong - posted by sx...@apache.org on 2024/09/10 04:23:57 UTC, 0 replies.
- (flink) 07/07: [FLINK-34079][config] Refactor callers that use deprecated get/setString - posted by sx...@apache.org on 2024/09/10 04:23:58 UTC, 0 replies.
- (flink) branch config-2.0 updated (ef57966dd23 -> 432ff6b27e7) - posted by sx...@apache.org on 2024/09/10 04:38:03 UTC, 0 replies.
- (flink) branch string-key created (now 1211e9d57e7) - posted by sx...@apache.org on 2024/09/10 07:04:38 UTC, 0 replies.
- (flink) 01/02: [FLINK-34085][config] Remove deprecated string configuration keys - posted by sx...@apache.org on 2024/09/10 07:04:39 UTC, 0 replies.
- (flink) 02/02: [FLINK-34085][config] Remove deprecated string configuration keys - posted by sx...@apache.org on 2024/09/10 07:04:40 UTC, 0 replies.
- (flink) branch master updated (7adeecd3445 -> 95ef07b789b) - posted by sr...@apache.org on 2024/09/10 07:09:21 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36012] [runtime] Integrate StateTransitionManager into WaitingForResources state - posted by ma...@apache.org on 2024/09/10 07:53:52 UTC, 0 replies.
- (flink) branch master updated (1f303a218f4 -> 62e986da8e3) - posted by da...@apache.org on 2024/09/10 09:30:10 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35972][state/runtime] Async process a runnable with a key provided (#25289) - posted by za...@apache.org on 2024/09/10 09:39:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-33677][core] Remove flink-conf.yaml from flink dist. - posted by zh...@apache.org on 2024/09/11 02:01:34 UTC, 0 replies.
- (flink-docker) branch dev-master updated: [FLINK-33677][core] Remove flink-conf.yaml from flink dist. - posted by zh...@apache.org on 2024/09/11 02:35:42 UTC, 0 replies.
- (flink) branch master updated (c0176fd6794 -> e3a48c2a58a) - posted by sx...@apache.org on 2024/09/11 02:36:36 UTC, 0 replies.
- (flink) branch string-key deleted (was 1211e9d57e7) - posted by sx...@apache.org on 2024/09/11 02:36:46 UTC, 0 replies.
- (flink) branch config-2.0 updated (432ff6b27e7 -> 6de8869e519) - posted by sx...@apache.org on 2024/09/11 03:07:28 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36246] Move async state related operators flink-runtime (#25306) - posted by za...@apache.org on 2024/09/11 05:46:43 UTC, 0 replies.
- (flink) branch master updated (1d5b214eb68 -> db682b9869d) - posted by ma...@apache.org on 2024/09/11 06:56:34 UTC, 0 replies.
- (flink) branch master updated (db682b9869d -> c749a1b61c9) - posted by li...@apache.org on 2024/09/11 08:44:39 UTC, 0 replies.
- (flink) 01/04: [FLINK-36123][table-common] Add ArgumentTypeStrategy for percentage (array) value - posted by li...@apache.org on 2024/09/11 08:44:40 UTC, 0 replies.
- (flink) 02/04: [FLINK-36123][table-planner] Refactor error test for built-in agg functions - posted by li...@apache.org on 2024/09/11 08:44:41 UTC, 0 replies.
- (flink) 03/04: [FLINK-36123][table-planner] Support creating AggregateInfo through BuiltInFunctionDefinition directly to avoid an extra SqlAggFunction conversion - posted by li...@apache.org on 2024/09/11 08:44:42 UTC, 0 replies.
- (flink) 04/04: [FLINK-36123][table] Add the built-in function PERCENTILE - posted by li...@apache.org on 2024/09/11 08:44:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35827][table-planner] Fix equivalence comparison between row type fields and constants - posted by li...@apache.org on 2024/09/11 08:58:28 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36243][state/forst] Store namespace in state request and contextKey (#25300) - posted by le...@apache.org on 2024/09/11 11:46:04 UTC, 0 replies.
- Re: [I] Flink-CDC 2.3.0 consumes data based on SPECIFIC_OFFSETS. If the table structure is changed after the starting offset, it will not be able to consume the data correctly. [flink-cdc] - posted by "maikouliujian (via GitHub)" <gi...@apache.org> on 2024/09/11 12:22:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36262][table] Avoid unnecessary String concatenations in the RexFieldAccess constructor - posted by sn...@apache.org on 2024/09/11 18:18:27 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36142][table] Remove TestTableSourceWithTime and its subclasses to prepare removing TableEnvironmentInternal#registerTableSourceInternal - posted by li...@apache.org on 2024/09/12 01:09:49 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36230][pyflink-table] Fix the incorrect calling of REGEXP_EXTRACT Python Table API - posted by li...@apache.org on 2024/09/12 01:14:12 UTC, 0 replies.
- (flink) branch master updated (8c6f13cead9 -> 356e2af4b27) - posted by zh...@apache.org on 2024/09/12 01:47:28 UTC, 0 replies.
- (flink) 01/04: [FLINK-36185][state-processor] Remove deprecated internal class BoundedOneInputStreamTaskRunner. - posted by zh...@apache.org on 2024/09/12 01:47:29 UTC, 0 replies.
- (flink) 02/04: [FLINK-36185][e2e] Rewrite end to end cases with new Kafka source. - posted by zh...@apache.org on 2024/09/12 01:47:30 UTC, 0 replies.
- (flink) 03/04: [FLINK-36185][core] Remove RuntimeContext#getExecutionConfig - posted by zh...@apache.org on 2024/09/12 01:47:31 UTC, 0 replies.
- (flink) 04/04: [FLINK-36185][e2e] Disable PyFlink end-to-end case that uses Kafka legacy source. - posted by zh...@apache.org on 2024/09/12 01:47:32 UTC, 0 replies.
- (flink) branch master updated (356e2af4b27 -> 4d131705b19) - posted by gu...@apache.org on 2024/09/12 02:00:44 UTC, 0 replies.
- (flink) 01/02: [hotfix][API] DataStream should also support connectAndProcess with ProcessConfigurableStream - posted by gu...@apache.org on 2024/09/12 02:00:45 UTC, 0 replies.
- (flink) 02/02: [FLINK-35795][API] Introduce the framework of ProcessFunction Attribute - posted by gu...@apache.org on 2024/09/12 02:00:46 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34168][config] Refactor callers that use deprecated get/setXXX (#25301) - posted by sx...@apache.org on 2024/09/12 04:22:04 UTC, 0 replies.
- (flink) branch config-2.0 deleted (was 6de8869e519) - posted by sx...@apache.org on 2024/09/12 04:22:13 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode (#117) - posted by ar...@apache.org on 2024/09/12 06:10:52 UTC, 0 replies.
- (flink) branch master updated (740a5674fd9 -> 77da0414929) - posted by ma...@apache.org on 2024/09/12 08:28:56 UTC, 0 replies.
- (flink) 01/02: [FLINK-36013] [runtime] Introduce the transition from Restarting to CreatingExecutionGraph state - posted by ma...@apache.org on 2024/09/12 08:28:57 UTC, 0 replies.
- (flink) 02/02: [hotfix] Added ExecutionGraph validation while transiting to WaitingForResources state in RestartingTest - posted by ma...@apache.org on 2024/09/12 08:28:58 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36138] Add a message to KinesisStreamsSource null checks (#161) - posted by ho...@apache.org on 2024/09/12 08:42:34 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36168][runtime] Replaces goToFinished with the cancel method (#25305) - posted by ma...@apache.org on 2024/09/12 15:44:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36207][build] Disables deprecated API from japicmp - posted by ma...@apache.org on 2024/09/12 17:17:48 UTC, 0 replies.
- (flink) branch master updated: [FLINK-32688][runtime] Removes deprecated JobExceptionsInfo. (#25248) - posted by ma...@apache.org on 2024/09/12 17:24:10 UTC, 0 replies.
- (flink) branch master updated (8dc40ab70c9 -> 6a5fa9962a9) - posted by ma...@apache.org on 2024/09/12 21:09:33 UTC, 0 replies.
- (flink) 01/02: [hotfix] Fixes JobExceptionsInfoWithHistory equals method - posted by ma...@apache.org on 2024/09/12 21:09:34 UTC, 0 replies.
- (flink) 02/02: [FLINK-36147][runtime] Removes deprecated location field (was deprecated in 1.19) - posted by ma...@apache.org on 2024/09/12 21:09:35 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35027][Runtime/Checkpoint] Drain async state request before snapshot barrier (#25317) - posted by za...@apache.org on 2024/09/13 02:33:05 UTC, 0 replies.
- [I] The flink-cdc-base module supports source metric statistics [flink-cdc] - posted by "liuxiao2shf (via GitHub)" <gi...@apache.org> on 2024/09/13 03:17:14 UTC, 1 replies.
- (flink) branch master updated (e94d433dd0b -> 644c027390a) - posted by gu...@apache.org on 2024/09/13 03:38:33 UTC, 0 replies.
- (flink) 01/02: [FLINK-5336][core] Remove IOReadableWritable from Path - posted by gu...@apache.org on 2024/09/13 03:38:34 UTC, 0 replies.
- (flink) 02/02: fixup! [FLINK-5336][core] Remove IOReadableWritable from Path - posted by gu...@apache.org on 2024/09/13 03:38:35 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36225][core] Remove deprecated method marked in FLIP-382 - posted by gu...@apache.org on 2024/09/13 03:41:04 UTC, 0 replies.
- (flink) branch master updated (8d4e98503fd -> 36103ff3a97) - posted by ro...@apache.org on 2024/09/13 09:43:37 UTC, 0 replies.
- (flink) 01/02: [FLINK-36242][test] Fix inconsistent logic between listTable and getTable in TestFileSystemCatalog - posted by ro...@apache.org on 2024/09/13 09:43:38 UTC, 0 replies.
- (flink) 02/02: [FLINK-36242][table] Drop all materialized tables manually instead of automatically dropping them in the after method. - posted by ro...@apache.org on 2024/09/13 09:43:39 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36270][Connectors/DynamoDB] Assign only children splits of a split when it is marked as finished - posted by ho...@apache.org on 2024/09/13 11:07:00 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36001][state] Store operator name and UID in state metadata - posted by ga...@apache.org on 2024/09/13 13:13:50 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated: [FLINK-33138][Connectors/Prometheus] DataStream sink implementation. AMP request signer. Example application - posted by ho...@apache.org on 2024/09/13 14:04:11 UTC, 0 replies.
- (flink-connector-prometheus) branch dependabot/maven/flink-connector-prometheus/com.github.tomakehurst-wiremock-jre8-2.35.1 created (now 86af5f0) - posted by gi...@apache.org on 2024/09/13 14:04:53 UTC, 0 replies.
- (flink-connector-prometheus) branch dependabot/maven/flink-connector-prometheus/org.xerial.snappy-snappy-java-1.1.10.4 created (now 047bd4c) - posted by gi...@apache.org on 2024/09/13 14:04:56 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated: Bump com.github.tomakehurst:wiremock-jre8 in /flink-connector-prometheus - posted by ho...@apache.org on 2024/09/13 14:08:06 UTC, 0 replies.
- (flink-connector-prometheus) branch dependabot/maven/flink-connector-prometheus/com.github.tomakehurst-wiremock-jre8-2.35.1 deleted (was 86af5f0) - posted by gi...@apache.org on 2024/09/13 14:08:13 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated: Bump org.xerial.snappy:snappy-java in /flink-connector-prometheus - posted by ho...@apache.org on 2024/09/13 14:08:25 UTC, 0 replies.
- (flink-connector-prometheus) branch dependabot/maven/flink-connector-prometheus/org.xerial.snappy-snappy-java-1.1.10.4 deleted (was 047bd4c) - posted by gi...@apache.org on 2024/09/13 14:08:32 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35927][state/forst] Make ForStFlinkFileSystem write misc file in local filesystem (#25310) - posted by le...@apache.org on 2024/09/13 14:18:57 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36001][state] Hotfix for OperatorIDPairTest missing header - posted by ga...@apache.org on 2024/09/13 21:24:05 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35667][state/forst] Implement Reducing Async State API for ForStStateBackend (#25308) - posted by le...@apache.org on 2024/09/14 02:10:27 UTC, 0 replies.
- (flink-connector-pulsar) branch hotfix/refactor-callers-conf created (now d9bb2cf) - posted by fa...@apache.org on 2024/09/14 08:11:47 UTC, 0 replies.
- (flink-connector-pulsar) 01/01: [hotfix] Refactor callers that use deprecated get/setXXX of Configuration - posted by fa...@apache.org on 2024/09/14 08:11:48 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36258][config] set `HADOOP_CONF_DIR` to config hadoop in YarnFileStageTestS3ITCase - posted by sx...@apache.org on 2024/09/14 09:00:29 UTC, 0 replies.
- (flink-connector-pulsar) branch main updated: [hotfix] Refactor callers that use deprecated get/setXXX of Configuration - posted by fa...@apache.org on 2024/09/15 10:09:35 UTC, 0 replies.
- (flink) branch master updated (ed7f57c9ccb -> 0d3be65c06b) - posted by ma...@apache.org on 2024/09/16 15:49:47 UTC, 0 replies.
- (flink) 01/03: [FLINK-36279][runtime] Making desired resources being calculated based on all available slots for the job - posted by ma...@apache.org on 2024/09/16 15:49:48 UTC, 0 replies.
- (flink) 02/03: [hotfix][test] Adds some additional logging to RescaleOnCheckpointITCase - posted by ma...@apache.org on 2024/09/16 15:49:49 UTC, 0 replies.
- (flink) 03/03: [hotfix][test] Adds back timestamp to log output - posted by ma...@apache.org on 2024/09/16 15:49:50 UTC, 0 replies.
- (flink) branch master updated (0d3be65c06b -> 15361471676) - posted by ma...@apache.org on 2024/09/16 19:41:22 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36281][runtime] resourceSpec replace SlotSharingGroupUtils.extractResourceSpec(slotSharingGroup) (#25333) - posted by fa...@apache.org on 2024/09/17 04:21:17 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-34470][Connectors/Kafka] Fix indefinite blocking by adjusting stopping condition on split reader (#100) - posted by ar...@apache.org on 2024/09/17 13:34:15 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36208][core] Use ThreadLocalRandom in AbstractID - posted by fc...@apache.org on 2024/09/17 16:01:28 UTC, 0 replies.
- (flink) branch master updated (96b84258b6e -> 6d60f41a9b1) - posted by ar...@apache.org on 2024/09/17 21:20:25 UTC, 0 replies.
- (flink) 01/08: [FLINK-25920] Straighten EOI handling in CommittableCollector - posted by ar...@apache.org on 2024/09/17 21:20:26 UTC, 0 replies.
- (flink) 02/08: [FLINK-25920] Turn CommittableManager#merge functional - posted by ar...@apache.org on 2024/09/17 21:20:27 UTC, 0 replies.
- (flink) 03/08: [FLINK-25920] Improve sink test assertions - posted by ar...@apache.org on 2024/09/17 21:20:28 UTC, 0 replies.
- (flink) 04/08: [FLINK-25920] Only process complete batches of committables - posted by ar...@apache.org on 2024/09/17 21:20:29 UTC, 0 replies.
- (flink) 05/08: [FLINK-25920] Refactor & Revise SinkWriterOperatorTestBase - posted by ar...@apache.org on 2024/09/17 21:20:30 UTC, 0 replies.
- (flink) 06/08: [FLINK-25920] Handle duplicate EOI in Sink - posted by ar...@apache.org on 2024/09/17 21:20:31 UTC, 0 replies.
- (flink) 07/08: [FLINK-25920] Improve logging in committable handling of the sink - posted by ar...@apache.org on 2024/09/17 21:20:32 UTC, 0 replies.
- (flink) 08/08: [FLINK-25920] Fix AbstractStreamingWriter sending after EOI - posted by ar...@apache.org on 2024/09/17 21:20:33 UTC, 0 replies.
- (flink) branch master updated (6d60f41a9b1 -> ffde2d34c02) - posted by sx...@apache.org on 2024/09/18 01:09:41 UTC, 0 replies.
- (flink) 01/04: [FLINK-33750][config] Remove deprecated option in flink-core - posted by sx...@apache.org on 2024/09/18 01:09:42 UTC, 0 replies.
- (flink) 02/04: [FLINK-33750][config] Remove deprecated option in flink-metrics-prometheus - posted by sx...@apache.org on 2024/09/18 01:09:43 UTC, 0 replies.
- (flink) 03/04: [FLINK-33750][config] Remove deprecated StreamPipelineOptions - posted by sx...@apache.org on 2024/09/18 01:09:44 UTC, 0 replies.
- (flink) 04/04: [FLINK-33750][config] Update config docs - posted by sx...@apache.org on 2024/09/18 01:09:45 UTC, 0 replies.
- (flink) branch master updated (ffde2d34c02 -> 4e825107c34) - posted by zh...@apache.org on 2024/09/18 02:39:49 UTC, 0 replies.
- (flink) 01/02: [FLINK-36249][streaming-java] Align DataSet API with DataStream API to support job configuration passing. - posted by zh...@apache.org on 2024/09/18 02:39:50 UTC, 0 replies.
- (flink) 02/02: [FLINK-36249][streaming-java] Remove RestartStrategy-related configuration getters/setters that return/set complex Java objects. - posted by zh...@apache.org on 2024/09/18 02:39:51 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36283][table-planner] Fix udaf incorrectly accessing the built-in function PERCENTILE's implementation with the same name - posted by li...@apache.org on 2024/09/18 03:11:43 UTC, 0 replies.
- (flink-benchmarks) branch master updated: [hotfix] Use `Duration` instead of `Time` (#95) - posted by za...@apache.org on 2024/09/18 07:52:54 UTC, 0 replies.
- (flink) branch master updated (cfd532d5520 -> 488a4ce4eae) - posted by mb...@apache.org on 2024/09/18 14:00:56 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff - posted by ho...@apache.org on 2024/09/18 14:22:01 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36016] [runtime] Synchronize initialization time and clock usage in DefaultStateTransitionManager - posted by ma...@apache.org on 2024/09/18 16:21:54 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35503] Add support for running Oracle connector unit test on ARM architecture (#3600) - posted by go...@apache.org on 2024/09/19 02:22:01 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36250][streaming-java] Remove CheckpointStorage-related configuration getters/setters that return/set complex Java objects. - posted by zh...@apache.org on 2024/09/19 03:54:03 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-36209] Remove redundant operations in the initialization of KafkaSourceEnumState (#116) - posted by ar...@apache.org on 2024/09/19 06:24:24 UTC, 0 replies.
- (flink) branch master updated (df412add389 -> ffd05220ffe) - posted by za...@apache.org on 2024/09/19 06:37:10 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36015] [runtime] Align rescale parameters - posted by ma...@apache.org on 2024/09/19 06:50:23 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35412][State/Runtime] Batch execution of async state request callback (#24832) - posted by za...@apache.org on 2024/09/19 10:51:29 UTC, 0 replies.
- (flink) branch master updated (9a831ebfec6 -> 54ebc8695e2) - posted by za...@apache.org on 2024/09/19 11:02:14 UTC, 0 replies.
- (flink) 01/02: [FLINK-36117] Setup internal interface hierarchy for state v2 - posted by za...@apache.org on 2024/09/19 11:02:15 UTC, 0 replies.
- (flink) 02/02: [FLINK-36117] Internal adaptor from State v1 interfaces to v2 - posted by za...@apache.org on 2024/09/19 11:02:16 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36112] Add Support for CreateFlag.NO_LOCAL_WRITE in FLINK on YARN's File Creation to Manage Disk Space and Network Load in Labeled YARN Nodes - posted by xt...@apache.org on 2024/09/19 11:32:36 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36328][Connectors/DynamoDB] Making the child split not found as a debug log instead of warn - posted by ho...@apache.org on 2024/09/19 13:41:35 UTC, 0 replies.
- (flink-connector-aws) branch dependabot/maven/com.google.protobuf-protobuf-java-3.25.5 created (now 3df4347) - posted by gi...@apache.org on 2024/09/19 16:16:56 UTC, 0 replies.
- (flink-connector-pulsar) branch dependabot/maven/com.google.protobuf-protobuf-java-3.25.5 created (now 9a52f94) - posted by gi...@apache.org on 2024/09/19 16:18:37 UTC, 0 replies.
- (flink-benchmarks) branch dependabot/maven/com.google.protobuf-protobuf-java-3.25.5 created (now 35c863a) - posted by gi...@apache.org on 2024/09/19 16:20:54 UTC, 0 replies.
- (flink) branch master updated (5559126733b -> 20e9826f770) - posted by fc...@apache.org on 2024/09/19 17:41:14 UTC, 0 replies.
- (flink) 01/02: [FLINK-36316][API / Core] Move PortRange class from flink-runtime to flink-core module - posted by fc...@apache.org on 2024/09/19 17:41:15 UTC, 0 replies.
- (flink) 02/02: [FLINK-36240][runtime/metrics] Fix incorrect Port display in the PrometheusReporter constructor - posted by fc...@apache.org on 2024/09/19 17:41:16 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36314][state/forst] Support state V1 interface in forst statebackend (#25349) - posted by le...@apache.org on 2024/09/20 08:09:46 UTC, 0 replies.
- (flink-connector-aws) branch main updated: Bump com.google.protobuf:protobuf-java from 3.21.7 to 3.25.5 - posted by ho...@apache.org on 2024/09/20 10:00:31 UTC, 0 replies.
- (flink-connector-aws) branch dependabot/maven/com.google.protobuf-protobuf-java-3.25.5 deleted (was 3df4347) - posted by gi...@apache.org on 2024/09/20 10:00:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36284][format-avro] Support extracting Avro type with new DataType stack - posted by li...@apache.org on 2024/09/20 10:23:13 UTC, 0 replies.
- (flink) branch master updated (1cd9110f858 -> 80d518624a8) - posted by sx...@apache.org on 2024/09/20 11:48:37 UTC, 0 replies.
- (flink) 01/04: [FLINK-33750][config] Remove legacy memory config option - posted by sx...@apache.org on 2024/09/20 11:48:38 UTC, 0 replies.
- (flink) 02/04: [FLINK-33750][config] Remove 'taskmanager.network.numberOfBuffers' - posted by sx...@apache.org on 2024/09/20 11:48:39 UTC, 0 replies.
- (flink) 03/04: [FLINK-33750][config] Remove floating/exclusive buffer config options - posted by sx...@apache.org on 2024/09/20 11:48:40 UTC, 0 replies.
- (flink) 04/04: [FLINK-33750][config] Remove BoundedBlockingShuffle config options - posted by sx...@apache.org on 2024/09/20 11:48:41 UTC, 0 replies.
- (flink) branch release-1.19 updated (194df6c4067 -> 513ed95ffe5) - posted by dw...@apache.org on 2024/09/20 14:51:57 UTC, 0 replies.
- (flink) 01/01: [FLINK-36318] Fix deserializing from 1.18 savepoint with RAW types - posted by dw...@apache.org on 2024/09/20 14:51:58 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36318] Fix deserializing from 1.18 savepoint with RAW types - posted by sn...@apache.org on 2024/09/20 18:43:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36330][table] Session Window TVFs with named parameters don't support column expansion - posted by sn...@apache.org on 2024/09/20 19:14:01 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36318] Fix deserializing from 1.18 savepoint with RAW types - posted by sn...@apache.org on 2024/09/20 19:53:00 UTC, 0 replies.
- (flink) branch master updated: [FLINK-29741][scala] Remove flink-scala and flink-streaming-scala dependency exclude table module - posted by gu...@apache.org on 2024/09/22 07:50:19 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36310] Remove per-job and run-application - posted by gu...@apache.org on 2024/09/22 08:06:27 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34975][state/forst] Execute read/write state request in different executor (#25360) - posted by le...@apache.org on 2024/09/23 04:01:54 UTC, 0 replies.
- (flink) branch master updated (1d1bf5c8f69 -> 7989f485f10) - posted by gu...@apache.org on 2024/09/23 05:51:25 UTC, 0 replies.
- (flink) 01/02: [FLINK-36257][API] Remove easy-to-drop deprecated API - posted by gu...@apache.org on 2024/09/23 05:51:26 UTC, 0 replies.
- (flink) 02/02: [FLINK-36257][K8S] Remove legacy k8s labels - posted by gu...@apache.org on 2024/09/23 05:51:27 UTC, 0 replies.
- (flink) branch master updated (7989f485f10 -> f393270f211) - posted by hx...@apache.org on 2024/09/23 06:59:49 UTC, 0 replies.
- (flink) branch master updated: [FLINK-28770][table-planner] Support EXPLAIN on CREATE TABLE AS SELECT - posted by tw...@apache.org on 2024/09/23 10:01:48 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Fix UnifiedSinkMigrationITCase - posted by ar...@apache.org on 2024/09/23 10:15:13 UTC, 0 replies.
- (flink) branch master updated (300e1ea1f2c -> 32dc6c019c0) - posted by ma...@apache.org on 2024/09/23 11:10:34 UTC, 0 replies.
- (flink) 01/03: [FLINK-36295] [runtime] Test AdaptiveSchedulerClusterITCase.testCheckpointStatsPersistedAcrossRescale() waits until the desired parallelism is reached - posted by ma...@apache.org on 2024/09/23 11:10:35 UTC, 0 replies.
- (flink) 02/03: [hotfix] UnsupportedOperationException in AdaptiveSchedulerClusterITCase fix - posted by ma...@apache.org on 2024/09/23 11:10:36 UTC, 0 replies.
- (flink) 03/03: [hotfix] Additional logs in AdaptiveScheduler components - posted by ma...@apache.org on 2024/09/23 11:10:37 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36338][State] Properly handle KeyContext when using AsyncKeyedStateBackendAdaptor (#25367) - posted by za...@apache.org on 2024/09/23 11:27:53 UTC, 0 replies.
- (flink-connector-kafka) branch main updated (52e7e580 -> 9b97c511) - posted by ar...@apache.org on 2024/09/23 12:18:47 UTC, 0 replies.
- (flink) branch master updated (b14ab764a0a -> 950fceb43e6) - posted by zh...@apache.org on 2024/09/23 15:50:49 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36342][runtime] Rename misleading BufferDebloater variable 'targetTotalBufferSize' - posted by fc...@apache.org on 2024/09/23 16:35:17 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34125][serializer] Remove deprecated TypeInformation#createSerializer(ExecutionConfig) method - posted by gu...@apache.org on 2024/09/24 01:57:14 UTC, 0 replies.
- (flink) branch master updated (195efff51eb -> 8bb2f4d7479) - posted by za...@apache.org on 2024/09/24 02:32:49 UTC, 0 replies.
- (flink) 01/04: [FLINK-35411][Runtime] Optimize drain of async state requests - posted by za...@apache.org on 2024/09/24 02:32:50 UTC, 0 replies.
- (flink) 02/04: [FLINK-35411][Runtime] Introduce periodic timeout check for state requests buffer - posted by za...@apache.org on 2024/09/24 02:32:51 UTC, 0 replies.
- (flink) 03/04: [FLINK-35411][Runtime] Use wait/notify instead of frequent sleep in AsyncExecutionController - posted by za...@apache.org on 2024/09/24 02:32:52 UTC, 0 replies.
- (flink) 04/04: [FLINK-35411][State] Support process write state requests within coordinator thread - posted by za...@apache.org on 2024/09/24 02:32:53 UTC, 0 replies.
- (flink) branch master updated (8bb2f4d7479 -> 01d62d3a195) - posted by ma...@apache.org on 2024/09/24 07:50:43 UTC, 0 replies.
- (flink) 01/02: [hotfix][test] Changes the way the thread name of the ComponentMainThreadExecutorServiceAdapter is created - posted by ma...@apache.org on 2024/09/24 07:50:44 UTC, 0 replies.
- (flink) 02/02: [FLINK-36299][runtime] Makes DeclarativeSlotPool rely on the ComponentMainThreadExecutor that's used in the corresponding test rather than the test's main thread - posted by ma...@apache.org on 2024/09/24 07:50:45 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36329][Connectors/DynamoDB] Changing retry strategy to use SDK retries to catch all retryable exceptions - posted by ho...@apache.org on 2024/09/24 08:14:20 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36357][Connectors/Kinesis] Set up AWS SDK default retry strategy configurations - posted by ho...@apache.org on 2024/09/24 09:18:12 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36346][API] Remove deprecated API in flink-streaming-java module - posted by gu...@apache.org on 2024/09/24 09:52:36 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36353] Allow to add affinity for operator pod of helm chart - posted by gy...@apache.org on 2024/09/24 09:56:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36349][tests] Fix ClosureCleanerITCase fail in the AdaptiveScheduler test profile - posted by gu...@apache.org on 2024/09/24 10:16:37 UTC, 0 replies.
- (flink) branch master updated (b2d328919c0 -> c9213b3bf75) - posted by fa...@apache.org on 2024/09/24 10:42:41 UTC, 0 replies.
- (flink) 01/02: [FLINK-34082][core] Remove deprecated methods of Configuration - posted by fa...@apache.org on 2024/09/24 10:42:42 UTC, 0 replies.
- (flink) 02/02: [FLINK-34082][config] Adapt the python configuration - posted by fa...@apache.org on 2024/09/24 10:42:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36248][table] Introduce new Join Operator with Async State API - posted by li...@apache.org on 2024/09/24 10:47:37 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated (75a4739 -> 47df621) - posted by ho...@apache.org on 2024/09/24 12:37:42 UTC, 0 replies.
- (flink-connector-prometheus) 01/04: [FLINK-36286][Connectors/Prometheus] Set up pull request template for prometheus connector repo - posted by ho...@apache.org on 2024/09/24 12:37:43 UTC, 0 replies.
- (flink-connector-prometheus) 02/04: [FLINK-36286][Connectors/Prometheus] Set up boring-cyborg - posted by ho...@apache.org on 2024/09/24 12:37:44 UTC, 0 replies.
- (flink-connector-prometheus) 03/04: [FLINK-36286][Connectors/Prometheus] Set up Github workflows - posted by ho...@apache.org on 2024/09/24 12:37:45 UTC, 0 replies.
- (flink-connector-prometheus) 04/04: [FLINK-36286][Connectors/Prometheus] Set up dependency convergence - posted by ho...@apache.org on 2024/09/24 12:37:46 UTC, 0 replies.
- (flink) branch master updated (5a63c56ca0b -> c5ed471414c) - posted by za...@apache.org on 2024/09/24 14:06:31 UTC, 0 replies.
- (flink) 01/08: [FLINK-34511][Checkpoint] Remove force checkpointing flag - posted by za...@apache.org on 2024/09/24 14:06:32 UTC, 0 replies.
- (flink) 02/08: [FLINK-36274][Checkpoint] Remove deprecated `ExternalizedCheckpointCleanup` - posted by za...@apache.org on 2024/09/24 14:06:33 UTC, 0 replies.
- (flink) 03/08: [FLINK-34511][Checkpoint] Remove deprecated `ExecutionCheckpointingOptions` - posted by za...@apache.org on 2024/09/24 14:06:34 UTC, 0 replies.
- (flink) 04/08: [FLINK-34511][Checkpoint] Remove deprecated `SavepointConfigOptions` - posted by za...@apache.org on 2024/09/24 14:06:35 UTC, 0 replies.
- (flink) 05/08: [FLINK-34511][Checkpoint] Cleanup `CheckpointConfig` - posted by za...@apache.org on 2024/09/24 14:06:36 UTC, 0 replies.
- (flink) 06/08: [FLINK-34511][State/rocksdb] Cleanup deprecated APIs in rocksdb state backend - posted by za...@apache.org on 2024/09/24 14:06:37 UTC, 0 replies.
- (flink) 07/08: [FLINK-34511][Runtime/State] Remove deprecated state related APIs - posted by za...@apache.org on 2024/09/24 14:06:38 UTC, 0 replies.
- (flink) 08/08: [FLINK-34511][Runtime/State] Remove deprecated checkpointing related APIs - posted by za...@apache.org on 2024/09/24 14:06:39 UTC, 0 replies.
- (flink-connector-prometheus) branch main updated: [FLINK-36319][Connector/Prometheus] Multiple fixes. Modified the default behavior for non-retriable errors to "discard and continue". Blocked the ability to set non-retriable error handling behavior to "fail". Removed ability to pass a custom AWS credential provider to the request signer, causing a serialization exception. Fixed bug in sink builder when retry configuration was not configured. Refactored parameter validation to make it more robust - posted by ho...@apache.org on 2024/09/24 15:49:26 UTC, 0 replies.
- (flink) branch master updated (c5ed471414c -> 7a06c3ba00e) - posted by li...@apache.org on 2024/09/24 15:49:45 UTC, 0 replies.
- (flink) 01/02: [FLINK-36327][table-api-scala] Copy utils and tests from flink-scala - posted by li...@apache.org on 2024/09/24 15:49:46 UTC, 0 replies.
- (flink) 02/02: [FLINK-36327][table] Remove dependency about flink-scala and flink-streaming-scala in table module - posted by li...@apache.org on 2024/09/24 15:49:47 UTC, 0 replies.
- (flink) branch master updated (7a06c3ba00e -> 74b9a480317) - posted by li...@apache.org on 2024/09/25 01:32:20 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36308][cep] Remove deprecated APIs from CEP module (#25381) - posted by di...@apache.org on 2024/09/25 02:51:50 UTC, 0 replies.
- (flink) branch master updated (42d918dec16 -> 483a94a15ae) - posted by di...@apache.org on 2024/09/25 02:55:01 UTC, 0 replies.
- (flink) 01/03: [FLINK-36311][format/avro] Remove deprecated APIs in Flink Avro format - posted by di...@apache.org on 2024/09/25 02:55:02 UTC, 0 replies.
- (flink) 02/03: [FLINK-36311][format/json] Remove deprecated APIs in Flink Json format - posted by di...@apache.org on 2024/09/25 02:55:03 UTC, 0 replies.
- (flink) 03/03: [FLINK-36311][format/csv] Remove deprecated APIs in Flink Csv format - posted by di...@apache.org on 2024/09/25 02:55:04 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36275][rest] Remove deprecated ProgramArgsQueryParameter - posted by gu...@apache.org on 2024/09/25 07:32:47 UTC, 0 replies.
- (flink) branch master updated (f58a3e02a63 -> 0578c8e17dd) - posted by sn...@apache.org on 2024/09/25 07:57:28 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][CI] Fix Stale label automatically removed without update activity - posted by le...@apache.org on 2024/09/25 10:01:00 UTC, 0 replies.
- (flink) branch master updated (0578c8e17dd -> 733a56682bc) - posted by li...@apache.org on 2024/09/25 10:18:26 UTC, 0 replies.
- (flink) 01/05: [FLINK-36273][table-planner] Add the config in values source to let it can disable agg push down - posted by li...@apache.org on 2024/09/25 10:18:27 UTC, 0 replies.
- (flink) 02/05: [FLINK-36273][table] Remove deprecated Table/SQL configuration related FLINK-35473 in 2.0 - posted by li...@apache.org on 2024/09/25 10:18:28 UTC, 0 replies.
- (flink) 03/05: [FLINK-36273][table] Remove all deprecated Table/SQL configuration in 2.0 in flink-sql-client module - posted by li...@apache.org on 2024/09/25 10:18:29 UTC, 0 replies.
- (flink) 04/05: [FLINK-36273][table] Remove all deprecated Table/SQL configuration in 2.0 in flink-table-api module - posted by li...@apache.org on 2024/09/25 10:18:30 UTC, 0 replies.
- (flink) 05/05: [FLINK-36273][table] Remove all deprecated configuration in 2.0 in flink-connector-hive module - posted by li...@apache.org on 2024/09/25 10:18:31 UTC, 0 replies.
- (flink-connector-hbase) branch main updated: [FLINK-36188] Fix disable buffer flush lose efficacy (#49) - posted by fc...@apache.org on 2024/09/25 10:22:40 UTC, 0 replies.
- (flink-connector-hbase) branch v3.0 updated: [FLINK-35233] Fix lookup cache reuse RowData object problem (#48) - posted by fc...@apache.org on 2024/09/25 10:31:55 UTC, 0 replies.
- (flink-connector-hbase) branch v3.0 updated: [FLINK-36188] Fix disable buffer flush lose efficacy (#49) - posted by fc...@apache.org on 2024/09/25 11:29:18 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34975][state/forst] Support multiget for forstdb (#25363) - posted by le...@apache.org on 2024/09/25 12:41:37 UTC, 0 replies.
- (flink) branch master updated (f33abffe1da -> 2f8b2d81a97) - posted by li...@apache.org on 2024/09/25 15:40:17 UTC, 0 replies.
- (flink) 01/07: [FLINK-34702][table-planner] Avoid using StreamPhysicalDeduplicate and instead decide to perform exec node transformations in StreamPhysicalRank - posted by li...@apache.org on 2024/09/25 15:40:18 UTC, 0 replies.
- (flink) 02/07: [FLINK-34702][table-planner] Remove StreamPhysicalDeduplicate from FlinkChangelogModeInferenceProgram and StreamNonDeterministicUpdatePlanVisitor - posted by li...@apache.org on 2024/09/25 15:40:19 UTC, 0 replies.
- (flink) 03/07: [FLINK-34702][table-planner] Remove StreamPhysicalDeduplicate from FlinkRelMdColumnUniqueness - posted by li...@apache.org on 2024/09/25 15:40:20 UTC, 0 replies.
- (flink) 04/07: [FLINK-34702][table-planner] Remove StreamPhysicalDeduplicate from FlinkRelMdUniqueKeys - posted by li...@apache.org on 2024/09/25 15:40:21 UTC, 0 replies.
- (flink) 05/07: [FLINK-34702][table-planner] Remove StreamPhysicalDeduplicate from FlinkRelMdModifiedMonotonicity - posted by li...@apache.org on 2024/09/25 15:40:22 UTC, 0 replies.
- (flink) 06/07: [FLINK-34702][table-planner] Remove StreamPhysicalDeduplicate from FlinkRelMdUpsertKeys - posted by li...@apache.org on 2024/09/25 15:40:23 UTC, 0 replies.
- (flink) 07/07: [FLINK-34702][table-planner] Remove physical node StreamPhysicalDeduplicate - posted by li...@apache.org on 2024/09/25 15:40:24 UTC, 0 replies.
- (flink) branch master updated: [FLINK-29741][scala] Delete flink-scala and flink-streaming-scala modules - posted by gu...@apache.org on 2024/09/26 01:59:05 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36364][state/forst] Do not reuse serialized key in Forst map state and/or other namespaces (#25394) - posted by za...@apache.org on 2024/09/26 04:05:09 UTC, 0 replies.
- (flink) branch master updated (82582b3a7b7 -> 9d21878befa) - posted by ar...@apache.org on 2024/09/26 08:39:52 UTC, 0 replies.
- (flink) branch master updated (9d21878befa -> 84eab0405a0) - posted by li...@apache.org on 2024/09/26 11:54:01 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36292][Connectors/Common][test]: remove timeout to avoid timeout exception (#25371) - posted by jq...@apache.org on 2024/09/26 18:25:15 UTC, 0 replies.
- (flink) branch master updated: [FLINK-3992][core] Do not implement deprecated Key interface - posted by gu...@apache.org on 2024/09/27 02:07:43 UTC, 0 replies.
- (flink) branch master updated (21092bf229d -> be4549de7e6) - posted by gu...@apache.org on 2024/09/27 02:12:38 UTC, 0 replies.
- (flink) branch master updated (be4549de7e6 -> be907074643) - posted by za...@apache.org on 2024/09/27 02:32:10 UTC, 0 replies.
- (flink) 01/02: [FLINK-30614][serializer] Remove old method of resolving schema compatibility. - posted by za...@apache.org on 2024/09/27 02:32:11 UTC, 0 replies.
- (flink) 02/02: [FLINK-30614][serializer] Remove deprecated GenericArraySerializerConfigSnapshot and EitherSerializerSnapshot. - posted by za...@apache.org on 2024/09/27 02:32:12 UTC, 0 replies.
- (flink) branch master updated (be907074643 -> fc3ace9bd65) - posted by di...@apache.org on 2024/09/27 03:03:10 UTC, 0 replies.
- Re: [I] CDC scan.startup.mode设置为timestamp读不到数据 [flink-cdc] - posted by "baiJoker (via GitHub)" <gi...@apache.org> on 2024/09/27 05:41:00 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36390][core] Remove deprecated open(Configuration) method in RichFunction - posted by gu...@apache.org on 2024/09/27 06:46:27 UTC, 0 replies.
- Re: [I] flinkcdc有可能支持clickhosue或达梦数据库吗？ [flink-cdc] - posted by "saidkind (via GitHub)" <gi...@apache.org> on 2024/09/27 07:24:50 UTC, 0 replies.
- (flink) branch master updated (6a290caf82a -> 6633719c728) - posted by gu...@apache.org on 2024/09/27 09:01:56 UTC, 0 replies.
- (flink) 01/03: [hotfix][batch] Fix incorrectly use of ExecutionMode in AdaptiveBatchSchedulerFactory - posted by gu...@apache.org on 2024/09/27 09:01:57 UTC, 0 replies.
- (flink) 02/03: [FLINK-36366][core] Remove deprecate API in flink-core exclude connector and state part - posted by gu...@apache.org on 2024/09/27 09:01:58 UTC, 0 replies.
- (flink) 03/03: [FLINK-36366][core] Remove deprecated serializer related config option and method - posted by gu...@apache.org on 2024/09/27 09:01:59 UTC, 0 replies.
- (flink-benchmarks) branch master updated (f8111a9 -> cf73aa0) - posted by pn...@apache.org on 2024/09/27 15:05:04 UTC, 0 replies.
- (flink-benchmarks) 01/02: [FLINK-28407] Added automation creation of Jenkins script parameters with default values - posted by pn...@apache.org on 2024/09/27 15:05:05 UTC, 0 replies.
- (flink-benchmarks) 02/02: [FLINK-28407] Information about Jenkins and Codespeed added to README - posted by pn...@apache.org on 2024/09/27 15:05:06 UTC, 0 replies.
- (flink-connector-kafka) branch main updated (9b97c511 -> 157813ea) - posted by ar...@apache.org on 2024/09/27 18:59:43 UTC, 0 replies.
- (flink-connector-kafka) 01/02: [FLINK-36177] Deprecate KafkaShuffle and more - posted by ar...@apache.org on 2024/09/27 18:59:44 UTC, 0 replies.
- (flink-connector-kafka) 02/02: [FLINK-36177] Introduce KafkaPartitioner to replace FlinkKafkaPartitioner - posted by ar...@apache.org on 2024/09/27 18:59:45 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36378][table] Fix type extraction bug between java BigDecimal and sql decimal. - posted by ji...@apache.org on 2024/09/28 19:52:07 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34738][cdc][docs-zh] "Deployment - YARN" Page for Flink CDC Chinese Documentation (#3205) - posted by go...@apache.org on 2024/09/29 02:00:04 UTC, 0 replies.
- (flink) branch master updated (502d9673f56 -> 338d0246ecc) - posted by sx...@apache.org on 2024/09/30 14:55:13 UTC, 0 replies.
- (flink) branch master updated (c0cd27e4739 -> f848df27ae5) - posted by sx...@apache.org on 2024/09/30 14:55:19 UTC, 0 replies.
- (flink) branch master updated (74864b0b376 -> 502d9673f56) - posted by ma...@apache.org on 2024/09/30 14:55:25 UTC, 0 replies.
- (flink) branch master updated (5a166e0a584 -> fc10d3e1d63) - posted by gu...@apache.org on 2024/09/30 14:55:33 UTC, 0 replies.
- (flink) branch master updated (73a02855caf -> ca11cb94c8a) - posted by za...@apache.org on 2024/09/30 14:55:40 UTC, 0 replies.
- (flink) branch master updated (fc10d3e1d63 -> c0cd27e4739) - posted by sx...@apache.org on 2024/09/30 14:55:45 UTC, 0 replies.
- (flink) branch master updated (ca11cb94c8a -> 74864b0b376) - posted by xt...@apache.org on 2024/09/30 14:56:29 UTC, 0 replies.
- (flink) branch master updated (18e195004ad -> 5a166e0a584) - posted by xt...@apache.org on 2024/09/30 14:57:54 UTC, 0 replies.
- (flink) branch master updated (6444f18ed36 -> 73a02855caf) - posted by le...@apache.org on 2024/09/30 14:58:02 UTC, 0 replies.
- (flink) branch master updated (338d0246ecc -> 18e195004ad) - posted by ga...@apache.org on 2024/09/30 14:58:31 UTC, 0 replies.
- (flink) branch master updated (f4cc8e8e519 -> e5ce2c34d81) - posted by ta...@apache.org on 2024/09/30 15:04:25 UTC, 0 replies.
- (flink) branch master updated (7a60c1916b1 -> 8391cfe4fdd) - posted by za...@apache.org on 2024/09/30 15:04:32 UTC, 0 replies.
- (flink) branch master updated (ec6695778e4 -> f2d6b5753db) - posted by re...@apache.org on 2024/09/30 15:04:39 UTC, 0 replies.
- (flink) branch master updated (f848df27ae5 -> 773ea76e046) - posted by za...@apache.org on 2024/09/30 15:04:45 UTC, 0 replies.
- (flink) branch master updated (773ea76e046 -> 54813b65790) - posted by za...@apache.org on 2024/09/30 15:04:52 UTC, 0 replies.
- (flink) branch master updated (e5ce2c34d81 -> ec6695778e4) - posted by sx...@apache.org on 2024/09/30 15:04:59 UTC, 0 replies.
- (flink) branch master updated (8391cfe4fdd -> f4cc8e8e519) - posted by za...@apache.org on 2024/09/30 15:05:05 UTC, 0 replies.
- (flink) branch master updated (f2d6b5753db -> 4fae64cb011) - posted by pn...@apache.org on 2024/09/30 15:05:11 UTC, 0 replies.
- (flink) branch master updated (4fae64cb011 -> bb6421d5e2f) - posted by gu...@apache.org on 2024/09/30 15:05:17 UTC, 0 replies.
- (flink) branch release-1.19 updated (513ed95ffe5 -> 98f1349bb4b) - posted by pn...@apache.org on 2024/09/30 15:10:06 UTC, 0 replies.
- (flink) branch release-1.20 updated (7e955c80ff9 -> c4dd2a6550a) - posted by pn...@apache.org on 2024/09/30 15:10:12 UTC, 0 replies.
- (flink) branch master updated (54813b65790 -> 7a60c1916b1) - posted by gu...@apache.org on 2024/09/30 15:11:29 UTC, 0 replies.
- (flink) branch master updated (bb6421d5e2f -> 3e1b3099229) - posted by za...@apache.org on 2024/09/30 15:14:29 UTC, 0 replies.
- (flink) branch master updated (3e1b3099229 -> a6a5ee64d57) - posted by za...@apache.org on 2024/09/30 15:14:38 UTC, 0 replies.
- (flink) branch f36260 created (now 4f48f020984) - posted by pn...@apache.org on 2024/09/30 15:21:09 UTC, 0 replies.
- (flink) 01/01: [FLINK-36260][metrics] Fix numBytesInLocal and numBuffersInLocal being reported as remote - posted by pn...@apache.org on 2024/09/30 15:21:10 UTC, 0 replies.
- (flink) branch f36260 deleted (was 4f48f020984) - posted by pn...@apache.org on 2024/09/30 15:22:06 UTC, 0 replies.