Messages by Date
-
2026/11/02
Re: [PR] [BP-1.20][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink]
RocMarshal (via GitHub) via issues
-
2026/11/02
Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink]
snuyanzin (via GitHub) via issues
-
2026/11/02
[jira] [Created] (FLINK-41302) Expose canary reconcile latency as a measure of reconciliation pool saturation
Dennis-Mircea Ciupitu (Jira) via issues
-
2026/11/02
Re: [PR] [BP-1.20][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink]
flinkbot (via GitHub) via issues
-
2026/11/02
[PR] [BP-3.7][FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc]
lvyanquan (via GitHub) via issues
-
2026/11/02
[jira] [Commented] (FLINK-40843) Add StateCatalog documentation
Gyula Fora (Jira) via issues
-
2026/11/02
[jira] [Assigned] (FLINK-40843) Add StateCatalog documentation
Gyula Fora (Jira) via issues
-
2026/11/02
[PR] [BP-1.20][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink]
snuyanzin (via GitHub) via issues
-
2026/11/02
Re: [PR] [BP-2.2][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink]
flinkbot (via GitHub) via issues
-
2026/11/02
[PR] [BP-2.3][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink]
snuyanzin (via GitHub) via issues
-
2026/11/02
Re: [PR] Bump org.xerial.snappy:snappy-java from 1.1.10.7 to 1.1.10.9 [flink]
dependabot[bot] (via GitHub) via issues
-
2026/11/02
[jira] [Commented] (FLINK-41244) PTF clearAllTimers() deletes unnamed timers across all keys and corrupts the key context
Timo Walther (Jira) via issues
-
2026/11/02
[jira] [Commented] (FLINK-41244) PTF clearAllTimers() deletes unnamed timers across all keys and corrupts the key context
Yuepeng Pan (Jira) via issues
-
2026/11/02
Re: [PR] [BP-2.2][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink]
twalthr (via GitHub) via issues
-
2026/11/02
[jira] [Comment Edited] (FLINK-40843) Add StateCatalog documentation
Yuepeng Pan (Jira) via issues
-
2026/11/02
[jira] [Commented] (FLINK-40843) Add StateCatalog documentation
Yuepeng Pan (Jira) via issues
-
2026/11/02
[jira] [Commented] (FLINK-40438) Add DataFrame inspection and rich display APIs
Yuepeng Pan (Jira) via issues
-
2026/11/02
[jira] [Updated] (FLINK-39258) FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs
Yuepeng Pan (Jira) via issues
-
2026/11/02
[jira] [Created] (FLINK-41301) Throw TableRuntimeException for every failed cast from VARIANT
Ramin Gharib (Jira) via issues
-
2026/11/02
Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink]
flinkbot (via GitHub) via issues
-
2026/11/02
Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink]
flinkbot (via GitHub) via issues
-
2026/11/02
Re: [PR] [runtime] Add cross-release state migration test for ActionExecutionOperator [flink-agents]
wenjin272 (via GitHub) via issues
-
2026/11/02
[jira] [Commented] (FLINK-41299) Watermark alignment deadlocks checkpoints after source subtasks finish
Chen Zhang (Jira) via issues
-
2026/11/02
Re: [PR] [api][plan][java] Add a decision-model routing strategy for MODEL_ROUTER [flink-agents]
wenjin272 (via GitHub) via issues
-
2026/11/02
Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink]
snuyanzin (via GitHub) via issues
-
2026/11/02
Re: [PR] [FLINK-41298][core] Reject content after the JSON value in `PARSE_JSON` and the raw format [flink]
snuyanzin (via GitHub) via issues
-
2026/11/02
Re: [PR] [FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink]
snuyanzin (via GitHub) via issues
-
2026/11/02
[jira] [Commented] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory
Robin Varghese (Jira) via issues
-
2026/11/02
Re: [PR] [BP-2.4][FLINK-40886][runtime] Do not create the blob directories in the file count checks [flink]
robinrvm (via GitHub) via issues
-
2026/11/02
Re: [PR] [FLINK-41253][python] Preserve scalar projection order when using async UDFs [flink]
bgeng777 (via GitHub) via issues
-
2026/11/02
[PR] [BP-2.3][FLINK-40886][runtime] Do not create the blob directories in the file count checks [flink]
robinrvm (via GitHub) via issues
-
2026/11/02
[PR] [BP-2.4][FLINK-40886][runtime] Do not create the blob directories in the file count checks [flink]
robinrvm (via GitHub) via issues
-
2026/11/02
Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink]
Myracle (via GitHub) via issues
-
2026/11/02
Re: [PR] [api][plan][runtime][java][python] Support bounded internal sub-agent batches [flink-agents]
wenjin272 (via GitHub) via issues
-
2026/11/02
[jira] [Assigned] (FLINK-41298) PARSE_JSON, TRY_PARSE_JSON and the raw format drop content after the first JSON value
Ramin Gharib (Jira) via issues
-
2026/11/02
Re: [PR] [BP-3.7][FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc]
yuxiqian (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-41269][runtime] Do not treat task clean-up failure as fatal [flink]
pnowojski (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36399) cast result is incorrect
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Resolved] (FLINK-41102) Keyed state clear operations are lost on key changes when python.state.cache-size is zero
Dian Fu (Jira) via issues
-
2026/11/01
Re: [D] Human-in-the-loop approval: pluggable approver (decision model first, human fallback) - design discussion for #1067 [flink-agents]
wenjin272 (via GitHub) via issues
-
2026/11/01
[PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink]
1996fanrui (via GitHub) via issues
-
2026/11/01
Re: [PR] [docs][release-0.4] Standardize Alibaba Cloud Model Studio naming [flink-agents]
wenjin272 (via GitHub) via issues
-
2026/11/01
Re: [PR] [hotfix][api][java] Move ResourceContext lookup factory to test utilities [flink-agents]
wenjin272 (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink]
flinkbot (via GitHub) via issues
-
2026/11/01
Re: [PR] [python] Read flat agent.* keys from configuration files [flink-agents]
wenjin272 (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink]
flinkbot (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink]
flinkbot (via GitHub) via issues
-
2026/11/01
[PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink]
1996fanrui (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-39386] For Flink 2.x+, support limit the rate at the source [flink-cdc]
lvyanquan (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache [flink]
dianfu (via GitHub) via issues
-
2026/11/01
[PR] [api][plan][runtime][java] Unify Future scheduling and tool execution [flink-agents]
wenjin272 (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39700) Fix name-based column matching in materialized table schema diff
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Resolved] (FLINK-41057) Iceberg append-only tables incorrectly append before-images from UPDATE and DELETE events
Yanquan Lv (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc]
lvyanquan (via GitHub) via issues
-
2026/11/01
[jira] [Commented] (FLINK-40185) Introduce DataFrame API in PyFlink
Dian Fu (Jira) via issues
-
2026/11/01
[PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink]
1996fanrui (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc.
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently
Rui Fan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37593) Add Some Reduce Expression Rules
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink]
snuyanzin (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink]
flinkbot (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink]
flinkbot (via GitHub) via issues
-
2026/11/01
[PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink]
1996fanrui (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink]
flinkbot (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36160) Support hive advanced configuration
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink]
flinkbot (via GitHub) via issues
-
2026/11/01
[PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink]
1996fanrui (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39387) Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation
Rui Fan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Created] (FLINK-41294) PyFlink batch: pandas UDAF over a RANGE frame with CURRENT ROW or n PRECEDING / FOLLOWING reads the ORDER BY key as TIMESTAMP(3) and gets wrong frames for INT and DECIMAL keys
Yaoxuan Wu (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39544) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Commented] (FLINK-39931) Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution
Rui Fan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink]
flinkbot (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink]
flinkbot (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36363) Remove references to scala-relate api in tests among table modules
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41291) Bump snappy-java to 1.1.10.12
ASF GitHub Bot (Jira) via issues
-
2026/11/01
[PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink]
1996fanrui (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41121) [release-2.4] Select executing release manager
Yuepeng Pan (Jira) via issues
-
2026/11/01
[PR] [BP-2.3][FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink]
1996fanrui (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink]
fresh-borzoni (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink]
fresh-borzoni (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink]
fresh-borzoni (via GitHub) via issues
-
2026/11/01
[PR] Bump org.xerial.snappy:snappy-java from 1.1.10.4 to 1.1.10.9 [flink-connector-prometheus]
dependabot[bot] (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40997) Regular join picks a random state key among equal-length upsert keys
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Resolved] (FLINK-41275) Start containers in e2e per class rather than per test in SQL e2e
Sergey Nuyanzin (Jira) via issues
-
2026/11/01
[jira] [Commented] (FLINK-41275) Start containers in e2e per class rather than per test in SQL e2e
Sergey Nuyanzin (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-41275][e2e] Start containers in e2e per class rather than per test in SQL e2e [flink]
snuyanzin (via GitHub) via issues
-
2026/11/01
[jira] [Commented] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39543) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Reopened] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36482) Remove all deprecated methods in `TableEnvironment`
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Created] (FLINK-41291) Bump snappy-java to 1.1.10.12
Sergey Nuyanzin (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36849) Introduce AppendOnlyFirstNFunction in Rank with Async State API
Yuepeng Pan (Jira) via issues
-
2026/11/01
[PR] Bump org.xerial.snappy:snappy-java from 1.1.10.5 to 1.1.10.9 [flink-connector-opensearch]
dependabot[bot] (via GitHub) via issues
-
2026/11/01
[PR] Bump org.xerial.snappy:snappy-java from 1.1.10.4 to 1.1.10.9 [flink-connector-pulsar]
dependabot[bot] (via GitHub) via issues
-
2026/11/01
[PR] [LINK-41289] Run canary health checks only with the health probe enabled, on one named thread [flink-kubernetes-operator]
Dennis-Mircea (via GitHub) via issues
-
2026/11/01
[jira] [Created] (FLINK-41289) Run canary health checks only with the health probe enabled, on one named thread
Dennis-Mircea Ciupitu (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41288) Recreating a canary resource leaves duplicate health check loops running
ASF GitHub Bot (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view
Purushottam Sinha (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40304) Incorrect upsert key inference for PTFs with multiple table arguments
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-33894) Implement restore tests for PythonGroupAggregate node
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40557) Make operation column optional in TO_CHANGELOG output
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents]
pranavshuklaa (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41129) [release-2.4] Add release notes
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38321) Optimize the timer registration logic n window early/late firing scenarios
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37117) Add docs for async state SQL operators in 2.0
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40303) Sink constraint enforcer rejects key-only DELETE records with NOT NULL non-key columns
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40234) Busy subtask thread may cause splits to be marked as idle erroneously and cause dropped records
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39545) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36487) Remove deprecated method `StreamTableEnvironment#createTemporaryView`
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink]
snuyanzin (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Commented] (FLINK-40751) State Processor environment and operators should use task memory/io manager
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink]
snuyanzin (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-33120) FLIP-361: Improve GC Metrics
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37551) Improve the state compatibility of ForStKeyeStateBackend and ForStSyncKeyeStateBackend
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink]
snuyanzin (via GitHub) via issues
-
2026/11/01
[jira] [Resolved] (FLINK-39924) Memory fragmentation from jemalloc misconfiguration
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40728) [FLIP-607] Migrate Flink off end-of-life OkHttp; keep it off the core classpath
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40648) PrometheusReporter drops all metrics of a process when two metric group variables sanitise to the same label name
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Commented] (FLINK-31040) Looping pattern notFollowedBy at end missing an element
Mohammad Bani Hani (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-33895) Implement restore tests for PythonGroupWindowAggregate node
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41119) Prepare Flink 2.4 release
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-31040][cep] Release a looping stage before a trailing notFollowedBy when its window expires [flink]
flinkbot (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41138) Release Testing Instructions: FLIP-566: Introduce a new IMMUTABLE columns constraint
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41132) Release Testing Instructions: FLIP-497: Early Fire Support for Flink SQL Interval Join
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41125) [release-2.4] Cross-team testing
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41143) Release Testing Instructions: FLIP-579: LATERAL SNAPSHOT Join
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41128) [release-2.4] Verify that no exclusions were erroneously added to the japicmp plugin
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41124) [release-2.4] Review release notes in JIRA
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41126) [release-2.4] Triage release blockers in JIRA
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41123) [release-2.4] Prepare RC0 release
Yuepeng Pan (Jira) via issues
-
2026/11/01
[PR] [FLINK-31040][cep] Release a looping stage before a trailing notFollowedBy when its window expires [flink]
mobanihan (via GitHub) via issues
-
2026/11/01
Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink]
snuyanzin (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-31040) Looping pattern notFollowedBy at end missing an element
ASF GitHub Bot (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink]
snuyanzin (via GitHub) via issues
-
2026/11/01
[jira] [Resolved] (FLINK-40751) State Processor environment and operators should use task memory/io manager
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40728) [FLIP-607] Migrate Flink off end-of-life OkHttp; keep it off the core classpath
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Resolved] (FLINK-41202) Make connector integrations easier to find from the Flink docs
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Resolved] (FLINK-40584) Bound RocksDB prefix iterators to avoid scanning unrelated tombstones
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40584) Bound RocksDB prefix iterators to avoid scanning unrelated tombstones
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Commented] (FLINK-40584) Bound RocksDB prefix iterators to avoid scanning unrelated tombstones
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-40557) Make operation column optional in TO_CHANGELOG output
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Resolved] (FLINK-40267) CREATE MATERIALIZED TABLE skips persisted-metadata-column validation applied by CREATE OR ALTER
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Closed] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37777) FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-40975][table-planner] Don't drop join conditions in FlinkBushyJoinReorderRule [flink]
snuyanzin (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36881) Introduce GroupTableAggFunction in GroupTableAggregate with Async State API
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Commented] (FLINK-39700) Fix name-based column matching in materialized table schema diff
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-40975][table-planner] Don't drop join conditions in FlinkBushyJoinReorderRule [flink]
snuyanzin (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39422) [FLINK][OpenAPI] OpenApiSpecGenerator produces incorrect schemas for types with custom Jackson serializers
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39109) [Phase 2] Native s3 Filesystem
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39404) HardwareDescription reports incorrect CPU cores in containerized environments with fractional CPU limits
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39285) Consider the result of filter pushdown rules in the MultiJoin rule
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37340) Flink supports pushing metrics immediately at the end of the task.
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38120) FLIP-536 Add latest checkpoint details endpoint
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37088) When the Flink application is running in k8s, the taskmanager log lacks a mount mapping to the host machine. Once the container is restarted, the log will disappear. It is necessary to have a log mount mapping to the host machine
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call.
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39322) Add some restore tests about cascaded delta join
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema`
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39947) Fix the flaky test case in class TaskExecutorPartitionLifecycleTest
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38942) Add documentation for async python scalar function
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38570) FLIP-554: Pipeline Testing Framework for Flink
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds
Yuepeng Pan (Jira) via issues
-
2026/11/01
Re: [PR] [FLINK-40976][table-planner] Don't apply a post-join filter twice when merging joins for reorder [flink]
snuyanzin (via GitHub) via issues
-
2026/11/01
[jira] [Updated] (FLINK-39991) Drop ReplaceIntersectWithSemiJoinRule
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36660) Release flink-connector-elasticsearch v4.0.0 for Flink 2.0
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38459) SinkUpsertMaterializer V2 (FLIP-544)
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38551) Extend MultiJoin tests based on current join tests
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38516) Add configuration option to enable read-only mode for Flink SQL Gateway
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38459) SinkUpsertMaterializer V2 (FLIP-544)
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38444) Join calculates upsert keys with null keys for left join
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38351) Docker images support OpenJDK
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-38172) Update japicmp configuration
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37549) Some scala and markdown syntax errors in tableApi page
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37526) Promote SinkV2 API classes from @Experimental to @PublicEvolving
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37442) Properly delete the directories for ForSt remote storage
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-41119) Prepare Flink 2.4 release
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Closed] (FLINK-36880) Hybrid Shuffle support batch job recovery
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36658) Support and Release Connectors for Flink 2.0
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API
Yuepeng Pan (Jira) via issues
-
2026/11/01
[jira] [Updated] (FLINK-36882) Introduce MiniBatchGroupAggFunction in GroupAggregate with Async State API
Yuepeng Pan (Jira) via issues