Messages by Thread
-
Re: [PR] [FLINK-40954] Force delete pods stuck Terminating on cluster resourcecleanup timeout [flink-kubernetes-operator]
gyfora (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter
Rui Fan (Jira) via issues
-
Re: [PR] [FLINK-40123][e2e] check_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh [flink]
mbarnacki (via GitHub) via issues
-
Re: [PR] [BP-2.3][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink]
twalthr (via GitHub) via issues
-
[jira] [Created] (FLINK-41302) Expose canary reconcile latency as a measure of reconciliation pool saturation
Dennis-Mircea Ciupitu (Jira) via issues
-
[PR] [BP-3.7][FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc]
lvyanquan (via GitHub) via issues
-
[jira] [Assigned] (FLINK-40843) Add StateCatalog documentation
Gyula Fora (Jira) via issues
-
[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
-
[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
-
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
-
[jira] [Commented] (FLINK-41244) PTF clearAllTimers() deletes unnamed timers across all keys and corrupts the key context
Yuepeng Pan (Jira) via issues
-
[jira] [Comment Edited] (FLINK-40843) Add StateCatalog documentation
Yuepeng Pan (Jira) via issues
-
[jira] [Commented] (FLINK-40843) Add StateCatalog documentation
Yuepeng Pan (Jira) via issues
-
[jira] [Commented] (FLINK-40438) Add DataFrame inspection and rich display APIs
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-39258) FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs
Yuepeng Pan (Jira) via issues
-
[jira] [Created] (FLINK-41301) Throw TableRuntimeException for every failed cast from VARIANT
Ramin Gharib (Jira) via issues
-
[jira] [Commented] (FLINK-41299) Watermark alignment deadlocks checkpoints after source subtasks finish
Chen Zhang (Jira) via issues
-
Re: [PR] [api][plan][java] Add a decision-model routing strategy for MODEL_ROUTER [flink-agents]
wenjin272 (via GitHub) via issues
-
Re: [PR] [FLINK-41253][python] Preserve scalar projection order when using async UDFs [flink]
bgeng777 (via GitHub) via issues
-
[PR] [BP-2.3][FLINK-40886][runtime] Do not create the blob directories in the file count checks [flink]
robinrvm (via GitHub) via issues
-
[PR] [BP-2.4][FLINK-40886][runtime] Do not create the blob directories in the file count checks [flink]
robinrvm (via GitHub) via issues
-
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
-
[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
-
[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
-
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
-
[PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink]
1996fanrui (via GitHub) via issues
-
[PR] [api][plan][runtime][java] Unify Future scheduling and tool execution [flink-agents]
wenjin272 (via GitHub) via issues
-
[jira] [Resolved] (FLINK-41057) Iceberg append-only tables incorrectly append before-images from UPDATE and DELETE events
Yanquan Lv (Jira) via issues
-
[jira] [Updated] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently
Rui Fan (Jira) via issues
-
[PR] [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check [flink]
1996fanrui (via GitHub) via issues
-
[PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink]
1996fanrui (via GitHub) via issues
-
[jira] [Updated] (FLINK-39387) Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation
Rui Fan (Jira) via issues
-
[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
-
[jira] [Commented] (FLINK-39931) Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-41291) Bump snappy-java to 1.1.10.12
ASF GitHub Bot (Jira) via issues
-
[PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink]
1996fanrui (via GitHub) via issues
-
[jira] [Updated] (FLINK-41121) [release-2.4] Select executing release manager
Yuepeng Pan (Jira) via issues
-
[PR] [BP-2.3][FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink]
1996fanrui (via GitHub) via issues
-
[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
-
[jira] [Resolved] (FLINK-41275) Start containers in e2e per class rather than per test in SQL e2e
Sergey Nuyanzin (Jira) via issues
-
[jira] [Commented] (FLINK-41275) Start containers in e2e per class rather than per test in SQL e2e
Sergey Nuyanzin (Jira) via issues
-
[jira] [Commented] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException
Yuepeng Pan (Jira) via issues
-
[jira] [Reopened] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore
Yuepeng Pan (Jira) via issues
-
[jira] [Created] (FLINK-41291) Bump snappy-java to 1.1.10.12
Sergey Nuyanzin (Jira) via issues
-
[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
-
[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
-
[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
-
[jira] [Created] (FLINK-41289) Run canary health checks only with the health probe enabled, on one named thread
Dennis-Mircea Ciupitu (Jira) via issues
-
[jira] [Updated] (FLINK-41288) Recreating a canary resource leaves duplicate health check loops running
ASF GitHub Bot (Jira) via issues
-
[jira] [Updated] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view
Purushottam Sinha (Jira) via issues
-
[jira] [Updated] (FLINK-41129) [release-2.4] Add release notes
Yuepeng Pan (Jira) via issues
-
[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
-
[jira] [Commented] (FLINK-40751) State Processor environment and operators should use task memory/io manager
Yuepeng Pan (Jira) via issues
-
[jira] [Resolved] (FLINK-39924) Memory fragmentation from jemalloc misconfiguration
Yuepeng Pan (Jira) via issues
-
[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
-
[jira] [Commented] (FLINK-31040) Looping pattern notFollowedBy at end missing an element
Mohammad Bani Hani (Jira) via issues
-
[jira] [Updated] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-41138) Release Testing Instructions: FLIP-566: Introduce a new IMMUTABLE columns constraint
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-41132) Release Testing Instructions: FLIP-497: Early Fire Support for Flink SQL Interval Join
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-41125) [release-2.4] Cross-team testing
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-41143) Release Testing Instructions: FLIP-579: LATERAL SNAPSHOT Join
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-41128) [release-2.4] Verify that no exclusions were erroneously added to the japicmp plugin
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-41124) [release-2.4] Review release notes in JIRA
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-41126) [release-2.4] Triage release blockers in JIRA
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-41123) [release-2.4] Prepare RC0 release
Yuepeng Pan (Jira) via issues
-
[PR] [FLINK-31040][cep] Release a looping stage before a trailing notFollowedBy when its window expires [flink]
mobanihan (via GitHub) via issues
-
[jira] [Updated] (FLINK-31040) Looping pattern notFollowedBy at end missing an element
ASF GitHub Bot (Jira) via issues
-
[jira] [Resolved] (FLINK-40751) State Processor environment and operators should use task memory/io manager
Yuepeng Pan (Jira) via issues
-
[jira] [Resolved] (FLINK-41202) Make connector integrations easier to find from the Flink docs
Yuepeng Pan (Jira) via issues
-
[jira] [Resolved] (FLINK-40584) Bound RocksDB prefix iterators to avoid scanning unrelated tombstones
Yuepeng Pan (Jira) via issues
-
[jira] [Commented] (FLINK-40584) Bound RocksDB prefix iterators to avoid scanning unrelated tombstones
Yuepeng Pan (Jira) via issues
-
[jira] [Resolved] (FLINK-40267) CREATE MATERIALIZED TABLE skips persisted-metadata-column validation applied by CREATE OR ALTER
Yuepeng Pan (Jira) via issues
-
[jira] [Closed] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException
Yuepeng Pan (Jira) via issues
-
[jira] [Commented] (FLINK-39700) Fix name-based column matching in materialized table schema diff
Yuepeng Pan (Jira) via issues
-
[jira] [Closed] (FLINK-36880) Hybrid Shuffle support batch job recovery
Yuepeng Pan (Jira) via issues
-
[jira] [Updated] (FLINK-37954) Full the exception message when the regular could not be optimized into delta join while delta join strategy is FORCE
Yuepeng Pan (Jira) via issues
-
Re: [PR] [FLINK-38023][formats] Fix GenericRecord Avro state migration [flink]
avi-sanwal (via GitHub) via issues
-
[jira] [Updated] (FLINK-28737) NDU analyzer skips the Calc condition once the upsert key covers the sink key
Yuepeng Pan (Jira) via issues
-
Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents]
pranavshuklaa (via GitHub) via issues
-
[jira] [Reopened] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE, TIME or a lower precision returns a wrong value
Yuepeng Pan (Jira) via issues
-
[jira] [Resolved] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-41152) Release Testing Instructions: Upgrade Calcite to 1.41.0
Sergey Nuyanzin (Jira) via issues
-
[jira] [Closed] (FLINK-41152) Release Testing Instructions: Upgrade Calcite to 1.41.0
Sergey Nuyanzin (Jira) via issues
-
[jira] [Closed] (FLINK-41151) Release Testing Instructions: FLINK-39268：Support Common Subexpression Elimination (CSE) in Calc Code Generation
Sergey Nuyanzin (Jira) via issues
-
[jira] [Commented] (FLINK-41151) Release Testing Instructions: FLINK-39268：Support Common Subexpression Elimination (CSE) in Calc Code Generation
Sergey Nuyanzin (Jira) via issues
-
[jira] [Updated] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-40904) FORWARD-to-REBALANCE downgrade compares producer parallelism with the number of subpartitions instead of the consumer parallelism
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-30112) Improve docs re state compression
ChenZhuo (Jira) via issues
-
[jira] [Resolved] (FLINK-40904) FORWARD-to-REBALANCE downgrade compares producer parallelism with the number of subpartitions instead of the consumer parallelism
Rui Fan (Jira) via issues
-
Re: [PR] [BP-1.20][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink]
1996fanrui (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBALANCE for autoscaler and adaptive scheduler
Rui Fan (Jira) via issues
-
[jira] [Comment Edited] (FLINK-40904) FORWARD-to-REBALANCE downgrade compares producer parallelism with the number of subpartitions instead of the consumer parallelism
Rui Fan (Jira) via issues
-
[jira] [Comment Edited] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams
Rui Fan (Jira) via issues
-
Re: [PR] [BP-2.2][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink]
1996fanrui (via GitHub) via issues
-
Re: [PR] [BP-2.3][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink]
1996fanrui (via GitHub) via issues
-
[PR] [hotfix][ci] Skip maven source in compile_ci and test jobs [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Commented] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE, TIME or a lower precision returns a wrong value
Ramin Gharib (Jira) via issues
-
[jira] [Closed] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE, TIME or a lower precision returns a wrong value
Ramin Gharib (Jira) via issues
-
[PR] [BP-2.4][FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision [flink]
raminqaf (via GitHub) via issues
-
Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink]
spuru9 (via GitHub) via issues