issues  

Messages by Thread

• [PR] [FLINK-40374] Fix redeploy-from-savepoint for suspended jobs [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40374] Fix redeploy-from-savepoint for suspended jobs [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40374] Fix redeploy-from-savepoint for suspended jobs [flink-kubernetes-operator] via GitHub
• [jira] [Assigned] (FLINK-36073) ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins Ferenc Csaky (Jira)
• [jira] [Commented] (FLINK-36073) ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins Ferenc Csaky (Jira)
• [PR] [FLINK-40372][metrics] Unregister JOSDK resource metrics after cleanup [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40372][metrics] Unregister JOSDK resource metrics after cleanup [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40372][metrics] Unregister JOSDK resource metrics after cleanup [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40372][metrics] Unregister JOSDK resource metrics after cleanup [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40372][metrics] Unregister JOSDK resource metrics after cleanup [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40372][metrics] Unregister JOSDK resource metrics after cleanup [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40372][metrics] Unregister JOSDK resource metrics after cleanup [flink-kubernetes-operator] via GitHub
• [PR] [FLINK-39554] Support multiple custom autoscaler evaluators with deterministic ordering [flink-kubernetes-operator] via GitHub
• [jira] [Assigned] (FLINK-40374) Redeploying a FlinkSessionJob from an explicit savepoint fails if the job was previously suspended Robert Metzger (Jira)
• Re: [PR] [FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode [flink] via GitHub
• [jira] [Created] (FLINK-40374) Redeploying a FlinkSessionJob from an explicit savepoint fails with IllegalArgumentException: Cannot parse JobID from "null" if the job was previously suspended Dale Lane (Jira)
• [jira] [Updated] (FLINK-40374) Redeploying a FlinkSessionJob from an explicit savepoint fails if the job was previously suspended Dale Lane (Jira)
  • [jira] [Updated] (FLINK-40374) Redeploying a FlinkSessionJob from an explicit savepoint fails if the job was previously suspended Robert Metzger (Jira)
  • [jira] [Updated] (FLINK-40374) Redeploying a FlinkSessionJob from an explicit savepoint fails if the job was previously suspended ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40374) Redeploying a FlinkSessionJob from an explicit savepoint fails if the job was previously suspended Gyula Fora (Jira)
• [jira] [Assigned] (FLINK-40367) Make Kafka consumer poll timeout configurable Robert Metzger (Jira)
• [jira] [Updated] (FLINK-40374) Redeploying a FlinkSessionJob from an explicit savepoint if the job was previously suspended Dale Lane (Jira)
  • [jira] [Updated] (FLINK-40374) Redeploying a FlinkSessionJob from an explicit savepoint if the job was previously suspended Dale Lane (Jira)
• [jira] [Updated] (FLINK-40373) JSON_VALUE might fail on code generation ASF GitHub Bot (Jira)
• [PR] [FLINK-40373][table] `JSON_VALUE` might fail on code gen for null input [flink] via GitHub
  • Re: [PR] [FLINK-40373][table] `JSON_VALUE` might fail on code gen for null input [flink] via GitHub
  • Re: [PR] [FLINK-40373][table] `JSON_VALUE` might fail on code gen for null input [flink] via GitHub
  • Re: [PR] [FLINK-40373][table] `JSON_VALUE` might fail on code gen for null input [flink] via GitHub
  • Re: [PR] [FLINK-40373][table] `JSON_VALUE` might fail on code gen for null input [flink] via GitHub
  • Re: [PR] [FLINK-40373][table] `JSON_VALUE` might fail on code gen for null input [flink] via GitHub
• [jira] [Created] (FLINK-40373) JSON_VALUE might fail on code generation Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
  • [jira] [Updated] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
  • [jira] [Updated] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
  • [jira] [Updated] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
  • [jira] [Updated] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
  • [jira] [Updated] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
  • [jira] [Updated] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
  • [jira] [Updated] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
  • [jira] [Updated] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
• [jira] [Commented] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
• [jira] [Created] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
• [jira] [Commented] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Andreas Bube (Jira)
  • [jira] [Commented] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Jing Hung (Jira)
  • [jira] [Commented] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Andreas Bube (Jira)
• Re: [PR] [FLINK-39218] Introduce Flink-Kafka Transactions Management Tool [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39218] Introduce Flink-Kafka Transactions Management Tool [flink-connector-kafka] via GitHub
• [PR] Optimize efficiency issues of PostgreSQL during the full snapshot phase. [flink-cdc] via GitHub
  • Re: [PR] Optimize efficiency issues of PostgreSQL during the full snapshot phase. [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-39824) [mysql-cdc] High CPU usage caused by repeated regex table filtering in large table synchronization Ruan Hang (Jira)
• [jira] [Closed] (FLINK-40364) flink-connector-pulsar Flink 2.x support Hongbo Miao (Jira)
• [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
• [PR] [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation [flink] via GitHub
  • Re: [PR] [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation [flink] via GitHub
  • Re: [PR] [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation [flink] via GitHub
  • Re: [PR] [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation [flink] via GitHub
• [jira] [Commented] (FLINK-40364) flink-connector-pulsar Flink 2.x support Purushottam Sinha (Jira)
  • [jira] [Commented] (FLINK-40364) flink-connector-pulsar Flink 2.x support Hongbo Miao (Jira)
• [PR] [integrations][vector-store][java] Apply Elasticsearch KNN filters before selecting neighbors [flink-agents] via GitHub
  • Re: [PR] [integrations][vector-store][java] Apply Elasticsearch KNN filters before selecting neighbors [flink-agents] via GitHub
• Re: [PR] [integration][openai] Align default parameters for openai chat model between java and python [flink-agents] via GitHub
  • Re: [PR] [integration][openai] Align default parameters for openai chat model between java and python [flink-agents] via GitHub
• [PR] [ci] Name the tools script test job after the command it runs [flink-agents] via GitHub
  • Re: [PR] [ci] Name the tools script test job after the command it runs [flink-agents] via GitHub
• [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents] via GitHub
  • Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents] via GitHub
  • Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents] via GitHub
  • Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents] via GitHub
  • Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents] via GitHub
  • Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents] via GitHub
  • Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents] via GitHub
  • Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents] via GitHub
  • Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents] via GitHub
  • Re: [I] [Bug] Elasticsearch queryEmbedding applies filters as a post-filter, returning fewer than k documents [flink-agents] via GitHub
• [jira] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
• [I] [Bug] Long-term memory operations read the partition key from shared mutable state on the async worker thread [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
  • [jira] [Updated] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
  • [jira] [Updated] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
  • [jira] [Updated] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
• [jira] [Commented] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
• [jira] [Assigned] (FLINK-39824) [mysql-cdc] High CPU usage caused by repeated regex table filtering in large table synchronization Yanquan Lv (Jira)
• [jira] [Created] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
• Re: [I] [Feature] Add VLLM_CONNECTION to the ChatModel out-of-the-box [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization Joey Pereira (Jira)
  • [jira] [Commented] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization Bhanu Chander Vallabaneni (Jira)
• [jira] [Updated] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization Joey Pereira (Jira)
  • [jira] [Updated] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization Joey Pereira (Jira)
• [jira] [Created] (FLINK-40369) ARRAY functions might lead to wrong results Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-40367) Make Kafka consumer poll timeout configurable ASF GitHub Bot (Jira)
• [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-40368) Deduplicate output should only be insert-only when ordered by time attribute David Anderson (Jira)
• [jira] [Updated] (FLINK-37005) Make StreamExecDeduplicate output insert only where possible David Anderson (Jira)
• [jira] [Created] (FLINK-40367) Make Kafka consumer poll timeout configurable Robert Metzger (Jira)
• [PR] [hotfix][runtime] Respect UDF precedence during type validation [flink-cdc] via GitHub
  • Re: [PR] [hotfix][runtime] Respect UDF precedence during type validation [flink-cdc] via GitHub
  • Re: [PR] [hotfix][runtime] Respect UDF precedence during type validation [flink-cdc] via GitHub
• Re: [PR] [FLINK-39565] Eliminate maven build warnings across all modules [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39565] Eliminate maven build warnings across all modules [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-40366) INSERT INTO with a column list or static partition fails for set-semantic PTFs Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-40366) INSERT INTO with a column list or static partition fails for set-semantic PTFs Gustavo de Morais (Jira)
• [jira] [Closed] (FLINK-35746) Add logic to override observed config based on settings observed through REST API Gyula Fora (Jira)
• [jira] [Reopened] (FLINK-36073) ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins Robert Metzger (Jira)
• [jira] [Updated] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Robert Metzger (Jira)
• [PR] [draft] Monotonic counters draft [flink] via GitHub
  • Re: [PR] [draft] Monotonic counters draft [flink] via GitHub
• [jira] [Resolved] (FLINK-40240) Support TRY_CAST, IFNULL and NULLIF in YAML Transform Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-40312) Support EXTRACT, date-part functions, and interval arithmetic in YAML Transform Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-40365) Job Management docs: "Config Requirement" for savepoint upgrade mode is incorrect Dale Lane (Jira)
• [jira] [Updated] (FLINK-40365) Job Management docs: "Config Requirement" for savepoint upgrade mode is incorrect ASF GitHub Bot (Jira)
• [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-40365) Job Management docs: "Config Requirement" for savepoint upgrade mode is incorrect Dale Lane (Jira)
• [jira] [Closed] (FLINK-39791) Helm chart silently ignores defaultConfiguration.config.yaml; always mounts flink-conf.yaml from chart defaults Gyula Fora (Jira)
• [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
  • Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
  • Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
  • Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
  • Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
  • Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
  • Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
  • Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents] via GitHub
• [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
  • Re: [PR] [hotfix][tools] Report RAT validation dependencies correctly [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-37666) Address CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation Roman Khachatryan (Jira)
• Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39824][mysql] Cache relational table filter results [flink-cdc] via GitHub
• [PR] [runtime] Introduce AI model client function API [flink-cdc] via GitHub
  • Re: [PR] [runtime] Introduce AI model client function API [flink-cdc] via GitHub
  • Re: [PR] [runtime] Introduce AI model client function API [flink-cdc] via GitHub
  • Re: [PR] [runtime] Introduce AI model client function API [flink-cdc] via GitHub
  • Re: [PR] [runtime] Introduce AI model client function API [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39568][runtime] Introduce AI model client function API [flink-cdc] via GitHub
• [PR] [DRAFT] Add parallel compile for test jobs [flink] via GitHub
  • Re: [PR] [DRAFT] Add parallel compile for test jobs [flink] via GitHub
  • Re: [PR] [hotfix][ci] Bump github-script to v9 in action.yml [flink] via GitHub
• [PR] [hotfix] Add help handling to build script [flink-agents] via GitHub
  • Re: [PR] [hotfix] Add help handling to build script [flink-agents] via GitHub
  • Re: [PR] [hotfix] Add help handling to build script [flink-agents] via GitHub
  • Re: [PR] [hotfix] Add help handling to build script [flink-agents] via GitHub
  • Re: [PR] [hotfix] Add help handling to build script [flink-agents] via GitHub
• Re: [PR] Kafka 4.x Queue Semantics support [flink-connector-kafka] via GitHub
  • Re: [PR] Kafka 4.x Queue Semantics support [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-32940] [SQL] Unnest projection and filter pushdown [flink] via GitHub
• Re: [PR] [FLINK-38987] Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem [flink] via GitHub
• Re: [PR] [FLINK-38050][UI] Correct Flink UI Dropdown Width [flink] via GitHub
• [jira] [Created] (FLINK-40364) flink-connector-pulsar Flink 2.x support Hongbo Miao (Jira)
• [jira] [Updated] (FLINK-40364) flink-connector-pulsar Flink 2.x support Hongbo Miao (Jira)
• [jira] [Commented] (FLINK-37666) Address CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation Samrat Deb (Jira)
• [PR] [hotfix][checkpoint] Refactor common behavior into ChannelStateFilteringHandler#getGateFilterHandler and GateFilterHandler#getVirtualChannelBy to reduce code duplication in ChannelStateFilteringHandler.java [flink] via GitHub
  • Re: [PR] [hotfix][checkpoint] Refactor common behavior into ChannelStateFilteringHandler#getGateFilterHandler and GateFilterHandler#getVirtualChannelBy to reduce code duplication [flink] via GitHub
  • Re: [PR] [hotfix][checkpoint] Refactor common behavior into ChannelStateFilteringHandler#getGateFilterHandler and GateFilterHandler#getVirtualChannelBy to reduce code duplication [flink] via GitHub
  • Re: [PR] [hotfix][checkpoint] Refactor common behavior into ChannelStateFilteringHandler#getGateFilterHandler and GateFilterHandler#getVirtualChannelBy to reduce code duplication [flink] via GitHub
  • Re: [PR] [hotfix][checkpoint] Refactor common behavior into ChannelStateFilteringHandler#getGateFilterHandler and GateFilterHandler#getVirtualChannelBy to reduce code duplication [flink] via GitHub
• [PR] [hotfix][java][python] Update main version to 0.4-SNAPSHOT [flink-agents] via GitHub
  • Re: [PR] [infra] Update main version to 0.4-SNAPSHOT [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-39732) Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) Leonard Xu (Jira)
• [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40360][runtime] Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40172) Support processing-time early fire on a row-time interval join ASF GitHub Bot (Jira)
• [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink] via GitHub

• Earlier messages
• Later messages