Messages by Thread
-
-
[jira] [Updated] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window
sepuri sai krishna (Jira)
-
[jira] [Commented] (FLINK-22599) Point to `client.timeout` in error messages where it is used for rpc timeout
Amrit Sarkar (Jira)
-
[jira] [Closed] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls
Weiqing Yang (Jira)
-
Re: [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink]
via GitHub
-
Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents]
via GitHub
-
[jira] [Assigned] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions
Martijn Visser (Jira)
-
[jira] [Resolved] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-39998) RocksDBStateDownloader loses parallel download failures, surfacing a misleading ClosedChannelException instead of the real root cause
Amrit Sarkar (Jira)
-
Re: [PR] [FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions [flink]
via GitHub
-
[jira] (FLINK-39998) RocksDBStateDownloader loses parallel download failures, surfacing a misleading ClosedChannelException instead of the real root cause
Amrit Sarkar (Jira)
-
[jira] [Resolved] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted
Zakelly Lan (Jira)
-
[jira] [Commented] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted
Zakelly Lan (Jira)
-
Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http]
via GitHub
-
[D] [Discussion] Context compaction for Flink Agents [flink-agents]
via GitHub
-
[jira] [Resolved] (FLINK-40913) CheckpointSyncPhaseTimeoutITCase failures race
Martijn Visser (Jira)
-
[PR] [FLINK-40910][table] Reject VARIANT where a query needs equality or ordering [flink]
via GitHub
-
[jira] [Updated] (FLINK-40910) Reject VARIANT where SQL needs equality. Byte comparison gives wrong results in GROUP BY, DISTINCT, joins and =
Ramin Gharib (Jira)
-
Re: [PR] [FLINK-40046][runtime-web] Upgrade @antv/g2 to v5 [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40200) Introduce sync phase timeout for TaskManagers locking up in org.rocksdb.Checkpoint.createCheckpoint
Martijn Visser (Jira)
-
[jira] [Resolved] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager
Martijn Visser (Jira)
-
[jira] [Closed] (FLINK-40826) Support casting constructed types to VARIANT
Timo Walther (Jira)
-
[jira] [Closed] (FLINK-40911) Variant builder mishandles a nested variant and a value of exactly 16 MiB
Timo Walther (Jira)
-
[jira] [Commented] (FLINK-40856) Support zip-style multi-column explode in DataFrame API
Bettle (Jira)
-
[jira] [Created] (FLINK-40926) Projection push down records a ReadingMetadata ability without metadata keys
Arvid Heise (Jira)
-
[PR] [BP-1.20][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink]
via GitHub
-
Re: [PR] [hotfix] Notice change [flink-connector-http]
via GitHub
-
[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
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40735][table] Compare non-time OVER accumulators with a generated equaliser [flink]
via GitHub
-
[jira] [Commented] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations
Isaac Montenegro Jimenez (Jira)
-
[jira] [Updated] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40916][runtime] Optionally skip eager initialization of checkpoint base locations [flink]
via GitHub
-
Re: [PR] [FLINK-33383] [Project Website] Remove deprecated Scala quickstart scripts [flink-web]
via GitHub
-
[jira] [Assigned] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window
Martijn Visser (Jira)
-
[PR] [Backport][FLINK-39966][FLINK-40368][table] Fix changelog inference for Top-1 ranks not ordered by a time attribute [flink]
via GitHub
-
[PR] [Backport][FLINK-40368][table] Deduplicate output should only be insert-only when ordered by time attribute [flink]
via GitHub
-
Re: [PR] [FLINK-24379] Add Glue Schema Registry SQL formats: Avro, Protobuf, JSON [flink-connector-aws]
via GitHub
-
[PR] [Backport][FLINK-40809][FLINK-40831][FLINK-40841][FLINK-40858][table] Backport streaming join update fixes to 2.2 [flink]
via GitHub
-
[jira] [Commented] (FLINK-40736) Non-time ROWS OVER window emits a malformed row for FIRST_VALUE, LAST_VALUE, LISTAGG, COUNT(DISTINCT), ARRAY_AGG, COLLECT and PERCENTILE
Martijn Visser (Jira)
-
[PR] [Backport][FLINK-40809][FLINK-40831][FLINK-40841][FLINK-40858][table] Backport streaming join update fixes to 2.3 [flink]
via GitHub
-
[jira] [Commented] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction
Martijn Visser (Jira)
-
[jira] [Closed] (FLINK-40736) Non-time ROWS OVER window emits a malformed row for FIRST_VALUE, LAST_VALUE, LISTAGG, COUNT(DISTINCT), ARRAY_AGG, COLLECT and PERCENTILE
Martijn Visser (Jira)
-
[PR] [BP-2.2][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink]
via GitHub
-
[PR] [BP-2.3][FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition [flink]
via GitHub
-
[jira] [Updated] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager
Martijn Visser (Jira)
-
[PR] [FLINK-40429][python] Add StatementSet support for DataFrame writes [flink]
via GitHub
-
[jira] [Updated] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-40354][state/forst] Configure the TTL compaction filter for State V2 states [flink]
via GitHub
-
[jira] [Assigned] (FLINK-40913) CheckpointSyncPhaseTimeoutITCase failures race
Martijn Visser (Jira)
-
[PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink]
via GitHub
-
[jira] [Commented] (FLINK-40500) DataStream V2 idleness detection is not backpressure-aware - FLIP-471 was never applied to ExtractEventTimeProcessFunction
yongfu.gao (Jira)
-
[jira] [Assigned] (FLINK-40921) Invoke statebackend's close() and dispose() in right order
Zakelly Lan (Jira)
-
[jira] [Commented] (FLINK-18692) AvroSerializationSchema does not work with types generated by avrohugger
Amrit Sarkar (Jira)
-
[PR] [FLINK-40925][rest] `JobVertexBackPressureHandler` throws `NoSuchElementException` when execution attempts are pruned concurrently [flink]
via GitHub
-
[jira] [Updated] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently
ASF GitHub Bot (Jira)
-
[jira] [Created] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently
Sergey Nuyanzin (Jira)
-
[jira] [Closed] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails
Robert Metzger (Jira)
-
[jira] [Updated] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails
Robert Metzger (Jira)
-
[jira] [Commented] (FLINK-40924) table.exec.sink.upsert-materialize=NONE silently bypasses the require-on-conflict check
sepuri sai krishna (Jira)
-
[jira] [Created] (FLINK-40924) table.exec.sink.upsert-materialize=NONE silently bypasses the require-on-conflict check
sepuri sai krishna (Jira)
-
[jira] [Updated] (FLINK-40658) UNNEST silently drops null ROW elements from ARRAY
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40658][table] Preserve null ROW elements in UNNEST [flink]
via GitHub
-
Re: [PR] [FLINK-40218][core] Let callers that already hold parsed JSON build a VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-34376][table] Fix DECIMAL precision loss in multiplication type inference [flink]
via GitHub
-
Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink]
via GitHub
-
Re: [PR] [FLINK-39860][runtime] Reduce ArchUnit violations: production code must not call @VisibleForTesting methods [flink]
via GitHub
-
[jira] [Updated] (FLINK-34376) FLINK SQL SUM() causes a precision error
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-40057][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink]
via GitHub
-
[jira] [Commented] (FLINK-31737) Hide the rescaling buttons for batch jobs in the WEB UI
Amrit Sarkar (Jira)
-
[PR] [FLINK-40920][table-planner] Fix ClassCastException when reducing a division by a constant expression [flink]
via GitHub
-
[jira] [Updated] (FLINK-40501) WatermarkStatus overtakes queued watermarks in AsyncWaitOperator, causing watermark loss downstream
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-40836) Restoring with execution.state-recovery.without-channel-state.checkpoint-id drops operator coordinator state
ASF GitHub Bot (Jira)