issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2024/04/14
Re: [PR] [FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController [flink]
via GitHub
2024/04/14
[jira] [Commented] (FLINK-34414) EXACTLY_ONCE guarantee doesn't work properly for Flink/Pulsar connector
Yufan Sheng (Jira)
2024/04/14
Re: [PR] [FLINK-35072][cdc][doris] Support applying compatible `AlterColumnTypeEvent` to Doris sink [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [FLINK-35072][cdc][doris] Support applying compatible `AlterColumnTypeEvent` to Doris sink [flink-cdc]
via GitHub
2024/04/14
[jira] [Resolved] (FLINK-33884) Update Pulsar dependency to 3.0.2 in Pulsar Connector
Zili Chen (Jira)
2024/04/14
Re: [PR] [FLINK-33884] Update Pulsar dependency to 3.0.2 in Pulsar Connector [flink-connector-pulsar]
via GitHub
2024/04/14
[jira] [Resolved] (FLINK-34629) Pulsar source lost topic subscribe
Zili Chen (Jira)
2024/04/14
[jira] [Commented] (FLINK-34436) Avro schema evolution and compatibility issues in Pulsar connector
Yufan Sheng (Jira)
2024/04/14
Re: [PR] [FLINK-34629] Fix invalid subtask assignment for non-partitioned topics [flink-connector-pulsar]
via GitHub
2024/04/14
Re: [PR] [FLINK-34629] Fix invalid subtask assignment for non-partitioned topics [flink-connector-pulsar]
via GitHub
2024/04/14
Re: [PR] [FLINK-25537][JUnit5 Migration] Module: flink-core with,Package: Configuration [flink]
via GitHub
2024/04/14
[jira] [Commented] (FLINK-35064) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict
Yufan Sheng (Jira)
2024/04/14
Re: [PR] [FLINK-35064] Update Pulsar dependency to solve the conflict of com.f… [flink-connector-pulsar]
via GitHub
2024/04/14
Re: [PR] [FLINK-34629] Fix non-partition topic subscribe lost. [flink-connector-pulsar]
via GitHub
2024/04/14
Re: [PR] [FLINK-33884] Update Pulsar dependency to 3.0.2 in Pulsar Connector [flink-connector-pulsar]
via GitHub
2024/04/14
Re: [PR] [FLINK-35064] Update Pulsar dependency to solve the conflict of com.f… [flink-connector-pulsar]
via GitHub
2024/04/14
Re: [PR] Allow specifying the ServerSocket port for the collect function when accessing the TaskManager from the client. [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-35072][cdc][doris] Support applying compatible `AlterColumnTypeEvent` to Doris sink [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-34936][Checkpointing] Register reused shared state handle to FileMergingSnapshotManager [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-32440][checkpoint] Introduce file merging configurations [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-25537][JUnit5 Migration] Module: flink-core with,Package: Configuration [flink]
via GitHub
2024/04/14
[jira] [Updated] (FLINK-34987) Introduce Internal State Interface for Async State API
ASF GitHub Bot (Jira)
2024/04/14
Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-35064] Update Pulsar dependency to solve the conflict of com.f… [flink-connector-pulsar]
via GitHub
2024/04/14
Re: [PR] [FLINK-35102][doris] Fix Doris connector type mapping issues [flink-cdc]
via GitHub
2024/04/14
[jira] [Updated] (FLINK-35102) Incorret Type mapping for Flink CDC Doris connector
ASF GitHub Bot (Jira)
2024/04/14
Re: [PR] [hotfix][runtime]Fix the missing methed parameter annotation problem [flink]
via GitHub
2024/04/14
[jira] [Created] (FLINK-35102) Incorret Type mapping for Flink CDC Doris connector
Xiqian YU (Jira)
2024/04/14
Re: [PR] [minor][cdc][docs] Optimize styles of the Flink CDC website docs home… [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [minor][docs] Optimize markdown styles in quickstart doc [flink-cdc]
via GitHub
2024/04/14
[PR] [minor][docs] Optimize markdown styles in quickstart doc [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-35101][runtime]Fix the missing methed parameter annotation problem [flink]
via GitHub
2024/04/14
[jira] [Commented] (FLINK-35040) The performance of serializerHeavyString regresses since April 3
Rui Fan (Jira)
2024/04/14
[jira] [Assigned] (FLINK-35046) Introduce New KeyedStateBackend related Async interfaces
Hangxiang Yu (Jira)
2024/04/14
[jira] [Updated] (FLINK-35046) Introduce New KeyedStateBackend related Async interfaces
ASF GitHub Bot (Jira)
2024/04/14
[PR] [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor [flink]
via GitHub
2024/04/14
[jira] [Commented] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
chenyu (Jira)
2024/04/14
[jira] [Updated] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
ASF GitHub Bot (Jira)
2024/04/14
[PR] [FLINK-35101][runtime]Fix the missing methed parameter annotation problem [flink]
via GitHub
2024/04/14
[jira] [Assigned] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot.
Weijie Guo (Jira)
2024/04/14
[jira] [Commented] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
Weijie Guo (Jira)
2024/04/14
[jira] [Updated] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
chenyu (Jira)
2024/04/14
[jira] [Updated] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
chenyu (Jira)
2024/04/14
[jira] [Commented] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
chenyu (Jira)
2024/04/14
[jira] [Updated] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
chenyu (Jira)
2024/04/14
[jira] [Updated] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
Weijie Guo (Jira)
2024/04/14
[jira] [Closed] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
Weijie Guo (Jira)
2024/04/14
[jira] [Updated] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
Weijie Guo (Jira)
2024/04/14
[jira] [Updated] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
Weijie Guo (Jira)
2024/04/14
[jira] [Commented] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
Weijie Guo (Jira)
2024/04/14
[jira] [Commented] (FLINK-34273) git fetch fails
Weijie Guo (Jira)
2024/04/14
[jira] [Created] (FLINK-35101) Missing method parameter annotation for ResourceManagerGateway.sendSlotReport
chenyu (Jira)
2024/04/14
[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails
Weijie Guo (Jira)
2024/04/14
[jira] [Comment Edited] (FLINK-34273) git fetch fails
Weijie Guo (Jira)
2024/04/14
[jira] [Updated] (FLINK-35100) Quickstarts Java nightly end-to-end test failed on Azure
Weijie Guo (Jira)
2024/04/14
[jira] [Created] (FLINK-35100) Quickstarts Java nightly end-to-end test failed on Azure
Weijie Guo (Jira)
2024/04/14
Re: [PR] [FLINK-35097][table] Fix 'raw' format deserialization [flink]
via GitHub
2024/04/14
[jira] [Updated] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot.
Hongshun Wang (Jira)
2024/04/14
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [FLINK-34969][cdc-cli]Add support for both new and old Flink config files in Flink… [flink-cdc]
via GitHub
2024/04/14
[jira] [Created] (FLINK-35099) Support for multiple datasources
melin (Jira)
2024/04/14
[jira] [Comment Edited] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging
dongwoo.kim (Jira)
2024/04/14
[jira] [Commented] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging
dongwoo.kim (Jira)
2024/04/14
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [FLINK-35098][orc] Fix incorrect results in thanEquals filters [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-34942][connectors/opensearch] Add support for Flink 1.19+ [flink-connector-opensearch]
via GitHub
2024/04/14
Re: [PR] [FLINK-34942][connectors/opensearch] Add support for Flink 1.19+ [flink-connector-opensearch]
via GitHub
2024/04/14
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
2024/04/14
[jira] [Comment Edited] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line
Kumar Mallikarjuna (Jira)
2024/04/14
Re: [PR] [FLINK-35098][ORC] Fix incorrect results with literal first expressions [flink]
via GitHub
2024/04/14
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/14
Re: [PR] [FLINK-35097][table] Fix 'raw' format deserialization [flink]
via GitHub
2024/04/14
[jira] [Commented] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line
Kumar Mallikarjuna (Jira)
2024/04/14
[jira] [Updated] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line
ASF GitHub Bot (Jira)
2024/04/14
[PR] [FLINK-35097][table] Fix 'raw' format deserialization [flink]
via GitHub
2024/04/14
[jira] [Commented] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line
Kumar Mallikarjuna (Jira)
2024/04/14
[jira] [Updated] (FLINK-34903) Add mysql-pipeline-connector with tables.exclude option to exclude unnecessary tables
Thorne (Jira)
2024/04/14
[jira] [Updated] (FLINK-34903) Add mysql-pipeline-connector with tables.exclude option to exclude unnecessary tables
Thorne (Jira)
2024/04/14
Re: [PR] [FLINK-30687][table] Support pushdown for aggregate filters [flink]
via GitHub
2024/04/14
Re: [PR] [FLINK-34903][MySQL][Feature] Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables [flink-cdc]
via GitHub
2024/04/14
[PR] [FLINK-30687][table] Support pushdown for aggregate filters [flink]
via GitHub
2024/04/14
[jira] [Updated] (FLINK-30687) FILTER not effect in count(*)
ASF GitHub Bot (Jira)
2024/04/14
Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]
via GitHub
2024/04/14
Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]
via GitHub
2024/04/14
[jira] [Comment Edited] (FLINK-31992) FlinkKafkaConsumer API is suggested to use as part of documentation, when that API is deprecated for flink version 1.14
Sandesh Mendan (Jira)
2024/04/14
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
2024/04/14
Re: [PR] [minor][docs] Optimize markdown styles in quickstart doc [flink-cdc]
via GitHub
2024/04/13
Re: [PR] [FLINK-35098][ORC] Fix incorrect results with literal first expressions [flink]
via GitHub
2024/04/13
[jira] [Commented] (FLINK-35098) Incorrect results for queries like "10 >= y" on tables using Filesystem connector and Orc format
Andrey Gaskov (Jira)
2024/04/13
[PR] [FLINK-35098][ORC] Fix incorrect results with literal first expressions [flink]
via GitHub
2024/04/13
Re: [PR] [FLINK-30081][runtime] Reset unused options like jvm-overhead.min/max for local executor [flink]
via GitHub
2024/04/13
[jira] [Commented] (FLINK-35098) Incorrect results for queries like "10 >= y" on tables using Filesystem connector and Orc format
Jeyhun Karimov (Jira)
2024/04/13
Re: [PR] [FLINK-35098][orc] Fix incorrect results in thanEquals filters [flink]
via GitHub
2024/04/13
Re: [PR] [FLINK-35098][orc] Fix incorrect results in thanEquals filters [flink]
via GitHub
2024/04/13
Re: [PR] [FLINK-35098][orc] Fix incorrect results in thanEquals filters [flink]
via GitHub
2024/04/13
Re: [PR] [FLINK-35098][orc] Fix incorrect results in thanEquals filters [flink]
via GitHub
2024/04/13
[jira] [Updated] (FLINK-35098) Incorrect results for queries like "10 >= y" on tables using Filesystem connector and Orc format
ASF GitHub Bot (Jira)
2024/04/13
[PR] [FLINK-35098][orc] Fix incorrect results in thanEquals filters [flink]
via GitHub
2024/04/13
Re: [PR] Bump org.apache.commons:commons-compress from 1.21 to 1.26.0 [flink-connector-aws]
via GitHub
2024/04/13
Re: [PR] Bump org.apache.commons:commons-compress from 1.21 to 1.26.0 [flink-connector-aws]
via GitHub
2024/04/13
Re: [PR] [FLINK-34961] Use dedicated CI name for Kubernetes Operator to differentiate it in infra-reports [flink-kubernetes-operator]
via GitHub
2024/04/13
Re: [PR] [FLINK-34961] Use dedicated CI name for Kubernetes Operator to differentiate it in infra-reports [flink-kubernetes-operator]
via GitHub
2024/04/13
Re: [PR] [FLINK-34961] Use dedicated CI name for Rabbit MQ connector to differentiate it in infra-reports [flink-connector-rabbitmq]
via GitHub
2024/04/13
Re: [PR] [FLINK-34961] Use dedicated CI name for Rabbit MQ connector to differentiate it in infra-reports [flink-connector-rabbitmq]
via GitHub
2024/04/13
[jira] [Commented] (FLINK-35040) The performance of serializerHeavyString regresses since April 3
Robert Metzger (Jira)
2024/04/13
[jira] [Commented] (FLINK-35098) Incorrect results for queries like "10 >= y" on tables using Filesystem connector and Orc format
Andrey Gaskov (Jira)
2024/04/13
[jira] [Created] (FLINK-35098) Incorrect results for queries like "10 >= y" on tables using Filesystem connector and Orc format
Andrey Gaskov (Jira)
2024/04/13
[jira] [Updated] (FLINK-35094) SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT
ASF GitHub Bot (Jira)
2024/04/13
[PR] [FLINK-35094] SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT [flink-connector-elasticsearch]
via GitHub
2024/04/13
Re: [PR] [FLINK-34970] Translate architecture documents into Chinese [flink-kubernetes-operator]
via GitHub
2024/04/13
Re: [PR] [FLINK-34961] Use dedicated CI name for Kubernetes Operator to differentiate it in infra-reports [flink-kubernetes-operator]
via GitHub
2024/04/13
Re: [PR] chore: fix typo [flink-kubernetes-operator]
via GitHub
2024/04/13
Re: [PR] [FLINK-30081][runtime] Reset jvm-overhead.min/max for local executor [flink]
via GitHub
2024/04/12
Re: [PR] [hotfix] Fix typo DataStream [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-35025][Runtime/State] Abstract stream operators for async state processing [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-35025][Runtime/State] Abstract stream operators for async state processing [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-35025][Runtime/State] Abstract stream operators for async state processing [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-35025][Runtime/State] Abstract stream operators for async state processing [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework [flink]
via GitHub
2024/04/12
Re: [PR] [minor][cdc][docs] Optimize styles of the Flink CDC website docs home… [flink-cdc]
via GitHub
2024/04/12
[jira] [Commented] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector
Balint Bene (Jira)
2024/04/12
[jira] [Created] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line
David Perkins (Jira)
2024/04/12
[jira] [Updated] (FLINK-35096) Flink OpenSearch Connector
Martijn Visser (Jira)
2024/04/12
[jira] [Created] (FLINK-35096) Flink OpenSearch Connector
Harish Sharma (Jira)
2024/04/12
Re: [PR] [FLINK-24379][Formats] Avro Glue Schema Registry table format [flink-connector-aws]
via GitHub
2024/04/12
Re: [PR] [FLINK-34158][table] Migrate WindowAggregateReduceFunctionsRule to java [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-35025][Runtime/State] Abstract stream operators for async state processing [flink]
via GitHub
2024/04/12
[jira] [Updated] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator
ASF GitHub Bot (Jira)
2024/04/12
[PR] [FLINK-35025][Runtime/State] Abstract stream operators for async state processing [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-34930] Externalize existing code from bahir-flink [flink-connector-kudu]
via GitHub
2024/04/12
[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Ryan Skraba (Jira)
2024/04/12
Re: [PR] [FLINK-34444] Initial implementation of JM operator metric rest api [flink]
via GitHub
2024/04/12
[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Ryan Skraba (Jira)
2024/04/12
[jira] [Created] (FLINK-35095) ExecutionEnvironmentImplTest.testFromSource failure on GitHub CI
Ryan Skraba (Jira)
2024/04/12
[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Ryan Skraba (Jira)
2024/04/12
[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager
Ryan Skraba (Jira)
2024/04/12
Re: [PR] [BP-1.19][FLINK-34517][table]fix environment configs ignored when calling procedure operation [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-35079] Fallback to timestamp startup mode when resume token has expired [flink-cdc]
via GitHub
2024/04/12
Re: [PR] [FLINK-35079] Fallback to timestamp startup mode when resume token has expired [flink-cdc]
via GitHub
2024/04/12
Re: [PR] [FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-34574] Add CPU and memory size autoscaler quota [flink-kubernetes-operator]
via GitHub
2024/04/12
Re: [PR] [FLINK-34574] Add CPU and memory size autoscaler quota [flink-kubernetes-operator]
via GitHub
2024/04/12
[jira] [Comment Edited] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name
Sergey Nuyanzin (Jira)
2024/04/12
[jira] [Updated] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name
Sergey Nuyanzin (Jira)
2024/04/12
Re: [PR] [FLINK-34961][BP v3.1] Use dedicated CI name for JDBC connector to differentiate it in infra-reports [flink-connector-jdbc]
via GitHub
2024/04/12
Re: [PR] [FLINK-34574] Add CPU and memory size autoscaler quota [flink-kubernetes-operator]
via GitHub
2024/04/12
[jira] [Commented] (FLINK-34127) Kafka connector repo runs a duplicate of `IntegrationTests` framework tests
Martijn Visser (Jira)
2024/04/12
[jira] [Comment Edited] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
Etienne Chauchot (Jira)
2024/04/12
[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
Etienne Chauchot (Jira)
2024/04/12
Re: [PR] [FLINK-35069][API/DataStream]ContinuousProcessingTimeTrigger avoids registering timers at the end of the window [flink]
via GitHub
2024/04/12
[jira] [Updated] (FLINK-35094) SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT
Sergey Nuyanzin (Jira)
2024/04/12
Re: [PR] [FLINK-34995] flink kafka connector source stuck when partition leade… [flink-connector-kafka]
via GitHub
2024/04/12
Re: [PR] [FLINK-34961] Use dedicated CI name for JDBC connector to differentiate it in infra-reports [flink-connector-jdbc]
via GitHub
2024/04/12
[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
yuanfenghu (Jira)
2024/04/12
[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
Etienne Chauchot (Jira)
2024/04/12
Re: [PR] [FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController [flink]
via GitHub
2024/04/12
[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
yuanfenghu (Jira)
2024/04/12
Re: [PR] [upgrade] fink to 1.18.1 and pulsar to 3.0.4 [flink-connector-pulsar]
via GitHub
2024/04/12
[jira] [Updated] (FLINK-35094) SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT
Sergey Nuyanzin (Jira)
2024/04/12
[jira] [Updated] (FLINK-35094) SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT
Sergey Nuyanzin (Jira)
2024/04/12
[jira] [Created] (FLINK-35094) SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT
Sergey Nuyanzin (Jira)
2024/04/12
[jira] [Updated] (FLINK-35094) SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT
Sergey Nuyanzin (Jira)
2024/04/12
Re: [PR] [FLINK-34574] Add CPU and memory size autoscaler quota [flink-kubernetes-operator]
via GitHub
2024/04/12
[jira] [Comment Edited] (FLINK-34953) Add github ci for flink-web to auto commit build files
Zhongqiang Gong (Jira)
2024/04/12
[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
Etienne Chauchot (Jira)
2024/04/12
Re: [PR] [FLINK-34961][BP v3.1] Use dedicated CI name for Kafka connector to differentiate it in infra-reports [flink-connector-kafka]
via GitHub
2024/04/12
[jira] [Commented] (FLINK-34953) Add github ci for flink-web to auto commit build files
Zhongqiang Gong (Jira)
2024/04/12
Re: [PR] [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework [flink]
via GitHub
2024/04/12
Re: [PR] [FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework [flink]
via GitHub
2024/04/12
[jira] [Commented] (FLINK-35078) Include Flink CDC pipeline connector sub-modules in the CI runs
Qingsheng Ren (Jira)
2024/04/12
[jira] [Resolved] (FLINK-35078) Include Flink CDC pipeline connector sub-modules in the CI runs
Qingsheng Ren (Jira)
2024/04/12
Re: [PR] [FLINK-35078][pipeline-connectors][ci] Adds flink-cdc-pipeline-connectors to the GHA CI [flink-cdc]
via GitHub
2024/04/12
[jira] [Assigned] (FLINK-35090) Doris sink fails to create table when database does not exist
Qingsheng Ren (Jira)
2024/04/12
Re: [PR] [FLINK-34574] Add CPU and memory size autoscaler quota [flink-kubernetes-operator]
via GitHub
2024/04/12
Re: [PR] [FLINK-34574] Add CPU and memory size autoscaler quota [flink-kubernetes-operator]
via GitHub
2024/04/11
[PR] [FLINK-34961] Use dedicated CI name for Kubernetes Operator to differentiate it in infra-reports [flink-kubernetes-operator]
via GitHub
2024/04/11
Re: [PR] [FLINK-35045][state] Introduce Internal State for Async State API [flink]
via GitHub
2024/04/11
Re: [PR] [FLINK-35079] Fallback to timestamp startup mode when resume token has expired [flink-cdc]
via GitHub
2024/04/11
Re: [PR] [FLINK-35045][state] Introduce Internal State for Async State API [flink]
via GitHub
2024/04/11
[jira] [Comment Edited] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
yuanfenghu (Jira)
2024/04/11
[PR] [BP-1.19][FLINK-34517][table]fix environment configs ignored when calling procedure operation [flink]
via GitHub
2024/04/11
Re: [PR] [BP-1.19][FLINK-34517][table]fix environment configs ignored when calling procedure operation [flink]
via GitHub
2024/04/11
Re: [PR] [FLINK-32440][checkpoint] Introduce file merging configurations [flink]
via GitHub
2024/04/11
Re: [PR] [FLINK-32440][checkpoint] Introduce file merging configurations [flink]
via GitHub
2024/04/11
Re: [PR] [FLINK-35089][runtime] Serialize the lastRecordAttributes in AbstractStreamOperator [flink]
via GitHub
2024/04/11
Re: [PR] [FLINK-35089][runtime] Serialize the lastRecordAttributes in AbstractStreamOperator [flink]
via GitHub
2024/04/11
[jira] [Updated] (FLINK-35089) Two input AbstractStreamOperator may throw NPE when receiving RecordAttributes
ASF GitHub Bot (Jira)
Earlier messages
Later messages