Messages by Thread
-
-
[jira] [Updated] (FLINK-40940) HTTP lookup source drops the row for a failed call with continue-on-error unless the planner calls applyReadableMetadata
ASF GitHub Bot (Jira)
-
[jira] [Comment Edited] (FLINK-40172) Support processing-time early fire on a row-time interval join
Weiqing Yang (Jira)
-
[jira] [Assigned] (FLINK-40173) Add restore coverage for early-fire interval join
Weiqing Yang (Jira)
-
Re: [PR] [FLINK-40173][table-planner] Add restore coverage for early-fire interval join [flink]
via GitHub
-
[PR] [hotfix][table-planner] Drop stale metadata=[] from the early-fire proctime golden [flink]
via GitHub
-
Re: [I] [Umbrella] Pluggable model routing (MODEL_ROUTER): delivery status, Python parity, documentation, and follow-ups [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-36419) Consider scaling in case of no input records on a source operator with long running job
Sergey Kononov (Jira)
-
[jira] [Closed] (FLINK-36419) Consider scaling in case of no input records on a source operator with long running job
Sergey Kononov (Jira)
-
[jira] [Closed] (FLINK-35892) Flink Kubernetes Operator docs lacks info on FlinkSessionJob submission
Sergey Kononov (Jira)
-
[jira] [Commented] (FLINK-35892) Flink Kubernetes Operator docs lacks info on FlinkSessionJob submission
Sergey Kononov (Jira)
-
[PR] [api][java][python] Add raw-bytes factories for media blocks [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-40856) Support zip-style multi-column explode in DataFrame API
Dian Fu (Jira)
-
[jira] [Comment Edited] (FLINK-40856) Support zip-style multi-column explode in DataFrame API
Dian Fu (Jira)
-
[PR] [api][runtime][python] Support running a ReActAgent as a general-purpose sub-agent [flink-agents]
via GitHub
-
Re: [PR] [FLINK-39415][postgres] Fix TIMESTAMPTZ type mapping in pipeline connector [flink-cdc]
via GitHub
-
[PR] [FLINK-40908][Connectors/HBase] Update bundled hbase-default.xml and NOTICE to HBase 2.6.6 [flink-connector-hbase]
via GitHub
-
[jira] [Resolved] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40927) Inconsistent NaN semantics for FLOAT/DOUBLE across planner and runtime
Sergey Nuyanzin (Jira)
-
[PR] Revert "[feature] Add flink-stateful-ops-agent-demo: a stateful runbook agent for Flink 2.2 balanced tasks scheduling (#10)" [flink-agents-demos]
via GitHub
-
[PR] [feature] Add flink-stateful-ops-agent-demo: a stateful runbook agent for Flink 2.2 balanced tasks scheduling [flink-agents-demos]
via GitHub
-
[jira] [Commented] (FLINK-40849) UNION ALL fails for RAW/BITMAP columns with different nullability
Charan Rathore (Jira)
-
[PR] [FLINK-40476][docs] Clarify that the Changelog state backend requires CLAIM restore mode [flink]
via GitHub
-
[jira] [Updated] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40950][table-planner] Drop stale metadata=[] from EarlyFireJoinHintTest plan [flink]
via GitHub
-
[jira] [Commented] (FLINK-40476) Clarify that the Changelog state backend requires CLAIM restore mode (NO_CLAIM unsupported)
Ravikiran kalal (Jira)
-
[jira] [Commented] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output
Yahya Kisana (Jira)
-
[PR] [hotfix][table] Fix `EarlyFireJoinHintTest#testEarlyFireProcTimeOnRowTimeJoin` [flink]
via GitHub
-
[jira] [Updated] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null."
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40949][table-runtime] Fail with a clear error on NULL window bounds in windowed assigners [flink]
via GitHub
-
[PR] [FLINK-40948][table] Maintain window properties for different joins [flink]
via GitHub
-
[jira] [Commented] (FLINK-40172) Support processing-time early fire on a row-time interval join
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null."
Yahya Kisana (Jira)
-
[jira] [Commented] (FLINK-40929) SUM on DECIMAL silently returns a wrong, order-dependent value after an overflow
Charan Rathore (Jira)
-
[jira] [Closed] (FLINK-40934) Table API row() fails when AS aliases produce duplicate field names
Ramin Gharib (Jira)
-
[jira] [Assigned] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null."
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40945) -0.0 and 0.0 are different keys in GROUP BY, DISTINCT, UNION and hash joins
Yaoxuan Wu (Jira)
-
[jira] [Created] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40946) SUM / AVG on DECIMAL(38, s) over a join are rounded to scale 6
Yaoxuan Wu (Jira)
-
[jira] [Created] (FLINK-40947) ROLLUP / CUBE / GROUPING SETS with () return no grand-total row on an empty input
Yaoxuan Wu (Jira)
-
[jira] [Updated] (FLINK-40945) -0.0 and 0.0 are different keys in GROUP BY, DISTINCT, UNION and hash joins
Yaoxuan Wu (Jira)
-
[jira] [Updated] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound
Yaoxuan Wu (Jira)
-
[jira] [Updated] (FLINK-40935) VAR_SAMP / STDDEV_SAMP return -1 for a group with a single row
Yaoxuan Wu (Jira)
-
[PR] [FLINK-40938][Connectors/DynamoDB] Support AT_TIMESTAMP initial position in DynamoDB Streams source [flink-connector-aws]
via GitHub
-
[PR] [api][plan] Abstain on runtime non-candidate model selections [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-40944) CPU limit-factor inflates the JVM's availableProcessors() to the CPU limit
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40944][operator] Pin -XX:ActiveProcessorCount to the CPU request when a CPU limit factor is set [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-40937) UPDATE fails with IndexOutOfBoundsException when a SET value's type doesn't match the column
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40936) Built-in functions compare VARIANT array elements and map keys by their binary encoding
Ramin Gharib (Jira)
-
[jira] [Updated] (FLINK-40937) UPDATE fails with IndexOutOfBoundsException when a SET value's type doesn't match the column
ASF GitHub Bot (Jira)
-
[PR] [FLINK-38569][table-planner] Don't record a ReadingMetadata ability without metadata keys [flink]
via GitHub
-
[jira] [Created] (FLINK-40944) CPU limit-factor inflates the JVM's availableProcessors() to the CPU limit
Jira
-
[PR] [integration][java][python] Send user images and documents to Anthropic [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1)
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink]
via GitHub
-
[jira] [Resolved] (FLINK-38569) ReadingMetadataSpec should not be generated if there are no metadataKeys to be read
Arvid Heise (Jira)
-
Re: [PR] [Tech Debt] align action recovery model [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-40939) TRY_RESOLVE accepts non-deterministic join keys and join conditions on updating inputs with a unique key
Gustavo de Morais (Jira)
-
[jira] [Updated] (FLINK-40902) LATERAL SNAPSHOT join wrongly rejected when a local filter targets the join key column
ASF GitHub Bot (Jira)
-
[jira] [Commented] (FLINK-40902) LATERAL SNAPSHOT join wrongly rejected when a local filter targets the join key column
Fabian Hueske (Jira)
-
[PR] [FLINK-40902][table] Support LATERAL SNAPSHOT join without an equi-key [flink]
via GitHub
-
[jira] [Updated] (FLINK-40942) NativeS3FileSystem#getFileStatus fails with "Key cannot be empty" for bucket-root paths
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40942][fs/s3-native] Return directory status for bucket-root paths in NativeS3FileSystem#getFileStatus [flink]
via GitHub
-
[PR] [FLINK-39883][table] Support broadcast state for process table functions [flink]
via GitHub
-
[jira] [Updated] (FLINK-39883) Support broadcast state in PTFs
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-34474][formats] Reset Avro decoder after a failed deserialization [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40809) Regular outer join loses the null-padded row when an input record is updated without UPDATE_BEFORE
Gustavo de Morais (Jira)
-
[jira] [Resolved] (FLINK-40368) Deduplicate output should only be insert-only when ordered by time attribute
Gustavo de Morais (Jira)
-
[jira] [Commented] (FLINK-40645) ForSt file cache: closed CachedDataInputStreams stay registered in FileCacheEntry.openedStreams until the file is evicted, accumulating on the heap
Zakelly Lan (Jira)
-
[jira] [Assigned] (FLINK-40852) PARSE_JSON fails with NullPointerException when allowDuplicateKeys is NULL
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-40645) ForSt file cache: closed CachedDataInputStreams stay registered in FileCacheEntry.openedStreams until the file is evicted, accumulating on the heap
Zakelly Lan (Jira)
-
[jira] [Updated] (FLINK-40936) Built-in functions compare VARIANT array elements and map keys by their binary encoding
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40936][table] Reject VARIANT elements and keys in functions that compare them [flink]
via GitHub
-
[jira] [Assigned] (FLINK-38569) ReadingMetadataSpec should not be generated if there are no metadataKeys to be read
Arvid Heise (Jira)
-
[jira] [Created] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound
Yaoxuan Wu (Jira)
-
[PR] [FLINK-40937][table] `UPDATE` fails with `IndexOutOfBoundsException` when a `SET` value's type doesn't match the column [flink]
via GitHub
-
[jira] [Created] (FLINK-40941) Add warmup for janino
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40852) PARSE_JSON fails with NullPointerException when allowDuplicateKeys is NULL
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40940) HTTP lookup source drops the row for a failed call with continue-on-error unless the planner calls applyReadableMetadata
Arvid Heise (Jira)
-
[jira] [Created] (FLINK-40937) UPDATE fails with IndexOutOfBoundsException when a SET value's type doesn't match the column
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1)
Jira
-
[jira] [Updated] (FLINK-40941) Add warmup for janino
ASF GitHub Bot (Jira)