issues
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] [FLINK-35415][base] Fix compatibility with Flink 1.19 [flink-cdc]
via GitHub
Re: [PR] [FLINK-35415][base] Fix compatibility with Flink 1.19 [flink-cdc]
via GitHub
Re: [PR] [FLINK-35415][base] Fix compatibility with Flink 1.19 [flink-cdc]
via GitHub
Re: [PR] [FLINK-35415][base] Fix compatibility with Flink 1.19 [flink-cdc]
via GitHub
Re: [PR] [FLINK-35415][base] Fix compatibility with Flink 1.19 [flink-cdc]
via GitHub
Re: [PR] Adding JDBC Connector v3.2.0 [flink-web]
via GitHub
Re: [PR] [FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector. [flink-cdc]
via GitHub
Re: [PR] [FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector. [flink-cdc]
via GitHub
Re: [PR] [FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector. [flink-cdc]
via GitHub
Re: [PR] [FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector. [flink-cdc]
via GitHub
Re: [PR] [FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector. [flink-cdc]
via GitHub
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
Re: [PR] [FLINK-33859] Support OpenSearch v2 [flink-connector-opensearch]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
Re: [PR] [FLINK-35216] Support for RETURNING clause of JSON_QUERY [flink]
via GitHub
[jira] [Updated] (FLINK-35415) CDC Fails to create sink with Flink 1.19
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions
ASF GitHub Bot (Jira)
[PR] [FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions [flink]
via GitHub
Re: [PR] [FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions [flink]
via GitHub
Re: [PR] [BP][FLINK-33493][connectors/elasticsearch] Fix ElasticsearchWriterITCase [flink-connector-elasticsearch]
via GitHub
[jira] [Commented] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging
Muhammet Orazov (Jira)
Re: [PR] [FLINK-23314][cep] State left behind for short lived keys [flink]
via GitHub
Re: [PR] [FLINK-27489] Allow users to run dedicated tests in the CI [flink]
via GitHub
[PR] [BP-3.0][FLINK-31696] ElasticSearch nightly CI failure [flink-connector-elasticsearch]
via GitHub
Re: [PR] [BP-3.0][FLINK-31696] ElasticSearch nightly CI failure [flink-connector-elasticsearch]
via GitHub
Re: [PR] [BP-3.0][FLINK-31696] ElasticSearch nightly CI failure [flink-connector-elasticsearch]
via GitHub
[PR] [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily [flink]
via GitHub
Re: [PR] [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily [flink]
via GitHub
Re: [PR] [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily [flink]
via GitHub
[PR] [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily [flink]
via GitHub
Re: [PR] [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily [flink]
via GitHub
Re: [PR] [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily [flink]
via GitHub
Re: [PR] [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily [flink]
via GitHub
[jira] [Commented] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
Martijn Visser (Jira)
[jira] [Commented] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
Xintong Song (Jira)
[jira] [Commented] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
Jeyhun Karimov (Jira)
[jira] [Commented] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
melin (Jira)
[jira] [Commented] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
Jing Ge (Jira)
Re: [PR] [docs] format shell code display for mysql-doris-pipeline doc [flink-cdc]
via GitHub
Re: [PR] Release 2.4 [flink-cdc]
via GitHub
Re: [PR] [jdbc] support read snapshot only [flink-cdc]
via GitHub
Re: [PR] [postgres] Postgres CDC Connector support automatically identify newly added tables [flink-cdc]
via GitHub
Re: [PR] [WIP][debezium] Bump debezium version to 2.3.1.Final [flink-cdc]
via GitHub
Re: [PR] using tikv limited scan to avoid oom [flink-cdc]
via GitHub
Re: [PR] Update OracleScanFetchTask.java [flink-cdc]
via GitHub
Re: [PR] Add a table of cdc json type [flink-cdc]
via GitHub
Re: [PR] Update mysql-postgres-tutorial-zh.md [flink-cdc]
via GitHub
Re: [PR] [cdc][base]Support dynamically table addition in flink-cdc-base [flink-cdc]
via GitHub
Re: [PR] [mysql] a new way to find binlog/positon in timestamp startupmode [flink-cdc]
via GitHub
Re: [PR] Switch to a MySQL image with arm64 support [flink-cdc]
via GitHub
Re: [PR] 升级Jackson版本 [flink-cdc]
via GitHub
Re: [PR] [e2e] optimization for arm64 [flink-cdc]
via GitHub
[jira] [Closed] (FLINK-35416) Weekly CI for ElasticSearch connector failed to compile
Weijie Guo (Jira)
Re: [PR] [mysql] Populate table schemas when scanNewlyAddedTables is enabled in binlog phase [flink-cdc]
via GitHub
Re: [PR] [metric] fix flink cdc metric conflict with flink built in metric [flink-cdc]
via GitHub
Re: [PR] [mysql] Support docker image of ARM chip [flink-cdc]
via GitHub
Re: [PR] [Debezium] Fix the server timeZone bug of debeziumDeserialization when using dataSream API(#317) [flink-cdc]
via GitHub
Re: [PR] [mysql] Fix use latest-offset mode during caused add newly table not … [flink-cdc]
via GitHub
Re: [PR] [PostgreSQL] Add DeserializationConverterFactory for PostGIS schemas [flink-cdc]
via GitHub
Re: [PR] [mysql] expose update_before field in the metadata through flink sql [flink-cdc]
via GitHub
Re: [PR] [mysql] expose op type in the metadata through flink sql [flink-cdc]
via GitHub
[jira] [Assigned] (FLINK-34993) Support Model CRUD in parser
Timo Walther (Jira)
[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests
liuzhuo (Jira)
[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests
Zakelly Lan (Jira)
[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests
liuzhuo (Jira)
[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35417) JobManager and TaskManager support merging and run in a single process
melin (Jira)
[jira] [Updated] (FLINK-35416) Weekly CI for ElasticSearch connector failed to compile
ASF GitHub Bot (Jira)
[PR] [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded [flink-connector-elasticsearch]
via GitHub
[PR] chore: Update pekko version [flink]
via GitHub
Re: [PR] chore: Update pekko version [flink]
via GitHub
Re: [PR] chore: Update pekko version [flink]
via GitHub
Re: [PR] chore: Update pekko version [flink]
via GitHub
Re: [PR] chore: Update pekko version [flink]
via GitHub
Re: [PR] chore: Update pekko version [flink]
via GitHub
Re: [PR] chore: Update pekko version [flink]
via GitHub
[jira] [Comment Edited] (FLINK-35334) Code generation: init method exceeds 64 KB when there is a long array field with Table API
Simon Lee (Jira)
[jira] [Created] (FLINK-35416) Weekly CI for ElasticSearch connector failed to compile
Weijie Guo (Jira)
Re: [PR] [FLINK-28109][connector/elasticsearch] Delete useful code in the row emitter [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-28109][connector/elasticsearch] Delete useful code in the row emitter [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-28109][connector/elasticsearch] Delete useful code in the row emitter [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-28428][connectors/elasticsearch][docs][docs-zh] Fix example and Chinese translations [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-28428][connectors/elasticsearch][docs][docs-zh] Fix example and Chinese translations [flink-connector-elasticsearch]
via GitHub
Re: [PR] Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.19 in /flink-connector-elasticsearch-base [flink-connector-elasticsearch]
via GitHub
Re: [PR] Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.19 in /flink-connector-elasticsearch-base [flink-connector-elasticsearch]
via GitHub
Re: [PR] Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.19 in /flink-connector-elasticsearch-base [flink-connector-elasticsearch]
via GitHub
[jira] [Closed] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8
Weijie Guo (Jira)
[jira] [Commented] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8
Weijie Guo (Jira)
[jira] [Assigned] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8
Weijie Guo (Jira)
[jira] [Closed] (FLINK-34549) FLIP-410: Config, Context and Processing Timer Service of DataStream API V2
Weijie Guo (Jira)
[jira] [Commented] (FLINK-34549) FLIP-410: Config, Context and Processing Timer Service of DataStream API V2
Weijie Guo (Jira)
Re: [PR] [FLINK-33461][Connector/JDBC] Support streaming related semantics for the new JDBC source [flink-connector-jdbc]
via GitHub
[jira] [Commented] (FLINK-35360) [Feature] Submit Flink CDC pipeline job yarn Application mode
ouyangwulin (Jira)
Re: [PR] [FLINK-32223][runtime][security] Add Hive delegation token support [flink]
via GitHub
Re: [PR] [FLINK-32223][runtime][security] Add Hive delegation token support [flink]
via GitHub
[jira] [Closed] (FLINK-35337) Keep up with the latest version of tikv client
ouyangwulin (Jira)
[jira] [Assigned] (FLINK-35415) CDC Fails to create sink with Flink 1.19
Leonard Xu (Jira)
[jira] [Updated] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
Rui Fan (Jira)
[jira] [Updated] (FLINK-35347) Implement InMemory workflow scheduler service and plugin to support materialized table
ASF GitHub Bot (Jira)
[PR] [FLINK-35347][table] Introduce inmemory scheduler service [flink]
via GitHub
Re: [PR] [FLINK-35347][table] Introduce inmemory scheduler service [flink]
via GitHub
Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]
via GitHub
Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]
via GitHub
Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]
via GitHub
Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]
via GitHub
Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]
via GitHub
[jira] [Created] (FLINK-35415) CDC Fails to create sink with Flink 1.19
yux (Jira)
[jira] [Commented] (FLINK-35385) upgrader flink dependency version to 1.19
yux (Jira)
[jira] [Commented] (FLINK-35385) upgrader flink dependency version to 1.19
Hongshun Wang (Jira)
[jira] [Commented] (FLINK-35388) Flink 1.18.1 get stuck after creating highly available job result storage directory
Jira
[jira] [Resolved] (FLINK-35383) Update compatibility matrix to include 1.19 release
Hong Liang Teoh (Jira)
[jira] [Commented] (FLINK-35383) Update compatibility matrix to include 1.19 release
Hong Liang Teoh (Jira)
[jira] [Commented] (FLINK-35383) Update compatibility matrix to include 1.19 release
Hong Liang Teoh (Jira)
[jira] [Created] (FLINK-35414) Cancel jobs through rest api for last-state upgrades
Gyula Fora (Jira)
[jira] [Commented] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails
Ryan Skraba (Jira)
[jira] [Commented] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails
Ryan Skraba (Jira)
[jira] [Commented] (FLINK-34282) Create a release branch
lincoln lee (Jira)
[jira] [Created] (FLINK-35413) VertexFinishedStateCheckerTest causes exit 239
Ryan Skraba (Jira)
Re: [PR] [FLINK-33130]reuse source and sink operator io metrics for task [flink]
via GitHub
[jira] [Updated] (FLINK-20402) Migrate test_tpch.sh
ASF GitHub Bot (Jira)
[PR] [FLINK-20402][e2e] Migrate test_tpch.sh [flink]
via GitHub
Re: [PR] [FLINK-20402][e2e] Migrate test_tpch.sh [flink]
via GitHub
Re: [PR] [FLINK-20402][e2e] Migrate test_tpch.sh [flink]
via GitHub
Re: [PR] [FLINK-20402][e2e] Migrate test_tpch.sh [flink]
via GitHub
[PR] [docs] Polish quickstart guide & migrate maven links from ververica to apache [flink-cdc]
via GitHub
[jira] [Assigned] (FLINK-20402) Migrate test_tpch.sh
Matthias Pohl (Jira)
[jira] [Commented] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting
david radley (Jira)
[jira] [Closed] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance
Yuxin Tan (Jira)
[jira] [Commented] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance
Yuxin Tan (Jira)
[jira] [Updated] (FLINK-35409) Request more splits if all splits are filtered from addSplits method
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-35409) Request more splits if all splits are filtered from addSplits method
Xiao Huang (Jira)
[jira] [Updated] (FLINK-35409) Request more splits if all splits are filtered from addSplits method
Xiao Huang (Jira)
[jira] [Updated] (FLINK-35409) Request more splits if all splits are filtered from addSplits method
Xiao Huang (Jira)
[jira] [Updated] (FLINK-35409) Request more splits if all splits are filtered from addSplits method
Xiao Huang (Jira)
[PR] [FLINK-35409][cdc][mysql] Request more splits if all splits are filtered from addSplits method [flink-cdc]
via GitHub
[jira] [Created] (FLINK-35412) Batch execution of async state request callback
Zakelly Lan (Jira)
[jira] [Commented] (FLINK-20402) Migrate test_tpch.sh
Muhammet Orazov (Jira)
[jira] [Created] (FLINK-35411) Optimize wait logic in draining of async state requests
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35410) Avoid sync waiting in coordinator thread of ForSt executor
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35409) Request more splits if all splits are filtered from addSplits method
Xiao Huang (Jira)
[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting
Xiao Huang (Jira)
[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting
Xiao Huang (Jira)
[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting
Xiao Huang (Jira)
[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting
Xiao Huang (Jira)
[jira] [Created] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting
Xiao Huang (Jira)
[PR] [hotfix][ci] Add new pipeline connectors into `labeler.yml` [flink-cdc]
via GitHub
[jira] [Updated] (FLINK-35242) Add fine-grained schema evolution strategy
ASF GitHub Bot (Jira)
[jira] [Commented] (FLINK-35384) Expose TaskIOMetricGroup to custom Partitioner via init Context
Zhu Zhu (Jira)
Re: [PR] [FLINK-30687][table] Support pushdown for aggregate filters [flink]
via GitHub
Re: [PR] [FLINK-30687][table] Support pushdown for aggregate filters [flink]
via GitHub
Re: [PR] [FLINK-30687][table] Support pushdown for aggregate filters [flink]
via GitHub
Re: [PR] [FLINK-30687][table] Support pushdown for aggregate filters [flink]
via GitHub
Re: [PR] [FLINK-30687][table] Support pushdown for aggregate filters [flink]
via GitHub
[PR] [hotfix][state] Avoid sync waiting in coordinator thread of ForSt executor [flink]
via GitHub
Re: [PR] [hotfix][state] Avoid sync waiting in coordinator thread of ForSt executor [flink]
via GitHub
Re: [PR] [hotfix][state] Avoid sync waiting in coordinator thread of ForSt executor [flink]
via GitHub
Re: [PR] [FLINK-35410][state] Avoid sync waiting in coordinator thread of ForSt executor [flink]
via GitHub
Re: [PR] [FLINK-34954][core] Kryo Input bug fix [flink]
via GitHub
Re: [PR] [FLINK-35130][runtime] Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance [flink]
via GitHub
Re: [PR] [FLINK-35130][runtime] Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance [flink]
via GitHub
[jira] [Created] (FLINK-35407) ensure orderly transactions during the full consumption stage of MySQL CDC
xiaotouming (Jira)
[jira] [Updated] (FLINK-35406) Use inner serializer when casting RAW type to BINARY or STRING in cast rules
ASF GitHub Bot (Jira)
[PR] [FLINK-35406] Use inner serializer when casting RAW type to BINARY or… [flink]
via GitHub
Re: [PR] [FLINK-35406] Use inner serializer when casting RAW type to BINARY or… [flink]
via GitHub
Re: [PR] [FLINK-35406] Use inner serializer when casting RAW type to BINARY or… [flink]
via GitHub
Earlier messages
Later messages