commits  

Messages by Date

• 2025/01/13 (flink) branch master updated (1f6a6af327d -> 60497e7dfdd) ron
• 2025/01/13 (flink) 01/02: [FLINK-36497][table] Remove deprecated method CatalogTable#of ron
• 2025/01/13 (flink) 02/02: [FLINK-36497][table] Remove deprecated method CatalogTable#toProperties ron
• 2025/01/13 (flink) branch master updated: [FLINK-36506][table] Remove all deprecated methods in ColumnStats (#25950) ron
• 2025/01/13 (flink-cdc) branch master updated: [FLINK-36985][pipeline-connector/paimon] Tolerante ColumnAlreadyExistException when apply AddColumnEvent in paimon leonard
• 2025/01/13 (flink) branch master updated (4ae4b871c08 -> c9311756582) leiyanfei
• 2025/01/13 (flink) branch master updated: [FLINK-36957][Datastream] Implement asyc state version of stream flatmap (#25848) leiyanfei
• 2025/01/13 (flink) branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions created (now 097d4982959) leiyanfei
• 2025/01/13 (flink) branch fhueske-hotfix-add-lead_lag-table-api-agg-functions-to-docs created (now cb22534b7d4) leiyanfei
• 2025/01/13 (flink) branch fhueske-FLINK-36642-backport created (now 1c51e884ff5) leiyanfei
• 2025/01/13 (flink) branch fhueske-hotfix-add-lead_lag-table-api-agg-functions-to-docs deleted (was cb22534b7d4) leiyanfei
• 2025/01/13 (flink) branch fhueske-FLINK-36642-backport deleted (was 1c51e884ff5) leiyanfei
• 2025/01/13 (flink) branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions deleted (was 097d4982959) leiyanfei
• 2025/01/13 (flink) branch ngn346 deleted (was 81ea19f5b19) leiyanfei
• 2025/01/13 (flink) 02/04: [FLINK-34123][docs][type] Add doc for built-in serialization support for Map, List, and Collection guoweijie
• 2025/01/13 (flink-kubernetes-operator) branch main updated: [FLINK-36836][Autoscaler] Supports config the upper and lower limits of target utilization (#921) fanrui
• 2025/01/13 (flink) 01/04: [FLINK-34123][core] Introduce built-in serialization support for Map, List, and Collection guoweijie
• 2025/01/13 (flink) branch master updated (4a6f84be0b2 -> 7588a4dcda5) guoweijie
• 2025/01/13 (flink) 03/04: [FLINK-35068][core] Introduce built-in serialization support for java.util.Set guoweijie
• 2025/01/13 (flink) 04/04: [FLINK-35555][core] Introduce Nullable{Map/List/Set}TypeInfo for collection type serialization with null value support guoweijie
• 2025/01/13 (flink) branch master updated (26436ac27ae -> 4a6f84be0b2) guoweijie
• 2025/01/13 (flink-connector-hive) 04/22: [FLINK-33705] Upgrade to flink-shaded 18.0 snuyanzin
• 2025/01/13 (flink-connector-hive) 19/22: [hotfix][doc] Update the Kafka DDL example in the hive catalog page to the new parameter style snuyanzin
• 2025/01/13 (flink-connector-hive) 21/22: [hotfix] Apply 1.20.0 in github ci snuyanzin
• 2025/01/13 (flink-connector-hive) 17/22: [FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 (#24905) snuyanzin
• 2025/01/13 (flink-connector-hive) 08/22: [FLINK-16627][json] Support ignore null fields when serializing into JSON snuyanzin
• 2025/01/13 (flink-connector-hive) 18/22: [FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 adapt for external connector snuyanzin
• 2025/01/13 (flink-connector-hive) 13/22: [FLINK-35188][table-api] Introduce CatalogMaterializedTable interface to support materialized table snuyanzin
• 2025/01/13 (flink-connector-hive) 20/22: [FLINK-35656][hive] Fix the issue that Hive Source incorrectly set max parallelism in dynamic inference mode snuyanzin
• 2025/01/13 (flink-connector-hive) 05/22: [hotfix] Use guava instead of flink-shaded snuyanzin
• 2025/01/13 (flink-connector-hive) 07/22: [FLINK-34204][core] Dispatch legacy serializer related methods in ExecutionConfig to SerializerConfig snuyanzin
• 2025/01/13 (flink-connector-hive) 06/22: [FLINK-34081][configuration] Refactor all callers of deprecated `getXxx(ConfigOption<Xxx>)`, `getXxx(ConfigOption<Xxx>, Xxx)` and `setXxx(ConfigOption<Integer>, Xxx)` methods of Configuration snuyanzin
• 2025/01/13 (flink-connector-hive) 11/22: [FLINK-33984][runtime] Support batch snapshot for OperatorCoordinator. snuyanzin
• 2025/01/13 (flink-connector-hive) 14/22: [FLINK-29050][test-utils] Rename AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase with JUnit4 suffix. snuyanzin
• 2025/01/13 (flink-connector-hive) branch main updated (bb951091 -> e9b15d59) snuyanzin
• 2025/01/13 (flink-connector-hive) 03/22: [hotfix] Bump Flink to 1.19.0 snuyanzin
• 2025/01/13 (flink-connector-hive) 01/22: Revert "[FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18)" snuyanzin
• 2025/01/13 (flink-connector-hive) 12/22: [FLINK-28048][connectors] Introduce Source API alternative to FiniteTestSource (#23777) snuyanzin
• 2025/01/13 (flink-connector-hive) 22/22: [hotfix] Dependency convergence snuyanzin
• 2025/01/13 (flink-connector-hive) 15/22: [FLINK-35293][hive] Hive source supports dynamic parallelism inference snuyanzin
• 2025/01/13 (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 snuyanzin
• 2025/01/13 (flink-connector-hive) 09/22: [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser (#18) snuyanzin
• 2025/01/13 (flink-connector-hive) 16/22: [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: core (#24881) snuyanzin
• 2025/01/13 (flink-connector-hive) 02/22: [FLINK-33905][core] Unify the provision of metadata in RuntimeContext snuyanzin
• 2025/01/13 (flink) branch release-1.19 updated: [FLINK-35512][tests] Do not depend on the `flink-clients` jar actually existing in `ArtifactFetchManagerTest` afedulov
• 2025/01/13 (flink) branch master updated: [FLINK-35512][tests] Do not depend on the `flink-clients` jar actually existing in `ArtifactFetchManagerTest` afedulov
• 2025/01/13 (flink) branch release-1.20 updated: [FLINK-35512][tests] Do not depend on the `flink-clients` jar actually existing in `ArtifactFetchManagerTest` afedulov
• 2025/01/13 (flink) branch master updated: [FLINK-35721][docs] Fix CAST compatibility table afedulov
• 2025/01/13 (flink) branch release-1.20 updated: [FLINK-35721][docs] Fix CAST compatibility table afedulov
• 2025/01/13 (flink-kubernetes-operator) branch main updated: [FLINK-36645] [flink-autoscaler] Gracefully handle null execution plan from autoscaler gyfora
• 2025/01/13 (flink) branch master updated: [FLINK-36825][table] Introduce FastTop1Function in Rank with Async State API lincoln
• 2025/01/13 (flink) branch master updated (105720fc5cb -> 5df3e4a8abb) zakelly
• 2025/01/13 (flink) branch release-1.19 updated: [FLINK-35721][docs] Fix CAST compatibility table afedulov
• 2025/01/13 (flink) branch release-1.19 updated: [FLINK-34194] Update CI to Ubuntu 22.04 (Jammy) (#25827) afedulov
• 2025/01/13 (flink-kubernetes-operator) branch main updated: [FLINK-37086] Clean up should remove all autoscaler state gyfora
• 2025/01/13 (flink) branch master updated (7f162dd1ff1 -> 105720fc5cb) shengkai
• 2025/01/13 (flink-cdc) branch master updated: [FLINK-36964][pipeline-connector/paimon] Fix potential exception when SchemaChange in parallel with Paimon Sink leonard
• 2025/01/13 (flink) branch master updated (c999e7e9a5d -> 7f162dd1ff1) dwysakowicz
• 2025/01/13 (flink-cdc) branch master updated: [FLINK-36865][cdc] Provide UNIX_TIMESTAMP series functions in YAML pipeline leonard
• 2025/01/13 (flink-cdc) branch master updated: [FLINK-36610] MySQL CDC supports parsing gh-ost / pt-osc generated schema changes (#3668) gongzhongqiang
• 2025/01/13 (flink-kubernetes-operator) branch main updated: [hotfix][docs] Typo fix in RBAC docs gyfora
• 2025/01/12 (flink-cdc) branch master updated: [FLINK-37012][transform] Fix argument type mismatch when metadata column used in function leonard
• 2025/01/12 (flink-cdc) branch master updated: [FLINK-36811][mysql] MySQL cdc setIsProcessingBacklog in snapshot phase and exit when snapshot phase finished (#3793) ruanhang1993
• 2025/01/12 (flink) 01/03: [FLINK-37045][Runtime] Move state descriptor v2 to flink-core zakelly
• 2025/01/12 (flink) 02/03: [FLINK-37045][Runtime] Merge two versions of KeyedStateStore zakelly
• 2025/01/12 (flink) 03/03: [FLINK-37045][Runtime] Merge two versions of OperatorStateStore zakelly
• 2025/01/12 (flink) branch master updated (3a9597339a0 -> c999e7e9a5d) zakelly
• 2025/01/12 (flink) branch master updated: [FLINK-36494][table-common] Remove deprecated method Catalog#getTableFactory (#25948) ron
• 2025/01/12 (flink) branch master updated: [FLINK-37083][e2e] Fix failed SqlYARNApplicationITCase on AZP (#25936) shengkai
• 2025/01/12 (flink-connector-jdbc) branch main updated: [FLINK-36009] Architecture tests refactor snuyanzin
• 2025/01/12 (flink) branch master updated: [FLINK-36862][table] Implement additional `TO_TIMESTAMP_LTZ` functions snuyanzin
• 2025/01/12 (flink) branch master updated: [FLINK-37019][tests] Bump junit5 to 5.11.4 snuyanzin
• 2025/01/12 (flink) 02/02: [FLINK-37089][Runtime] Prioritize the record context and queue in order zakelly
• 2025/01/12 (flink) branch master updated (7f1c201d92b -> 78ea6ecfca2) zakelly
• 2025/01/12 (flink) 01/02: [FLINK-37089][Runtime] Avoid deadlock draining for derived async processing zakelly
• 2025/01/11 (flink) 02/04: [FLINK-36576][runtime] Introduce two correlations to allow operators to flexibly choose the data distribution algorithm zhuzh
• 2025/01/11 (flink) 01/04: [hotfix][runtime] ConsumedSubpartitionContext#getConsumedShuffleDescriptorRanges should return a non-overlapping result zhuzh
• 2025/01/11 (flink) branch master updated (34924affa9c -> 7f1c201d92b) zhuzh
• 2025/01/11 (flink) 03/04: [FLINK-36576][runtime] Introduce BlockingInputInfo to provide more input information for parallelism decider zhuzh
• 2025/01/10 (flink) branch master updated: [FLINK-36227] Restore compatibility with Logback 1.2 afedulov
• 2025/01/10 (flink-kubernetes-operator) branch main updated: [hotfix][docs] Add 2025 on NOTICE gyfora
• 2025/01/10 (flink) 03/03: [FLINK-36608][table-runtime] Add AdaptiveBroadcastJoinOptimizationStrategy to support adaptive broadcast join. zhuzh
• 2025/01/10 (flink) 02/03: [FLINK-36608][table-runtime] Add shouldReorderInputs method to AdaptiveJoin. zhuzh
• 2025/01/10 (flink) 01/03: [FLINK-36608][runtime] Expand the adaptive graph component to support adaptive broadcast join capability. zhuzh
• 2025/01/10 (flink) branch master updated (37c70c482a0 -> 80a79bb5f63) zhuzh
• 2025/01/10 (flink-cdc) branch master updated: [FLINK-35325][transform] Skip insufficient_quota error when running test case using ad model. (#3849) ruanhang1993
• 2025/01/10 (flink) branch release-1.19 updated: [FLINK-37025] Fix generating watermarks in SQL on-periodic (#25921) (#25935) dwysakowicz
• 2025/01/10 (flink) branch master updated: [FLINK-37024][task] Make cancel watchdog cover tasks stuck in DEPLOYING state (#25915) huweihua
• 2025/01/09 (flink) branch master updated (b75d76e2f94 -> 89c7c2b9c55) junrui
• 2025/01/09 (flink) branch master updated: [FLINK-36946][Metrics] Optimize sink operator name truncate (#25832) fanrui
• 2025/01/09 (flink-cdc) branch master updated: [hotfix][ci] Fix CI failure due to implicit conflicts leonard
• 2025/01/09 (flink) branch master updated: [FLINK-36773][table] Introduce new Group Aggregate Operator with Async State API lincoln
• 2025/01/09 (flink) branch release-1.20 updated: [FLINK-37025] Fix generating watermarks in SQL on-periodic (#25921) (#25933) dwysakowicz
• 2025/01/09 (flink) branch dependabot/maven/flink-end-to-end-tests/flink-sql-client-test/org.apache.kafka-kafka-clients-3.7.1 created (now 62ac3b56c32) github-bot
• 2025/01/09 (flink) branch master updated: [FLINK-37031][state/forst] Bump forstjni to 0.1.5 && make ForStFlinkFileSystem thread safe" (#25927) leiyanfei
• 2025/01/09 (flink-connector-hbase) branch main updated: [FLINK-36923] Bump Flink version to 1.20.0, adapt CI workflow fcsaky
• 2025/01/09 (flink) branch master updated (09750220e78 -> de40a756e2e) lincoln
• 2025/01/09 (flink) branch release-1.20 updated: [FLINK-37016] ClusterEntrypoint can be closed before initialization chesnay
• 2025/01/09 (flink) branch release-1.19 updated: [FLINK-37016] ClusterEntrypoint can be closed before initialization chesnay
• 2025/01/09 (flink) branch master updated (7597fe34dbc -> 09750220e78) zhuzh
• 2025/01/09 (flink) branch master updated (42e25939e4a -> 7597fe34dbc) zakelly
• 2025/01/09 (flink) branch master updated: [FLINK-36871][runtime] add rescale metrics in scheduler (#25770) mxm
• 2025/01/09 (flink) branch master updated: [FLINK-37025] Fix generating watermarks in SQL on-periodic (#25921) dwysakowicz
• 2025/01/08 (flink) 04/04: [FLINK-36483][table] Remove deprecated method TableResult#getTableSchema ron
• 2025/01/08 (flink) 02/04: [FLINK-36478][table] Remove deprecated methods EnvironmentSettings#fromConfiguration and EnvironmentSettings#toConfiguration ron
• 2025/01/08 (flink) branch master updated (5e0e5a233eb -> 96a4e90f8c3) ron
• 2025/01/08 (flink) 03/04: [FLINK-36480][table] Remove all deprecated methods in TableConfig ron
• 2025/01/08 (flink) 01/04: [FLINK-36477][table] Remove deprecated method BaseExpressions#cast ron
• 2025/01/08 (flink-cdc) branch master updated: [FLINK-36970][cdc-common] Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING leonard
• 2025/01/08 (flink-cdc) branch master updated: [FLINK-36981][transform] Considering sharding tables with different schema in transform projection leonard
• 2025/01/08 (flink-cdc) branch master updated: [FLINK-36956][transform] Append NOT NULL attribute for Primary Key columns leonard
• 2025/01/08 (flink-cdc) branch master updated: [FLINK-36877][pipeline-connector/kafka] Correct canal-json output for delete record leonard
• 2025/01/08 (flink-cdc) branch master updated: [FLINK-36524][pipeline-connector][paimon] Bump Paimon version to 0.9.0 leonard
• 2025/01/08 (flink) branch release-1.20 updated: [FLINK-37014][docs] Fix typo in materialized table doc (#25904) (#25926) ron
• 2025/01/08 (flink) 03/04: [FLINK-36994][table] Support executing ALTER MATERIALIZED TABLE AS operation ron
• 2025/01/08 (flink) 01/04: [FLINK-36994][table] Support parsing ALTER MATERIALIZED TABLE AS statement ron
• 2025/01/08 (flink) 04/04: [FLINK-36994][table] Fix expand sql error when materialized table creation with UDTF queries ron
• 2025/01/08 (flink) branch master updated (329ad1e22b6 -> 5e0e5a233eb) ron
• 2025/01/08 (flink) 02/04: [FLINK-36994][table] Support converting ALTER MATERIALIZED TABLE AS node to operation ron
• 2025/01/08 (flink) branch release-1.20 updated: [FLINK-36227] Restore compatibility with Logback 1.2 (#25813) afedulov
• 2025/01/08 (flink) branch release-1.20 updated (bcc44d2d3b8 -> 294840a444c) snuyanzin
• 2025/01/08 (flink) branch release-1.19 updated: [FLINK-36941][docs] Update `DATE_FORMAT` Doc and Python Tests snuyanzin
• 2025/01/08 (flink) branch master updated (d5ee2988da1 -> 329ad1e22b6) ron
• 2025/01/08 (flink) branch master updated: [FLINK-37014][docs] Fix typo in materialized table doc (#25904) ron
• 2025/01/08 (flink) branch master updated: [FLINK-36486] [table-api] Remove deprecated methods StreamTableEnvironment#registerDataStream ron
• 2025/01/08 (flink) branch master updated: [FLINK-37016] ClusterEntrypoint can be closed before initialization chesnay
• 2025/01/08 (flink) branch master updated: [FLINK-36507][table-common] Remove the deprecated method LogicalTypeParser#parse (#25909) ron
• 2025/01/08 (flink) branch master updated: [FLINK-36968][table-planner] Deduplicate data with the same pk in values lookup table used for testing (#25864) shengkai
• 2025/01/07 (flink-cdc) branch master updated: [hotfix][cdc-common] Remove duplicated code to improve performance leonard
• 2025/01/07 (flink-cdc) branch master updated: [hotfix][k8s] Fix command-line option `from-savepoint` does not work in K8s deployment mode leonard
• 2025/01/07 (flink) branch master updated (9720dcccc9e -> 75c26e8c9fd) guoweijie
• 2025/01/07 (flink) branch master updated: [FLINK-37010][Runtime] Unify KeyedProcessFunction and the async one (#25901) zakelly
• 2025/01/07 (flink) branch master updated: [FLINK-36950][table] Migrate WindowPropertiesRules to java snuyanzin
• 2025/01/07 (flink) branch master updated (503ad9b7b8e -> 58047a8eb12) snuyanzin
• 2025/01/07 (flink) 01/02: [FLINK-37007][table] Add missing createView methods to TableEnvironment snuyanzin
• 2025/01/07 (flink) branch master updated (ae7184bd222 -> 503ad9b7b8e) snuyanzin
• 2025/01/07 (flink) 02/02: [hotfix][docs] Add python docs for `create_table`/`create_temporary_table` snuyanzin
• 2025/01/07 (flink) branch release-1.20 updated: [FLINK-36739] Update the NodeJS to v22.11.0 (LTS) afedulov
• 2025/01/07 (flink) branch master updated (4a8b8c03e3a -> ae7184bd222) junrui
• 2025/01/07 (flink) branch master updated: [FLINK-36760][sql-client] Supports to deploy script via sql client (#25754) shengkai
• 2025/01/07 (flink-cdc) branch master updated: [hotfix][docs] Add missed enumeration in MySQL Source leonard
• 2025/01/06 (flink) branch master updated (f0c8f18ee09 -> 734491625b2) ron
• 2025/01/06 (flink) branch master updated: [FLINK-22091][yarn] Make Flink on YARN honor env.java.home (#25877) zjureel
• 2025/01/06 (flink) branch release-1.19 updated: [FLINK-28091][tests] Replaces ForkJoinPool by TestExecutorExtension mapohl
• 2025/01/06 (flink) branch release-1.20 updated: [FLINK-28091][tests] Replaces ForkJoinPool by TestExecutorExtension mapohl
• 2025/01/06 (flink-cdc) branch master updated: [FLINK-36790][cdc-connector][paimon] Set waitCompaction to true in PaimonWriter to avoid CME problem leonard
• 2025/01/06 (flink) branch master updated: [FLINK-36935][state/forst] Implement fast link for ForStFileSystem (#25818) leiyanfei
• 2025/01/06 (flink) branch master updated: [FLINK-28091][tests] Replaces ForkJoinPool by TestExecutorExtension mapohl
• 2025/01/06 (flink-web) branch asf-site updated: Update blogpost for Prometheus connector dannycranmer
• 2025/01/05 (flink) branch master updated: [FLINK-36989][runtime] Fix scheduler benchmark regression caused by ConsumedSubpartitionContext zhuzh
• 2025/01/05 (flink) branch release-1.19 updated: [FLINK-33571][table] Upgrade json-path from 2.7.0 to 2.9.0 afedulov
• 2025/01/05 (flink) branch release-1.19 updated: [FLINK-36593][runtime] Backport io.airlift:aircompressor upgrade to 0.27 afedulov
• 2025/01/04 (flink) branch master updated: [FLINK-36759][sql-gateway] Add REST API to deploy script in application mode (#25730) shengkai
• 2025/01/04 (flink) branch master updated: [FLINK-36007][table] Apply changes from FLINK-36277 to AdaptiveJoin snuyanzin
• 2025/01/03 (flink) branch release-1.20 updated: [FLINK-34194] Update CI to Ubuntu 22.04 (Jammy) (#25827) mapohl
• 2025/01/03 (flink) branch danderson-hotfix-mr-docs deleted (was f6f062d61af) danderson
• 2025/01/03 (flink) branch master updated: [hotfix][docs] In match_recognize docs, remove extracting time attributes from list of limitations danderson
• 2025/01/03 (flink) branch master updated (ea1055683f5 -> bbbd160ca79) ron
• 2025/01/02 (flink-connector-elasticsearch) branch v3.1 updated: [FLINK-36987][docs] Correct the docs to the active ES table connector (#114) tangyun
• 2025/01/02 (flink-connector-elasticsearch) branch v3.0 updated: [FLINK-36987][docs] Correct the docs to the active ES table connector (#114) tangyun
• 2025/01/02 (flink-connector-elasticsearch) branch main updated: [FLINK-36987][docs] Correct the docs to the active ES table connector (#114) tangyun
• 2025/01/02 (flink-cdc) branch master updated: [hotfix][tests] Fix unstable `OceanBaseMySQLModelITCase` (#3831) ruanhang1993
• 2025/01/02 (flink) branch master updated (4263ad3ed43 -> ea1055683f5) ron
• 2025/01/02 (flink) branch master updated: [FLINK-36484] [table-api] Remove deprecated methods StreamTableEnvironment#registerFunction (#25529) ron
• 2025/01/02 (flink) 01/02: [FLINK-36850][streaming-java] Support IntermediateDataSetID generated from source JobVertexID and consumer stream node id. zhuzh
• 2025/01/02 (flink) 02/02: [FLINK-36850][runtime] Disable adaptive batch execution when batch job progress recovery is enabled. zhuzh
• 2025/01/02 (flink) branch master updated (49d0a759ada -> fafd86cd648) zhuzh
• 2025/01/02 (flink) 01/03: [FLINK-36607][table-planner] Introduce configuration options for adaptive broadcast join. zhuzh
• 2025/01/02 (flink) 02/03: [FLINK-36607][table-planner] Introduce ExecNode for adaptive join. zhuzh
• 2025/01/02 (flink) 03/03: [FLINK-36607][table-planner] Introduce AdaptiveJoinProcessor to inject adaptive join node. zhuzh
• 2025/01/02 (flink) branch master updated (c3daf84d551 -> 49d0a759ada) zhuzh
• 2025/01/02 (flink) branch master updated: [FLINK-36269][python] Remove usage about TableEnvironmentInternal#fromTableSource in python module (#25322) hxb
• 2025/01/02 (flink) branch master updated (4952b58d27b -> b700f1c2dec) shengkai
• 2025/01/02 (flink) branch release-1.20 updated (d61126a8a7d -> 6ce145b98ac) afedulov
• 2025/01/02 (flink) branch master updated (73afb6e636c -> 4952b58d27b) zakelly
• 2025/01/01 (flink) branch master updated: [FLINK-36491][table-common] Remove the deprecated method in DataStreamSinkProvider (#25564) ron
• 2025/01/01 (flink) branch master updated: [FLINK-36490][table-common] Remove the deprecated method in DataStreamScanProvider (#25563) ron
• 2025/01/01 (flink) branch danderson-hotfix-mr-docs created (now f6f062d61af) danderson
• 2025/01/01 (flink) 01/01: [hotfix][docs] In match_recognize docs, remove extracting time attributes from list of limitations danderson
• 2024/12/31 (flink) branch master updated: [FLINK-36961][state/forst] Wait ForSt state excutor shutdown when disposing (#25854) leiyanfei
• 2024/12/30 Re: [I] There is a bug in non-standard timestamp values [flink-cdc] via GitHub
• 2024/12/30 Re: [I] There is a bug in non-standard timestamp values [flink-cdc] via GitHub
• 2024/12/30 [I] There is a bug in non-standard timestamp values [flink-cdc] via GitHub
• 2024/12/27 (flink) branch master updated: [FLINK-36069][runtime/rest] Extending job detail rest API to expose json stream graph junrui
• 2024/12/27 Re: [I] Flink CDC Issue Management（Flink CDC Issue 管理指南） [flink-cdc] via GitHub
• 2024/12/27 Re: [I] Flink CDC Issue Management（Flink CDC Issue 管理指南） [flink-cdc] via GitHub
• 2024/12/27 (flink) branch master updated: [FLINK-36951][table] Migrate ProjectSemiAntiJoinTransposeRule to java snuyanzin
• 2024/12/27 (flink) branch master updated: [FLINK-36954][table] Migrate CalcRankTransposeRule to java snuyanzin
• 2024/12/27 (flink) branch master updated (9b12ec0fbde -> 59ef8d6af85) snuyanzin
• 2024/12/27 (flink) branch master updated (60b23d11cb9 -> 9b12ec0fbde) snuyanzin
• 2024/12/27 (flink) branch master updated: [FLINK-34675][table] Migrate AggregateReduceGroupingRule to java snuyanzin
• 2024/12/27 (flink) branch master updated: [hotfix][docs] Fix typo in Amazon S3 Access Credential snuyanzin
• 2024/12/27 (flink) branch master updated: [FLINK-36966][tests] Bump mockito to 5.14.2 snuyanzin
• 2024/12/27 (flink-cdc) branch master updated: [build][hotfix] Allow pinning issues & PRs that never decay leonard
• 2024/12/26 (flink) 02/02: [FLINK-36880][network] Hybrid shuffle supports job master failover if only external tier used. guoweijie
• 2024/12/26 (flink) branch master updated (dacb848f84f -> 3f247042fa8) guoweijie
• 2024/12/26 (flink) 01/02: [FLINK-36880][network] Handle the finished vertex in InputConsumableDecider guoweijie
• 2024/12/26 Re: [I] Flink CDC Issue Management（Flink CDC Issue 管理指南） [flink-cdc] via GitHub
• 2024/12/26 Re: [I] Flink CDC Issue Management（Flink CDC Issue 管理指南） [flink-cdc] via GitHub
• 2024/12/26 Re: [I] Why test taskContext.getSourceConfig().isScanNewlyAddedTableEnabled() in IncrementalSourceStreamFetcher‘s method shouldEmit [flink-cdc] via GitHub

• Earlier messages
• Later messages