commits@flink.apache.org, 2025-01

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

- (flink) branch master updated: [FLINK-36961][state/forst] Wait ForSt state excutor shutdown when disposing (#25854) - posted by le...@apache.org on 2025/01/01 01:52:33 UTC, 0 replies.
- (flink) branch danderson-hotfix-mr-docs created (now f6f062d61af) - posted by da...@apache.org on 2025/01/01 19:13:06 UTC, 0 replies.
- (flink) 01/01: [hotfix][docs] In match_recognize docs, remove extracting time attributes from list of limitations - posted by da...@apache.org on 2025/01/01 19:13:07 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36490][table-common] Remove the deprecated method in DataStreamScanProvider (#25563) - posted by ro...@apache.org on 2025/01/02 05:57:06 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36491][table-common] Remove the deprecated method in DataStreamSinkProvider (#25564) - posted by ro...@apache.org on 2025/01/02 06:01:40 UTC, 0 replies.
- (flink) branch master updated (73afb6e636c -> 4952b58d27b) - posted by za...@apache.org on 2025/01/02 10:46:27 UTC, 0 replies.
- (flink) branch release-1.20 updated (d61126a8a7d -> 6ce145b98ac) - posted by af...@apache.org on 2025/01/02 10:48:15 UTC, 0 replies.
- (flink) branch master updated (4952b58d27b -> b700f1c2dec) - posted by sh...@apache.org on 2025/01/02 12:25:16 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36269][python] Remove usage about TableEnvironmentInternal#fromTableSource in python module (#25322) - posted by hx...@apache.org on 2025/01/02 13:00:37 UTC, 0 replies.
- (flink) branch master updated (c3daf84d551 -> 49d0a759ada) - posted by zh...@apache.org on 2025/01/03 01:55:14 UTC, 0 replies.
- (flink) 01/03: [FLINK-36607][table-planner] Introduce configuration options for adaptive broadcast join. - posted by zh...@apache.org on 2025/01/03 01:55:15 UTC, 0 replies.
- (flink) 02/03: [FLINK-36607][table-planner] Introduce ExecNode for adaptive join. - posted by zh...@apache.org on 2025/01/03 01:55:16 UTC, 0 replies.
- (flink) 03/03: [FLINK-36607][table-planner] Introduce AdaptiveJoinProcessor to inject adaptive join node. - posted by zh...@apache.org on 2025/01/03 01:55:17 UTC, 0 replies.
- (flink) branch master updated (49d0a759ada -> fafd86cd648) - posted by zh...@apache.org on 2025/01/03 02:38:47 UTC, 0 replies.
- (flink) 01/02: [FLINK-36850][streaming-java] Support IntermediateDataSetID generated from source JobVertexID and consumer stream node id. - posted by zh...@apache.org on 2025/01/03 02:38:48 UTC, 0 replies.
- (flink) 02/02: [FLINK-36850][runtime] Disable adaptive batch execution when batch job progress recovery is enabled. - posted by zh...@apache.org on 2025/01/03 02:38:49 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36484] [table-api] Remove deprecated methods StreamTableEnvironment#registerFunction (#25529) - posted by ro...@apache.org on 2025/01/03 02:56:11 UTC, 0 replies.
- (flink) branch master updated (4263ad3ed43 -> ea1055683f5) - posted by ro...@apache.org on 2025/01/03 03:24:28 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][tests] Fix unstable `OceanBaseMySQLModelITCase` (#3831) - posted by ru...@apache.org on 2025/01/03 05:43:13 UTC, 0 replies.
- (flink-connector-elasticsearch) branch main updated: [FLINK-36987][docs] Correct the docs to the active ES table connector (#114) - posted by ta...@apache.org on 2025/01/03 07:00:06 UTC, 0 replies.
- (flink-connector-elasticsearch) branch v3.0 updated: [FLINK-36987][docs] Correct the docs to the active ES table connector (#114) - posted by ta...@apache.org on 2025/01/03 07:03:54 UTC, 0 replies.
- (flink-connector-elasticsearch) branch v3.1 updated: [FLINK-36987][docs] Correct the docs to the active ES table connector (#114) - posted by ta...@apache.org on 2025/01/03 07:05:11 UTC, 0 replies.
- (flink) branch master updated (ea1055683f5 -> bbbd160ca79) - posted by ro...@apache.org on 2025/01/03 09:40:37 UTC, 0 replies.
- (flink) branch master updated: [hotfix][docs] In match_recognize docs, remove extracting time attributes from list of limitations - posted by da...@apache.org on 2025/01/03 12:50:58 UTC, 0 replies.
- (flink) branch danderson-hotfix-mr-docs deleted (was f6f062d61af) - posted by da...@apache.org on 2025/01/03 12:51:10 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-34194] Update CI to Ubuntu 22.04 (Jammy) (#25827) - posted by ma...@apache.org on 2025/01/03 13:21:50 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36007][table] Apply changes from FLINK-36277 to AdaptiveJoin - posted by sn...@apache.org on 2025/01/04 10:40:21 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36759][sql-gateway] Add REST API to deploy script in application mode (#25730) - posted by sh...@apache.org on 2025/01/04 15:17:46 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36593][runtime] Backport io.airlift:aircompressor upgrade to 0.27 - posted by af...@apache.org on 2025/01/05 15:59:03 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-33571][table] Upgrade json-path from 2.7.0 to 2.9.0 - posted by af...@apache.org on 2025/01/05 16:13:37 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36989][runtime] Fix scheduler benchmark regression caused by ConsumedSubpartitionContext - posted by zh...@apache.org on 2025/01/06 03:03:57 UTC, 0 replies.
- (flink-web) branch asf-site updated: Update blogpost for Prometheus connector - posted by da...@apache.org on 2025/01/06 09:49:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-28091][tests] Replaces ForkJoinPool by TestExecutorExtension - posted by ma...@apache.org on 2025/01/06 11:20:45 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36935][state/forst] Implement fast link for ForStFileSystem (#25818) - posted by le...@apache.org on 2025/01/06 13:00:33 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36790][cdc-connector][paimon] Set waitCompaction to true in PaimonWriter to avoid CME problem - posted by le...@apache.org on 2025/01/06 14:31:18 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34545][pipeline-connector/ob]Add OceanBase pipeline connector to Flink CDC - posted by le...@apache.org on 2025/01/06 14:33:27 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37017][cdc-common] Supports map and array types for binary record data - posted by le...@apache.org on 2025/01/06 16:09:47 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-28091][tests] Replaces ForkJoinPool by TestExecutorExtension - posted by ma...@apache.org on 2025/01/06 18:02:36 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-28091][tests] Replaces ForkJoinPool by TestExecutorExtension - posted by ma...@apache.org on 2025/01/06 18:02:44 UTC, 0 replies.
- (flink) branch master updated: [FLINK-22091][yarn] Make Flink on YARN honor env.java.home (#25877) - posted by zj...@apache.org on 2025/01/07 02:29:54 UTC, 0 replies.
- (flink) branch master updated (f0c8f18ee09 -> 734491625b2) - posted by ro...@apache.org on 2025/01/07 07:23:02 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][docs] Add missed enumeration in MySQL Source - posted by le...@apache.org on 2025/01/07 09:22:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36760][sql-client] Supports to deploy script via sql client (#25754) - posted by sh...@apache.org on 2025/01/07 11:15:24 UTC, 0 replies.
- (flink) branch master updated (4a8b8c03e3a -> ae7184bd222) - posted by ju...@apache.org on 2025/01/07 11:31:22 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36739] Update the NodeJS to v22.11.0 (LTS) - posted by af...@apache.org on 2025/01/07 20:28:26 UTC, 0 replies.
- (flink) branch master updated (ae7184bd222 -> 503ad9b7b8e) - posted by sn...@apache.org on 2025/01/07 21:47:12 UTC, 0 replies.
- (flink) 01/02: [FLINK-37007][table] Add missing createView methods to TableEnvironment - posted by sn...@apache.org on 2025/01/07 21:47:13 UTC, 0 replies.
- (flink) 02/02: [hotfix][docs] Add python docs for `create_table`/`create_temporary_table` - posted by sn...@apache.org on 2025/01/07 21:47:14 UTC, 0 replies.
- (flink) branch master updated (503ad9b7b8e -> 58047a8eb12) - posted by sn...@apache.org on 2025/01/07 22:35:25 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36950][table] Migrate WindowPropertiesRules to java - posted by sn...@apache.org on 2025/01/08 00:20:30 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37010][Runtime] Unify KeyedProcessFunction and the async one (#25901) - posted by za...@apache.org on 2025/01/08 01:58:37 UTC, 0 replies.
- (flink) branch master updated (9720dcccc9e -> 75c26e8c9fd) - posted by gu...@apache.org on 2025/01/08 02:22:37 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35167][pipeline-connector/maxcompute] Introduce MaxCompute pipeline DataSink - posted by le...@apache.org on 2025/01/08 02:34:02 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][k8s] Fix command-line option `from-savepoint` does not work in K8s deployment mode - posted by le...@apache.org on 2025/01/08 06:34:31 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][cdc-common] Remove duplicated code to improve performance - posted by le...@apache.org on 2025/01/08 06:53:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36968][table-planner] Deduplicate data with the same pk in values lookup table used for testing (#25864) - posted by sh...@apache.org on 2025/01/08 08:26:01 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36507][table-common] Remove the deprecated method LogicalTypeParser#parse (#25909) - posted by ro...@apache.org on 2025/01/08 09:02:32 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37016] ClusterEntrypoint can be closed before initialization - posted by ch...@apache.org on 2025/01/08 10:31:38 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36486] [table-api] Remove deprecated methods StreamTableEnvironment#registerDataStream - posted by ro...@apache.org on 2025/01/08 11:16:29 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37014][docs] Fix typo in materialized table doc (#25904) - posted by ro...@apache.org on 2025/01/08 11:21:41 UTC, 0 replies.
- (flink) branch master updated (d5ee2988da1 -> 329ad1e22b6) - posted by ro...@apache.org on 2025/01/08 13:03:43 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36941][docs] Update `DATE_FORMAT` Doc and Python Tests - posted by sn...@apache.org on 2025/01/08 20:52:24 UTC, 0 replies.
- (flink) branch release-1.20 updated (bcc44d2d3b8 -> 294840a444c) - posted by sn...@apache.org on 2025/01/08 20:53:31 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36689][Runtime/Web Frontend] Update ng-zorro-antd to v18. This closes #25713 - posted by af...@apache.org on 2025/01/08 22:22:22 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36227] Restore compatibility with Logback 1.2 (#25813) - posted by af...@apache.org on 2025/01/08 22:54:26 UTC, 0 replies.
- (flink) branch master updated (329ad1e22b6 -> 5e0e5a233eb) - posted by ro...@apache.org on 2025/01/09 02:43:18 UTC, 0 replies.
- (flink) 01/04: [FLINK-36994][table] Support parsing ALTER MATERIALIZED TABLE AS statement - posted by ro...@apache.org on 2025/01/09 02:43:19 UTC, 0 replies.
- (flink) 02/04: [FLINK-36994][table] Support converting ALTER MATERIALIZED TABLE AS node to operation - posted by ro...@apache.org on 2025/01/09 02:43:20 UTC, 0 replies.
- (flink) 03/04: [FLINK-36994][table] Support executing ALTER MATERIALIZED TABLE AS operation - posted by ro...@apache.org on 2025/01/09 02:43:21 UTC, 0 replies.
- (flink) 04/04: [FLINK-36994][table] Fix expand sql error when materialized table creation with UDTF queries - posted by ro...@apache.org on 2025/01/09 02:43:22 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37014][docs] Fix typo in materialized table doc (#25904) (#25926) - posted by ro...@apache.org on 2025/01/09 03:41:09 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36524][pipeline-connector][paimon] Bump Paimon version to 0.9.0 - posted by le...@apache.org on 2025/01/09 04:01:56 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36877][pipeline-connector/kafka] Correct canal-json output for delete record - posted by le...@apache.org on 2025/01/09 04:05:00 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36956][transform] Append NOT NULL attribute for Primary Key columns - posted by le...@apache.org on 2025/01/09 04:06:37 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36981][transform] Considering sharding tables with different schema in transform projection - posted by le...@apache.org on 2025/01/09 04:13:30 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36970][cdc-common] Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING - posted by le...@apache.org on 2025/01/09 06:18:29 UTC, 0 replies.
- (flink) branch master updated (5e0e5a233eb -> 96a4e90f8c3) - posted by ro...@apache.org on 2025/01/09 07:12:56 UTC, 0 replies.
- (flink) 01/04: [FLINK-36477][table] Remove deprecated method BaseExpressions#cast - posted by ro...@apache.org on 2025/01/09 07:12:57 UTC, 0 replies.
- (flink) 02/04: [FLINK-36478][table] Remove deprecated methods EnvironmentSettings#fromConfiguration and EnvironmentSettings#toConfiguration - posted by ro...@apache.org on 2025/01/09 07:12:58 UTC, 0 replies.
- (flink) 03/04: [FLINK-36480][table] Remove all deprecated methods in TableConfig - posted by ro...@apache.org on 2025/01/09 07:12:59 UTC, 0 replies.
- (flink) 04/04: [FLINK-36483][table] Remove deprecated method TableResult#getTableSchema - posted by ro...@apache.org on 2025/01/09 07:13:00 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37025] Fix generating watermarks in SQL on-periodic (#25921) - posted by dw...@apache.org on 2025/01/09 10:00:17 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36871][runtime] add rescale metrics in scheduler (#25770) - posted by mx...@apache.org on 2025/01/09 10:23:16 UTC, 0 replies.
- (flink) branch master updated (42e25939e4a -> 7597fe34dbc) - posted by za...@apache.org on 2025/01/09 12:08:24 UTC, 0 replies.
- (flink) branch master updated (7597fe34dbc -> 09750220e78) - posted by zh...@apache.org on 2025/01/09 12:29:25 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-37016] ClusterEntrypoint can be closed before initialization - posted by ch...@apache.org on 2025/01/09 13:02:25 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37016] ClusterEntrypoint can be closed before initialization - posted by ch...@apache.org on 2025/01/09 13:02:30 UTC, 0 replies.
- (flink) branch master updated (09750220e78 -> de40a756e2e) - posted by li...@apache.org on 2025/01/09 13:12:35 UTC, 0 replies.
- (flink-connector-hbase) branch main updated: [FLINK-36923] Bump Flink version to 1.20.0, adapt CI workflow - posted by fc...@apache.org on 2025/01/09 13:20:42 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37031][state/forst] Bump forstjni to 0.1.5 && make ForStFlinkFileSystem thread safe" (#25927) - posted by le...@apache.org on 2025/01/09 14:44:12 UTC, 0 replies.
- (flink) branch dependabot/maven/flink-end-to-end-tests/flink-sql-client-test/org.apache.kafka-kafka-clients-3.7.1 created (now 62ac3b56c32) - posted by gi...@apache.org on 2025/01/09 14:59:02 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36707][table] Integrate PTF type inference into Calcite - posted by tw...@apache.org on 2025/01/09 15:40:21 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37025] Fix generating watermarks in SQL on-periodic (#25921) (#25933) - posted by dw...@apache.org on 2025/01/09 17:08:40 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36740] [WebFrontend] Update frontend dependencies to address vulnerabilities (#25718) - posted by af...@apache.org on 2025/01/09 17:20:42 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36773][table] Introduce new Group Aggregate Operator with Async State API - posted by li...@apache.org on 2025/01/10 01:21:26 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][ci] Fix CI failure due to implicit conflicts - posted by le...@apache.org on 2025/01/10 02:14:57 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36946][Metrics] Optimize sink operator name truncate (#25832) - posted by fa...@apache.org on 2025/01/10 02:57:26 UTC, 0 replies.
- (flink) branch master updated (b75d76e2f94 -> 89c7c2b9c55) - posted by ju...@apache.org on 2025/01/10 05:45:57 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37024][task] Make cancel watchdog cover tasks stuck in DEPLOYING state (#25915) - posted by hu...@apache.org on 2025/01/10 08:35:10 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-37025] Fix generating watermarks in SQL on-periodic (#25921) (#25935) - posted by dw...@apache.org on 2025/01/10 08:37:47 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35325][transform] Skip insufficient_quota error when running test case using ad model. (#3849) - posted by ru...@apache.org on 2025/01/10 10:54:29 UTC, 0 replies.
- (flink) branch master updated (37c70c482a0 -> 80a79bb5f63) - posted by zh...@apache.org on 2025/01/10 11:00:42 UTC, 0 replies.
- (flink) 01/03: [FLINK-36608][runtime] Expand the adaptive graph component to support adaptive broadcast join capability. - posted by zh...@apache.org on 2025/01/10 11:00:43 UTC, 0 replies.
- (flink) 02/03: [FLINK-36608][table-runtime] Add shouldReorderInputs method to AdaptiveJoin. - posted by zh...@apache.org on 2025/01/10 11:00:44 UTC, 0 replies.
- (flink) 03/03: [FLINK-36608][table-runtime] Add AdaptiveBroadcastJoinOptimizationStrategy to support adaptive broadcast join. - posted by zh...@apache.org on 2025/01/10 11:00:45 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [hotfix][docs] Add 2025 on NOTICE - posted by gy...@apache.org on 2025/01/10 15:21:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36227] Restore compatibility with Logback 1.2 - posted by af...@apache.org on 2025/01/10 18:57:50 UTC, 0 replies.
- (flink) branch master updated (34924affa9c -> 7f1c201d92b) - posted by zh...@apache.org on 2025/01/11 10:06:08 UTC, 0 replies.
- (flink) 01/04: [hotfix][runtime] ConsumedSubpartitionContext#getConsumedShuffleDescriptorRanges should return a non-overlapping result - posted by zh...@apache.org on 2025/01/11 10:06:09 UTC, 0 replies.
- (flink) 02/04: [FLINK-36576][runtime] Introduce two correlations to allow operators to flexibly choose the data distribution algorithm - posted by zh...@apache.org on 2025/01/11 10:06:10 UTC, 0 replies.
- (flink) 03/04: [FLINK-36576][runtime] Introduce BlockingInputInfo to provide more input information for parallelism decider - posted by zh...@apache.org on 2025/01/11 10:06:11 UTC, 0 replies.
- (flink) 04/04: [FLINK-36576][runtime] Improving amount-based data balancing distribution algorithm for DefaultVertexParallelismAndInputInfosDecider - posted by zh...@apache.org on 2025/01/11 10:06:12 UTC, 0 replies.
- (flink) branch master updated (7f1c201d92b -> 78ea6ecfca2) - posted by za...@apache.org on 2025/01/12 08:13:57 UTC, 0 replies.
- (flink) 01/02: [FLINK-37089][Runtime] Avoid deadlock draining for derived async processing - posted by za...@apache.org on 2025/01/12 08:13:58 UTC, 0 replies.
- (flink) 02/02: [FLINK-37089][Runtime] Prioritize the record context and queue in order - posted by za...@apache.org on 2025/01/12 08:13:59 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37019][tests] Bump junit5 to 5.11.4 - posted by sn...@apache.org on 2025/01/12 20:28:57 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36862][table] Implement additional `TO_TIMESTAMP_LTZ` functions - posted by sn...@apache.org on 2025/01/12 20:30:50 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated: [FLINK-36009] Architecture tests refactor - posted by sn...@apache.org on 2025/01/12 23:25:13 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37083][e2e] Fix failed SqlYARNApplicationITCase on AZP (#25936) - posted by sh...@apache.org on 2025/01/13 01:33:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36494][table-common] Remove deprecated method Catalog#getTableFactory (#25948) - posted by ro...@apache.org on 2025/01/13 01:50:41 UTC, 0 replies.
- (flink) branch master updated (3a9597339a0 -> c999e7e9a5d) - posted by za...@apache.org on 2025/01/13 04:10:57 UTC, 0 replies.
- (flink) 01/03: [FLINK-37045][Runtime] Move state descriptor v2 to flink-core - posted by za...@apache.org on 2025/01/13 04:10:58 UTC, 0 replies.
- (flink) 02/03: [FLINK-37045][Runtime] Merge two versions of KeyedStateStore - posted by za...@apache.org on 2025/01/13 04:10:59 UTC, 0 replies.
- (flink) 03/03: [FLINK-37045][Runtime] Merge two versions of OperatorStateStore - posted by za...@apache.org on 2025/01/13 04:11:00 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36811][mysql] MySQL cdc setIsProcessingBacklog in snapshot phase and exit when snapshot phase finished (#3793) - posted by ru...@apache.org on 2025/01/13 06:56:10 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37012][transform] Fix argument type mismatch when metadata column used in function - posted by le...@apache.org on 2025/01/13 07:24:02 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [hotfix][docs] Typo fix in RBAC docs - posted by gy...@apache.org on 2025/01/13 08:03:52 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36610] MySQL CDC supports parsing gh-ost / pt-osc generated schema changes (#3668) - posted by go...@apache.org on 2025/01/13 08:17:01 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36865][cdc] Provide UNIX_TIMESTAMP series functions in YAML pipeline - posted by le...@apache.org on 2025/01/13 08:18:18 UTC, 0 replies.
- (flink) branch master updated (c999e7e9a5d -> 7f162dd1ff1) - posted by dw...@apache.org on 2025/01/13 08:25:19 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36964][pipeline-connector/paimon] Fix potential exception when SchemaChange in parallel with Paimon Sink - posted by le...@apache.org on 2025/01/13 08:43:36 UTC, 0 replies.
- (flink) branch master updated (7f162dd1ff1 -> 105720fc5cb) - posted by sh...@apache.org on 2025/01/13 09:13:59 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37086] Clean up should remove all autoscaler state - posted by gy...@apache.org on 2025/01/13 09:39:36 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-34194] Update CI to Ubuntu 22.04 (Jammy) (#25827) - posted by af...@apache.org on 2025/01/13 11:01:08 UTC, 0 replies.
- (flink) branch master updated (105720fc5cb -> 5df3e4a8abb) - posted by za...@apache.org on 2025/01/13 12:19:30 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35721][docs] Fix CAST compatibility table - posted by af...@apache.org on 2025/01/13 12:23:27 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36825][table] Introduce FastTop1Function in Rank with Async State API - posted by li...@apache.org on 2025/01/13 13:22:26 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36645] [flink-autoscaler] Gracefully handle null execution plan from autoscaler - posted by gy...@apache.org on 2025/01/13 14:31:35 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35721][docs] Fix CAST compatibility table - posted by af...@apache.org on 2025/01/13 15:08:11 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35721][docs] Fix CAST compatibility table - posted by af...@apache.org on 2025/01/13 15:08:52 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35512][tests] Do not depend on the `flink-clients` jar actually existing in `ArtifactFetchManagerTest` - posted by af...@apache.org on 2025/01/13 19:58:10 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35512][tests] Do not depend on the `flink-clients` jar actually existing in `ArtifactFetchManagerTest` - posted by af...@apache.org on 2025/01/13 20:01:15 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35512][tests] Do not depend on the `flink-clients` jar actually existing in `ArtifactFetchManagerTest` - posted by af...@apache.org on 2025/01/13 20:03:40 UTC, 0 replies.
- (flink-connector-hive) branch main updated (bb951091 -> e9b15d59) - posted by sn...@apache.org on 2025/01/13 21:03:30 UTC, 0 replies.
- (flink-connector-hive) 01/22: Revert "[FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18)" - posted by sn...@apache.org on 2025/01/13 21:03:31 UTC, 0 replies.
- (flink-connector-hive) 02/22: [FLINK-33905][core] Unify the provision of metadata in RuntimeContext - posted by sn...@apache.org on 2025/01/13 21:03:32 UTC, 0 replies.
- (flink-connector-hive) 03/22: [hotfix] Bump Flink to 1.19.0 - posted by sn...@apache.org on 2025/01/13 21:03:33 UTC, 0 replies.
- (flink-connector-hive) 04/22: [FLINK-33705] Upgrade to flink-shaded 18.0 - posted by sn...@apache.org on 2025/01/13 21:03:34 UTC, 0 replies.
- (flink-connector-hive) 05/22: [hotfix] Use guava instead of flink-shaded - posted by sn...@apache.org on 2025/01/13 21:03:35 UTC, 0 replies.
- (flink-connector-hive) 06/22: [FLINK-34081][configuration] Refactor all callers of deprecated `getXxx(ConfigOption)`, `getXxx(ConfigOption, Xxx)` and `setXxx(ConfigOption, Xxx)` methods of Configuration - posted by sn...@apache.org on 2025/01/13 21:03:36 UTC, 0 replies.
- (flink-connector-hive) 07/22: [FLINK-34204][core] Dispatch legacy serializer related methods in ExecutionConfig to SerializerConfig - posted by sn...@apache.org on 2025/01/13 21:03:37 UTC, 0 replies.
- (flink-connector-hive) 08/22: [FLINK-16627][json] Support ignore null fields when serializing into JSON - posted by sn...@apache.org on 2025/01/13 21:03:38 UTC, 0 replies.
- (flink-connector-hive) 09/22: [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18) - posted by sn...@apache.org on 2025/01/13 21:03:39 UTC, 0 replies.
- (flink-connector-hive) 10/22: [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory - posted by sn...@apache.org on 2025/01/13 21:03:40 UTC, 0 replies.
- (flink-connector-hive) 11/22: [FLINK-33984][runtime] Support batch snapshot for OperatorCoordinator. - posted by sn...@apache.org on 2025/01/13 21:03:41 UTC, 0 replies.
- (flink-connector-hive) 12/22: [FLINK-28048][connectors] Introduce Source API alternative to FiniteTestSource (#23777) - posted by sn...@apache.org on 2025/01/13 21:03:42 UTC, 0 replies.
- (flink-connector-hive) 13/22: [FLINK-35188][table-api] Introduce CatalogMaterializedTable interface to support materialized table - posted by sn...@apache.org on 2025/01/13 21:03:43 UTC, 0 replies.
- (flink-connector-hive) 14/22: [FLINK-29050][test-utils] Rename AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase with JUnit4 suffix. - posted by sn...@apache.org on 2025/01/13 21:03:44 UTC, 0 replies.
- (flink-connector-hive) 15/22: [FLINK-35293][hive] Hive source supports dynamic parallelism inference - posted by sn...@apache.org on 2025/01/13 21:03:45 UTC, 0 replies.
- (flink-connector-hive) 16/22: [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: core (#24881) - posted by sn...@apache.org on 2025/01/13 21:03:46 UTC, 0 replies.
- (flink-connector-hive) 17/22: [FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 (#24905) - posted by sn...@apache.org on 2025/01/13 21:03:47 UTC, 0 replies.
- (flink-connector-hive) 18/22: [FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 adapt for external connector - posted by sn...@apache.org on 2025/01/13 21:03:48 UTC, 0 replies.
- (flink-connector-hive) 19/22: [hotfix][doc] Update the Kafka DDL example in the hive catalog page to the new parameter style - posted by sn...@apache.org on 2025/01/13 21:03:49 UTC, 0 replies.
- (flink-connector-hive) 20/22: [FLINK-35656][hive] Fix the issue that Hive Source incorrectly set max parallelism in dynamic inference mode - posted by sn...@apache.org on 2025/01/13 21:03:50 UTC, 0 replies.
- (flink-connector-hive) 21/22: [hotfix] Apply 1.20.0 in github ci - posted by sn...@apache.org on 2025/01/13 21:03:51 UTC, 0 replies.
- (flink-connector-hive) 22/22: [hotfix] Dependency convergence - posted by sn...@apache.org on 2025/01/13 21:03:52 UTC, 0 replies.
- (flink) branch master updated (26436ac27ae -> 4a6f84be0b2) - posted by gu...@apache.org on 2025/01/14 01:49:29 UTC, 0 replies.
- (flink) branch master updated (4a6f84be0b2 -> 7588a4dcda5) - posted by gu...@apache.org on 2025/01/14 02:20:45 UTC, 0 replies.
- (flink) 01/04: [FLINK-34123][core] Introduce built-in serialization support for Map, List, and Collection - posted by gu...@apache.org on 2025/01/14 02:20:46 UTC, 0 replies.
- (flink) 02/04: [FLINK-34123][docs][type] Add doc for built-in serialization support for Map, List, and Collection - posted by gu...@apache.org on 2025/01/14 02:20:47 UTC, 0 replies.
- (flink) 03/04: [FLINK-35068][core] Introduce built-in serialization support for java.util.Set - posted by gu...@apache.org on 2025/01/14 02:20:48 UTC, 0 replies.
- (flink) 04/04: [FLINK-35555][core] Introduce Nullable{Map/List/Set}TypeInfo for collection type serialization with null value support - posted by gu...@apache.org on 2025/01/14 02:20:49 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36836][Autoscaler] Supports config the upper and lower limits of target utilization (#921) - posted by fa...@apache.org on 2025/01/14 02:24:42 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36310][deploy] Remove per-job mode - posted by gu...@apache.org on 2025/01/14 02:24:59 UTC, 0 replies.
- (flink) branch ngn346 deleted (was 81ea19f5b19) - posted by le...@apache.org on 2025/01/14 02:38:25 UTC, 0 replies.
- (flink) branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions deleted (was 097d4982959) - posted by le...@apache.org on 2025/01/14 02:38:41 UTC, 0 replies.
- (flink) branch fhueske-FLINK-36642-backport deleted (was 1c51e884ff5) - posted by le...@apache.org on 2025/01/14 02:38:50 UTC, 0 replies.
- (flink) branch fhueske-hotfix-add-lead_lag-table-api-agg-functions-to-docs deleted (was cb22534b7d4) - posted by le...@apache.org on 2025/01/14 02:39:03 UTC, 0 replies.
- (flink) branch fhueske-FLINK-36642-backport created (now 1c51e884ff5) - posted by le...@apache.org on 2025/01/14 02:46:33 UTC, 0 replies.
- (flink) branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions created (now 097d4982959) - posted by le...@apache.org on 2025/01/14 02:47:02 UTC, 0 replies.
- (flink) branch fhueske-hotfix-add-lead_lag-table-api-agg-functions-to-docs created (now cb22534b7d4) - posted by le...@apache.org on 2025/01/14 02:51:29 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36957][Datastream] Implement asyc state version of stream flatmap (#25848) - posted by le...@apache.org on 2025/01/14 03:11:18 UTC, 0 replies.
- (flink) branch master updated (4ae4b871c08 -> c9311756582) - posted by le...@apache.org on 2025/01/14 03:11:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36506][table] Remove all deprecated methods in ColumnStats (#25950) - posted by ro...@apache.org on 2025/01/14 03:50:33 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36985][pipeline-connector/paimon] Tolerante ColumnAlreadyExistException when apply AddColumnEvent in paimon - posted by le...@apache.org on 2025/01/14 03:50:53 UTC, 0 replies.
- (flink) branch master updated (1f6a6af327d -> 60497e7dfdd) - posted by ro...@apache.org on 2025/01/14 04:00:55 UTC, 0 replies.
- (flink) 01/02: [FLINK-36497][table] Remove deprecated method CatalogTable#of - posted by ro...@apache.org on 2025/01/14 04:00:56 UTC, 0 replies.
- (flink) 02/02: [FLINK-36497][table] Remove deprecated method CatalogTable#toProperties - posted by ro...@apache.org on 2025/01/14 04:00:57 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37108] Use-non terminal savepoint in source/sink suite - posted by ar...@apache.org on 2025/01/14 07:01:29 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37108] Use-non terminal savepoint in source/sink suite - posted by ar...@apache.org on 2025/01/14 07:01:39 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37042][pipeline-connector/maxcompute] Rename maxcompute pipieline connector options to follow flink style - posted by le...@apache.org on 2025/01/14 07:44:37 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated (66f7b42f -> cd55bdc7) - posted by fa...@apache.org on 2025/01/14 09:36:44 UTC, 0 replies.
- (flink-kubernetes-operator) 01/03: [hotfix] Refactor autoscaler related `setClock` to optimize testing - posted by fa...@apache.org on 2025/01/14 09:36:45 UTC, 0 replies.
- (flink-kubernetes-operator) 02/03: [FLINK-36863][autoscaler] Use the maximum parallelism in the past scale-down.interval window when scaling down - posted by fa...@apache.org on 2025/01/14 09:36:46 UTC, 0 replies.
- (flink-kubernetes-operator) 03/03: [FLINK-36863][autoscaler] Add the end-to-end test for delayed scale down - posted by fa...@apache.org on 2025/01/14 09:36:47 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36193][pipeline-connectors][paimon/doris/starrocks] Supports applying TRUNCATE & DROP Table Event to Paimon, StarRocks and Doris - posted by le...@apache.org on 2025/01/14 09:41:45 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36700][pipeline-connector][elasticsearch] Elasticsearch pipeline sink supports authentication - posted by le...@apache.org on 2025/01/14 09:49:51 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36739] Update the NodeJS to v22.11.0 (LTS) - posted by af...@apache.org on 2025/01/14 10:16:51 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37026] Add Stale PR GitHub Action workflow - posted by fa...@apache.org on 2025/01/14 10:48:43 UTC, 0 replies.
- (flink-benchmarks) branch master updated: [FLINK-37115] Fix compile error related with SerializerConfig (#99) - posted by za...@apache.org on 2025/01/14 10:50:56 UTC, 0 replies.
- (flink) branch master updated (fd0222041b1 -> df021354008) - posted by zh...@apache.org on 2025/01/14 11:01:41 UTC, 0 replies.
- (flink) 01/04: [FLINK-36629][table-planner] Introduce configuration options for adaptive skewed join optimization. - posted by zh...@apache.org on 2025/01/14 11:01:42 UTC, 0 replies.
- (flink) 02/04: [FLINK-36629][table-planner] Modify StreamGraphContext to provide more necessary interfaces - posted by zh...@apache.org on 2025/01/14 11:01:43 UTC, 0 replies.
- (flink) 03/04: [FLINK-36629][table-planner] Modify AdaptiveJoinProcessor to support adaptive skewed join optimization - posted by zh...@apache.org on 2025/01/14 11:01:44 UTC, 0 replies.
- (flink) 04/04: [FLINK-36629][table-planner] Introduce the AdaptiveSkewedJoinOptimizationStrategy - posted by zh...@apache.org on 2025/01/14 11:01:45 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37011][cdc-transform] Improve get source field value by column name in PreTransformProcessor - posted by le...@apache.org on 2025/01/14 11:19:11 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35634][build] Add CdcUp playground CLI scripts - posted by le...@apache.org on 2025/01/14 11:29:35 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36707][table] Add output strategy to SystemTypeInference - posted by tw...@apache.org on 2025/01/14 11:48:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36831][table] Introduce AppendOnlyTopNFunction in Rank with Async State API - posted by li...@apache.org on 2025/01/14 12:39:49 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36974][cdc-cli] Support overwrite flink configuration via command line - posted by le...@apache.org on 2025/01/14 13:37:40 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35387][cdc-connector][postgres] PG CDC source support heart beat - posted by le...@apache.org on 2025/01/14 13:39:23 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36636][transform] Supports timestamp comparison in cdc pipeline transform - posted by le...@apache.org on 2025/01/14 13:43:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36926][table] Introduce window join operator with async state api - posted by li...@apache.org on 2025/01/14 14:20:21 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36977][pipeline-connector/paimon] Apply default value when process add_column schema change envent - posted by le...@apache.org on 2025/01/14 15:52:54 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36689][Runtime/Web Frontend] Update ng-zorro-antd to v18 - posted by af...@apache.org on 2025/01/14 17:22:59 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-37108] Use-non terminal savepoint in source/sink suite - posted by ar...@apache.org on 2025/01/14 21:59:13 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37015][doc] Remove Scala contents in serialization doc - posted by gu...@apache.org on 2025/01/15 01:55:18 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36493][table-common] Remove all deprecated methods in MapView (#25566) - posted by ro...@apache.org on 2025/01/15 02:51:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36492][table-common] Remove all deprecated methods in ListView (#25565) - posted by ro...@apache.org on 2025/01/15 02:55:05 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36496][table-common] Remove deprecated method CatalogFunction#isGeneric (#25981) - posted by ro...@apache.org on 2025/01/15 02:57:42 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36741][transform] Fix the decimal precision and length lost during transform - posted by le...@apache.org on 2025/01/15 03:01:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36503][table-common] Remove deprecated method FunctionDefinitionFactory#createFunctionDefinition (#25979) - posted by ro...@apache.org on 2025/01/15 03:05:02 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36499][table-common] Remove deprecated method `SupportsProjectionPushDown#applyProjection` (#25967) - posted by ro...@apache.org on 2025/01/15 03:55:00 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36504][table-common]Remove all deprecated methods ModuleFactory (#25963) - posted by ro...@apache.org on 2025/01/15 04:06:08 UTC, 0 replies.
- (flink-connector-hive) branch main updated: [hotfix] Update dependencies - posted by sn...@apache.org on 2025/01/15 07:14:49 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/commons-net-commons-net-3.9.0 updated (c6b8b4e5 -> 7f0fdb93) - posted by gi...@apache.org on 2025/01/15 07:17:26 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was 1e7b3a1e) - posted by gi...@apache.org on 2025/01/15 07:19:32 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/org.apache.avro-avro-1.11.3 deleted (was 9f902af9) - posted by gi...@apache.org on 2025/01/15 07:20:05 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.apache.avro-avro-1.11.3 deleted (was 725b7e36) - posted by gi...@apache.org on 2025/01/15 07:20:51 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.apache.zookeeper-zookeeper-3.8.4 created (now 03923afe) - posted by gi...@apache.org on 2025/01/15 07:21:52 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.apache.zookeeper-zookeeper-3.7.2 deleted (was b3f30eb1) - posted by gi...@apache.org on 2025/01/15 07:21:54 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.eclipse.jetty-jetty-server-9.4.51.v20230217 deleted (was 8b59eb0f) - posted by gi...@apache.org on 2025/01/15 07:22:31 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.eclipse.jetty-jetty-server-9.4.55.v20240627 created (now 65d1a4c0) - posted by gi...@apache.org on 2025/01/15 07:22:36 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/commons-net-commons-net-3.9.0 updated (7f0fdb93 -> 407d2a40) - posted by sn...@apache.org on 2025/01/15 08:57:31 UTC, 0 replies.
- (flink-connector-hive) branch main updated: [hotfix] Bump commons-net:commons-net from 3.6 to 3.9.0 - posted by sn...@apache.org on 2025/01/15 09:24:50 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/commons-net-commons-net-3.9.0 deleted (was 407d2a40) - posted by gi...@apache.org on 2025/01/15 09:24:58 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/flink-connector-hive/org.apache.hadoop-hadoop-common-3.4.0 created (now bf73a4b1) - posted by gi...@apache.org on 2025/01/15 09:25:30 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/io.netty-netty-common-4.1.115.Final created (now 7b498df4) - posted by gi...@apache.org on 2025/01/15 09:25:39 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/com.nimbusds-nimbus-jose-jwt-9.37.2 created (now 9a57b2db) - posted by gi...@apache.org on 2025/01/15 09:25:45 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36740] [WebFrontend] Update frontend dependencies to address vulnerabilities (#25718) - posted by af...@apache.org on 2025/01/15 10:09:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36181] Use Java 17 by default (#25898) - posted by ma...@apache.org on 2025/01/15 11:25:32 UTC, 0 replies.
- (flink) branch master updated (997b48340d2 -> d0165dee9e0) - posted by za...@apache.org on 2025/01/15 15:15:56 UTC, 0 replies.
- (flink) 01/02: [FLINK-37130][State] An util converting future of StateIterator to Iterable - posted by za...@apache.org on 2025/01/15 15:15:57 UTC, 0 replies.
- (flink) 02/02: [FLINK-37130][table] Minor optimization of async state api usage in window join operator - posted by za...@apache.org on 2025/01/15 15:15:58 UTC, 0 replies.
- (flink) branch master updated: [hotfix][javadoc] Use correct syntax for `TRIM` in `SqlCallSyntax` javadoc - posted by sn...@apache.org on 2025/01/15 18:08:38 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37026] Fix the stale pr message formatting (#25992) - posted by fa...@apache.org on 2025/01/16 01:32:10 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37137][runtime] Fix unstable test testGenerateStreamGraphJson (#25990) - posted by ju...@apache.org on 2025/01/16 02:04:44 UTC, 0 replies.
- (flink-cdc) branch master updated (79e868b86 -> 50e6c8287) - posted by le...@apache.org on 2025/01/16 02:06:49 UTC, 0 replies.
- (flink-cdc) 01/02: [FLINK-36647][transform] Support Timestampdiff and Timestampadd function in cdc pipeline transform - posted by le...@apache.org on 2025/01/16 02:06:50 UTC, 0 replies.
- (flink-cdc) 02/02: [build][minor] Upgrade the max file length from 3k to 4k - posted by le...@apache.org on 2025/01/16 02:06:51 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34865][pipeline-connector/mysql] Support sync table and column comment - posted by le...@apache.org on 2025/01/16 02:11:34 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37124][build] Simplify logs in test cases to avoid flooding GHA outputs - posted by le...@apache.org on 2025/01/16 02:17:38 UTC, 0 replies.
- (flink) branch master updated (07ea97cd1ae -> 9da368d6cb1) - posted by za...@apache.org on 2025/01/16 03:41:16 UTC, 0 replies.
- (flink) 01/04: [FLINK-35412][Runtime] Remove `BatchCallbackRunner` - posted by za...@apache.org on 2025/01/16 03:41:17 UTC, 0 replies.
- (flink) 02/04: [FLINK-37017][Runtime] Allow buffer overdraft in async state processing - posted by za...@apache.org on 2025/01/16 03:41:18 UTC, 0 replies.
- (flink) 03/04: [FLINK-37017][Runtime] Drain in best efforts when allowing overdraft - posted by za...@apache.org on 2025/01/16 03:41:19 UTC, 0 replies.
- (flink) 04/04: [FLINK-37017][Runtime] Prevent stack overflow when draining in-flight records - posted by za...@apache.org on 2025/01/16 03:41:20 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37090][e2e] add adaptive broadcast join to e2e tpc-ds tests. (#25954) - posted by ju...@apache.org on 2025/01/16 04:04:09 UTC, 0 replies.
- (flink) branch tisonkun-patch-1 created (now eafa803ce45) - posted by ti...@apache.org on 2025/01/16 04:30:28 UTC, 0 replies.
- (flink) 01/01: [hotfix] Add homepage link to .asf.yaml - posted by ti...@apache.org on 2025/01/16 04:30:29 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37139][table-planner] Improve AdaptiveSkewedJoinOptimizationStrategy to make it effective in more scenarios (#25989) - posted by ju...@apache.org on 2025/01/16 05:00:38 UTC, 0 replies.
- (flink) branch master updated (d774cf1bdea -> b3e7f9bd972) - posted by gu...@apache.org on 2025/01/16 07:23:51 UTC, 0 replies.
- (flink) 01/03: [hotfix] Add missing generic type param for the use of PartitionedContext - posted by gu...@apache.org on 2025/01/16 07:23:52 UTC, 0 replies.
- (flink) 02/03: [FLINK-37135][API] Introduce JoinFunction, JoinType and BuiltinFuncs for Join extension in DataStream V2 - posted by gu...@apache.org on 2025/01/16 07:23:53 UTC, 0 replies.
- (flink) 03/03: [FLINK-37135][runtime] Implement Join extension for DataStream V2 - posted by gu...@apache.org on 2025/01/16 07:23:54 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36754][transform] Projection should treated as an asterisk when projection expression is empty or null - posted by le...@apache.org on 2025/01/16 07:32:31 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][pipeline-connector][maxcompute] Fix MaxCompute Pipeline Connector tests by upgrading maxcompute-emulator - posted by le...@apache.org on 2025/01/16 08:40:24 UTC, 0 replies.
- (flink-cdc) branch master updated (47e5cd6d8 -> 9ad071c1f) - posted by go...@apache.org on 2025/01/16 09:54:23 UTC, 0 replies.
- (flink-cdc) branch master updated (9ad071c1f -> 5691b7bf9) - posted by le...@apache.org on 2025/01/16 09:55:09 UTC, 0 replies.
- (flink-cdc) branch master updated (5691b7bf9 -> 087195a3a) - posted by le...@apache.org on 2025/01/16 10:03:49 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36620][cdc-cli] Add support for specifying the --flink-home parameter via an '=' character - posted by le...@apache.org on 2025/01/16 10:09:03 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36351][pipeline-connector/doris] Support the conversion of Flink TIME type to Doris String type - posted by le...@apache.org on 2025/01/16 11:24:34 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37092][e2e] Add adaptive skewed join optimization to e2e tpc-ds tests - posted by ju...@apache.org on 2025/01/16 11:30:00 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35802][pipeline-connectors/mysql] Clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method - posted by le...@apache.org on 2025/01/16 11:43:29 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35600][pipeline-connector/mysql] Add timestamp for low and high watermark - posted by le...@apache.org on 2025/01/16 11:48:38 UTC, 0 replies.
- (flink-cdc) branch master updated (2fa215e5c -> cf95dcab6) - posted by le...@apache.org on 2025/01/16 11:52:45 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix[cdc-runtime] Close MetadataApplier in SchemaRegistry when the job stops - posted by le...@apache.org on 2025/01/16 12:07:34 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36913][pipeline-connector][kafka] Introduce option to define custom mapping from upstream table id to downstream topic name - posted by le...@apache.org on 2025/01/16 12:23:42 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35067][cdc-connector][postgres] Adding metadata 'row_kind' for Postgres CDC Connector. - posted by le...@apache.org on 2025/01/16 12:59:52 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37122][build] Try to be compatible with old flink version 1.18.x - posted by le...@apache.org on 2025/01/16 13:05:07 UTC, 0 replies.
- (flink) branch master updated (ed6de585481 -> 55de8d683cc) - posted by tw...@apache.org on 2025/01/16 16:47:12 UTC, 0 replies.
- (flink-cdc) branch master updated (947dffca3 -> e81df946b) - posted by le...@apache.org on 2025/01/16 17:18:18 UTC, 0 replies.
- (flink-cdc) 01/02: [FLINK-36578][pipeline-connector/mysql] Introduce option to unify json type output between snapshot phase and binlog phase - posted by le...@apache.org on 2025/01/16 17:18:19 UTC, 0 replies.
- (flink-cdc) 02/02: [minor][ci] Set proper timeout for compile_and_test step of CI job - posted by le...@apache.org on 2025/01/16 17:18:20 UTC, 0 replies.
- (flink) branch master updated (55de8d683cc -> c4bea91284b) - posted by xt...@apache.org on 2025/01/17 01:39:04 UTC, 0 replies.
- (flink) branch tisonkun-patch-1 deleted (was eafa803ce45) - posted by ti...@apache.org on 2025/01/17 01:39:26 UTC, 0 replies.
- (flink) branch master updated (c4bea91284b -> 9a4f2895b7a) - posted by hx...@apache.org on 2025/01/17 01:39:58 UTC, 0 replies.
- (flink) branch master updated (9a4f2895b7a -> 69e67fa8ca7) - posted by gu...@apache.org on 2025/01/17 01:51:55 UTC, 0 replies.
- (flink) 01/03: [FLINK-37112][API] Introduce EventTimeWatermark definition and EventTimeWatermarkGeneratorBuilder for DataStream V2 - posted by gu...@apache.org on 2025/01/17 01:51:56 UTC, 0 replies.
- (flink) 02/03: [FLINK-37112][runtime] Process event time extension related watermarks in operator for DataStream V2 - posted by gu...@apache.org on 2025/01/17 01:51:57 UTC, 0 replies.
- (flink) 03/03: [FLINK-37112][API] Process event time extension related watermarks in EventTimeProcessFunction for DataStream V2 - posted by gu...@apache.org on 2025/01/17 01:51:58 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36293][state] make sure register is closed before verification (#25373) - posted by za...@apache.org on 2025/01/17 02:34:13 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34865][pipeline-connector/mysql] Support sync newly added table's comment - posted by le...@apache.org on 2025/01/17 02:52:36 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36927][table] Introduce slicing & one stage Window Aggregate with Async State API - posted by li...@apache.org on 2025/01/17 03:00:25 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37098] Fix selecting time attribute from a view - posted by dw...@apache.org on 2025/01/17 07:32:18 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37001][table] Remove deprecated TableEnvironmentInternal#registerTableSinkInternal method and related tests - posted by ro...@apache.org on 2025/01/17 07:54:12 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37140][runtime] Create async timer service when restore async operator (#25993) - posted by le...@apache.org on 2025/01/17 11:51:39 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36837][table] Introduce RowTimeDeduplicateFunction with Async State API - posted by li...@apache.org on 2025/01/17 12:30:33 UTC, 0 replies.
- (flink) branch release-1.20 updated: Update overview.md - posted by fh...@apache.org on 2025/01/17 13:54:55 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37098] Fix selecting time attribute from a view - posted by dw...@apache.org on 2025/01/17 14:02:43 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Fix compile error in EventTimeWatermarkHandlerTest (#26007) - posted by le...@apache.org on 2025/01/17 16:09:18 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 - posted by sn...@apache.org on 2025/01/17 17:49:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37084][python] Fix TimerRegistration concurrency issue in PyFlink (#26004) - posted by di...@apache.org on 2025/01/17 23:57:02 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37084][python] Fix TimerRegistration concurrency issue in PyFlink (#26004) - posted by di...@apache.org on 2025/01/17 23:58:18 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-37084][python] Fix TimerRegistration concurrency issue in PyFlink (#26004) - posted by di...@apache.org on 2025/01/18 00:01:09 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37164][Runtime] Speed up state v2 synchronous methods execution (#26005) - posted by za...@apache.org on 2025/01/18 03:57:00 UTC, 0 replies.
- svn commit: r74277 - in /dev/flink/flink-cdc-3.3.0-rc1: ./ flink-cdc-3.3.0-bin.tar.gz flink-cdc-3.3.0-bin.tar.gz.asc flink-cdc-3.3.0-bin.tar.gz.sha512 flink-cdc-3.3.0-src.tgz flink-cdc-3.3.0-src.tgz.asc flink-cdc-3.3.0-src.tgz.sha512 - posted by ru...@apache.org on 2025/01/18 04:56:42 UTC, 0 replies.
- (flink-cdc) annotated tag release-3.3.0-rc1 updated (6b53136c8 -> 5e4909a6a) - posted by ru...@apache.org on 2025/01/18 05:17:18 UTC, 0 replies.
- (flink) branch master updated (180d587717b -> f2460c889dd) - posted by gu...@apache.org on 2025/01/18 10:30:40 UTC, 0 replies.
- (flink) 01/02: [FLINK-37136][API] Introduce Window extension components for DataStream V2 - posted by gu...@apache.org on 2025/01/18 10:30:41 UTC, 0 replies.
- (flink) 02/02: [FLINK-37136][runtime] Implement Window extension for DataStream V2 - posted by gu...@apache.org on 2025/01/18 10:30:42 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35405][runtime] Add metrics for AsyncExecutionController (#25998) - posted by le...@apache.org on 2025/01/19 15:47:12 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37021][state/forst] Forst remote dir share checkpoint dir (#26006) - posted by le...@apache.org on 2025/01/19 15:51:42 UTC, 0 replies.
- (flink-connector-hive) branch main updated: [hotfix] Enable tests for java 11 with hive2 - posted by sn...@apache.org on 2025/01/19 21:16:08 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.apache.zookeeper-zookeeper-3.8.4 updated (03923afe -> a202487f) - posted by gi...@apache.org on 2025/01/19 21:17:03 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/io.netty-netty-common-4.1.115.Final updated (7b498df4 -> 1679efaf) - posted by gi...@apache.org on 2025/01/19 21:17:15 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/io.netty-netty-common-4.1.115.Final updated (1679efaf -> 26e4c192) - posted by sn...@apache.org on 2025/01/19 21:19:44 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/io.netty-netty-common-4.1.115.Final updated (26e4c192 -> 7ba09e35) - posted by sn...@apache.org on 2025/01/19 21:21:50 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37045] Remove useless StateDescriptor of state v2 (#26009) - posted by za...@apache.org on 2025/01/20 01:27:14 UTC, 0 replies.
- (flink) branch master updated (7964466016da -> 65705096e164) - posted by za...@apache.org on 2025/01/20 01:28:16 UTC, 0 replies.
- (flink) 01/04: [FLINK-37028][State] Hotfix the callback of asyncAdd() in Reducing/AggregatingState - posted by za...@apache.org on 2025/01/20 01:28:17 UTC, 0 replies.
- (flink) 02/04: [FLINK-37028][State] Introduce namespace wrapped state for window operator. - posted by za...@apache.org on 2025/01/20 01:28:18 UTC, 0 replies.
- (flink) 03/04: [FLINK-37028][Runtime] Implement async state version of DataStream window for tumbling/sliding - posted by za...@apache.org on 2025/01/20 01:28:19 UTC, 0 replies.
- (flink) 04/04: [FLINK-37028][Runtime] Integrate async window operator to DataStream API - posted by za...@apache.org on 2025/01/20 01:28:20 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35282][python] Upgrade Apache Beam >=2.54 (#25541) - posted by di...@apache.org on 2025/01/20 01:54:29 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37168][python] Clean up TimerRegistrationAction in unregisteredTimers list after timers are registered (#26011) - posted by di...@apache.org on 2025/01/20 05:39:56 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37168][python] Clean up TimerRegistrationAction in unregisteredTimers list after timers are registered (#26011) - posted by di...@apache.org on 2025/01/20 05:41:07 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-37168][python] Clean up TimerRegistrationAction in unregisteredTimers list after timers are registered (#26011) - posted by di...@apache.org on 2025/01/20 05:42:00 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37166] Use concurrenthashmap in flink config manager - posted by gy...@apache.org on 2025/01/20 06:53:33 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37172][table-runtime] Add logs in all existing async state ops to check if they are under async state when running - posted by li...@apache.org on 2025/01/20 07:15:29 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][build] Miscellaneous fixes on GHA workflows - posted by le...@apache.org on 2025/01/20 07:21:29 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37174][sql-client] Fix failed tests about SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp (#26018) - posted by di...@apache.org on 2025/01/20 09:56:53 UTC, 0 replies.
- (flink) branch master updated (1afe645f59fc -> 4a2535cb8ab9) - posted by ro...@apache.org on 2025/01/20 10:04:54 UTC, 0 replies.
- (flink) 01/04: [FLINK-37133][table] Fix ScriptExecutor to properly split scripts without trailing semicolon - posted by ro...@apache.org on 2025/01/20 10:04:55 UTC, 0 replies.
- (flink) 02/04: [FLINK-37133][table] Fix TestFileSystemCatalog losing scheme information when constructing table paths - posted by ro...@apache.org on 2025/01/20 10:04:56 UTC, 0 replies.
- (flink) 03/04: [FLINK-37133][table] Fix NullPointerException in EmbeddedWorkflowScheduler when closing without open - posted by ro...@apache.org on 2025/01/20 10:04:57 UTC, 0 replies.
- (flink) 04/04: [FLINK-37133][table] Support Submitting Refresh Job of Materialized Table to Yarn/K8s - posted by ro...@apache.org on 2025/01/20 10:04:58 UTC, 0 replies.
- (flink) branch master updated (4a2535cb8ab9 -> dccb782134b4) - posted by za...@apache.org on 2025/01/20 11:34:47 UTC, 0 replies.
- (flink) 01/02: [FLINK-37021][state/forst] Implement fast cp/restore for ForSt StateBackend - posted by za...@apache.org on 2025/01/20 11:34:48 UTC, 0 replies.
- (flink) 02/02: [FLINK-37021][state/forst] Leverage fast-copying of FileSystems for snapshots - posted by za...@apache.org on 2025/01/20 11:34:49 UTC, 0 replies.
- (flink) branch release-2.0 created (now dccb782134b4) - posted by gu...@apache.org on 2025/01/20 12:08:20 UTC, 0 replies.
- (flink) branch release-2.0 updated: Update for 2.0.0 - posted by gu...@apache.org on 2025/01/20 12:14:01 UTC, 0 replies.
- (flink) branch master updated (dccb782134b4 -> c065920c1c99) - posted by gu...@apache.org on 2025/01/20 12:15:02 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37176][docs] Support mac binary for setup_hugo - posted by dw...@apache.org on 2025/01/20 12:22:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36652][Formats/ORC] Upgrade Apache ORC Version to 1.9.4 (#25711) - posted by ma...@apache.org on 2025/01/20 12:29:08 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37170][ci] Removes 1.18 version from GHA nightly builds - posted by ma...@apache.org on 2025/01/20 22:46:05 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37173][build] Fix license check issue in JDK11 build - posted by gu...@apache.org on 2025/01/21 02:26:38 UTC, 0 replies.
- (flink-benchmarks) branch dev-2.0 created (now 481ff96) - posted by gu...@apache.org on 2025/01/21 04:01:42 UTC, 0 replies.
- (flink) branch master updated (cf6ba7aad53 -> 632f3fe88d6) - posted by gu...@apache.org on 2025/01/21 08:08:53 UTC, 0 replies.
- (flink) branch release-2.0 updated (12596c72bf9 -> 2dfac963567) - posted by gu...@apache.org on 2025/01/21 08:11:26 UTC, 0 replies.
- (flink) 01/02: [FLINK-37189][build] Correct version string of maven-enforcer-plugin requireJavaVersion in release profile - posted by gu...@apache.org on 2025/01/21 08:11:27 UTC, 0 replies.
- (flink) 02/02: [FLINK-37173][build] Fix license check issue in JDK11 build - posted by gu...@apache.org on 2025/01/21 08:11:28 UTC, 0 replies.
- (flink) branch master updated (632f3fe88d6 -> e000678091b) - posted by dw...@apache.org on 2025/01/21 08:12:02 UTC, 0 replies.
- (flink-cdc) annotated tag release-3.3.0 updated (6b53136c8 -> acd02ca78) - posted by ru...@apache.org on 2025/01/21 08:42:07 UTC, 0 replies.
- (flink) branch master updated (e000678091b -> 9ba5afc2605) - posted by ma...@apache.org on 2025/01/21 08:54:41 UTC, 0 replies.
- svn commit: r74327 - /dev/flink/flink-cdc-3.3.0-rc1/ /release/flink/flink-cdc-3.3.0/ - posted by le...@apache.org on 2025/01/21 09:16:18 UTC, 0 replies.
- (flink) annotated tag release-2.0.0-rc0 updated (03bcb11290d -> 14e9144db7c) - posted by gu...@apache.org on 2025/01/21 09:25:46 UTC, 0 replies.
- (flink-web) branch asf-site updated (f95c24752 -> 83e0ab92b) - posted by ru...@apache.org on 2025/01/21 09:29:00 UTC, 0 replies.
- (flink-web) 01/02: Add release announcement for Flink CDC 3.3.0 - posted by ru...@apache.org on 2025/01/21 09:29:01 UTC, 0 replies.
- (flink-web) 02/02: Rebuild website - posted by ru...@apache.org on 2025/01/21 09:29:02 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [FLINK-37190] Make Kudu `FlushMode` configurable in Flink SQL - posted by fc...@apache.org on 2025/01/21 12:47:52 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36348][test] Fix the Netty shuffle direct memory test by increase the direct memory of TM - posted by af...@apache.org on 2025/01/21 13:30:47 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36348][test] Fix the Netty shuffle direct memory test by increase the direct memory of TM - posted by af...@apache.org on 2025/01/21 13:30:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37076][table-planner] Support PTFs until ExecNode level - posted by tw...@apache.org on 2025/01/21 14:36:37 UTC, 0 replies.
- svn commit: r74336 - /release/flink/KEYS - posted by gy...@apache.org on 2025/01/21 16:15:28 UTC, 0 replies.
- (flink) branch master updated (5749a07b072 -> abbfc66c905) - posted by ju...@apache.org on 2025/01/22 02:09:52 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [FLINK-36074][Connectors/mongodb] Support insert overwrite semantics for mongodb table sink (#43) - posted by ji...@apache.org on 2025/01/22 02:33:24 UTC, 0 replies.
- svn commit: r74350 - in /dev/flink/flink-2.0.0-rc0: ./ python/ - posted by gu...@apache.org on 2025/01/22 03:04:21 UTC, 0 replies.
- svn commit: r74352 - /release/flink/KEYS - posted by le...@apache.org on 2025/01/22 03:53:33 UTC, 0 replies.
- (flink-benchmarks) branch master updated: [hotfix] Bump flink version to 2.1-SNAPSHOT - posted by za...@apache.org on 2025/01/22 04:26:07 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37035][release] Add new version 2.1 and update GHA nightly build versions - posted by gu...@apache.org on 2025/01/22 06:31:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37035][release] Build doc for release-2.0 branch - posted by gu...@apache.org on 2025/01/22 06:32:25 UTC, 0 replies.
- (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-0dbc78daaa created (now 73608a77e3f) - posted by gi...@apache.org on 2025/01/22 06:33:36 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37183][clients] Fix symbolic links not being followed in "usrlib" - posted by fc...@apache.org on 2025/01/22 06:59:41 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37183][clients] Fix symbolic links not being followed in "usrlib" - posted by fc...@apache.org on 2025/01/22 07:00:19 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-37183][clients] Fix symbolic links not being followed in "usrlib" - posted by fc...@apache.org on 2025/01/22 07:01:18 UTC, 0 replies.
- (flink-benchmarks) branch master updated: [hotfix] Bump CI to jdk17 (#102) - posted by za...@apache.org on 2025/01/22 07:10:16 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37098] Fix UnresolvedSchema of QueryOperationCatalogView - posted by dw...@apache.org on 2025/01/22 07:51:59 UTC, 0 replies.
- Error while running notifications feature from refs/heads/master:.asf.yaml in flink-cdc! - posted by Apache Infrastructure <us...@infra.apache.org> on 2025/01/22 09:17:26 UTC, 0 replies.
- (flink-cdc) branch master updated: [build] Update version to 3.4-SNAPSHOT and add release-3.3 docs - posted by le...@apache.org on 2025/01/22 09:17:26 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][docs][pipeline-connector/maxcompute] Fix maxcompute connector typo in examples section - posted by le...@apache.org on 2025/01/22 09:38:53 UTC, 0 replies.
- (flink-cdc) branch release-3.3 updated: [hotfix][docs] Fix dead links in Doris (#3878) - posted by ru...@apache.org on 2025/01/22 09:53:24 UTC, 0 replies.
- (flink) branch release-2.0 updated (2dfac963567 -> 95450ed676f) - posted by fc...@apache.org on 2025/01/22 18:51:20 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36868][state/forst] Fix the deadlock when quit forst state backend (#26053) - posted by za...@apache.org on 2025/01/23 02:23:01 UTC, 0 replies.
- (flink) branch release-2.0 updated: [BP-2.0][FLINK-36838][state/forst] Fix the deadlock when quit forst state backend (#26054) - posted by za...@apache.org on 2025/01/23 02:27:31 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][cdc][docs] Build 3.3 docs and mark it as stable (#3882) - posted by ru...@apache.org on 2025/01/23 07:00:48 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [hotfix][docs] Fix dead links in Doris (#3878) (#3885) - posted by ru...@apache.org on 2025/01/23 07:41:26 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][docs] Change docs in master to 3.4-SNAPSHOT (#3886) - posted by ru...@apache.org on 2025/01/23 07:55:48 UTC, 0 replies.
- (flink-benchmarks) branch master updated: [hotfix] Add profile to apply `--add-opens` for java17 CI (#103) - posted by za...@apache.org on 2025/01/23 08:01:36 UTC, 0 replies.
- (flink-benchmarks) branch master updated: [hotfix] Remove flink-java dependency - posted by gu...@apache.org on 2025/01/23 08:30:19 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37099][docs] Document memory/performance considerations and config possibilities for Netty4 - posted by fc...@apache.org on 2025/01/23 11:36:17 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37099][docs] Document memory/performance considerations and config possibilities for Netty4 - posted by fc...@apache.org on 2025/01/23 11:36:48 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37099][docs] Document memory/performance considerations and config possibilities for Netty4 - posted by fc...@apache.org on 2025/01/23 11:37:21 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-37099][docs] Document memory/performance considerations and config possibilities for Netty4 - posted by fc...@apache.org on 2025/01/23 11:37:42 UTC, 0 replies.
- (flink) branch release-1.19 updated (47b10b2efa7 -> 5ec21ad66ee) - posted by fc...@apache.org on 2025/01/23 17:30:59 UTC, 0 replies.
- (flink) 01/02: Revert "[FLINK-36348][test] Fix the Netty shuffle direct memory test by increase the direct memory of TM" - posted by fc...@apache.org on 2025/01/23 17:31:00 UTC, 1 replies.
- (flink) 02/02: [FLINK-37100][tests] Fix `test_netty_shuffle_memory_control.sh` with Netty4 RPC - posted by fc...@apache.org on 2025/01/23 17:31:01 UTC, 1 replies.
- (flink) branch release-1.20 updated (d46e1ada621 -> 72a32327c1b) - posted by fc...@apache.org on 2025/01/23 17:34:23 UTC, 0 replies.
- (flink) branch master updated (ea2251e843b -> b615a7e9b6a) - posted by le...@apache.org on 2025/01/24 02:11:05 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37208][Runtime] Properly notify a new key is selected for async state operators (#26063) - posted by za...@apache.org on 2025/01/24 02:30:37 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-35578][state/rocksdb] Bump frocksdbjni to 8.10.0-ververica-1.0 (#26067) - posted by le...@apache.org on 2025/01/24 02:40:00 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37196][docs] Use cp to sync local docs - posted by gu...@apache.org on 2025/01/24 03:23:28 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37196][docs] Use JDK17 to run documentation build - posted by gu...@apache.org on 2025/01/24 03:37:28 UTC, 0 replies.
- (flink) branch release-2.0 updated (9c4c3fad4b9 -> 5832b4ba098) - posted by gu...@apache.org on 2025/01/24 04:01:34 UTC, 0 replies.
- (flink) 01/02: [FLINK-37196][docs] Use cp to sync local docs - posted by gu...@apache.org on 2025/01/24 04:01:35 UTC, 0 replies.
- (flink) 02/02: [FLINK-37196][docs] Use JDK17 to run documentation build - posted by gu...@apache.org on 2025/01/24 04:01:36 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-37196][docs] Use cp to sync local docs - posted by gu...@apache.org on 2025/01/24 04:04:21 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37196][docs] Use cp to sync local docs - posted by gu...@apache.org on 2025/01/24 04:16:10 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37181][build] Fix MacOS sha256sum tool compile error - posted by gy...@apache.org on 2025/01/24 04:34:18 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37148][docs] Add documents for DataStream V2 - posted by gu...@apache.org on 2025/01/24 06:39:12 UTC, 0 replies.
- (flink) branch master updated: [hotfix] [docs] Fix code typo in task_failure_recovery.md - posted by ju...@apache.org on 2025/01/24 06:42:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36905][doc] Update Chinese doc on serialization to reflect the latest changes in Flink 2.0 - posted by gu...@apache.org on 2025/01/24 06:50:21 UTC, 0 replies.
- (flink) branch release-2.0 updated (5832b4ba098 -> 68199affe09) - posted by gu...@apache.org on 2025/01/24 06:53:38 UTC, 0 replies.
- (flink) 01/02: [FLINK-37148][docs] Add documents for DataStream V2 - posted by gu...@apache.org on 2025/01/24 06:53:39 UTC, 0 replies.
- (flink) 02/02: [FLINK-36905][doc] Update Chinese doc on serialization to reflect the latest changes in Flink 2.0 - posted by gu...@apache.org on 2025/01/24 06:53:40 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37208][Runtime] Properly notify a new key is selected for async state operators (#26068) - posted by za...@apache.org on 2025/01/24 14:29:22 UTC, 0 replies.
- (flink) branch master updated (07a2c260d45 -> 3e5b9ddc81d) - posted by ma...@apache.org on 2025/01/24 15:55:13 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37218][network] Avoid repeatedly reading the broadcast buffer from the sort-merge shuffle data file while accumulating small buffers from multiple sub-partitions. - posted by ju...@apache.org on 2025/01/24 16:26:05 UTC, 0 replies.
- (flink) branch master updated (8b6a6084903 -> ddfdd4940e9) - posted by ju...@apache.org on 2025/01/25 04:29:30 UTC, 0 replies.
- (flink) 01/03: A typo mistake on 'Configuring a State Backend' section has been fixed. - posted by ju...@apache.org on 2025/01/25 04:29:31 UTC, 0 replies.
- (flink) 02/03: Chinese document fix for same default state backend typo - posted by ju...@apache.org on 2025/01/25 04:29:32 UTC, 0 replies.
- (flink) 03/03: Fixed the statebackend keyword - Replaced jobmanager with hashmap - posted by ju...@apache.org on 2025/01/25 04:29:33 UTC, 0 replies.
- (flink) branch revert-26020-doc-patch1 created (now b209635ff64) - posted by ju...@apache.org on 2025/01/25 04:31:28 UTC, 0 replies.
- (flink) 01/03: Revert "Fixed the statebackend keyword - Replaced jobmanager with hashmap" - posted by ju...@apache.org on 2025/01/25 04:31:29 UTC, 1 replies.
- (flink) 02/03: Revert "Chinese document fix for same default state backend typo" - posted by ju...@apache.org on 2025/01/25 04:31:30 UTC, 1 replies.
- (flink) 03/03: Revert "A typo mistake on 'Configuring a State Backend' section has been fixed." - posted by ju...@apache.org on 2025/01/25 04:31:31 UTC, 1 replies.
- (flink) branch master updated (ddfdd4940e9 -> 994e20620d2) - posted by ju...@apache.org on 2025/01/25 04:36:47 UTC, 0 replies.
- (flink) branch master updated: [hotfix][doc] Fixed the statebackend keyword typo. - posted by ju...@apache.org on 2025/01/25 04:39:41 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36696] [flink-autoscaler-plugin-jdbc] Switch sql connection usages to datasource (#929) - posted by fa...@apache.org on 2025/01/26 08:59:37 UTC, 0 replies.
- [I] oseanbase default '0' [flink-cdc] - posted by "weigphf (via GitHub)" <gi...@apache.org> on 2025/01/27 01:44:17 UTC, 3 replies.
- (flink) branch master updated: Update ResourceManager.java - posted by da...@apache.org on 2025/01/27 14:47:51 UTC, 0 replies.
- Error while running notifications feature from refs/heads/master:.asf.yaml in flink! - posted by Apache Infrastructure <us...@infra.apache.org> on 2025/01/27 14:47:51 UTC, 0 replies.
- (flink) branch release-1.20 updated: [hotfix] Mark Column#rename internal - posted by af...@apache.org on 2025/01/27 16:56:45 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [FLINK-37230] Consolidate Table options - posted by fc...@apache.org on 2025/01/27 18:41:33 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37229] Add/record DELETING/DELETED lifecycle states - posted by gy...@apache.org on 2025/01/28 11:26:16 UTC, 0 replies.
- svn commit: r74499 - in /dev/flink/flink-1.19.2-rc1: ./ python/ - posted by af...@apache.org on 2025/01/28 13:51:40 UTC, 0 replies.
- (flink) annotated tag release-1.19.2-rc1 updated (7d9f0e043b4 -> 2f79c4e86eb) - posted by af...@apache.org on 2025/01/28 13:55:40 UTC, 0 replies.
- (flink) branch release-1.20 updated (035307ef355 -> a7c197ee23e) - posted by af...@apache.org on 2025/01/28 19:11:51 UTC, 0 replies.
- (flink) 01/02: [FLINK-35886][source] Exclude japi checks for the API changes - posted by af...@apache.org on 2025/01/28 19:11:52 UTC, 0 replies.
- (flink) 02/02: [hotfix] Enable @PublicEvolving japicmp checks - posted by af...@apache.org on 2025/01/28 19:11:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37214][runtime] Refactors test to use proper Executor service for the main thread - posted by ma...@apache.org on 2025/01/29 09:19:19 UTC, 0 replies.
- svn commit: r74516 - in /dev/flink/flink-1.20.1-rc1: ./ python/ - posted by af...@apache.org on 2025/01/29 11:56:23 UTC, 0 replies.
- (flink) annotated tag release-1.20.1-rc1 updated (cb1e7b5571b -> 77c52abcc3b) - posted by af...@apache.org on 2025/01/29 12:02:00 UTC, 0 replies.
- (flink) branch dependabot/maven/flink-connectors/flink-sql-connector-hive-2.3.10/org.apache.hive-hive-exec-4.0.1 created (now 73d5c097987) - posted by gi...@apache.org on 2025/01/29 19:22:18 UTC, 0 replies.
- Re: [I] 请问出现这个错误(io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4{timestamp=1627541881000,)是什么原因? [flink-cdc] - posted by "yoheimuta (via GitHub)" <gi...@apache.org> on 2025/01/30 02:40:04 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [FLINK-37237] Improve Kudu table creation based on Flink SQL `CREATE TABLE` - posted by fc...@apache.org on 2025/01/30 09:32:23 UTC, 0 replies.