issues  

Messages by Thread

• • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink] via GitHub
• [jira] [Closed] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore Ferenc Csaky (Jira)
• [PR] Flink 40208/job mdc registry [flink] via GitHub
  • Re: [PR] Flink 40208/job mdc registry [flink] via GitHub
  • Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
  • Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
  • Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
  • Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
  • Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
  • Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
  • Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
  • Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
  • Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
  • Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink] via GitHub
• Re: [PR] [FLINK-39925][Autoscaler] Skip scaling decisions when vertex IO metrics are incomplete to prevent incorrect scale down [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-40267) CREATE MATERIALIZED TABLE skips persisted-metadata-column validation applied by CREATE OR ALTER ASF GitHub Bot (Jira)
• [PR] [FLINK-40267][table-planner] Validate persisted columns on CREATE MATERIALIZED TABLE [flink] via GitHub
  • Re: [PR] [FLINK-40267][table-planner] Validate persisted columns on CREATE MATERIALIZED TABLE [flink] via GitHub
  • Re: [PR] [FLINK-40267][table-planner] Validate persisted columns on CREATE MATERIALIZED TABLE [flink] via GitHub
• [jira] [Commented] (FLINK-40262) Support matching Avro record fields by name in the Avro RowData converters Dale Lane (Jira)
• [PR] [runtime][python] Refresh imports for new dependency generations [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Refresh imports for new dependency generations [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Refresh imports for new dependency generations [flink-agents] via GitHub
• [PR] [runtime][python] Release Pemja objects when closing action executor [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release Pemja objects when closing action executor [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release Pemja objects when closing action executor [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release Pemja objects when closing action executor [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
  • Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
• [I] [Bug] PythonActionExecutor leaks Pemja PyObject references across task restarts [flink-agents] via GitHub
• [I] [Bug] Refresh Python import state when Flink replaces dependency directories [flink-agents] via GitHub
• Re: [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] via GitHub
• Re: [PR] [runtime][java][python] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [runtime][java][python] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [runtime][java][python] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [runtime][java][python] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [runtime][java][python] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [runtime][java][python] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [runtime][java][python] Add CEL Action condition filtering [flink-agents] via GitHub
• [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink] via GitHub
  • Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink] via GitHub
  • Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink] via GitHub
  • Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink] via GitHub
  • Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink] via GitHub
  • Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink] via GitHub
• [jira] [Updated] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• [jira] [Closed] (FLINK-40259) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• [jira] [Closed] (FLINK-40258) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on native s3 [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on native s3 [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on native s3 [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on native s3 [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on native s3 [flink] via GitHub
• [jira] [Updated] (FLINK-37918) Restore the ability to set an interval for GetRecords calls to Kinesis shards. hajimeni (Jira)
• Re: [PR] [FLINK-39732] Introduce ObjectIdDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) [flink-cdc] via GitHub
• Re: [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc] via GitHub
• [jira] [Comment Edited] (FLINK-40253) [Prometheus] PrometheusPushGatewayReporter fails to read boolean configuration values from YAML file Yao Zhang (Jira)
• [jira] [Created] (FLINK-40269) Unaligned checkpoint restore may fail after rescale when a two-input task reads from the same upstream Rui Fan (Jira)
• [jira] [Assigned] (FLINK-40269) Unaligned checkpoint restore may fail after rescale when a two-input task reads from the same upstream Rui Fan (Jira)
• Re: [PR] [FLINK-40108] Adding snapshot capability with split enumerator [flink-connector-jdbc] via GitHub
• [jira] [Resolved] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39964) Checkpoints taken after a CLAIM-mode restore from a native savepoint can be unrestorable Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Roman Khachatryan (Jira)
• [jira] [Reopened] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Roman Khachatryan (Jira)
• [jira] [Closed] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Roman Khachatryan (Jira)
  • [jira] [Closed] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Roman Khachatryan (Jira)
• [jira] [Assigned] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Roman Khachatryan (Jira)
• [PR] [BP-2.2][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
• [PR] [BP-2.3][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink] via GitHub
• [jira] [Assigned] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-40268) Add new JSON_TYPE built-in function ASF GitHub Bot (Jira)
• [PR] [FLINK-40268][table] JSON_TYPE implementation [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] JSON_TYPE implementation [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
  • Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink] via GitHub
• Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
  • Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink] via GitHub
• [jira] [Created] (FLINK-40268) Add new JSON_TYPE built-in function Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40267) CREATE MATERIALIZED TABLE skips persisted-metadata-column validation applied by CREATE OR ALTER Arvid Heise (Jira)
• [jira] [Closed] (FLINK-39110) Add CRT Support Gabor Somogyi (Jira)
• [jira] [Resolved] (FLINK-39110) Add CRT Support Gabor Somogyi (Jira)
• [jira] [Commented] (FLINK-39110) Add CRT Support Gabor Somogyi (Jira)
• Re: [PR] [FLINK-31951][format] Reset decoder on Avro deserialization failure [flink] via GitHub
• [PR] [test][python] Fix Action deserialize tests on release branch [flink-agents] via GitHub
  • Re: [PR] [test][python] Fix Action deserialize tests on release branch [flink-agents] via GitHub
• [PR] [hotfix][tests] Fix flaky NPE in SpeculativeExecutionTest [flink] via GitHub
  • Re: [PR] [hotfix][tests] Fix flaky NPE in SpeculativeExecutionTest [flink] via GitHub
  • Re: [PR] [hotfix][tests] Fix flaky NPE in SpeculativeExecutionTest [flink] via GitHub
• [jira] [Updated] (FLINK-40164) FlinkSessionJob's lifecycleState stays "UPGRADING" even after it's suspended successfully ASF GitHub Bot (Jira)
• [PR] [FLINK-40164] Complete suspending when the cancellation is observed [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40164] Complete suspending when the cancellation is observed [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40164] Complete suspending when the cancellation is observed [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40164] Complete suspending when the cancellation is observed [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40164] Complete suspending when the cancellation is observed [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-39373) An error occurred when modifying the default value of a column while executing the StarRocks Pipeline Sink operation Leonard Xu (Jira)

• Earlier messages
• Later messages