commits  

Messages by Thread

• (flink) branch master updated (047c5e4ca37 -> 4f41151f08b) zhuzh
  • (flink) 01/03: [FLINK-38975][runtime] Add ApplicationStore zhuzh
  • (flink) 02/03: [FLINK-38975][runtime] Add ApplicationResultStore zhuzh
• (flink) branch master updated (c2e2b169661 -> 047c5e4ca37) lincoln
• (flink) branch release-2.2 updated: [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values fanrui
• (flink) branch release-2.1 updated: [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values fanrui
• (flink) branch master updated: [FLINK-38205][format][pb] Discard unknown fields by default (#26881) panyuepeng
• (flink) branch master updated: [FLINK-39042][webui] Make watermark timestamps timezone-aware and configurable (#27552) davidrad
• (flink) branch master updated: [hotfix][table] Suppress FileLength for BuiltInFunctionDefinitions lincoln
• (flink) branch master updated: [FLINK-39119] Package Native S3 FileSystem in Distribution gaborgsomogyi
• svn commit: r83294 - dev/flink/flink-cdc-3.6.0-rc1 kunni
• svn commit: r83293 - dev/flink/flink-cdc-3.6.0-rc1 kunni
• (flink) branch master updated: [FLINK-38988][table] Support INET_ATON and INET_NTOA functions for IP address conversion lincoln
• (flink) branch master updated: [FLINK-39053][format/avro] Support VARCHAR to ENUM conversion in avro-confluent format snuyanzin
• svn commit: r83247 - dev/flink/flink-cdc-3.6.0-rc1 kunni
• svn commit: r83246 - dev/flink/flink-cdc-3.6.0-rc1 kunni
• (flink) branch master updated: [FLINK-38261] add catalog connection resource (#27504) rmetzger
• (flink) branch master updated: [FLINK-38936][connectors/filesystem] Improve OS-Independent File Path Resolution for FileSystem Connector snuyanzin
• svn commit: r83244 - dev/flink/flink-cdc-3.6.0-rc1 kunni
• svn commit: r83243 - dev/flink/flink-cdc-3.6.0-rc1 kunni
• (flink-cdc) branch release-3.6 updated: [hotfix] Fix e2e test error for StarRocks Pipeline. kunni
• (flink-cdc) annotated tag release-3.6.0-rc1 deleted (was 3089caf69) kunni
• (flink-cdc) annotated tag release-3.6.0-rc1 updated (87a41c3a8 -> 3089caf69) kunni
  • (flink-cdc) annotated tag release-3.6.0-rc1 updated (87a41c3a8 -> 3089caf69) kunni
• svn commit: r83242 - dev/flink/flink-cdc-3.6.0-rc1 kunni
• (flink-cdc) branch release-3.6 updated: [hotfix] Fix compile error. kunni
• (flink-cdc) branch release-3.6 updated: [FLINK-38729] Add flink-cdc-flink*-compat to output t jar for source connector. kunni
• (flink-cdc) branch release-3.6 created (now 21ec4aeb5) kunni
  • (flink-cdc) 01/01: [docs] Update config.toml. kunni
• (flink-cdc) branch master updated: [FLINK-38959][postgres] Update split state's table schemas info and infer schema change event based on pgoutput plugin's relation message. (#4316) kunni
• (flink) branch master updated: [FLINK-39280][docs] Add missing State Size Tracking Options to configuration page fanrui
• (flink) branch master updated: [FLINK-39279][table] Make `CREATE OR ALTER MATERIALIZED TABLE` respect distribution snuyanzin
• (flink) branch master updated: [FLINK-39278][table] Indexing of columns in `CREATE [MATERIALIZED ]TABLE` should start with 1 in error messages snuyanzin
• (flink) branch master updated: [FLINK-39146] Update log4j to 2.25.3 snuyanzin
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/flatted-3.4.2 created (now b14721d8250) github-bot
• (flink) branch master updated: [FLINK-39229][test] Migrate tests of flink-protobuf to JUnit5 snuyanzin
• (flink-cdc) branch master updated: [FLINK-38839][runtime] Support semicolon delimiter for table-options (#4199) kunni
• (flink-cdc) branch master updated: [FLINK-39245][Iceberg] Add AWS Glue Catalog support for Iceberg pipeline connector (#4314) kunni
• (flink-cdc) branch master updated: [build] Add update_version.sh to help build connector jars with FLINK_VERSION suffix version. (#4325) kunni
• (flink) branch master updated: [FLINK-39276][table] `CREATE OR ALTER MATERIALIZED TABLE` should respect nullability defined in schema snuyanzin
• (flink-cdc) branch master updated: [FLINK-36520] MySQL CDC Supports connecting to MySQL server 8.4+ (#3666) yux
• (flink-cdc) branch master updated: [hotfix] Fix compile error (#4326) yux
• (flink-cdc) branch master updated: [FLINK-38139] Fix consecutive online schema change causes job failure (#4324) yux
• (flink-cdc) branch master updated: [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission (#4087) kunni
• (flink-cdc) branch master updated: [FLINK-37837][core] Always add create.table to include.schema.changes option (#4262) kunni
• (flink) branch master updated: [FLINK-39259][table] Support basic TO_CHANGELOG built-in process table function twalthr
• (flink-cdc) branch FLINK-38729-2 deleted (was 3240e50fa) kunni
• (flink-cdc) branch 2.x-connect-tmp-2 deleted (was 94e0a07db) kunni
• (flink-cdc) branch master updated: [FLINK-39207][mysql] Fix mysql cdc could get stuck in backfill binlog reading when reuse snapshot split reader (#4311) kunni
• (flink) branch master updated: [FLINK-39272][table] Changing of `REFRESH_MODE` for `CREATE OF ALTER MATERIALIZED TABLE` should fail snuyanzin
• (flink) branch master updated: [FLINK-38970][runtime/tests] Fix flaky AdaptiveBatchSchedulerTest by using synchronous executor without thread checks (#27660) panyuepeng
• (flink) branch master updated: [FLINK-39244][table] Support precision 0-9 for TO_TIMESTAMP_LTZ function twalthr
• (flink-connector-pulsar) branch main updated: [hotfix] Bump testcontainers version to 1.21.4 fcsaky
• (flink-agents) annotated tag release-0.2.1-rc1 updated (96b098d2 -> 1ddd1ad5) sxnan
• svn commit: r83209 - in dev/flink/flink-agents-0.2.1-rc1: . python sxnan
• (flink) branch master updated: [FLINK-39183][table] Support BITMAP type in Calcite parser lincoln
• (flink-agents) branch release-0.2 updated: [infra] Use GHA workflow triggers to run pull request labeler workflow xtsong
• (flink-agents) branch release-0.2 updated: [hotfix] Fix mismatch version. (#577) sxnan
• (flink-cdc) branch master updated: [FLINK-39149][mysql-cdc] Implement LATEST mode GTID merging to prevent replaying pre-checkpoint transactions with non-contiguous ranges (#4286) kunni
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/js-yaml-4.1.1 deleted (was 40bc84e3293) github-bot
• (flink-agents) branch release-0.2 updated (50434fd6 -> 2ace21f8) sxnan
• (flink-agents) branch release-0.2 updated (2ace21f8 -> 50434fd6) sxnan
  • (flink-agents) 01/03: [AONE-80306915] Add internal fork workflow docs sxnan
  • (flink-agents) 02/03: [AONE-80306915] Add internal maintenance scripts sxnan
  • (flink-agents) 03/03: [AONE-80306915] Switch release-0.2 to internal version scheme sxnan
• (flink-agents) branch release-0.2 updated: [infra] Update the script for sdist release (#574) sxnan
• (flink-agents) branch release-0.2 updated: [infra] Download JARs from Maven Central during pip install (#567) sxnan
• (flink-agents) branch main updated: [infra] Update the script for sdist release (#574) sxnan
• (flink) branch master updated: [FLINK-39195][Table SQL/API] ObjectPath should implement Comparable junrui
• (flink-agents) branch release-0.1 updated (df247803 -> 766f7c35) sxnan
• (flink-agents) branch release-0.1 updated (766f7c35 -> df247803) sxnan
  • (flink-agents) 02/03: [AONE-80306915] Add internal maintenance scripts sxnan
  • (flink-agents) 01/03: [AONE-80306915] Add internal fork workflow docs sxnan
  • (flink-agents) 03/03: [internal] Update version to 0.1-vvr-SNAPSHOT sxnan
• (flink) branch master updated (2fe7660c1e8 -> b3fa7a45f7e) junrui
• (flink) branch master updated: [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization junrui
• (flink-agents) branch main updated (84e065b2 -> 0b1dab7a) xtsong
  • (flink-agents) 02/02: [minor] Update fixVersion label from 'fixVersion/0.1.1' to 'fixVersion/0.1.2' xtsong
  • (flink-agents) 01/02: [infra] Use GHA workflow triggers to run pull request labeler workflow xtsong
• (flink-web) branch asf-site updated: Community blog March 2026 (#832) davidrad
• (flink) branch master updated: [FLINK-39124][JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests (#27666) panyuepeng
• (flink) branch master updated: [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values fanrui
• (flink) branch master updated: [FLINK-39124][JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests (#27665) panyuepeng
• (flink-cdc) branch master updated: [FLINK-39209][doris] Fix time data type serialiazation when sink to doris with pipeline connector (#4312) kunni
• (flink-cdc) branch 2.x-connect-tmp-2 created (now 94e0a07db) kunni
  • (flink-cdc) 01/03: Address comments. kunni
  • (flink-cdc) 03/03: Remove pipeline_e2e for 1.19. kunni
  • (flink-cdc) 02/03: Remove pipeline_e2e for 1.19. kunni
• (flink-agents) branch release-0.2 updated: [infra] Deduplicate common jar dependency to reduce wheel size (#557) sxnan
• (flink-agents) branch main updated: [infra] Download JARs from Maven Central during pip install (#567) sxnan
• (flink-cdc) branch master updated: [FLINK-39230] Transform should convert partially filtered UPDATE events to INSERT / DELETE (#4319) kunni
• (flink-connector-kafka) branch main updated: [FLINK-39238] Support watermark alignment in dynamic Kafka reader (#240) bli
• (flink-connector-kafka) branch main updated: [FLINK-39138] Update `flink-connector-parent` version to 2.0.0 fcsaky
• (flink-connector-shared-utils) branch ci_utils updated: [hotfix] Update CI for Flink Connector Parent POM 2.0 compatibility fcsaky
• (flink-cdc) branch master updated: [FLINK-38831][runtime] Route configuration support FIRST_MATCH mode (#4212) yux
• (flink-agents) branch release-0.2 updated: [feature] Support pretty-printed JSON format for FileEvent logs option (#572) sxnan
• (flink-agents) branch main updated: [feature] Support pretty-printed JSON format for FileEvent logs option (#572) sxnan
• (flink-agents-demos) branch dependabot/maven/flink-operations-agent-demo/sample-jobs/org.apache.logging.log4j-log4j-core-2.25.3 created (now 9a73b02) github-bot
• (flink-cdc) branch master updated: [FLINK-39257] Remove compatibility code for older versions of Flink (#4317) yux
• (flink) branch master updated (b7a186b4553 -> f16345aef7e) snuyanzin
• (flink-cdc) branch master updated: [FLINK-39232] Loosen transformed schema merging validation check (#4315) yux
• (flink) branch release-2.2 updated: [FLINK-39242][python] Fix error when getting columns from ResolvedSchema twalthr
• (flink) branch release-2.1 updated: [FLINK-39242][python] Fix error when getting columns from ResolvedSchema twalthr
• (flink) branch master updated: [FLINK-38998][table] Fix cascaded event time WindowAggregate does not produce data when offset is specified snuyanzin
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/core-20.3.17 deleted (was 9dd1ce17caf) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/compiler-20.3.18 created (now 9220cd847f0) github-bot
• (flink) branch master updated: [FLINK-39248][runtime] Fix RowDataKeySerializerSnapshot restore roman
• (flink-agents) branch main updated: [Feature][Java] Add OpenAI Responses API integration (#556) xtsong
• (flink-agents) branch release-0.2 updated: [hotfix] Fix Azure ChatModel class path in ResourceName. (#562) xtsong
• (flink-agents) branch main updated: [hotfix] Fix Azure ChatModel class path in ResourceName. (#562) xtsong
• (flink) branch release-2.2 updated (b5bdb239505 -> 6290979fa1a) snuyanzin
  • (flink) 02/02: [FLINK-33217][table] `UNNEST` fails with on `LEFT JOIN` with `NOT NULL` type in array snuyanzin
  • (flink) 01/02: [FLINK-38720][table] Nested nullability might lead to class cast `RexCall` cannot be cast to class `RexFieldAccess` snuyanzin
• (flink) branch release-2.2 updated: [FLINK-39162][checkpoints] Disable UC for CustomPartitioner roman
• (flink) branch master updated: [FLINK-39015][table] Fix key extractor for multi join by changing GenericRowData to BinaryRowData twalthr
• (flink) branch master updated: [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause twalthr
• (flink) branch master updated: [FLINK-39162][checkpoints] Disable UC for CustomPartitioner roman
• (flink) branch master updated (e6d7a33507e -> f71c6a16c97) xuyangzhong
• (flink-cdc) branch FLINK-38729-2 updated (2d09d68c0 -> 3240e50fa) kunni
  • (flink-cdc) 02/12: Address comments. kunni
  • (flink-cdc) 04/12: Fix CI failure. kunni
  • (flink-cdc) 10/12: Rename module to avoid using minor version. kunni
  • (flink-cdc) 06/12: Add flink-cdc-flink2.2-compat module. kunni
  • (flink-cdc) 11/12: Remove flink-cdc-pipeline-e2e-tests-2.x module. kunni
  • (flink-cdc) 07/12: Fix compile. kunni
  • (flink-cdc) 09/12: Update java doc. kunni
  • (flink-cdc) 03/12: Fix CI failure. kunni
  • (flink-cdc) 12/12: Address comment. kunni
• (flink-cdc) branch master updated: [hotfix] Fix spotless check failure (#4313) yux
• (flink-cdc) branch FLINK-38729-2 updated (41172a30f -> 2d09d68c0) kunni
• (flink-cdc) branch master updated: [FLINK-39231][test][sqlserver] Fix unstable sqlserver connector test (#4309) kunni
• (flink-cdc) branch master updated: [FLINK-38844][pipeline-connector][postgres]Add metadata column support (#4202) kunni
• (flink-cdc) branch FLINK-38729-2 updated: Remove flink-cdc-pipeline-e2e-tests-2.x module. kunni
• (flink) branch master updated: [FLINK-39242][python] Fix error when getting columns from ResolvedSchema twalthr
• (flink) branch master updated: [hotfix] Fix incorrect JavaDoc for session window assigners tangyun
• (flink-cdc) branch master updated: [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive (#4284) kunni
• (flink) branch dependabot/maven/flink-kubernetes/io.netty-netty-codec-http-4.1.127.Final-redhat-00001 deleted (was 30cb95b947d) github-bot
• (flink-connector-kafka) branch weekly-ci-test updated: remove v3.4 to test everything else fcsaky
• (flink-cdc) branch FLINK-38729-2 updated (c4247b266 -> 714021db1) kunni
• (flink-connector-elasticsearch) branch main updated: [FLINK-38373][Connectors / ElasticSearch] ES index supports fields suffix junrui
• (flink-agents-demos) branch main created (now 57a5522) sxnan
  • (flink-agents-demos) 01/01: init commit sxnan
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-d882bb14c6 deleted (was 862b30e4885) github-bot
• (flink-connector-kafka) branch weekly-ci-test created (now dcb14db1) fcsaky
  • (flink-connector-kafka) 01/01: 1.20 snapshot in weekly fcsaky
• (flink-connector-http) branch main updated: [hotfix] Fix grammar (#28) davidrad
• (flink-cdc) branch FLINK-38729-2 updated: Update java doc. kunni
• (flink-cdc) branch FLINK-38729-2 updated (e5e8b48be -> 1bfa51294) kunni
• (flink-connector-elasticsearch) branch main updated: [FLINK-38371][Connectors/ElasticSearch] Add `sink.retry-on-conflicts` option to Elasticsearch Sink (#132) junrui
• (flink-connector-http) branch main updated: [FLINK-39222] Add missing licenses fcsaky
• (flink-connector-kafka) branch main updated: [hotfix] Update weekly CI versions fcsaky
• (flink-cdc) branch master updated: [FLINK-39055][Iceberg] Support default column values in Iceberg sink connector (#4277) kunni
• (flink-cdc) branch FLINK-38729-2 updated (16c483c5a -> e5e8b48be) kunni
• (flink-cdc) branch FLINK-38729-2 updated (a3adc9d3f -> 16c483c5a) kunni
• (flink-cdc) branch FLINK-38729-2 updated (b0764446c -> a3adc9d3f) kunni
• (flink-cdc) branch FLINK-38729-2 updated (112bc35ac -> b0764446c) kunni
• (flink-cdc) branch master updated: [FLINK-38247][MySQL] Handle BIGINT UNSIGNED overflow correctly in PreparedStatement. (#4117) kunni
• (flink-cdc) branch master updated: [minor][docs][style] Update documentation link and improve code style (#3961) kunni
• (flink-cdc) branch FLINK-38729-2 updated (1d48d77d0 -> 112bc35ac) kunni
• (flink-cdc) branch FLINK-38729-2 updated (b03ff0ce4 -> 1d48d77d0) kunni
• (flink-cdc) branch master updated: [FLINK-37292] [cdc] Remove the flink-kubernetes dependencies during the packaging of flink-cdc-dist (#4024) kunni
• (flink-cdc) branch master updated: [DOC][MINOR] Update starrocks.md (#4304) kunni
• (flink-cdc) branch FLINK-38729-2 updated (abb4deed5 -> b03ff0ce4) kunni
• (flink-cdc) branch master updated: [FLINK-38160][starrocks] Add support for BINARY and VARBINARY types in StarRocks connector (#4303) kunni
• (flink-cdc) branch FLINK-38729-2 updated (bbff9719d -> abb4deed5) kunni
• (flink) branch master updated: [FLINK-38857][Model] Add docs for Triton inference model (#27490) panyuepeng
• (flink-cdc) branch master updated: [FLINK-39152][pipeline-connector][Fluss]Fix FlussConfig Utils class is not in the correct directory and should have a private instance (#4306) kunni
• (flink-cdc) branch FLINK-38729-2 updated (4e9263832 -> bbff9719d) kunni
• (flink-cdc) branch FLINK-38729-2 updated (acfb3b1af -> 4e9263832) kunni
• (flink-cdc) branch FLINK-38729-2 updated (a814a86e3 -> acfb3b1af) kunni
• (flink-cdc) branch FLINK-38729-2 updated (3ac0e1aa1 -> a814a86e3) kunni
• (flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc-sqlserver/com.microsoft.sqlserver-mssql-jdbc-11.1.0.jre8-preview deleted (was 12ee79b8) github-bot
• (flink-cdc) branch FLINK-38729-2 updated (5b4757143 -> 3ac0e1aa1) kunni
• (flink-cdc) branch FLINK-38729-2 updated (375a6221e -> 5b4757143) kunni
• (flink-connector-http) branch fix-history deleted (was e5df568) fcsaky
• (flink-connector-http) branch main updated (2991fdf -> e5df568) fcsaky
• (flink-cdc) branch FLINK-38729-2 updated (56aa2443d -> 375a6221e) kunni
• (flink) branch master updated: [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding of global aggregates fpaul
• (flink-cdc) branch FLINK-38729-2 updated (2f3e5cd12 -> 56aa2443d) kunni
• (flink-cdc) branch master updated: [FLINK-39204][pipeline-connector/fluss] Fluss yaml sink support add column at last leonard
• (flink) branch master updated (dfd785c2b3a -> 5af78e24cc0) zhuzh
• (flink-cdc) branch master updated: [FLINK-38726][fluss] Bump Fluss version to 0.9.0-incubating leonard
• (flink) branch master updated (ba95b2eb6f0 -> dfd785c2b3a) zhuzh
  • (flink) 02/03: [hotfix][runtime] Associate job with application after successful JobManagerRunner creation zhuzh
  • (flink) 01/03: [hotfix][runtime] Fix statusListeners NPE after application deserialization zhuzh
• (flink) branch release-2.2 updated: [FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers zhuzh
• (flink) branch master updated: [FLINK-38981][table] Migrate BatchPhysicalSortMergeJoinRule to java snuyanzin
• (flink) branch master updated: [FLINK-39077][table] Throw for materialized table change query operation in case of non persisted columns in schema snuyanzin
• (flink) branch master updated: [FLINK-17224][table] Support precision of `TIME` type snuyanzin
• (flink) branch master updated: [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest panyuepeng
• (flink-connector-jdbc) branch main updated: [FLINK-38850] Support PostgreSQL uuid type (#182) panyuepeng
• (flink) branch master updated: [FLINK-39199][table] `CREATE OR ALTER MATERIALIZED TABLE` doesn't support table options changes snuyanzin
• (flink-agents) branch main updated: [infra] Deduplicate common jar dependency to reduce wheel size (#557) sxnan
• (flink-cdc) branch master updated: [FLINK-37586][udf] Add support for options in user-defined functions and update related documentation (#4252) kunni
• (flink) branch master updated: [FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers zhuzh
• (flink-agents) branch main updated: [FLINK-AGENTS-524] Add Amazon OpenSearch and S3 Vectors vector store integrations (#533) xtsong
• (flink-agents) branch main updated: [integration] Add Amazon Bedrock chat model and embedding model integrations (#534) xtsong
• (flink) branch master updated: [FLINK-38832][table-planner] Push down single column when using count star (#27681) xuyangzhong
• (flink-cdc) branch master updated: [FLINK-38334][mysql] Fix MySQL CDC source stuck in INITIAL_ASSIGNING (#4278) kunni
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-d882bb14c6 created (now 862b30e4885) github-bot

• Earlier messages
• Later messages