issues  

Messages by Thread

• [jira] [Created] (FLINK-40878) Add dynamic rate limit interfaces Peter Huang (Jira)
• [jira] [Created] (FLINK-40877) Support Dynamic Rate Limit in Flink Sources Peter Huang (Jira)
• [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
  • Re: [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
  • Re: [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
  • Re: [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
  • Re: [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
  • Re: [PR] [FLINK-40876][table] Code splitter should generate same code after repeated runs [flink] via GitHub
• [jira] [Created] (FLINK-40876) Code splitter should generate same code after repeated runs Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-40876) Code splitter should generate same code after repeated runs Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-40876) Code splitter should generate same code after repeated runs Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-40876) Code splitter should generate same code after repeated runs ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Martijn Visser (Jira)
• Re: [PR] [FLINK-40728][k8s][build] Migrate Flink off end-of-life OkHttp and keep it off the core classpath (FLIP-607) [flink] via GitHub
  • Re: [PR] [FLINK-40728][k8s][build] Migrate Flink off end-of-life OkHttp and keep it off the core classpath (FLIP-607) [flink] via GitHub
• Re: [PR] [FLINK-40797][table-planner] Exclude NestedLoopJoin from CBO search space for equi-joins [flink] via GitHub
  • Re: [PR] [FLINK-40797][table-planner] Exclude NestedLoopJoin from CBO search space for equi-joins [flink] via GitHub
  • Re: [PR] [FLINK-40797][table-planner] Exclude NestedLoopJoin from CBO search space for equi-joins [flink] via GitHub
  • Re: [PR] [FLINK-40797][table-planner] Exclude NestedLoopJoin from CBO search space for equi-joins [flink] via GitHub
  • Re: [PR] [FLINK-40797][table-planner] Exclude NestedLoopJoin from CBO search space for equi-joins [flink] via GitHub
• [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
  • Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
  • Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
  • Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
  • Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
  • Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
  • Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
  • Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
  • Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
  • Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
  • Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• [PR] [runtime][java] Reject memory writes below a value field before mutating state [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Reject memory writes below a value field before mutating state [flink-agents] via GitHub
• [I] [Bug][runtime] Memory writes below a value field mutate state before failing [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] Memory writes below a value field mutate state before failing [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] Memory writes below a value field mutate state before failing [flink-agents] via GitHub
• [jira] [Created] (FLINK-40875) Optimization to let streaming joins fill key-only deletes instead of adding a ChangelogNormalize Gustavo de Morais (Jira)
• Re: [PR] [FLINK-38023][formats] Fix GenericRecord Avro state migration [flink] via GitHub
• [jira] [Updated] (FLINK-40816) Remove the deprecated configuration keys from the flink-kubernetes module. ASF GitHub Bot (Jira)
• [PR] [FLINK-40816][kubernetes/configuration] Remove the deprecated configuration keys from the flink-kubernetes module. [flink] via GitHub
  • Re: [PR] [FLINK-40816][kubernetes/configuration] Remove the deprecated configuration keys from the flink-kubernetes module. [flink] via GitHub
  • Re: [PR] [FLINK-40816][kubernetes/configuration] Remove the deprecated configuration keys from the flink-kubernetes module. [flink] via GitHub
  • Re: [PR] [FLINK-40816][kubernetes/configuration] Remove the deprecated configuration keys from the flink-kubernetes module. [flink] via GitHub
  • Re: [PR] [FLINK-40816][kubernetes/configuration] Remove the deprecated configuration keys from the flink-kubernetes module. [flink] via GitHub
• [jira] [Reopened] (FLINK-40326) GatedRateLimiter admits more events per cycle than configured Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40815) Remove the deprecated configuration keys from the flink-dstl-dfs module. ASF GitHub Bot (Jira)
• [PR] [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. [flink] via GitHub
  • Re: [PR] [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. [flink] via GitHub
  • Re: [PR] [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. [flink] via GitHub
  • Re: [PR] [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. [flink] via GitHub
  • Re: [PR] [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. [flink] via GitHub
• Re: [I] [Tech Debt][API][Action] Improve annotation-based cross-language Action declarations [flink-agents] via GitHub
• [jira] [Comment Edited] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams Roman Khachatryan (Jira)
• Re: [PR] [FLINK-40504][core] Re-activate the source output on any sign of activity [flink] via GitHub
  • Re: [PR] [FLINK-40504][core] Re-activate the source output on any sign of activity [flink] via GitHub
• [jira] [Created] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs Gustavo de Morais (Jira)
• [jira] [Assigned] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)
• [PR] [integration][java][python] Reject media blocks in providers that send text only [flink-agents] via GitHub
  • Re: [PR] [integration][java][python] Reject media blocks in providers that send text only [flink-agents] via GitHub
  • Re: [PR] [integration][java][python] Reject media blocks in providers that send text only [flink-agents] via GitHub
  • Re: [PR] [integration][java][python] Reject media blocks in providers that send text only [flink-agents] via GitHub
  • Re: [PR] [integration][java][python] Reject media blocks in providers that send text only [flink-agents] via GitHub
  • Re: [PR] [integration][java][python] Reject media blocks in providers that send text only [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)
• Re: [PR] [FLINK-40615][Connectors/Kafka] fix: Prevent duplicate partition assignment in KafkaSourceEnumerator [flink-connector-kafka] via GitHub
• [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Martijn Visser (Jira)
  • [jira] [Assigned] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Martijn Visser (Jira)
• [PR] [FLINK-40872][runtime] Close AsyncExecutionController when async state operators close [flink] via GitHub
  • Re: [PR] [FLINK-40872][runtime] Close AsyncExecutionController when async state operators close [flink] via GitHub
• [jira] [Updated] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER ASF GitHub Bot (Jira)
• [jira] [Comment Edited] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
  • [jira] [Comment Edited] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
  • [jira] [Comment Edited] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
  • [jira] [Comment Edited] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
• [jira] [Commented] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
• [jira] [Resolved] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness Martijn Visser (Jira)
• [jira] [Reopened] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Martijn Visser (Jira)
• [jira] [Created] (FLINK-40873) Fix overlapping config key prefixes in the operator Gyula Fora (Jira)
• [jira] [Comment Edited] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• [PR] [FLINK-40705][python] Fix Java 8 compilation of ArrowReaderWriterTest [flink] via GitHub
  • Re: [PR] [FLINK-40705][python] Fix Java 8 compilation of ArrowReaderWriterTest [flink] via GitHub
  • Re: [PR] [FLINK-40705][python] Fix Java 8 compilation of ArrowReaderWriterTest [flink] via GitHub
• [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Naveen Joseph (Jira)
  • [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• [jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore Martijn Visser (Jira)
• [jira] [Reopened] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Martijn Visser (Jira)
• [jira] [Reopened] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40857) Kubernetes Operator always replaces CR status 3 times on reconciliation Gyula Fora (Jira)
• [jira] [Closed] (FLINK-40857) Kubernetes Operator always replaces CR status 3 times on reconciliation Gyula Fora (Jira)
• [jira] [Created] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
• [jira] [Created] (FLINK-40871) Avoid the UTF-8 round trip when casting strings and decimals to VARIANT Ramin Gharib (Jira)
• [jira] [Assigned] (FLINK-40860) Add bin/minicluster.sh to run an application on a MiniCluster Robert Metzger (Jira)
• [jira] [Resolved] (FLINK-40834) CI artifacts keep only one of jobmanager.log and jobmanager.log.N for YARN containers Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40859) FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Robert Metzger (Jira)
• [jira] [Commented] (FLINK-40326) GatedRateLimiter admits more events per cycle than configured Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40326) GatedRateLimiter admits more events per cycle than configured Martijn Visser (Jira)
• Re: [PR] [BP-2.3][FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter [flink] via GitHub
• Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
• [jira] [Commented] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams Roman Khachatryan (Jira)
  • [jira] [Commented] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams Rui Fan (Jira)
• Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
  • Re: [PR] [FLINK-40528][table] Make codegen tolerant to partial deletes [flink] via GitHub
• Re: [PR] [BP-2.2][FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter [flink] via GitHub
• [jira] [Commented] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness Martijn Visser (Jira)
• Re: [PR] [FLINK-35726][table] Honor @DataTypeHint on POJO fields in type conve… [flink] via GitHub
  • Re: [PR] [FLINK-35726][table] Honor @DataTypeHint on POJO fields in type conve… [flink] via GitHub
• Re: [PR] [FLINK-40705][python] Reset Arrow map child writers between batches [flink] via GitHub
  • Re: [PR] [FLINK-40705][python] Reset Arrow map child writers between batches [flink] via GitHub
• Re: [PR] [FLINK-33404][python] Add default timer callbacks [flink] via GitHub
• Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
• [jira] [Closed] (FLINK-40419) Add regular join support to DataFrame API Dian Fu (Jira)
• [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Restore built-in event types at the JSON boundary [flink-agents] via GitHub
• [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable [flink-agents] via GitHub
• [jira] [Closed] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Dian Fu (Jira)
• [jira] [Closed] (FLINK-40427) Add catalog management and catalog table I/O to DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40869) Document FlinkMiniCluster and add a MiniCluster example Dale Lane (Jira)
• [jira] [Created] (FLINK-40868) Report operator metrics for FlinkMiniCluster resources Dale Lane (Jira)
• [jira] [Created] (FLINK-40870) End-to-end test coverage for FlinkMiniCluster Dale Lane (Jira)
• [jira] [Created] (FLINK-40860) Add bin/minicluster.sh to run an application on a MiniCluster Dale Lane (Jira)
• [jira] [Created] (FLINK-40867) Support FlinkStateSnapshot for FlinkMiniCluster jobs Dale Lane (Jira)
• [jira] [Created] (FLINK-40862) Generate the MiniCluster pod, Deployment, Service and ConfigMap Dale Lane (Jira)
• [PR] [FLINK-40724][build] Add maven wrapper [flink-connector-mongodb] via GitHub
• [jira] [Created] (FLINK-40866) Add FlinkMiniClusterController and register the FlinkMiniCluster kind Dale Lane (Jira)
• [jira] [Created] (FLINK-40865) Add the FlinkMiniCluster observer Dale Lane (Jira)
• [jira] [Created] (FLINK-40864) Add the FlinkMiniCluster Flink service and reconciler Dale Lane (Jira)
• [jira] [Created] (FLINK-40863) Derive FlinkMiniCluster memory configuration from spec.resources Dale Lane (Jira)
• [jira] [Updated] (FLINK-40862) Generate the FlinkMiniCluster pod, Deployment, Service and ConfigMap Dale Lane (Jira)
• [jira] [Created] (FLINK-40861) Add the FlinkMiniCluster custom resource definition and API types Dale Lane (Jira)
• [PR] [hotfix] Update Maven version recommendation to 3.9.16 [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [hotfix] Update Maven version recommendation to 3.9.16 [flink-connector-elasticsearch] via GitHub
• [PR] [hotfix] Update Maven version recommendation to 3.9.16 [flink-connector-opensearch] via GitHub
• [jira] [Created] (FLINK-40859) FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane (Jira)
• [PR] [hotfix] Update Maven version recommendation to 3.9.16 [flink-connector-jdbc] via GitHub
• Re: [PR] [FLINK-24379][Formats] Avro Glue Schema Registry table format [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-24379][Formats] Avro Glue Schema Registry table format [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-24379][Formats] Avro Glue Schema Registry table format [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-24379][Formats] Avro Glue Schema Registry table format [flink-connector-aws] via GitHub
• [PR] [BP-2.2][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
• [PR] [BP-2.3][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub

• Earlier messages
• Later messages