commits
Thread
Date
Earlier messages
Messages by Date
2025/09/03
(flink) branch master updated: [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES`
snuyanzin
2025/09/03
(flink-agents) branch main updated: [infra] Show python version in GHA job names
xtsong
2025/09/03
(flink-agents) branch main updated: [integration][python] Integrate OpenAI chat model. (#128)
xtsong
2025/09/02
(flink) branch master updated: [FLINK-38308] Reduce logging of date parse errors in DateTimeUtils
roman
2025/08/29
(flink-connector-kafka) branch main updated: [FLINK-38289] Update to Flink 2.1
gaborgsomogyi
2025/08/29
(flink-agents) branch main updated: [hotfix] Fix incorrect import path of flink_agents (#137)
xtsong
2025/08/29
(flink-connector-kafka) branch main updated: [FLINK-37583] Upgrade to Kafka 4.0.0 client.
fpaul
2025/08/29
(flink) branch release-2.0 updated (f8a3985c566 -> e4ea3d81948)
fanrui
2025/08/29
(flink) 03/03: [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint
fanrui
2025/08/29
(flink) 02/03: [FLINK-38267][checkpoint] Only call channel state rescaling logic for exchange with channel state to avoid UnsupportedOperationException
fanrui
2025/08/29
(flink) 01/03: [FLINK-38267][checkpoint] Refactor hasInputState and hasOutputState related logic in TaskStateAssignment
fanrui
2025/08/29
(flink) 01/03: [FLINK-38267][checkpoint] Refactor hasInputState and hasOutputState related logic in TaskStateAssignment
fanrui
2025/08/29
(flink) 02/03: [FLINK-38267][checkpoint] Only call channel state rescaling logic for exchange with channel state to avoid UnsupportedOperationException
fanrui
2025/08/29
(flink) branch release-1.20 updated (b4a60319045 -> 6268448a811)
fanrui
2025/08/29
(flink) 03/03: [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint
fanrui
2025/08/29
(flink) 03/03: [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint
fanrui
2025/08/29
(flink) 01/03: [FLINK-38267][checkpoint] Refactor hasInputState and hasOutputState related logic in TaskStateAssignment
fanrui
2025/08/29
(flink) 02/03: [FLINK-38267][checkpoint] Only call channel state rescaling logic for exchange with channel state to avoid UnsupportedOperationException
fanrui
2025/08/29
(flink) branch release-2.1 updated (d67c45a750e -> 90762ab27d0)
fanrui
2025/08/28
(flink) branch master updated: [FLINK-38193] Bump commons-lang3 to version 3.18.0
snuyanzin
2025/08/28
(flink) branch master updated: [FLINK-38288] Enhance BlobWriter logging with offloading time in millis.
fanrui
2025/08/28
(flink-kubernetes-operator) branch main updated: [FLINK-37669][HELM] Add Helm chart unit tests to flink kubernetes operator
gyfora
2025/08/28
(flink) branch master updated: [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint
fanrui
2025/08/28
(flink) branch master updated: [FLINK-37827][table] Add support for `SHOW CREATE MATERIALIZED TABLE`
snuyanzin
2025/08/28
(flink) branch master updated (e2a2755a046 -> 1e7525f5625)
fpaul
2025/08/28
(flink-agents) branch main updated: [hotfix] Fix coredump when close async thread pool. (#133)
xtsong
2025/08/27
(flink-agents) branch main updated: [Integration][ChatModel]Add built-in tongyi chat model in python (#121)
xtsong
2025/08/27
(flink-cdc) branch master updated: [FLINK-38278][postgres-pipeline] supported array type field. (#4108)
kunni
2025/08/27
(flink) branch release-2.1 updated: [FLINK-38286][table] Fix: MAP function with duplicate keys produces non-deterministic results
dwysakowicz
2025/08/27
(flink) branch release-2.0 updated: [FLINK-38286][table] Fix: MAP function with duplicate keys produces non-deterministic results
dwysakowicz
2025/08/27
(flink) branch master updated (f7a159bfc6b -> e2a2755a046)
dwysakowicz
2025/08/26
Re: [I] Compatibility Inquiry: Will Flink CDC support Flink 2.0 in future releases? [flink-cdc]
via GitHub
2025/08/26
Re: [I] Compatibility Inquiry: Will Flink CDC support Flink 2.0 in future releases? [flink-cdc]
via GitHub
2025/08/26
Re: [I] Compatibility Inquiry: Will Flink CDC support Flink 2.0 in future releases? [flink-cdc]
via GitHub
2025/08/26
(flink) branch master updated: [FLINK-38257][SQL] Add module dynamic function loading possibility
gaborgsomogyi
2025/08/26
(flink) branch release-2.0 updated: [FLINK-37181][build] Fix MacOS sha256sum tool compile error
gaborgsomogyi
2025/08/26
(flink) branch release-1.20 updated: [FLINK-37181][build] Fix MacOS sha256sum tool compile error
gaborgsomogyi
2025/08/26
[I] Compatibility Inquiry: Will Flink CDC support Flink 2.0 in future releases? [flink-cdc]
via GitHub
2025/08/26
Re: [I] Compatibility Inquiry: Will Flink CDC support Flink 2.0 in future releases? [flink-cdc]
via GitHub
2025/08/25
(flink-cdc) branch master updated: [FLINK-37738][docs] Fix Postgres Chinese and English document contents (#4109)
yux
2025/08/25
(flink-kubernetes-operator) branch main updated: [FLINK-37193] Feature flag if operator should manage ingress
gyfora
2025/08/25
(flink) branch release-2.1 updated: [FLINK-38020] Fix NPE in NonTimeRangeUnboundedFunction (#26807)
fhueske
2025/08/24
(flink) branch master updated: [FLINK-38131][flink-runtime] Fix that JM still redistributes broadcast state when all subtask have reported their states (#26925)
zakelly
2025/08/24
(flink-kubernetes-operator) branch main updated: [FLINK-38148] Support Flink v1.17 when listing job exceptions
gyfora
2025/08/24
(flink) branch master updated (0eeab73fe4a -> d81751aea0b)
fanrui
2025/08/22
(flink-kubernetes-operator) branch main updated: [FLINK-37406] Fix config array serialization
gyfora
2025/08/22
(flink-cdc) branch master updated: [FLINK-38157][connect/postgres] Supports assigning unbounded chunk first (#4103)
yux
2025/08/22
(flink-web) 01/02: [FLINK-38176] Add Flink kafka connector 4.0.1
fpaul
2025/08/22
(flink-web) branch asf-site updated (0af510acc -> a0bec613f)
fpaul
2025/08/22
svn commit: r78806 - dev/flink/flink-connector-kafka-4.0.1-rc1
arvid
2025/08/22
(flink) branch master updated: [FLINK-32695] [Tests] Migrated TableFactoryHarness.ScanSourceBase to Source V2
fpaul
2025/08/21
(flink-kubernetes-operator) branch main updated: [FLINK-37406] Update examples to use yaml based configs
gyfora
2025/08/21
(flink) branch release-2.0 updated: [FLINK-37868][state/forst] Respect the `maxTransferBytes` when using path copying in ForSt (#26763)
zakelly
2025/08/20
(flink-agents) branch main updated: [hotfix]Enrich test cases of Short-Term Memory in java (#124)
xtsong
2025/08/20
(flink) branch master updated: [FLINK-32695] Moved TestSource in TypeFillTest to SourceV2
fpaul
2025/08/20
svn commit: r78765 - dev/flink/flink-connector-kafka-4.0.1-rc2 release/flink/flink-connector-kafka-4.0.1
arvid
2025/08/20
(flink-cdc) branch master updated: [FLINK-37959][postgres]Supports all pgsql field types like debezium (#4086)
kunni
2025/08/20
(flink-agents) branch main updated: [API][Runtime]Introduce Memory Reference (#110)
xtsong
2025/08/20
(flink-kubernetes-operator) branch main updated: [FLINK-37391][docs] Improve documentation for dynamic namespace watching configuration
gyfora
2025/08/20
(flink) branch master updated: [FLINK-32695]-Added-flink-test-utils-connectors module
fpaul
2025/08/19
(flink-agents) branch main updated: [hotfix] fix examples can't execute (#114)
sxnan
2025/08/19
svn commit: r78734 - dev/flink/flink-connector-kafka-4.0.1-rc2
arvid
2025/08/19
svn commit: r78733 - dev/flink/flink-connector-kafka-4.0.1-rc2
arvid
2025/08/19
(flink-cdc) branch FLINK-38206 updated (90020ad21 -> c661d2980)
kunni
2025/08/19
(flink-agents) branch main updated: [Feature] [API] Support Event Logger and Event Listener in Java (#103)
xtsong
2025/08/19
(flink) branch master updated: [FLINK-38255][table] Add ITCase to verify sensitive table option redaction
gaborgsomogyi
2025/08/18
(flink-cdc) branch master updated: [FLINK-38244][hotfix] Fix case-insensitive error when adding column After an existed column. (#4100)
kunni
2025/08/18
(flink) branch master updated (62ddda7a58a -> 469644d43da)
snuyanzin
2025/08/18
(flink) branch master updated: [hotfix][docs] Fix variable name in Java Batch example in `README`
snuyanzin
2025/08/18
(flink) branch master updated: [FLINK-38246][table-planner] Remove unreachable code in CodeGenUtils
snuyanzin
2025/08/18
(flink) branch master updated: [FLINK-38256][table] Sync unparse for `TABLE` and `SHOW CREATE TABLE`
snuyanzin
2025/08/18
(flink-connector-kafka) annotated tag v4.0.1 updated (9e4bd3c0 -> faba5c24)
fpaul
2025/08/18
(flink-kubernetes-operator) branch main updated: [FLINK-38147] Add Flink 2.1 support
gyfora
2025/08/18
(flink-cdc) branch master updated: [FLINK-38248][pipeline-connector][paimon][starrocks][doris] The default value of '0000-00-00 00:00:00' for MySQL TIMESTAMP fields is not supported in downstream systems. (#4096)
kunni
2025/08/18
(flink-agents) branch main updated: [hotfix] fix parameter name inconsistency in ollama example (#116)
xtsong
2025/08/18
(flink-agents) branch main updated: [hotfix] fix hashCode don't override when equals override (#115)
xtsong
2025/08/18
(flink-cdc) branch master updated: [FLINK-38244] When the column name of mysql supports case-insensitive, fix the error that column name not being found. (#4095)
kunni
2025/08/18
(flink-cdc) branch FLINK-38206 updated (22d96aebd -> 90020ad21)
kunni
2025/08/17
(flink-connector-hbase) branch main updated: [hotfix] Fix `v4.0` JDK config in `weekly.yml`
fcsaky
2025/08/15
(flink) branch master updated: [hotfix][docs] Typos and format in `state.md` and `state_v2.md`
snuyanzin
2025/08/15
(flink) branch master updated: [hotfix][docs] `WITH` in `CREATE DATABASE` is optional
snuyanzin
2025/08/15
(flink-kubernetes-operator) branch main updated: [FLINK-37193] Ingress recreated after perform a change to CR FlinkDeployment
gyfora
2025/08/15
(flink-cdc) branch FLINK-38206 updated (c85444d5e -> 22d96aebd)
kunni
2025/08/15
(flink) branch master updated: [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows
snuyanzin
2025/08/15
(flink-cdc) branch master updated: [Flink-38238] Support varchar(0) and map to cdc string type (#4097)
kunni
2025/08/15
(flink) branch master updated: [FLINK-38251][table-planner] Enable restore tests again
twalthr
2025/08/15
(flink) branch master updated (c80a1f35f89 -> 4cdc67933a8)
dianfu
2025/08/14
(flink-cdc) branch master updated (d0fe46cb6 -> fea9807e4)
kunni
2025/08/14
(flink-agents) branch main updated: [api][python] Separate the abstraction of ChatModel to connection and settings (#113)
xtsong
2025/08/14
(flink-cdc) branch master updated: [FLINK-38045] Build createTableEventCache using TableSchemas from split and Make transform operator stateless (#4056)
kunni
2025/08/14
(flink-connector-hbase) branch main updated: [FLINK-38222] Bump HBase version from 2.2 to 2.6 (#56)
fcsaky
2025/08/14
(flink) branch master updated (60170ffb754 -> c80a1f35f89)
twalthr
2025/08/14
(flink) branch master updated (fbc7d0a66e3 -> 60170ffb754)
fpaul
2025/08/13
(flink-cdc) branch fix-doc deleted (was e22e9d6e5)
kunni
2025/08/13
(flink-cdc) branch master updated: [FLINK-38204][pipeline-connector][maxcompute] Use getLatestEvolvedSchema to get Schema in SessionManageOperator in case of using route. #4094
kunni
2025/08/13
(flink-cdc) branch master updated: [hotfix][doc] Update uses of Upload documentation in build_docs.yml. (#4093)
kunni
2025/08/13
(flink-cdc) branch fix-doc updated (5b6d8d273 -> e22e9d6e5)
kunni
2025/08/13
(flink-cdc) 01/01: [hotfix][doc] Update uses of Upload documentation in build_docs.yml.
kunni
2025/08/13
(flink-cdc) branch fix-doc updated: [hotfix][doc] Update uses of Upload documentation in build_docs.yml.
kunni
2025/08/13
(flink-cdc) branch fix-doc created (now bd6f52f4e)
kunni
2025/08/13
Re: [I] java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction [flink-cdc]
via GitHub
2025/08/13
Re: [I] java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction [flink-cdc]
via GitHub
2025/08/13
Re: [I] java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction [flink-cdc]
via GitHub
2025/08/13
(flink) branch master updated: [FLINK-38230][table-planner] Add visitMultiJoin to StreamNDUPlanVisitor
twalthr
2025/08/12
(flink-cdc) branch master updated: [FLINK-38188][pipeline-connector][postgres] Fix database name validation logic in PostgresDataSourceFactory (#4075)
kunni
2025/08/12
(flink) branch dependabot/maven/flink-end-to-end-tests/flink-end-to-end-tests-sql/com.nimbusds-nimbus-jose-jwt-10.0.2 deleted (was 8193d179388)
github-bot
2025/08/12
(flink) branch dependabot/maven/flink-end-to-end-tests/flink-end-to-end-tests-sql/com.nimbusds-nimbus-jose-jwt-9.37.4 created (now 6a43df5709c)
github-bot
2025/08/12
Re: [I] java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction [flink-cdc]
via GitHub
2025/08/12
[I] java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction [flink-cdc]
via GitHub
2025/08/12
(flink-cdc) branch master updated: [FLINK-37835] Fix NoPointException when start with latest-offset. (#4091)
kunni
2025/08/12
(flink-kubernetes-operator) branch main updated: [FLINK-38207] Update Flink Operator to use JOSDK 5.1.2
gyfora
2025/08/12
(flink-kubernetes-operator) branch main updated (2e582792 -> 3069d5a9)
gyfora
2025/08/12
(flink-kubernetes-operator) branch main updated (3069d5a9 -> 92a26935)
gyfora
2025/08/11
(flink) 02/02: [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources (#26887)
dwysakowicz
2025/08/11
(flink) branch release-2.1 updated (ce026532018 -> 75ee2b388c9)
dwysakowicz
2025/08/11
(flink) 01/02: [FLINK-38219][table-runtime] Fix row kind in StreamingMultiJoinOperator
dwysakowicz
2025/08/11
(flink-cdc) branch master updated: [FLINK-38059][doc] Add fluss pipeline connector documentation (#4088)
kunni
2025/08/11
Re: [I] Flink-CDC Postgres with Incremental Change does not work [flink-cdc]
via GitHub
2025/08/11
Re: [I] Flink-CDC Postgres with Incremental Change does not work [flink-cdc]
via GitHub
2025/08/11
Re: [I] Flink-CDC Postgres with Incremental Change does not work [flink-cdc]
via GitHub
2025/08/11
Re: [I] Flink-CDC Postgres with Incremental Change does not work [flink-cdc]
via GitHub
2025/08/11
[I] Flink-CDC Postgres with Incremental Change does not work [flink-cdc]
via GitHub
2025/08/11
(flink) branch master updated: [FLINK-38201][table-planner] SinkUpsertMaterializer should not be inserted for retract sinks
twalthr
2025/08/11
(flink-agents) 01/02: [hotfix] Fix serializable resource deserialize error.
xtsong
2025/08/11
(flink-agents) 02/02: [api][java] Support serialize and deserialize AgentPlan with python resource providers.
xtsong
2025/08/11
(flink-agents) branch main updated (fa6dd85 -> 1c62fd6)
xtsong
2025/08/11
(flink-agents) branch main updated: feat: add reasoning extraction from think tags in OllamaChatModel (#101)
xtsong
2025/08/11
(flink) branch master updated (4a98ded5524 -> 19f27ea80ac)
dwysakowicz
2025/08/11
(flink-agents) branch main updated: [Python] Support for Event containing Row field can be json serializable (#63)
xtsong
2025/08/11
(flink) branch master updated: [FLINK-38219][table-runtime] Fix row kind in StreamingMultiJoinOperator
twalthr
2025/08/11
(flink) branch master updated: [FLINK-38198] Support WITH Clause in CREATE FUNCTION Statement (#26874)
dwysakowicz
2025/08/09
(flink-cdc) branch master updated: [FLINK-37963] Fix potential NPE when triggering JobManager failover prematurely (#4044)
kunni
2025/08/09
(flink-cdc) branch FLINK-38206 updated (a1aa28d58 -> c85444d5e)
kunni
2025/08/09
(flink-cdc) branch master updated: [FLINK-38142] Upgrading the Paimon version to 1.2.0 (#4066)
kunni
2025/08/08
(flink-agents) branch main updated: [plan][runtime][java] Introduce Resource and Resource Provider in java (#91)
xtsong
2025/08/08
(flink) branch master updated: [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin
twalthr
2025/08/08
(flink-cdc) branch master updated: [FLINK-37905][runtime] Fix transform failure with non-ascii string literals (#4038)
yux
2025/08/08
(flink) branch master updated: [FLINK-38154][metrics] Add HTTP protocol support to OpenTelemetry reporters (#26850)
rmetzger
2025/08/07
(flink-cdc) branch master updated: [FLINK-38194][pipeline-connector/iceberg] Iceberg connector supports auto-creating namespace (#4080)
kunni
2025/08/07
(flink-cdc) branch master updated: [FLINK-37828] Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability (#4082)
kunni
2025/08/07
(flink) branch master updated: [FLINK-38135][table] Fix call to non-existent method for RAW type hashing
snuyanzin
2025/08/07
(flink) branch master updated (720172be1e5 -> eef14cb8781)
twalthr
2025/08/07
(flink) branch master updated (5d914f207d8 -> 720172be1e5)
snuyanzin
2025/08/07
(flink) branch master updated (59278c95b33 -> 5d914f207d8)
snuyanzin
2025/08/07
(flink) branch master updated (db91239b92b -> 59278c95b33)
fpaul
2025/08/07
(flink) branch master updated: FLINK-32695-ReactiveModeITCase-NewSource-Migration
fpaul
2025/08/07
(flink-agents) 01/02: [hotfix] Rename input/output event name in EventUtil to keep consistency.
xtsong
2025/08/07
(flink-cdc) branch master updated: [FLINK-38164][pipeline-connector/mysql] support mysql long and long varchar type (#4076)
kunni
2025/08/07
(flink-agents) 02/02: [hotfix] Add timeout for pulling and starting ollama server.
xtsong
2025/08/07
(flink-agents) branch main updated (5d9c35e -> c8cdedf)
xtsong
2025/08/07
(flink-agents) branch main updated (6278185 -> 5d9c35e)
xtsong
2025/08/07
(flink-agents) 01/02: [hotfix] Rename Agent whose name is begin with Test to avoid being treated as test class by pytest.
xtsong
2025/08/07
(flink-agents) 02/02: [api][python] Support add action and resource to Agent instance.
xtsong
2025/08/07
(flink-cdc) branch FLINK-38206 created (now a1aa28d58)
kunni
2025/08/07
(flink-cdc) 01/01: [FLINK-38206][pipeline-connector][paimon] Support writing to existed table with inconsistent schema with upstream.
kunni
2025/08/06
(flink-cdc) branch security-issue-2 deleted (was 03e934928)
kunni
2025/08/06
(flink-cdc) branch security-issue-3 deleted (was 60485f9dc)
kunni
2025/08/06
(flink-cdc) branch master updated: [FLINK-38184] one time of GetCopyOfBuffer is enough When serializing split. (#4073)
kunni
2025/08/06
(flink-agents) branch main updated: [api][java] Support DataStream / Table as input / output of Flink Agents in Java (#85)
xtsong
2025/08/06
(flink) branch master updated: [FLINK-38199] Allow to specify output in AbstractStreamOperatorTestHarness
roman
2025/08/06
(flink) branch master updated: [FLINK-38200][table] Allow to use `FIRST_VALUE` and `LAST_VALUE` with other types
snuyanzin
2025/08/06
(flink) branch master updated (f85946210f4 -> bbe109c8f9b)
fanrui
2025/08/06
(flink) branch master updated (17bedd4bc61 -> f85946210f4)
huweihua
2025/08/06
(flink-agents) branch main updated (57c4446 -> 4b8beab)
xtsong
2025/08/06
(flink-agents) 02/02: [integration][python] Introduce ollama chat model in python.
xtsong
2025/08/06
(flink-agents) 01/02: [hotfix] Remove useless parameter chat_history from ChatModel#chat.
xtsong
2025/08/06
(flink) branch master updated (9463c9b155e -> 17bedd4bc61)
twalthr
2025/08/06
(flink-cdc) branch master updated: [tests][pipeline-connector/fluss] Add MySQL to Fluss E2e IT case (#4057)
yux
2025/08/05
Re: [I] SQL Server CDC connector incorrectly handles special characters in database [flink-cdc]
via GitHub
2025/08/05
Re: [I] SQL Server CDC connector incorrectly handles special characters in database [flink-cdc]
via GitHub
2025/08/05
Re: [I] SQL Server CDC connector incorrectly handles special characters in database [flink-cdc]
via GitHub
2025/08/05
Re: [I] SQL Server CDC connector incorrectly handles special characters in database [flink-cdc]
via GitHub
2025/08/05
[I] SQL Server CDC connector incorrectly handles special characters in database [flink-cdc]
via GitHub
2025/08/05
(flink) branch master updated: [FLINK-32695] [Tests] Removed SourceFunction Dependency from YarnTestCacheJob.
fpaul
2025/08/05
(flink) branch master updated (066a957bcf7 -> 10c53c28658)
fpaul
2025/08/05
(flink-agents) branch main updated (cc46f29 -> 57c4446)
xtsong
2025/08/05
(flink-agents) 03/03: [hotfix] fix: format code with lint.sh to resolve style issues
xtsong
2025/08/05
(flink-agents) 02/03: [infra] Add license check tool and integrate with CI
xtsong
2025/08/05
(flink-agents) 01/03: [infra] Fix: lint.sh no longer modifies files during code style check
xtsong
2025/08/04
(flink-agents) 03/07: [hotfix] Refactor function to reduce serialize complexity.
xtsong
2025/08/04
(flink-agents) branch main updated (4ed5fc5 -> cc46f29)
xtsong
2025/08/04
(flink-agents) 04/07: [api][python] Introduce Prompt in python.
xtsong
2025/08/04
(flink-agents) 05/07: [api][python] Introduce Tool api and FunctionTool in python.
xtsong
2025/08/04
(flink-agents) 07/07: [plan][python] Add built-in actions for processing chat and tool call.
xtsong
2025/08/04
(flink-agents) 06/07: [api][python] Introduce ChatModel in python.
xtsong
2025/08/04
(flink-agents) 02/07: [hotfix] Move event and action to separate module.
xtsong
2025/08/04
(flink-agents) 01/07: [hotfix] Fixup unstable plan compatibility e2e test.
xtsong
2025/08/04
(flink) branch release-2.0 updated: [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging (#26803)
dianfu
2025/08/04
(flink) branch release-2.1 updated: [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging (#26803)
dianfu
2025/08/04
(flink) branch release-1.20 updated: [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging (#26841)
dianfu
2025/08/04
(flink-cdc) branch master updated: [FLINK-38185][pipeline-connector][iceberg] Correctly handle the type conversion of TIMESTAMP_TITH_TIME_ZONE. (#4074)
kunni
2025/08/04
(flink-cdc) branch master updated (f58158ae3 -> 7d93fc190)
kunni
2025/08/04
(flink-cdc) branch master updated (5eaf9eb86 -> f58158ae3)
kunni
2025/08/04
(flink-cdc) branch FLINK-38185 deleted (was b164f7c9e)
kunni
2025/08/04
(flink-cdc) 01/01: [FLINK-38185][pipeline-connector][iceberg] Correctly handle the type conversion of TIMESTAMP_TITH_TIME_ZONE.
kunni
2025/08/04
(flink-cdc) branch FLINK-38185 created (now b164f7c9e)
kunni
2025/08/04
(flink) branch master updated (a356421ded6 -> 066a957bcf7)
snuyanzin
2025/08/04
(flink-agents) 01/04: [runtime] Check memory access in task mailbox thread
xtsong
2025/08/04
(flink-agents) branch main updated (8c59d4e -> 4ed5fc5)
xtsong
2025/08/04
(flink-agents) 02/04: [API][runtime] Introduce RunnerContext#execute_async method and implement it for local runner
xtsong
Earlier messages