Messages by Thread
-
Re: [PR] [FLINK-40294][table-planner] Instrument async scalar and table UDF calls with metrics [flink]
via GitHub
-
[jira] [Created] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in
Mohsen Rezaei (Jira)
-
[jira] [Created] (FLINK-40930) MIN/MAX on FLOAT/DOUBLE return NaN only if NaN is the first input row (order-dependent result)
Yaoxuan Wu (Jira)
-
[jira] [Created] (FLINK-40929) SUM on DECIMAL silently returns a wrong, order-dependent value after an overflow
Yaoxuan Wu (Jira)
-
[jira] [Created] (FLINK-40928) DISTINCT over a cross join with an IS NULL filter returns rows with NULL that are not in the input
Yaoxuan Wu (Jira)
-
[jira] [Updated] (FLINK-40894) Expose counters for unmatched retractions in SinkUpsertMaterializer and KeyedLookupJoinWrapper
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40894][table-runtime] Expose numUnmatchedBuildRetractions counter [flink]
via GitHub
-
[jira] [Updated] (FLINK-40927) Inconsistent NaN semantics for FLOAT/DOUBLE across planner and runtime
Yahya Kisana (Jira)
-
[jira] [Updated] (FLINK-40923) `a >= b` on DOUBLE NaN keeps the row in one query but drops it when the input is first written to a table (reflexive comparison simplified to TRUE)
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40923][table] Do not simplify reflexive comparisons on FLOAT/DOUBLE [flink]
via GitHub
-
[jira] [Created] (FLINK-40927) Inconsistent NaN semantics for FLOAT/DOUBLE across planner and runtime
Yahya Kisana (Jira)
-
[jira] [Commented] (FLINK-40923) `a >= b` on DOUBLE NaN keeps the row in one query but drops it when the input is first written to a table (reflexive comparison simplified to TRUE)
Yahya Kisana (Jira)
-
Re: [PR] [FLINK-39797] Support disabling automatic table creation [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-40298][table] Opt-in name-based state schema evolution for RowData [flink]
via GitHub
-
[PR] [FLINK-40737][table] Keep non-time OVER data views inside the accumulator [flink]
via GitHub
-
[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)
-
[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
-
[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)
-
[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