commits  

Messages by Thread

• (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
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-98109dc53c deleted (was 41211bd2974) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/immutable-5.1.5 created (now c4d1f048acc) github-bot
• (flink-connector-mongodb) branch v1.2 updated: [FLINK-36595][docs] Fix docs data file fcsaky
• (flink-connector-mongodb) branch main updated: [hotfix] Fix test-case failure for Flink 2.2 support fcsaky
• (flink-connector-http) branch fix-history created (now e5df568) fcsaky
  • (flink-connector-http) 04/04: [hotfix] Add `.asf.yaml` fcsaky
  • (flink-connector-http) 03/04: [hotfix] Fix typos in constants, Javadoc, and documentation fcsaky
  • (flink-connector-http) 02/04: [hotfix] Doc typo fix fcsaky
  • (flink-connector-http) 01/04: [hotfix] Fix typos in docs fcsaky
• (flink) branch master updated: [FLINK-39201] Add test coverage for null values and error constraint fpaul
• (flink-connector-mongodb) branch dependabot/maven/org.assertj-assertj-core-3.27.7 deleted (was b19a109) fcsaky
• (flink-connector-mongodb) branch main updated: Bump org.assertj:assertj-core from 3.21.0 to 3.27.7 (#60) fcsaky
• (flink-connector-mongodb) branch main updated: [FLINK-39098] Bump testcontainers version to 1.21.4 fcsaky
• (flink-connector-mongodb) branch dependabot/maven/org.assertj-assertj-core-3.27.7 updated (bd9a9f9 -> b19a109) github-bot
• [I] 请问flinkcdc最新版支持集成到flink2.2.0版本吗 [flink-cdc] via GitHub
  • Re: [I] 请问flinkcdc最新版支持集成到flink2.2.0版本吗 [flink-cdc] via GitHub
  • Re: [I] 请问flinkcdc最新版支持集成到flink2.2.0版本吗 [flink-cdc] via GitHub
• (flink) branch master updated (6278f7ac267 -> ebaa7b8420b) fanrui
  • (flink) 02/05: [FLINK-39140][test] Allow multiple rescales in Unaligned Checkpoint ITCases to perform checkpointing during recovery fanrui
  • (flink) 01/05: [FLINK-39140][test] Disable CUSTOM_PARTITIONER in unaligned checkpoint it case since it does not work well fanrui
  • (flink) 04/05: [FLINK-39140][test] Change record type from Long to String in UnalignedCheckpointRescaleWithMixedExchangesITCase fanrui
  • (flink) 05/05: [hotfix][runtime] Including task name and subtask index into channel-state-unspilling thread name fanrui
  • (flink) 03/05: [FLINK-39140][test] Fix MAX_RETAINED_CHECKPOINTS not effective in UnalignedCheckpointRescaleWithMixedExchangesITCase fanrui
• (flink-cdc) branch master updated: [FLINK-38833][paimon] Shuffle record to different subtasks by table, partition and bucket. (#4298) kunni
• (flink) branch master updated (9da78118bee -> 6278f7ac267) martijnvisser
  • (flink) 02/03: [FLINK-39181][ci] Scope shade plugin DEBUG logging to compile step martijnvisser
  • (flink) 03/03: [hotfix][runtime] Guard DEBUG log calls with isDebugEnabled in ZooKeeperLeaderRetrievalDriver martijnvisser
  • (flink) 01/03: [hotfix][ci] Disable DEBUG logging for ZooKeeper and leader election in tests martijnvisser
• (flink-agents) branch release-0.2 updated: [hotfix][mcp] Skip listPrompts for MCP servers without prompt support (#539) xtsong
• (flink-agents) branch main updated: [hotfix][mcp] Skip listPrompts for MCP servers without prompt support (#539) xtsong
• (flink-agents) branch release-0.2 updated: [FLINK-AGENTS] Fix MCPTool deserialization: add @JsonIgnore on Tool getters per review feedback (#532) xtsong
• (flink-agents) branch main updated: [FLINK-AGENTS] Fix MCPTool deserialization: add @JsonIgnore on Tool getters per review feedback (#532) xtsong
• (flink-connector-jdbc) branch main updated: [FLINK-38851] Support passing arbitrary database options to JDBC Catalog (#183) panyuepeng
• (flink-cdc) branch master updated: [chore][test] Fix flaky postgres pipeline test case (#4293) kunni
• (flink) branch master updated: [FLINK-39201] Skip null values during length enforcement fpaul
• (flink) branch master updated: [FLINK-38263][table] Add SecretStore related interfaces twalthr
• (flink-connector-http) annotated tag v1.0.0-rc1 updated (ca4a9bc -> beee93a) davidrad
• (flink) branch master updated: [FLINK-38866][flink-table-planner] Passing timestamp precision to window operators to respect BinaryRowData non-compact timestamp form snuyanzin
• (flink-cdc) branch master updated: [FLINK-37485][starrocks] Add support for TIME type (#4253) kunni
• svn commit: r82827 - dev/flink/flink-connector-http-1.0.0-rc1 davidrad
• (flink) branch master updated: [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API (#27580) weizhong
• (flink) branch release-1.20 updated: [FLINK-39022][security] Set security.ssl.algorithms default value to modern cipher suite gaborgsomogyi
• (flink) branch master updated: [FLINK-27661][Runtime / Metrics] PrometheusPushGatewayReporter support pushgateway http authentication (#27576) junrui
• (flink) branch master updated: [FLINK-38971][table] Migrate ExpandWindowTableFunctionTransposeRule to java snuyanzin
• (flink) branch release-2.1 updated: [FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule snuyanzin
• (flink) branch release-2.0 updated: [FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule snuyanzin
• (flink) branch release-2.2 updated: [FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule snuyanzin
• (flink-kubernetes-operator) branch main updated: [FLINK-33634] Add Conditions to Flink CRD's Status field (#1064) davidrad
• (flink-cdc) branch FLINK-38729-2 created (now 2f3e5cd12) kunni
• (flink-cdc) branch FLINK-38729-2 deleted (was 761e1a22f) kunni
• (flink) branch master updated: [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() twalthr
• (flink-cdc) branch FLINK-38729-2 created (now 761e1a22f) kunni
  • (flink-cdc) 02/02: [FLINK-38729] Add support for Flink 2.2.0 kunni
• (flink-connector-http) branch main updated (12eb058 -> 2991fdf) davidrad
  • (flink-connector-http) 01/01: Merge pull request #27 from Ami-Thomas/fix/typos-constants-javadoc-docs davidrad
• (flink) branch release-2.0 updated: [FLINK-39022][security] Set security.ssl.algorithms default value to modern cipher suite gaborgsomogyi
• (flink) branch release-2.1 updated: [FLINK-39022][security] Set security.ssl.algorithms default value to modern cipher suite gaborgsomogyi
• (flink) branch release-2.2 updated: [FLINK-39022][security] Set security.ssl.algorithms default value to modern cipher suite gaborgsomogyi
• (flink-agents) branch main updated: [Feature][Java] Added retries to remote calls in MCP server (#531) xtsong
• (flink-agents) branch main updated: [infra] Support python 3.12. (#554) xtsong
• (flink-agents) branch main updated: [hotfix][mcp][python] Check whether mcp server supports prompts via server capabilities (#551) xtsong
• (flink-connector-kafka) branch main updated: [hotfix] Revert [FLINK-38869] InitializationContext for KafkaSubscriber leonard
• (flink-connector-http) branch main updated (e9bc502 -> 12eb058) davidrad
  • (flink-connector-http) 01/01: Merge pull request #26 from atpugtihsrah/docs-typos-u0aeb7zcip davidrad
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/core-20.3.17 created (now 9dd1ce17caf) github-bot
• (flink) branch dependabot/maven/flink-models/flink-model-triton/com.fasterxml.jackson.core-jackson-core-2.18.6 created (now 3ffd8cf368e) github-bot
• (flink) branch master updated: [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling martijnvisser
• (flink-kubernetes-operator) branch main updated: Install yamale to allow linting to work (#1067) davidrad
• (flink) branch master updated: [FLINK-34644][runtime] Fix race condition in RestServerEndpoint shutdown (#27708) martijnvisser
• (flink) branch master updated: [FLINK-39041][docs] Rebuild REST API docs pages to supplement the missing content. panyuepeng
• (flink) branch master updated (3cf73f3d809 -> 9b7c95c8e0a) zhuzh
  • (flink) 02/02: [FLINK-38977][ui] Expose exceptions for applications zhuzh
  • (flink) 01/02: [FLINK-38977][runtime] Expose exceptions for applications zhuzh
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-f5f34deeac created (now cec1ce0ddcf) github-bot
• (flink) branch master updated: [FLINK-39164][history] Fix HistoryServerTest by adding delay to avoid identical archive timestamps zhuzh
• (flink-connector-http) branch main updated (1b26ab2 -> e9bc502) davidrad
  • (flink-connector-http) 01/01: Merge pull request #25 from mariyageorge01/fix-readme-typo davidrad
• (flink-cdc) branch master updated: [ci] Fix docker environment related test failure (#4275) kunni
• (flink-cdc) branch master updated: [Minor][FLINK-39168][cdc-connector-mysql] Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: (#4288) kunni
• (flink-cdc) branch master updated: [FLINK-39071] Select fields rather * to read snapshot data in case schema changes. (#4273) kunni
• (flink-kubernetes-operator) branch main updated: [FLINK-39177] Enable Flink 2.2 tests and bump example flink versions gyfora
• (flink) branch master updated: [FLINK-38892][runtime/rest] Introduce the scheduler and type information of the target job in the JobDetails(Info).java (#27544) weizhong
• (flink) branch master updated (4e383d6a692 -> f6fffd7d33f) roman
  • (flink) 02/02: [hotfix][runtime] Log watermark alignment duration (and all other stages) roman
  • (flink) 01/02: [FLINK-39167][runtime] Initialize source output before emitting final watermark roman
• (flink) branch master updated: [FLINK-39134][test] Fix UnalignedCheckpointFailureHandlingITCase roman
• (flink) branch master updated: [FLINK-39158][runtime/test] Minor polish for RestAPIStabilityTestUtils to reduce redundant lines panyuepeng
• (flink) branch master updated: [FLINK-38613][tests] Force number of splits in UnalignedCheckpointRescaleWithMixedExchangesITCase roman
• (flink) branch master updated: [FLINK-39022][security] Set security.ssl.algorithms default value to modern cipher suite gaborgsomogyi
• (flink) branch release-1.20 updated: [FLINK-38585][python] Fix python env set in Pyflink's thread mode when using shipped venv.zip archive dianfu
• (flink) branch release-2.1 updated: [FLINK-38585][python] Fix python env set in Pyflink's thread mode when using shipped venv.zip archive dianfu
• (flink) branch release-2.2 updated: [FLINK-38585][python] Fix python env set in Pyflink's thread mode when using shipped venv.zip archive dianfu
• (flink) branch master updated: [FLINK-38585][python] Fix python env set in Pyflink's thread mode when using shipped venv.zip archive dianfu
• (flink-connector-http) branch main updated: [hotfix] Fix doc typos fcsaky
• (flink) branch master updated: [FLINK-39155] Validate watermarks are available when using ON CONFLICT DO ERROR/NOTHING (#27687) dwysakowicz
• (flink) branch release-2.0 updated: [Hotfix] Update lz4-java to 1.10.3 pnowojski
• (flink-kubernetes-operator) branch main updated: [hotfix] Fix typo in AggregatedMetric string representation gyfora
• (flink) branch release-2.2 updated: [FLINK-39130][metrics] Allow native types in MetricConfig fanrui
• (flink) branch release-2.1 updated: [FLINK-39130][metrics] Allow native types in MetricConfig fanrui
• (flink) branch master updated: [FLINK-39161][table] Port fix for `INTERVAL ... WEEK, QUARTER` from Calcite snuyanzin
• (flink-cdc) branch FLINK-38729-2 deleted (was cb27d5acf) kunni
• (flink-cdc) branch FLINK-38729-2 created (now cb27d5acf) kunni
• (flink) branch master updated: [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING (#27502) (#27602) dwysakowicz
• (flink-cdc) branch master updated: [pipeline] Use GHA workflow triggers to run labeler workflow (#4274) kunni
• (flink) branch master updated (67f0cebeea4 -> 197c7b97adc) zhuzh
  • (flink) 01/02: [FLINK-38973][runtime] Job ID assignment and matching based on name zhuzh
  • (flink) 02/02: [FLINK-38973][runtime] Make jobId nullable in StreamGraph to maintain compatibility for fixed jobId zhuzh
• (flink) branch master updated: [FLINK-38340][runtime] Introduce the rescale timeline related abstraction for performing rescale operations (#27285) weizhong
• (flink-cdc) branch FLINK-38729-2 deleted (was 5e0471ef0) kunni
• (flink) branch dependabot/maven/flink-runtime/io.airlift-aircompressor-2.0.3 created (now e9c229d8df5) github-bot
• (flink) branch release-1.20 updated: [FLINK-39139] Update lz4-java to 1.10.3 (#27647) fanrui
• (flink) branch release-2.1 updated: [Hotfix] Update lz4-java to 1.10.3 fanrui
• (flink) branch release-2.2 updated: [Hotfix] Update lz4-java to 1.10.3 fanrui
• (flink) branch master updated: [FLINK-39130][metrics] Allow native types in MetricConfig fanrui
• (flink-cdc) branch master updated: [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors (#4247) kunni
• (flink-cdc) branch FLINK-38729-2 created (now 5e0471ef0) kunni
• (flink) branch master updated: [FLINK-38978][runtime] Expose JM config for applications zhuzh
• (flink) branch master updated: [FLINK-39133][runtime] Fix DispatcherTest to properly handle async operations for applications zhuzh
• (flink-cdc) branch master updated: [FLINK-38455][elasticsearch][fix] Fix Elasticsearch Missing required property 'BulkRequest.operations' error (#4270) kunni
• (flink-cdc) branch master updated: [FLINK-39143][pipeline-connecotr][Fluss]Optimize the connection of fluss when use FlussMetaDataApplier (#4282) kunni
• (flink-agents) branch release-0.2 updated: [hotfix][doc] Use version 0.2.0 rather than 0.2-SNAPSHOT in maven dependency doc. (#550) xtsong
• (flink-agents) branch main updated: [hotfix][doc] Use version 0.2.0 rather than 0.2-SNAPSHOT in maven dependency doc. (#550) xtsong
• (flink-connector-http) branch main updated: [hotfix] Update to `flink-connector-parent` 1.1.0 fcsaky
• (flink) branch master updated: [FLINK-38916][table-planner] MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 twalthr
• (flink) branch master updated: [FLINK-39107][metrics][test] Run otel container from a prebuilt image (#27637) martijnvisser
• (flink-cdc) branch master updated: [FLINK-39144][paimon] Fix ioManager close.(#4283) kunni
• (flink-cdc) branch master updated: [test] Improve pipeline connector test coverage i.e. doris/postgres/fluss (#4266) kunni
• (flink-cdc) branch master updated: [FLINK-39066][pipeline-connector][Fluss] Fix the metric histogram always return null (#4281) kunni
• (flink-agents) branch main updated: [example] Add missing flink-json dependency (#544) xtsong
• (flink) branch master updated: [FLINK-39084][core] variant accessor methods for handling map or array types in converters gyfora
• (flink-connector-jdbc) branch main updated: [hotfix][OceanBase] Stabilize integration tests (#186) panyuepeng
• (flink) branch master updated: [FLINK-38807][state] Add state SQL metadata based type inference gaborgsomogyi
• (flink) branch master updated (de569e4d930 -> 8ff299d7782) snuyanzin
  • (flink) 02/04: [FLINK-38624][table] Replace deprecated `RexBuilder#makeAbstractCast` snuyanzin
  • (flink) 01/04: [FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule snuyanzin
  • (flink) 04/04: [hotfix][test] Use `assertThatExceptionOfType` instead of `assertThatThrownBy` in OverAggregateTest.scala snuyanzin
  • (flink) 03/04: [FLINK-38624][table] Convert FlinkLogicalOverAggregate to java snuyanzin
• (flink-connector-kafka) branch main updated: [FLINK-38999][lineage] License lineage files arvid
• (flink-connector-kafka) branch main updated (d6785701 -> ffb1fc6c) fanrui
• (flink-connector-kafka) branch main updated: [FLINK-39121][tests] Retry kafka containers startup roman
• (flink) branch master updated: [FLINK-39088][table] Support injective casts from CHAR/VARCHAR to BINARY/VARBINARY twalthr
• (flink) branch master updated (e9afe8bfc52 -> 7536cfe9e47) pnowojski
  • (flink) 02/03: [FLINK-39073][runtime] Improve logging of invalid split transitions pnowojski
  • (flink) 03/03: [FLINK-39073][runtime] Test split state timers during deferred alignment check pnowojski
  • (flink) 01/03: [FLINK-39073][runtime] Defer alignment check for idle splits pnowojski
• (flink) branch master updated: [FLINK-38764] Update lz4-java to 1.10.3 (#27535) pnowojski
• (flink) branch master updated: [FLINK-39105][rest] Fix RestClientTest.testConnectionTimeout to handle environment-dependent exception types martijnvisser
• (flink) branch master updated (b1192e8a8e8 -> 45c62cacc0a) roman
  • (flink) 01/02: [hotfix][runtime] Release all channels' deserializers before failing in StreamTaskNetworkInput roman
  • (flink) 02/02: [FLINK-39103][runtime] Tolerate deserializer release failure if the corresponding channel already had errors roman
• (flink) branch master updated: [FLINK-39029] move catalog store factory builder to new class (#27531) rmetzger
• (flink) branch release-1.11 updated: [FLINK-38925][docs] Add Matomo config to PyDocs martijnvisser
• (flink) branch release-1.12 updated: [FLINK-38925][docs] Add Matomo config to PyDocs martijnvisser
• (flink) branch release-1.1 updated (4c3cd0ed349 -> 92cc3bd341c) martijnvisser
  • (flink) 02/04: [FLINK-38955][docs] Add canonical tag to generated Javadoc and Scaladoc martijnvisser
  • (flink) 01/04: [hotfix][docs] Add docs.sh for legacy CI pipeline martijnvisser

• Earlier messages