commits
Thread
Date
Earlier messages
Messages by Thread
(flink) branch master updated (33029143730 -> 8ae4de69520)
junrui
(flink) 01/02: [FLINK-31931][runtime/rest] Return 404 instead of 500 for unknown TaskManager in TaskManagerDetailsHandler
junrui
(flink) 02/02: [FLINK-31931][runtime-web] Stop polling a TaskManager once it is gone
junrui
(flink) branch master updated: [FLINK-40520][checkpointing] Release spilled channel state on recovery abort between fetch and drain
fanrui
(flink) branch master updated: [FLINK-40282][docs] Expand and correct the concepts Glossary (#28863)
davidrad
(flink) branch master updated: [FLINK-40515][core] Extend BinaryVariant to support UUID
snuyanzin
(flink-connector-kafka) branch main updated: [FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update (#291)
martijnvisser
(flink) branch master updated: [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation (#29062)
rmetzger
(flink) branch master updated: [FLINK-40593][s3] Batch recursive S3 deletes in native s3 connector with global and per-bucket opt-out
dbsamrat
(flink) branch master updated: [FLINK-40492][table] Support casting from VARIANT to TIME and nanosecond timestamps
twalthr
(flink) branch master updated: [FLINK-40464][python] Bump cibuildwheel to 4.2.0 (#29016)
dianfu
(flink-connector-kafka) branch main updated: [FLINK-40618][tests] Run SourceTopicIntegrity test in the integration-test phase
martijnvisser
(flink) branch master updated: [FLINK-35321][runtime] Ensure pendingCommitables metric is not re-registered while copying CommittableCollector (#27598)
davidrad
(flink) branch master updated: [FLINK-40478][runtime-web] Log effective HistoryServer configuration at startup (#29020)
rmetzger
(flink) branch master updated (f83a73c19a4 -> fb806c8fcaa)
twalthr
(flink) branch master updated: [FLINK-40449][table] Reject non-temporal streaming sort during planning
martijnvisser
(flink-connector-kafka) branch main updated: [FLINK-40137][Connectors/Kafka] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator
martijnvisser
(flink) branch master updated: [FLINK-40421][python] Add sorting APIs to DataFrame API
dianfu
(flink) branch release-2.3 updated: [FLINK-40529][python] Warn on use of deprecated APIs not at import time (#29061)
dianfu
(flink) branch master updated: [FLINK-40529][python] Warn on use of deprecated APIs not at import time (#29061)
dianfu
(flink) branch release-1.20 updated: [FLINK-23758][python] Fix semantics of Expression.__invert__ (#29148)
dianfu
(flink) branch release-2.3 updated: [FLINK-23758][python] Fix semantics of Expression.__invert__ (#29148)
dianfu
(flink) branch master updated: [FLINK-23758][python] Fix semantics of Expression.__invert__ (#29148)
dianfu
(flink) branch master updated: [FLINK-40606][table-planner] Fix code generation for binary array casts
snuyanzin
(flink) branch master updated: [FLINK-40599][python] Allow pyarrow up to 25.x (#29134)
dianfu
(flink-cdc) branch master updated: [FLINK-40572][runtime] Support dynamic AI model selection (#4525)
yux
(flink-agents) branch main updated: [plan][runtime] Do not retry or persist interrupted chat calls on cancellation (#1071)
wenjin
(flink) branch master updated: [FLINK-40580][table] Render VARIANT object/array as SQL when casting to character string
twalthr
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/vitest-4.1.11 deleted (was dad9ae121ab)
github-bot
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-d0c2d048a7 created (now 7578582ef9f)
github-bot
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/vitest-4.1.11 created (now dad9ae121ab)
github-bot
(flink) branch master updated: [FLINK-40603][build] Use hadoop 3.4.3 for jdk25
snuyanzin
(flink) branch release-2.2 updated: [FLINK-40596] Closing metric might lead to a number of test failures
snuyanzin
(flink) branch release-2.3 updated: [FLINK-40596] Closing metric might lead to a number of test failures
snuyanzin
(flink) branch master updated: [FLINK-40430][python] Add configuration support to DataFrame API
dianfu
(flink) branch master updated: [FLINK-40567][tests] Avoid @TempDir cleanup race in HistoryServerArchiveFetcherTest (#29116)
rmetzger
(flink) branch master updated: [FLINK-40117][runtime-web] Extend Vitest smoke-test coverage to more web-dashboard views
martijnvisser
(flink) branch master updated: [FLINK-40596] Closing metric might lead to a number of test failures
snuyanzin
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/fast-uri-3.1.7 deleted (was 547ab71826b)
github-bot
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/browserslist-4.28.8 deleted (was ac83da8c8e8)
github-bot
(flink) branch master updated: [FLINK-40590][runtime-web] Update Angular and monaco-editor to latest available versions
martijnvisser
(flink) branch release-2.3 updated (252231a7474 -> b2f4045f301)
pnowojski
(flink) 01/02: [FLINK-40549][metrics] Remove metricGroup parent reference upon close()
pnowojski
(flink) 02/02: [FLINK-40549][metrics] Close splitMetricGroup along with the child splitWatermarkMetricGroup
pnowojski
(flink) branch master updated: [FLINK-40399][state] Separate key filter runtime contract from push-down planning
gaborgsomogyi
(flink-web) branch asf-site updated (4cfed62010 -> 3eecf581df)
davidrad
(flink-connector-kafka) branch v3.4 updated: [FLINK-39699][tests] Stabilize KafkaWriterFaultToleranceITCase exception-on-unavailable tests
martijnvisser
(flink-connector-kafka) branch v5.0 updated (5daafa34 -> aebf1b57)
martijnvisser
(flink-connector-kafka) 01/04: [hotfix] Stabilize KafkaWriterFaultToleranceITCase exception-on-unavailable tests
martijnvisser
(flink-connector-kafka) 04/04: [FLINK-39723][tests] Wait for partition assignment in KafkaTableTestBase.createTestTopic
martijnvisser
(flink-connector-kafka) 03/04: [FLINK-39699][tests] Wait for partitions assignment in KafkaSinkITCase
martijnvisser
(flink-connector-kafka) 02/04: [FLINK-39699][tests] Wait for completed checkpoint stats in KafkaSinkITCase
martijnvisser
(flink-connector-kafka) branch main updated: [FLINK-40589][source/tests] Increase job failure timeout
martijnvisser
(flink) branch release-2.2 updated (a0197d5d739 -> 61ec50ecfe5)
pnowojski
(flink) 01/02: [FLINK-40549][metrics] Remove metricGroup parent reference upon close()
pnowojski
(flink) 02/02: [FLINK-40549][metrics] Close splitMetricGroup along with the child splitWatermarkMetricGroup
pnowojski
(flink-docker) branch master updated (5faea49 -> bc3472d)
snuyanzin
(flink-docker) 02/05: [hotfix] Bump login-action to `dbcb813823bdd20940b903addbd779551569679f`
snuyanzin
(flink-docker) 01/05: [hotfix] Bump setup-buildx-action to `37fe631027851001ddb9b187196cc803df7f5f0e`
snuyanzin
(flink-docker) 03/05: [hotfix] Bump setup-qemu-action `ce360397dd3f832beb865e1373c09c0e9f86d70a`
snuyanzin
(flink-docker) 05/05: [hotfix] Bump checkout to v7
snuyanzin
(flink-docker) 04/05: [hotfix] Bump docker push action to `53b7df96c91f9c12dcc8a07bcb9ccacbed38856a`
snuyanzin
(flink-cdc) branch master updated: [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. (#4498)
hongshun
(flink-connector-shared-utils) branch ci_utils updated: [FLINK-39941][python] Pin virtualenv below 21.5 so py38 tox environments can still be created
martijnvisser
(flink) branch master updated: [hotfix][table] Fix tryParseJson() docs to say NULL instead of throws an error
twalthr
(flink-connector-kafka) branch main updated: [FLINK-40579][ci] Make weekly branch lines independent and run one JDK per release line (#299)
martijnvisser
(flink) branch master updated (78b0df60e34 -> 7fcc6b8d11a)
pnowojski
(flink) 01/02: [FLINK-40549][metrics] Remove metricGroup parent reference upon close()
pnowojski
(flink) 02/02: [FLINK-40549][metrics] Close splitMetricGroup along with the child splitWatermarkMetricGroup
pnowojski
(flink) branch master updated: [FLINK-37926][table] Support casting from VARIANT to MAP
twalthr
(flink) branch release-2.3 updated: [FLINK-40350][table-runtime] `LPAD`/`RPAD` split supplementary-plane characters into unpaired surrogates
snuyanzin
(flink) branch master updated: [FLINK-37926][table] Support casting from VARIANT to ROW and STRUCTURED
twalthr
(flink-shaded) branch release-20.0 updated: [FLINK-39570] Bump Netty to 4.1.136.Final (release-20.0)
rmetzger
(flink) branch master updated: [hotfix][docs] Add 2.3 to PreviousDocs list
gustavodemorais
(flink) branch master updated: [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join
twalthr
(flink-shaded) branch master updated: [FLINK-40510] Bump Apache parent pom to 39
snuyanzin
(flink) branch master updated (ad4a20ab486 -> 0fb6dcf6b75)
snuyanzin
(flink) branch master updated: [FLINK-40573][build] Remove wildcard imports while spotless apply
snuyanzin
(flink-web) branch asf-site updated (6b23067e90 -> 4cfed62010)
snuyanzin
(flink) branch master updated (bf4a71a990d -> 1705984b43f)
zakelly
(flink) 02/02: [FLINK-39977][runtime] Add ITCase for file-merged channel state recovery
zakelly
(flink) 01/02: [FLINK-39977][runtime] Recovery of merged channel state handles
zakelly
(flink) branch master updated: [FLINK-40545][table] Add `parseJson()` and `tryParseJson()` Table API expression methods
snuyanzin
(flink) branch master updated: [FLINK-40071][build] Bump jackson-bom to 2.22.2
snuyanzin
(flink) branch master updated: [FLINK-40563][build] Bump lombok to 1.18.48
snuyanzin
(flink-web) branch asf-site updated (b65de93329 -> 6b23067e90)
snuyanzin
(flink) branch master updated: [FLINK-40565] Bump netty to 4.2.17
snuyanzin
(flink) branch master updated: [FLINK-40517][checkpointing] Aggregate cross-channel watermarks on the recovery unspilling thread for fan-in rescale
fanrui
[I] [Bug][postgres] snapshot-only replication slot is never dropped unless the snapshot is instantaneous [flink-cdc]
via GitHub
Re: [I] [Bug][postgres] snapshot-only replication slot is never dropped unless the snapshot is instantaneous [flink-cdc]
via GitHub
Re: [I] [Bug][postgres] snapshot-only replication slot is never dropped unless the snapshot is instantaneous [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-40350][table-runtime] `LPAD`/`RPAD` split supplementary-plane characters into unpaired surrogates
snuyanzin
(flink) branch master updated: [FLINK-40527] Update flink-shaded to 22.0
snuyanzin
(flink) branch master updated: [FLINK-40540][table-planner] Put the rule's reason first in the planning error
martijnvisser
(flink) branch master updated: [FLINK-37926][table] Support casting from `VARIANT` to `ARRAY`
snuyanzin
(flink-ci-docker) branch main updated: [hotfix] Fix image name in `README`
snuyanzin
(flink) branch release-2.2 updated: [FLINK-40548][ci] Use image with ubuntu 24.04
snuyanzin
(flink) branch release-1.20 updated: [FLINK-40548][ci] Use image with ubuntu 24.04
snuyanzin
(flink) branch release-1.20 updated: [FLINK-40548][ci] Use image with ubuntu 24.04
snuyanzin
(flink) branch release-2.3 updated: [FLINK-40548][ci] Use image with ubuntu 24.04
snuyanzin
(flink) branch release-2.1 updated: [FLINK-40548][ci] Use image with ubuntu 24.04
snuyanzin
(flink) branch master updated: [FLINK-40548][ci] Use image with ubuntu 24.04
snuyanzin
(flink) branch master updated: [FLINK-40490][table] Add runtime serialization and codegen for the `UUID` type
snuyanzin
(flink) branch master updated (e0fed5bfefa -> aff06f86705)
snuyanzin
(flink) 02/02: Revert "[FLINK-39977][runtime] Recovery of merged channel state handles"
snuyanzin
(flink) 01/02: Revert "[FLINK-39977][runtime] Add ITCase for file-merged channel state recovery"
snuyanzin
(flink) branch release-2.0 updated: [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses
gaborgsomogyi
(flink) branch release-1.20 updated: [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses
gaborgsomogyi
(flink) branch release-2.3 updated: [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses
gaborgsomogyi
(flink) branch release-2.1 updated: [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses
gaborgsomogyi
(flink) branch release-2.2 updated: [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses
gaborgsomogyi
(flink) branch master updated (c4bfcd5ea75 -> ab65430b64a)
zakelly
(flink) 02/02: [FLINK-39977][runtime] Add ITCase for file-merged channel state recovery
zakelly
(flink) 01/02: [FLINK-39977][runtime] Recovery of merged channel state handles
zakelly
(flink) branch master updated: [FLINK-40370][python] Fix bytes-backed Avro decimal framing (#28996)
dianfu
(flink) branch master updated: [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments (#29018)
fhueske
(flink) branch release-2.2 updated: [FLINK-40451][ci] E2E test timeout keeps CI running until the timeout ends, even after the test passes
snuyanzin
(flink) branch release-1.20 updated: [FLINK-40451][ci] E2E test timeout keeps CI running until the timeout ends, even after the test passes
snuyanzin
(flink-ci-docker) branch main updated: [FLINK-40548][ci] Bump ubuntu to 24.04
snuyanzin
(flink) branch release-2.2 updated: [FLINK-40370][python] Fix bytes-backed Avro decimal framing (#28996)
dianfu
(flink) branch release-2.3 updated: [FLINK-40370][python] Fix bytes-backed Avro decimal framing (#28996)
dianfu
(flink) branch master updated: [FLINK-40491][core] Extend `BinaryVariant` with `TIME`, `TIMESTAMP_NS`, `TIMESTAMP_LTZ_NS` primitives
snuyanzin
(flink) branch master updated: [FLINK-40477][table] Fix constraint enforcer for partial deletes (#29067)
fhueske
(flink-connector-kafka) branch main updated: [hotfix] Fix compiler varargs warning in KafkaSinkBuilderTest (#297)
davidrad
(flink-connector-kafka) branch main updated (dc707db6 -> db222b3c)
fanrui
(flink-connector-kafka) 01/04: [FLINK-40128][connector] Introduce topic integrity utilities in static kafka source
fanrui
(flink-connector-kafka) 04/04: [FLINK-40128][connector] Topic integrity ITCase
fanrui
(flink-connector-kafka) 02/04: [FLINK-40128][connector] Add an opt-in based topic integrity config option
fanrui
(flink-connector-kafka) 03/04: [FLINK-40128][connector] Implement topic integrity awareness across kafka subscribers
fanrui
(flink) branch master updated: [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses
gaborgsomogyi
(flink-agents) branch main updated: [infra] Add a guide for AI-assisted PR implementation descriptions (#1073)
wenjin
(flink) branch release-2.3 updated: [FLINK-40451][ci] E2E test timeout keeps CI running until the timeout ends, even after the test passes
snuyanzin
(flink) branch master updated: [FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover
fanrui
(flink) branch master updated: [FLINK-40422][python] Add slicing APIs to DataFrame API
dianfu
(flink) branch master updated: [FLINK-40522][network] Deduplicate RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel
fanrui
(flink) branch master updated: [FLINK-40537][build] IDEA should use java version same as in `source.java.version`
snuyanzin
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/fast-uri-3.1.7 created (now 547ab71826b)
github-bot
(flink-agents) branch main updated: [e2e][java] Temporarily disable Mem0 cross-language test (#1089)
wenjin
(flink) branch master updated: [FLINK-40518][checkpointing] Only enable checkpointing-during-recovery when unaligned checkpoints are enabled
fanrui
(flink) branch master updated: [FLINK-40431][python] Add UDF support to DataFrame API (#29029)
dianfu
(flink) branch master updated: [FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery
fanrui
(flink-cdc) branch master updated: [FLINK-40513][runtime] Introduce multimodal AI functions for image understanding (#4520)
yux
(flink) branch master updated: [FLINK-40496][table-planner] Apply append-only column rules consistently when altering a materialized table (#29034)
arvid
(flink) branch master updated: [FLINK-40525][network] Remove residual receivedBuffers lock in finishReadRecoveredState to avoid ABBA deadlock
fanrui
(flink) branch master updated: [FLINK-40521][network] Document potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery
fanrui
(flink) branch master updated: [FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled
fanrui
(flink-agents) branch main updated: [tools][ci] Fix the bats suite's boundary with the scripts it tests (#1081)
wenjin
(flink-cdc) branch master updated: [FLINK-40512] Cache typeRegistry to reduce the busy work on inferring schema change event (#4519)
hongshun
(flink-agents) branch main updated: ci: update checkout, setup-python, and setup-java to current majors in ci.yml (#1078)
wenjin
(flink-agents) branch main updated: [integrations][anthropic] Stop sending rejected sampling parameters (#1037)
wenjin
(flink) branch master updated: [FLINK-40536][build] Bump cyclonedx-maven-plugin to 2.9.3
snuyanzin
(flink-agents) branch main updated: [runtime][api] Scope long-term memory operations to the action that obtained the memory set (#1002)
wenjin
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/browserslist-4.28.8 created (now ac83da8c8e8)
github-bot
(flink-agents) branch release-0.3 updated: [plan][java][python] Reject unsafe Bash redirects (#1079)
wenjin
(flink-agents) branch main updated: [plan][java][python] Reject unsafe Bash redirects (#1079)
wenjin
(flink-agents) branch main updated: [integrations][plan] Handle finish_reason in OpenAI-family connections (#1040)
wenjin
(flink) branch master updated: [FLINK-40197][python] Add sql() to the DataFrame API
dianfu
(flink-agents) branch release-0.3 updated: [hotfix][java][python] Harden Bash arithmetic evaluation (#1083)
wenjin
(flink-agents) branch main updated: [hotfix][java][python] Harden Bash arithmetic evaluation (#1083)
wenjin
(flink) branch master updated: [FLINK-40486][table] Introduce the UUID logical type
gustavodemorais
(flink) branch master updated: [FLINK-40017] Introduce Seaweedfs in native-s3-fs
dbsamrat
(flink-cdc) branch master updated: [FLINK-40416][runtime] Add built-in text AI functions (#4512)
yux
(flink-cdc) branch master updated: [FLINK-40507][connect/paimon] Upgrade Paimon SDK to 2.0.0
yux
(flink) branch master updated (622106923e0 -> a922643b248)
snuyanzin
(flink) 02/02: [hotfix][build] Bump `directory-maven-plugin` to 1.0
snuyanzin
(flink) 01/02: [FLINK-40510][build] Bump Apache Parent pom to 39
snuyanzin
(flink-shaded) annotated tag release-22.0 updated (d0c2705 -> 1bacef4)
snuyanzin
svn commit: r87100 - dev/flink/flink-shaded-22.0-rc1 release/flink/flink-shaded-22.0
snuyanzin
(flink-agents) branch main updated: [integrations][java][python] Apply Ollama native structured output (#981)
wenjin
(flink-agents) branch release-0.2 updated (dddb1e2b -> 611bbbaa)
wenjin
(flink-agents) 02/02: [python] Pin googleapis common protos below 1.72.1 (#1052)
wenjin
(flink-agents) 01/02: [runtime][java] Reject raw bytes from PyFlink inputs
wenjin
(flink) branch master updated: [FLINK-40382][tests] Execute static nested test class variants and guard against regressions
snuyanzin
(flink) branch master updated: [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5
snuyanzin
(flink) branch master updated: [FLINK-40356][table] Add new MapFromEntries built-in function
gustavodemorais
(flink-connector-aws) branch main updated: [FLINK-35500] Build DELETE key from primary key for CDC deletes
fcsaky
(flink-connector-aws) branch main updated: [FLINK-39137] Add configurable interval between non-empty `getRecords` calls
fcsaky
(flink) branch master updated: [hotfix][docs] Fix AzureTableConfiguration class name casing in Azure Table Storage doc (#29044)
dbsamrat
(flink-agents) branch main updated: [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered (#1046)
wenjin
Re: [I] [Bug] update flink version to 1.16.2and CDC version to 2.3.0:NoSuchMethodError [flink-cdc]
via GitHub
Re: [I] [Bug] update flink version to 1.16.2and CDC version to 2.3.0:NoSuchMethodError [flink-cdc]
via GitHub
(flink-agents) branch main updated: [integrations][anthropic] Update the stale default model to claude-sonnet-4-6 (#1039)
wenjin
(flink-agents) branch release-0.3 updated (18a94a1a -> b952dc23)
wenjin
(flink-agents) 01/02: [runtime][java] Reject raw bytes from PyFlink inputs
wenjin
(flink-agents) 02/02: [python] Pin googleapis common protos below 1.72.1 (#1052)
wenjin
(flink-agents) branch main updated: [runtime][java] Reject raw bytes from PyFlink inputs (#1075)
wenjin
(flink-agents) branch main updated: [runtime][python] Release bridge-owned Pemja objects (#944)
wenjin
(flink) branch master updated: [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo (#29046)
panyuepeng
(flink) branch master updated: [FLINK-40506][s3] Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies
gaborgsomogyi
(flink-agents) branch main updated (54f8c69a -> 0417dad3)
wenjin
(flink) branch master updated: [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction (#29030)
arvid
(flink) branch master updated: [FLINK-40241][table-runtime] Support `VARIANT` as column type in the 'raw' format
snuyanzin
(flink) branch master updated: [FLINK-40498][tests] Adjust LateralSnapshotJoin tests for optional TABLE keyword (#29035)
fhueske
(flink) branch master updated: [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation
roman
(flink) branch master updated: [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness (#29024)
martijnvisser
(flink) branch master updated (6fc280fb163 -> e3a53a5e1ab)
martijnvisser
(flink) branch master updated: [FLINK-39780] Make TABLE keyword optional in LATERAL context (#28276)
fhueske
(flink) branch master updated: [hotfix][docs] Fix OPTIONS hint key in time attributes docs
snuyanzin
(flink-agents) branch main updated: [ci][integrations] Consolidate vector store tests (#1061)
wenjin
(flink) branch master updated: [FLINK-39986][table-planner] Support Python UDF deduplication in projection and condition (#28638)
dianfu
Earlier messages