issues
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] [FLINK-40554][runtime] Skipping job recovery for jobs with broken execution plan instead of failing cluster recovery hidden behind newly introduced config parameter cluster.job-error-isolation.enabled [flink]
via GitHub
Re: [PR] [FLINK-40554][runtime] Skipping job recovery for jobs with broken execution plan instead of failing cluster recovery hidden behind newly introduced config parameter cluster.job-error-isolation.enabled [flink]
via GitHub
[jira] [Updated] (FLINK-40554) Handle errors during JobGraph recovery
ASF GitHub Bot (Jira)
[jira] [Reopened] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework
Sergey Nuyanzin (Jira)
[jira] [Commented] (FLINK-37926) Support type casting between variant and constructed type
Sergey Nuyanzin (Jira)
[jira] [Commented] (FLINK-37926) Support type casting between variant and constructed type
Timo Walther (Jira)
[jira] [Resolved] (FLINK-40527) Update flink-shaded to 22.0
Sergey Nuyanzin (Jira)
[jira] [Commented] (FLINK-40527) Update flink-shaded to 22.0
Sergey Nuyanzin (Jira)
[PR] [FLINK-40528][table-planner] Don't evaluate non-key expressions for partial delete StreamExecCalc [flink]
via GitHub
Re: [PR] [FLINK-40528][table-planner] Don't evaluate non-key expressions for partial delete StreamExecCalc [flink]
via GitHub
Re: [PR] [FLINK-40528][table-planner] Don't evaluate non-key expressions for partial delete StreamExecCalc [flink]
via GitHub
Re: [PR] [FLINK-40528][table-planner] Don't evaluate non-key expressions for partial delete StreamExecCalc [flink]
via GitHub
Re: [PR] [FLINK-40528][table-planner] Don't evaluate non-key expressions for partial delete StreamExecCalc [flink]
via GitHub
Re: [PR] [FLINK-40528][table-planner] Don't evaluate non-key expressions for partial delete StreamExecCalc [flink]
via GitHub
Re: [PR] [FLINK-40528][table-planner] Don't evaluate non-key expressions for partial delete StreamExecCalc [flink]
via GitHub
Re: [PR] [FLINK-40528][table-planner] Don't evaluate non-key expressions for partial delete StreamExecCalc [flink]
via GitHub
[jira] [Commented] (FLINK-38259) FLIP-529: Connections in Flink SQL and TableAPI
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-40558) Apply in-place scaling only on SCALE spec diff type
ASF GitHub Bot (Jira)
[PR] [FLINK-40558] Apply in-place scaling only on SCALE spec diff type [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-40558] Apply in-place scaling only on SCALE spec diff type [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-40558] Apply in-place scaling only on SCALE spec diff type [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-40558] Apply in-place scaling only on SCALE spec diff type [flink-kubernetes-operator]
via GitHub
[jira] [Created] (FLINK-40558) Apply in-place scaling only on SCALE spec diff type
Dennis-Mircea Ciupitu (Jira)
[jira] [Updated] (FLINK-33064) Improve the error message when the lookup source is used as the scan source
Martijn Visser (Jira)
[jira] [Updated] (FLINK-40423) Add Top-N support to DataFrame API
ASF GitHub Bot (Jira)
[PR] [FLINK-40423][python] Add Top-N support to the DataFrame API [flink]
via GitHub
Re: [PR] [FLINK-40423][python] Add Top-N support to the DataFrame API [flink]
via GitHub
Re: [PR] [FLINK-40423][python] Add Top-N support to the DataFrame API [flink]
via GitHub
[jira] [Resolved] (FLINK-40540) Put the rule's reason first in the planner's "Cannot generate a valid execution plan" message
Martijn Visser (Jira)
Re: [PR] [hotfix] [pyflink] Fix Python Datastream JDBC Java method reference [flink]
via GitHub
[jira] [Assigned] (FLINK-40554) Handle errors during JobGraph recovery
Matthias Pohl (Jira)
[jira] [Assigned] (FLINK-40555) Handle errors during JobResultStore entry retrieval
Matthias Pohl (Jira)
[PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
Re: [PR] [FLINK-40515][core] Extend BinaryVariant to support UUID [flink]
via GitHub
[jira] [Updated] (FLINK-40515) Extend BinaryVariant to support UUID (Code 20)
ASF GitHub Bot (Jira)
[PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink]
via GitHub
Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink]
via GitHub
Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink]
via GitHub
Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink]
via GitHub
Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink]
via GitHub
Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink]
via GitHub
Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink]
via GitHub
Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink]
via GitHub
[jira] [Resolved] (FLINK-37926) Support type casting between variant and constructed type
Sergey Nuyanzin (Jira)
[jira] [Updated] (FLINK-40557) Make operation column optional in TO_CHANGELOG output
Ferenc Csaky (Jira)
[jira] [Updated] (FLINK-40557) Make operation column optional in TO_CHANGELOG output
ASF GitHub Bot (Jira)
[jira] [Created] (FLINK-40557) Make operation column optional in TO_CHANGELOG output
Ferenc Csaky (Jira)
[jira] [Created] (FLINK-40556) Support UUID value literals in the Table API
Ramin Gharib (Jira)
[jira] [Assigned] (FLINK-40553) Corrupted job-local HA data causes cluster-wide failover
Matthias Pohl (Jira)
[jira] [Created] (FLINK-40555) Handle errors during JobResultStore entry retrieval
Matthias Pohl (Jira)
[jira] [Created] (FLINK-40554) Handle errors during JobGraph recovery
Matthias Pohl (Jira)
[jira] [Created] (FLINK-40553) Corrupted job-local HA data causes cluster-wide failover
Matthias Pohl (Jira)
[jira] [Updated] (FLINK-40487) CAST between UUID and STRING / BINARY(16)
ASF GitHub Bot (Jira)
[PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
Re: [PR] [FLINK-40487][table] CAST between UUID and STRING / BINARY(16) [flink]
via GitHub
[jira] [Updated] (FLINK-40549) Split level metrics leak the closed metricGroup on split finish
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-40549) Split level metrics leak the closed metricGroup on split finish
Piotr Nowojski (Jira)
[jira] [Updated] (FLINK-40549) Split level metrics leak the closed metricGroup on split finish
Piotr Nowojski (Jira)
[PR] [runtime][api][python] Add checkpoint-aligned Kafka action-state cleanup [flink-agents]
via GitHub
Re: [PR] [runtime][api][python] Add checkpoint-aligned Kafka action-state cleanup [flink-agents]
via GitHub
Re: [PR] [runtime][api][python] Add checkpoint-aligned Kafka action-state cleanup [flink-agents]
via GitHub
[PR] [runtime] Preserve typed Flink key identity in action state [flink-agents]
via GitHub
Re: [PR] [runtime] Preserve typed Flink key identity in action state [flink-agents]
via GitHub
Re: [PR] [runtime] Preserve typed Flink key identity in action state [flink-agents]
via GitHub
Re: [PR] [runtime] Preserve typed Flink key identity in action state [flink-agents]
via GitHub
[jira] [Resolved] (FLINK-40490) Runtime serialization and codegen for UUID
Sergey Nuyanzin (Jira)
[jira] [Commented] (FLINK-40490) Runtime serialization and codegen for UUID
Sergey Nuyanzin (Jira)
Re: [PR] [FLINK-39009] Support PostgreSQL unnest insert in dynamic table. [flink-connector-jdbc]
via GitHub
[jira] [Comment Edited] (FLINK-40539) Redact sensitive values in SET; and session config responses
Gabor Somogyi (Jira)
[jira] [Created] (FLINK-40552) Support ordered asynchronous execution for YAML Transform
Mao Jiayi (Jira)
Re: [PR] [FLINK-39837][connectors/kafka] Add tombstone-based retention for removed splits in dynamic Kafka source [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-39529][table] Add SQL-to-operator lifecycle and restructure planner AGENTS.md [flink]
via GitHub
Re: [PR] [FLINK-39529][table] Add SQL-to-operator lifecycle and restructure planner AGENTS.md [flink]
via GitHub
[jira] [Closed] (FLINK-40539) Redact sensitive values in SET; and session config responses
Gabor Somogyi (Jira)
[jira] [Resolved] (FLINK-40539) Redact sensitive values in SET; and session config responses
Gabor Somogyi (Jira)
Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc]
via GitHub
[PR] Revert "[FLINK-39977][runtime] Add ITCase for file-merged channel state recovery" [flink]
via GitHub
Re: [PR] Revert "[FLINK-39977][runtime] Add ITCase for file-merged channel state recovery" [flink]
via GitHub
Re: [PR] Revert "[FLINK-39977][runtime] Add ITCase for file-merged channel state recovery" [flink]
via GitHub
Re: [PR] Revert "[FLINK-39977][runtime] Add ITCase for file-merged channel state recovery" [flink]
via GitHub
[I] [Bug] Preserve Flink key identity in ActionState [flink-agents]
via GitHub
Re: [I] [Bug] Preserve Flink key identity in ActionState [flink-agents]
via GitHub
[jira] [Commented] (FLINK-40551) FileMergingChannelStateITCase is very flaky
Sergey Nuyanzin (Jira)
[jira] [Commented] (FLINK-40551) FileMergingChannelStateITCase is very flaky
Sergey Nuyanzin (Jira)
[jira] [Commented] (FLINK-40551) FileMergingChannelStateITCase is very flaky
Yuepeng Pan (Jira)
[jira] [Commented] (FLINK-40551) FileMergingChannelStateITCase is very flaky
Jira
[jira] [Created] (FLINK-40551) FileMergingChannelStateITCase is very flaky
Sergey Nuyanzin (Jira)
[PR] [FLINK-25453] [core] Ignore files deleted concurrently in LocalFileSystem#listStatus [flink]
via GitHub
Re: [PR] [FLINK-25453] [core] Ignore files deleted concurrently in LocalFileSystem#listStatus [flink]
via GitHub
[jira] [Updated] (FLINK-25453) LocalFileSystem#listStatus throws FileNotFoundException when a file is deleted concurrently in the directory
ASF GitHub Bot (Jira)
Re: [PR] [FLINK-20454][formats] Add metadata support for Debezium Avro [flink]
via GitHub
Re: [PR] [FLINK-20454][formats] Add metadata support for Debezium Avro [flink]
via GitHub
Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents]
via GitHub
Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents]
via GitHub
Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents]
via GitHub
Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents]
via GitHub
Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents]
via GitHub
Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents]
via GitHub
Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents]
via GitHub
Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents]
via GitHub
Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents]
via GitHub
Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents]
via GitHub
Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents]
via GitHub
Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents]
via GitHub
Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents]
via GitHub
Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents]
via GitHub
Re: [I] [Tech Debt] Align Java and Python recovery model [flink-agents]
via GitHub
[PR] [integrations][gemini] Cover buildConfig with unit tests [flink-agents]
via GitHub
Re: [PR] [integrations][gemini] Cover buildConfig with unit tests [flink-agents]
via GitHub
[PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents]
via GitHub
[PR] [integrations][gemini] Apply Gemini native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][gemini] Apply Gemini native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][gemini] Apply Gemini native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][gemini] Apply Gemini native structured output [flink-agents]
via GitHub
Re: [PR] [integrations][gemini] Apply Gemini native structured output [flink-agents]
via GitHub
[PR] [hotfix][runtime] Raise Kafka admin future timeout from 100ms to 30s [flink-agents]
via GitHub
Re: [PR] [hotfix][runtime] Raise Kafka admin future timeout from 100ms to 30s [flink-agents]
via GitHub
[PR] [bug][runtime] Derive durable-state action UUID from the plan-unique action name [flink-agents]
via GitHub
Re: [PR] [bug][runtime] Derive durable-state action UUID from the plan-unique action name [flink-agents]
via GitHub
Re: [PR] [bug][runtime] Derive durable-state action UUID from the plan-unique action name [flink-agents]
via GitHub
Re: [PR] [bug][runtime] Derive durable-state action UUID from the plan-unique action name [flink-agents]
via GitHub
Re: [PR] [bug][runtime] Derive durable-state action UUID from the plan-unique action name [flink-agents]
via GitHub
Re: [PR] [bug][runtime] Derive durable-state action UUID from the plan-unique action name [flink-agents]
via GitHub
Re: [PR] [bug][runtime] Derive durable-state action UUID from the plan-unique action name [flink-agents]
via GitHub
Re: [PR] [bug][runtime] Derive durable-state action UUID from the plan-unique action name [flink-agents]
via GitHub
Re: [PR] [runtime] Cover the cross-loader action key failure and document action renaming [flink-agents]
via GitHub
Re: [PR] [runtime] Cover the cross-loader action key failure and document action renaming [flink-agents]
via GitHub
Re: [PR] [runtime] Cover the cross-loader action key failure and document action renaming [flink-agents]
via GitHub
[PR] [BP-2.3][FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
Re: [PR] [BP-2.3][FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
Re: [PR] [BP-2.3][FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
[jira] [Updated] (FLINK-40550) Kubernetes Operator: documented reconcile.parallelism: -1 crashes operator at startup
ASF GitHub Bot (Jira)
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39725][python] Apply the Python TimestampAssigner in from_source [flink]
via GitHub
[jira] [Resolved] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework
Zakelly Lan (Jira)
[jira] [Resolved] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework
Zakelly Lan (Jira)
[jira] [Updated] (FLINK-40245) Wire parquet.page.size.row.check.min/max conf keys in FlinkParquetBuilder
ASF GitHub Bot (Jira)
[PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink]
via GitHub
Re: [PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink]
via GitHub
Re: [PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink]
via GitHub
Re: [PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink]
via GitHub
Re: [PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink]
via GitHub
Re: [PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink]
via GitHub
Re: [PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink]
via GitHub
Re: [PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink]
via GitHub
Re: [PR] [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join [flink]
via GitHub
[jira] [Closed] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization
Dian Fu (Jira)
[jira] [Created] (FLINK-40550) Kubernetes Operator: documented reconcile.parallelism: -1 crashes operator at startup
Purushottam Sinha (Jira)
[jira] [Resolved] (FLINK-40466) Refactor defining table arguments in PTF Test Harness builder for more complex table arguments
Fabian Hueske (Jira)
[PR] [BP-2.1][FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
Re: [PR] [BP-2.1][FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
Re: [PR] [BP-2.1][FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
[PR] [BP-2.2][FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
Re: [PR] [BP-2.2][FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
Re: [PR] [BP-2.2][FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
[PR] [FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
Re: [PR] [FLINK-40548][ci] Use image with ubuntu 24.04 [flink]
via GitHub
Earlier messages
Later messages