issues  

Messages by Thread

• [jira] [Updated] (FLINK-27492) Flink table scala example does not including the scala-api jars Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-27591) Improve the plan for batch queries when statistics is unavailable Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-25354) Document API graduation process Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-25354) Document API graduation process Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17539) Migrate the configuration options which do not follow the xyz.max/min pattern. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17535) Treat min/max as part of the hierarchy of config option Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-15018) Add event time page to Concepts Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14707) Refactor checkpoint related methods within Environment Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-15000) WebUI Metrics is very slow in large parallelism Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14934) Remove error log statement in ES connector Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14879) Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14690) Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and SQL Client Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14471) Hide error message when metric api failed Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14410) Retrieve CharacterFilter once after registration Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Sergey Nuyanzin (Jira) via issues
  • [jira] [Updated] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Gustavo de Morais (Jira) via issues
• [jira] [Updated] (FLINK-14351) Refactor MetricRegistry delimiter retrieval into separate interface Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14222) Optimize for Python UDFs with all parameters are constant values Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-12491) Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-10374) [Map State] Let user value serializer handle null values Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-10113) Drop support for pre 1.6 shared buffer state Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-6810) Add a set of built-in functions to Table API & SQL Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID' Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-13928) Make windows api more extendable Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-13928) Make windows api more extendable Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14028) Support to configure the log level of the Python user-defined functions Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique Anton Borisov (Jira)
  • [jira] [Updated] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique Sergey Nuyanzin (Jira) via issues
• [jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14125) Display memory and CPU usage in the overview page Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-14125) Display memory and CPU usage in the overview page Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Gustavo de Morais (Jira)
  • [jira] [Commented] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Sergey Nuyanzin (Jira) via issues
• [jira] [Created] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique Anton Borisov (Jira)
• [jira] [Resolved] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Robert Metzger (Jira)
• [jira] [Commented] (FLINK-37719) Support Java 25 (LTS) Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-37719) Support Java 25 (LTS) Sumin Joo (Jira)
• [PR] [hotfix][python] Fix Java 8 compilation of PythonTypeUtils [flink] via GitHub
  • Re: [PR] [hotfix][python] Fix Java 8 compilation of PythonTypeUtils [flink] via GitHub
  • Re: [PR] [hotfix][python] Fix Java 8 compilation of PythonTypeUtils [flink] via GitHub
  • Re: [PR] [hotfix][python] Fix Java 8 compilation of PythonTypeUtils [flink] via GitHub
• Re: [PR] [FLINK-39330][runtime] Make CollectSinkFunction teardown null-safe to fix flaky FileSourceTextLinesITCase JM failover [flink] via GitHub
  • Re: [PR] [FLINK-39330][runtime] Make CollectSinkFunction teardown null-safe to fix flaky FileSourceTextLinesITCase JM failover [flink] via GitHub
• Re: [PR] [FLINK-41079][runtime-web] Update Angular to v22 and ng-zorro-antd to v22 [flink] via GitHub
• [jira] [Closed] (FLINK-41266) Upgrade Java versions for CVE-2026-91403 Chanhae Oh (Jira)
• [jira] [Closed] (FLINK-40365) Job Management docs: "Config Requirement" for savepoint upgrade mode is incorrect Gyula Fora (Jira)
• [jira] [Commented] (FLINK-40185) Introduce DataFrame API in PyFlink Sumin Joo (Jira)
  • [jira] [Commented] (FLINK-40185) Introduce DataFrame API in PyFlink Dian Fu (Jira) via issues
• [jira] [Commented] (FLINK-40607) Introduce Type Inference for Python User Defined Functions Sumin Joo (Jira)
• [jira] [Commented] (FLINK-40805) FLIP-612: Native XML Functions for Flink SQL Sumin Joo (Jira)
• [PR] [hotfix][runtime] Fix typo in JobManagerProcessSpec and TaskExecutorP… [flink] via GitHub
  • Re: [PR] [hotfix][runtime] Fix typo in JobManagerProcessSpec and TaskExecutorP… [flink] via GitHub
  • Re: [PR] [hotfix][runtime] Fix typo 'refering' in process spec javadoc [flink] garvitlnmiit (via GitHub) via issues
  • Re: [PR] Fix typo 'refering' to 'referring' in TaskExecutorProcessSpec & JobManagerProcessSpec [flink] garvitlnmiit (via GitHub) via issues
  • Re: [PR] Fix typo 'refering' to 'referring' in TaskExecutorProcessSpec & JobManagerProcessSpec [flink] garvitlnmiit (via GitHub) via issues
• [jira] [Assigned] (FLINK-41281) Allow CAST from a VARIANT timestamp to the other temporal types Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41281) Allow CAST from a VARIANT timestamp to the other temporal types Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE or TIME returns a wrong value ASF GitHub Bot (Jira)
• [PR] [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE and TIME [flink] via GitHub
  • Re: [PR] [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE and TIME [flink] via GitHub
  • Re: [PR] [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision [flink] raminqaf (via GitHub) via issues
• [PR] [BP-2.4][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• [PR] [BP-2.3][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• [jira] [Created] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE or TIME returns a wrong value Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-41279) Support the :: infix cast operator ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41279) Support the :: infix cast operator Ramin Gharib (Jira)
  • [jira] [Updated] (FLINK-41279) Support the :: infix cast operator Ramin Gharib (Jira)
• [PR] [BP-2.2][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• [jira] [Closed] (FLINK-41256) Operators changing the current key out of order silently lose state in BATCH execution mode Piotr Nowojski (Jira)
• [jira] [Updated] (FLINK-41256) Operators changing the current key out of order silently lose state in BATCH execution mode Piotr Nowojski (Jira)
• Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-41260) ARRAY_AGG/JSON_ARRAYAGG with ORDER BY ignores the ordering Gustavo de Morais (Jira)
• [jira] [Commented] (FLINK-41260) ARRAY_AGG/JSON_ARRAYAGG with ORDER BY ignores the ordering Gustavo de Morais (Jira)
• Re: [PR] [FLINK-41267] Skip state size in cluster info when checkpointing is disabled [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-41267] Skip state size in cluster info when checkpointing is disabled [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-41267] Skip state size in cluster info when checkpointing is disabled [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-41267] Skip state size in cluster info when checkpointing is disabled [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-41267] Skip state size in cluster info when checkpointing is disabled [flink-kubernetes-operator] via GitHub
• Re: [PR] [FLINK-40942][fs/s3-native] Return directory status for bucket-root paths in NativeS3FileSystem#getFileStatus [flink] via GitHub
• [jira] [Created] (FLINK-41279) Support the PostgreSQL-style :: cast operator Ramin Gharib (Jira)
• [jira] [Assigned] (FLINK-41214) Declare a materialized table with Table#materializeInto Timo Theusner (Jira)
• [jira] [Updated] (FLINK-41278) Distinguish DEFAULT arguments from explicit NULL during type inference ASF GitHub Bot (Jira)
• [PR] [FLINK-41278][table] Distinguish DEFAULT arguments from explicit NULL during type inference [flink] via GitHub
  • Re: [PR] [FLINK-41278][table] Distinguish DEFAULT arguments from explicit NULL during type inference [flink] via GitHub
• Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] eskabetxe (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] gaborgsomogyi (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] eskabetxe (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
• [jira] [Commented] (FLINK-41211) List materialized tables of a given catalog and database Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-41211) List materialized tables of a given catalog and database Gustavo de Morais (Jira)
• [jira] [Resolved] (FLINK-41211) List materialized tables of a given catalog and database Gustavo de Morais (Jira)
• [PR] [docs][release-0.4] Standardize Alibaba Cloud Model Studio naming [flink-agents] via GitHub
  • Re: [PR] [docs][release-0.4] Standardize Alibaba Cloud Model Studio naming [flink-agents] wenjin272 (via GitHub) via issues
• [jira] [Created] (FLINK-41278) Distinguish DEFAULT arguments from explicit NULL during type inference dylanhz (Jira)
• [jira] [Created] (FLINK-41277) test_file_sink.sh hangs in the second OpenSSL linkage run Sergey Nuyanzin (Jira)
• [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] via GitHub
  • Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] via GitHub
  • Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] via GitHub
  • Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] gaborgsomogyi (via GitHub) via issues
• Re: [PR] [FLINK-39565] Eliminate maven build warnings across all modules [flink-kubernetes-operator] via GitHub
• Re: [PR] [runtime][java] Complete batch workflows before key switches [flink-agents] via GitHub
• Re: [PR] [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache [flink] via GitHub
  • Re: [PR] [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache [flink] via GitHub
  • Re: [PR] [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache [flink] dianfu (via GitHub) via issues
• [PR] [runtime][java][python] Preserve internal subagent framework faults through tool calls and the Python bridge [flink-agents] via GitHub
  • Re: [PR] [runtime][java][python] Preserve internal subagent framework faults through tool calls and the Python bridge [flink-agents] eemario (via GitHub) via issues
• [jira] [Updated] (FLINK-41276) Make License check CI parallel ASF GitHub Bot (Jira)
• [PR] [FLINK-41276][ci] Run the License task in parallel and regroup its log so the license checks still work [flink] via GitHub
  • Re: [PR] [FLINK-41276][ci] Run the License task in parallel and regroup its log so the license checks still work [flink] via GitHub
  • Re: [PR] [FLINK-41276][ci] Run the License task in parallel and regroup its log so the license checks still work [flink] via GitHub
  • Re: [PR] [FLINK-41276][ci] Run the License task in parallel and regroup its log so the license checks still work [flink] via GitHub
• [jira] [Created] (FLINK-41276) Make License check CI parallel Sergey Nuyanzin (Jira)
• Re: [PR] Announce Flink Agents 0.4.0 [flink-web] via GitHub
• [jira] [Resolved] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Dian Fu (Jira)
• Re: [PR] [FLINK-41104][python] Return true from MapState.contains for keys mapped to None [flink] via GitHub
  • Re: [PR] [FLINK-41104][python] Return true from MapState.contains for keys mapped to None [flink] via GitHub
  • Re: [PR] [FLINK-41104][python] Return true from MapState.contains for keys mapped to None [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-41104][python] Return true from MapState.contains for keys mapped to None [flink] dianfu (via GitHub) via issues
  • Re: [PR] [FLINK-41104][python] Return true from MapState.contains for keys mapped to None [flink] flinkbot (via GitHub) via issues
• Re: [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator] via GitHub
• [jira] [Resolved] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs Dian Fu (Jira)
• [PR] [BP-2.4][FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
  • Re: [PR] [BP-2.4][FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
• Re: [PR] [FLINK-41106][python] Iterate key-value pairs in MapState.put_all [flink] via GitHub
• Re: [PR] [FLINK-39890] Fix NaN in observed scaling coefficient when baseline rate is zero [flink-kubernetes-operator] via GitHub
• [jira] [Comment Edited] (FLINK-41206) PyFlink loses Python worker exit status when the worker process is killed Biao Geng (Jira)
• [PR] [FLINK-41206][python] Log Python worker process exits [flink] via GitHub
  • Re: [PR] [FLINK-41206][python] Log Python worker process exits [flink] via GitHub
• [jira] [Updated] (FLINK-41206) PyFlink loses Python worker exit status when the worker process is killed ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-41228) Thread-mode PyFlink DataStream converters mishandle rows in arrays, lists and maps Dian Fu (Jira)
• Re: [PR] [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps [flink] via GitHub
  • Re: [PR] [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps [flink] via GitHub
  • Re: [PR] [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps [flink] via GitHub
• [jira] [Commented] (FLINK-41206) PyFlink loses Python worker exit status when the worker process is killed Sangkyoon Nam (Jira)
  • [jira] [Commented] (FLINK-41206) PyFlink loses Python worker exit status when the worker process is killed Biao Geng (Jira)
• Re: [PR] [FLINK-39382][docs] Clarify auto.offset.reset support in Kafka SQL connector [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39382][docs] Clarify auto.offset.reset support in Kafka SQL connector [flink-connector-kafka] via GitHub
• [jira] [Commented] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Dian Fu (Jira)
• Re: [PR] [FLINK-40196][table] Remove IS_NOT_NAN in favor of NOT IS_NAN [flink] via GitHub
• [jira] [Assigned] (FLINK-41271) PyFlink tasks remain RUNNING after a Beam data RPC failure Dian Fu (Jira)
• Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] lvyanquan (via GitHub) via issues
  • Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] lvyanquan (via GitHub) via issues
• [jira] [Updated] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Dian Fu (Jira)
• Re: [PR] [FLINK-41050] Canary health checks revert canary metadata changes and restart a healthy operator [flink-kubernetes-operator] via GitHub
• [PR] [FLINK-41269][runtime] Do not treat task clean-up failure as fatal [flink] via GitHub
  • Re: [PR] [FLINK-41269][runtime] Do not treat task clean-up failure as fatal [flink] via GitHub
  • Re: [PR] [FLINK-41269][runtime] Do not treat task clean-up failure as fatal [flink] via GitHub
  • Re: [PR] [FLINK-41269][runtime] Do not treat task clean-up failure as fatal [flink] pnowojski (via GitHub) via issues
• [jira] [Commented] (FLINK-41133) Release Testing Instructions: FLIP-529: Connections in Flink SQL and TableAPI Hao Li (Jira)
  • [jira] [Commented] (FLINK-41133) Release Testing Instructions: FLIP-529: Connections in Flink SQL and TableAPI Yuepeng Pan (Jira) via issues
• [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40958) VARIANT might fail with StackOverflow Sergey Nuyanzin (Jira)
• [jira] [Commented] (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)

• Earlier messages
• Later messages