issues  

Messages by Thread

• [jira] [Updated] (FLINK-39140) [FLINK-39140][checkpoint] Allow multiple rescales in Unaligned Checkpoint ITCases to perform checkpointing during recovery Rui Fan (Jira)
• [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-39198) Fix the issue of potential data loss during recovery from a checkpoint. Hao Yu (Jira)
  • [jira] [Updated] (FLINK-39198) Fix the issue of potential data loss during recovery from a checkpoint. ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39198) Fix the issue of potential data loss during recovery from a checkpoint. Hao Yu (Jira)
  • [jira] [Updated] (FLINK-39198) Fix the issue of potential data loss during recovery from a checkpoint. Hao Yu (Jira)
• [jira] [Created] (FLINK-39198) Fix the issue of potential data loss during recovery from a checkpoint. Hao Yu (Jira)
• [jira] [Commented] (FLINK-38697) TaskInformation blobs accumulate without cleanup causing storage exhaustion Piotr Rudnicki (Jira)
• [jira] [Commented] (FLINK-39197) Fix NPE when finding chunk end Hao Yu (Jira)
• [jira] [Updated] (FLINK-39197) Fix NPE when finding chunk end ASF GitHub Bot (Jira)
• [PR] [FLINK-39197][jdbc&mysql] Fix NPE when finding chunk end [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-39196) Oracle pipeline support change column nullable without data type ASF GitHub Bot (Jira)
• [PR] [FLINK-39196][pipeline-connector][oracle] Support change column nullable without data type [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39197) Fix NPE when finding chunk end Chengbing Liu (Jira)
• [jira] [Created] (FLINK-39196) Oracle pipeline support change column nullable without data type Mingliang Zhu (Jira)
• [jira] [Updated] (FLINK-39195) ObjectPath should implement Comparable ASF GitHub Bot (Jira)
• [PR] [FLINK-39195][Table SQL/API] ObjectPath should implement Comparable [flink] via GitHub
  • Re: [PR] [FLINK-39195][Table SQL/API] ObjectPath should implement Comparable [flink] via GitHub
• [jira] [Created] (FLINK-39195) ObjectPath should implement Comparable Liu (Jira)
• Re: [PR] [FLINK-38374][SQL API] Introduce new ARTIFACT keyword as an alternative to JAR [flink] via GitHub
• [jira] [Updated] (FLINK-39152) The FlussConfig Utils class is not in the correct directory and does not have a private instance ASF GitHub Bot (Jira)
• [jira] [Closed] (FLINK-27661) [Metric]Flink-Metrics PrometheusPushGatewayReporter support pushgateway http authentication Junrui Lee (Jira)
• [jira] [Updated] (FLINK-27661) [Metric]Flink-Metrics PrometheusPushGatewayReporter support pushgateway http authentication Junrui Lee (Jira)
• [jira] [Assigned] (FLINK-27661) [Metric]Flink-Metrics PrometheusPushGatewayReporter support pushgateway http authentication Junrui Lee (Jira)
• [PR] [FLINK-XXXX] [table] Support lineage extraction for DataStreamscan/sink providers [flink] via GitHub
  • Re: [PR] [FLINK-XXXX] [table] Support lineage extraction for DataStreamscan/sink providers [flink] via GitHub
  • Re: [PR] [FLINK-XXXX] [table] Support lineage extraction for DataStreamscan/sink providers [flink] via GitHub
• Re: [PR] [FLINK-38844][pipeline-connector][postgres]Add metadata column support [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39194) Improve PyFlink's support on specifying local resource files Biao Geng (Jira)
• [PR] [Feature] Simplify the custom event definition [flink-agents] via GitHub
  • Re: [PR] [Feature] Simplify the custom event definition [flink-agents] via GitHub
• Re: [PR] [FLINK-38851] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38851] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• Re: [PR] [FLINK-39030][Table SQL/API] Support emit-only-on-update mode for CUMULATE window TVF to reduce unnecessary outputs [flink] via GitHub
• [jira] [Commented] (FLINK-39021) Support native PersistentVolumeClaim (PVC) mounting for Kubernetes deployments Liu (Jira)
• Re: [I] [Feature] Simplify the custom event definition. [flink-agents] via GitHub
  • Re: [I] [Feature] Simplify the custom event definition. [flink-agents] via GitHub
  • Re: [I] [Feature] Simplify the custom event definition. [flink-agents] via GitHub
  • Re: [I] [Feature] Simplify the custom event definition. [flink-agents] via GitHub
  • Re: [I] [Feature] Simplify the custom event definition. [flink-agents] via GitHub
  • Re: [I] [Feature] Simplify the custom event definition. [flink-agents] via GitHub
• Re: [PR] FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP) [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-39193) SpecifiedOffsetsInitializer can fail if the caller passes a non-empty but incomplete specific-offset map. Bowen Li (Jira)
• [jira] [Created] (FLINK-39193) SpecifiedOffsetsInitializer can fail if the caller passes a non-empty but incomplete specific-offset map. Bowen Li (Jira)
• [jira] [Updated] (FLINK-39192) SinkWriterOperator in post-commit topology throws IllegalStateException with bounded source in streaming mode Calico Shop (Jira)
  • [jira] [Updated] (FLINK-39192) SinkWriterOperator in post-commit topology throws IllegalStateException with bounded source in streaming mode Calico Shop (Jira)
• [jira] [Created] (FLINK-39192) SinkWriterOperator in post-commit topology throws IllegalStateException with bounded source in streaming mode Calico Shop (Jira)
• [jira] [Updated] (FLINK-38697) TaskInformation blobs accumulate without cleanup causing storage exhaustion ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-38971) Migrate ExpandWindowTableFunctionTransposeRule Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-38971) Migrate ExpandWindowTableFunctionTransposeRule Sergey Nuyanzin (Jira)
• [PR] Update Dependencies in Flink 1.19 [flink] via GitHub
  • Re: [PR] Update Dependencies in Flink 1.19 [flink] via GitHub
  • Re: [PR] Update Dependencies in Flink 1.19 [flink] via GitHub
• [PR] [FLINK-38697][runtime] Store task information blob key in JobVertex [flink] via GitHub
  • Re: [PR] [FLINK-38697][runtime] Store task information blob key in JobVertex [flink] via GitHub
• [jira] [Created] (FLINK-39191) Upgrade monaco-editor to 0.55.1 to get rid of DOMPurify CVEs Yaroslav (Jira)
• [PR] [hotfix] Fix grammar [flink-connector-http] via GitHub
• [jira] [Comment Edited] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39059) Add unified metrics support to AsyncPredictFunction and PredictFunction ASF GitHub Bot (Jira)
• [PR] [FLINK-39059][models] Add unified inference metrics for model functions [flink] via GitHub
  • Re: [PR] [FLINK-39059][models] Add unified inference metrics for model functions [flink] via GitHub
• Re: [PR] [FLINK-38822] Extend URL_DECODE with optional recursive decoding [flink] via GitHub
• [PR] [FLINK-34610] Migrate StreamPhysicalLimitRule from Scala to Java [flink] via GitHub
  • Re: [PR] [FLINK-34610] Migrate `StreamPhysicalLimitRule` from Scala to Java [flink] via GitHub
• [PR] [infra] Deduplicate common jar dependency to reduce wheel size [flink-agents] via GitHub
  • Re: [PR] [infra] Deduplicate common jar dependency to reduce wheel size [flink-agents] via GitHub
  • Re: [PR] [infra] Deduplicate common jar dependency to reduce wheel size [flink-agents] via GitHub
  • Re: [PR] [infra] Deduplicate common jar dependency to reduce wheel size [flink-agents] via GitHub
  • Re: [PR] [infra] Deduplicate common jar dependency to reduce wheel size [flink-agents] via GitHub
• [jira] [Updated] (FLINK-39190) flink-s3-fs-hadoop bundles unshaded Jackson 2.17.2 (via AWS SDK v1) ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-39190] Relocate Jackson in filesystem plugin POMs to prevent classpath conflicts [flink] via GitHub
• [PR] [FLINK-38729] Add support for Flink 2.2.0 [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-39157) ColumnList has no hashCode/equals Timo Walther (Jira)
• [jira] [Created] (FLINK-39190) flink-s3-fs-hadoop bundles unshaded Jackson 2.17.2 (via AWS SDK v1) Dries Samyn (Jira)
• Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
  • Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
  • Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
  • Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
  • Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
  • Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
  • Re: [PR] [FLINK-17224][table] Support precision of TIME type [flink] via GitHub
• [PR] [FLINK-39181 ][ci] Reduce Verbose DEBUG Logging in CI [flink] via GitHub
  • Re: [PR] [FLINK-39181 ][ci] Reduce Verbose DEBUG Logging in CI [flink] via GitHub
  • Re: [PR] [FLINK-39181 ][ci] Reduce Verbose DEBUG Logging in CI [flink] via GitHub
  • Re: [PR] [FLINK-39181 ][ci] Reduce Verbose DEBUG Logging in CI [flink] via GitHub
  • Re: [PR] [FLINK-39181 ][ci] Reduce Verbose DEBUG Logging in CI [flink] via GitHub
• [jira] [Updated] (FLINK-39022) Update default cipher suite value in SecurityOptions Gabor Somogyi (Jira)
  • [jira] [Updated] (FLINK-39022) Update default cipher suite value in SecurityOptions Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-39189) MinioTestContainerTest.testSetS3ConfigOptions fails on 1.20 Gabor Somogyi (Jira)
• [PR] [FLINK-39173][runtime] Support application-level blob storage [flink] via GitHub
  • Re: [PR] [FLINK-39173][runtime] Support application-level blob storage [flink] via GitHub
  • Re: [PR] [FLINK-39173][runtime] Support application-level blob storage [flink] via GitHub
  • Re: [PR] [FLINK-39173][runtime] Support application-level blob storage [flink] via GitHub
  • Re: [PR] [FLINK-39173][runtime] Support application-level blob storage [flink] via GitHub
  • Re: [PR] [FLINK-39173][runtime] Support application-level blob storage [flink] via GitHub
  • Re: [PR] [FLINK-39173][runtime] Support application-level blob storage [flink] via GitHub
• Re: [PR] [hotfix][metrics] Fix NullArgumentException when calculating checkpoint statistics with empty data [flink] via GitHub
• Re: [PR] [hotfix] Add Postgresql UUID catalog support [flink-connector-jdbc] via GitHub
• Re: [PR] Bump express in /flink-runtime-web/web-dashboard [flink] via GitHub
• Re: [PR] [FLINK-24493] [flink-connector-base] Introduce DemultiplexingSink [flink] via GitHub
  • Re: [PR] [FLINK-24493] [flink-connector-base] Introduce DemultiplexingSink [flink] via GitHub
• [PR] [FLINK-39183][table] Support BITMAP type in Calcite parser [flink] via GitHub
  • Re: [PR] [FLINK-39183][table] Support BITMAP type in Calcite parser [flink] via GitHub
  • Re: [PR] [FLINK-39183][table] Support BITMAP type in Calcite parser [flink] via GitHub
  • Re: [PR] [FLINK-39183][table] Support BITMAP type in Calcite parser [flink] via GitHub
  • Re: [PR] [FLINK-39183][table] Support BITMAP type in Calcite parser [flink] via GitHub
• [jira] [Updated] (FLINK-39173) Support application-level blob storage Yi Zhang (Jira)
  • [jira] [Updated] (FLINK-39173) Support application-level blob storage ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-39183) Support BITMAP type in Calcite parser dylanhz (Jira)
  • [jira] [Updated] (FLINK-39183) Support BITMAP type in Calcite parser ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-39173) Support application-level blob storage Zhu Zhu (Jira)
• [jira] [Created] (FLINK-39188) Documentation for BITMAP type dylanhz (Jira)
• [jira] [Created] (FLINK-39187) Add core built-in aggregate functions for BITMAP dylanhz (Jira)
• [jira] [Created] (FLINK-39186) Add core built-in scalar functions for BITMAP dylanhz (Jira)
• [jira] [Created] (FLINK-39185) Introduce BITMAP type for Table API/SQL dylanhz (Jira)
• [jira] [Created] (FLINK-39183) Support BITMAP type in Calcite parser dylanhz (Jira)
• [jira] [Created] (FLINK-39184) Introduce Bitmap type for DataStream API dylanhz (Jira)
• Re: [PR] [hotfix] Fix incorrect JavaDoc for session window assigners [flink] via GitHub
• Re: [PR] Revert [FLINK-38869] InitializationContext for KafkaSubscriber (#208) [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers [flink] via GitHub
  • Re: [PR] [FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers [flink] via GitHub
  • Re: [PR] [FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers [flink] via GitHub
  • Re: [PR] [FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers [flink] via GitHub
• [PR] [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest [flink] via GitHub
  • Re: [PR] [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest [flink] via GitHub
  • Re: [PR] [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest [flink] via GitHub
  • Re: [PR] [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest [flink] via GitHub
  • Re: [PR] [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest [flink] via GitHub
  • Re: [PR] [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest [flink] via GitHub
• [jira] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Yuepeng Pan (Jira)
• [PR] [hotfix] Fix typos in constants, Javadoc and documentation [flink-connector-http] via GitHub
  • Re: [PR] [hotfix] Fix typos in constants, Javadoc and documentation [flink-connector-http] via GitHub
  • Re: [PR] [hotfix] Fix typos in constants, Javadoc and documentation [flink-connector-http] via GitHub
  • Re: [PR] [hotfix] Fix typos in constants, Javadoc and documentation [flink-connector-http] via GitHub
• [jira] [Updated] (FLINK-39181) Reduce Verbose DEBUG Logging in CI Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39181) Reduce Verbose DEBUG Logging in CI ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39181) Reduce Verbose DEBUG Logging in CI Martijn Visser (Jira)
• Re: [PR] [FLINK-39176][runtime] Introduce NodeHealthManager abstraction [flink] via GitHub
• [PR] Bump @angular/core from 20.1.3 to 20.3.17 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump @angular/core from 20.1.3 to 20.3.17 in /flink-runtime-web/web-dashboard [flink] via GitHub
• [PR] Bump com.fasterxml.jackson.core:jackson-core from 2.15.2 to 2.18.6 in /flink-models/flink-model-triton [flink] via GitHub
  • Re: [PR] Bump com.fasterxml.jackson.core:jackson-core from 2.15.2 to 2.18.6 in /flink-models/flink-model-triton [flink] via GitHub
• [jira] [Resolved] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion Martijn Visser (Jira)
• [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
  • Re: [PR] [FLINK-39176][WebUI] Add Node Health status page to Job Manager UI [flink] via GitHub
• [PR] [FLINK-39176][Runtime] Add expiration cleanup scheduler for NodeHealthManager [flink] via GitHub
  • Re: [PR] [FLINK-39176][Runtime] Add expiration cleanup scheduler for NodeHealthManager [flink] via GitHub
• Re: [I] [Feature] [integration] [Java] Chroma vector store for Java [flink-agents] via GitHub
  • Re: [I] [Feature] [integration] [Java] Chroma vector store for Java [flink-agents] via GitHub
  • Re: [I] [Feature] [integration] [Java] Chroma vector store for Java [flink-agents] via GitHub
  • Re: [I] [Feature] [integration] [Java] Chroma vector store for Java [flink-agents] via GitHub
  • Re: [I] [Feature] [integration] [Java] Chroma vector store for Java [flink-agents] via GitHub
• Re: [I] [Feature] Batched Summarization for Long-Term Memory [flink-agents] via GitHub
  • Re: [I] [Feature] Batched Summarization for Long-Term Memory [flink-agents] via GitHub
  • Re: [I] [Feature] Batched Summarization for Long-Term Memory [flink-agents] via GitHub
• Re: [I] [Feature] [runtime] Support batched summarization for long-term memory. [flink-agents] via GitHub
  • Re: [I] [Feature] [runtime] Support batched summarization for long-term memory. [flink-agents] via GitHub
  • Re: [I] [Feature] [runtime] Support batched summarization for long-term memory. [flink-agents] via GitHub
  • Re: [I] [Feature] [runtime] Support batched summarization for long-term memory. [flink-agents] via GitHub
• [PR] [FLINK-39176][runtime] Add configuration support for management blocklist [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management blocklist [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Add configuration support for management node quarantine [flink] via GitHub
• [PR] Add OpenAI Responses API integration [Java] [flink-agents] via GitHub
• Re: [PR] [hotfix] Install yamale to allow CI Kubenetes linting to work [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Martijn Visser (Jira)
• [PR] [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling [flink] via GitHub
  • Re: [PR] [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling [flink] via GitHub
  • Re: [PR] [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling [flink] via GitHub
  • Re: [PR] [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling [flink] via GitHub
• [jira] [Commented] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39180) RestClientTest.testRestClientClosedHandling fails with wrong assertion Martijn Visser (Jira)
• Re: [PR] [FLINK-3154][runtime] Upgrade from Kryo v2 + Chill 0.7.6 to Kryo v5 w… [flink] via GitHub
• [jira] [Resolved] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException Martijn Visser (Jira)

• Earlier messages