issues  

Messages by Thread

• • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• [jira] [Closed] (FLINK-37476) Update Kafka connector's ChangelogMode Dawid Wysakowicz (Jira)
• [jira] [Updated] (FLINK-37629) Use Checkpointed Offset while migrating clusters in DynamicKafkaSource Chirag Dewan (Jira)
• Re: [PR] [FLINK-36925][table] Introduce SemiAntiJoinOperator in Join with Async State API [flink] via GitHub
  • Re: [PR] [FLINK-36925][table] Introduce SemiAntiJoinOperator in Join with Async State API [flink] via GitHub
  • Re: [PR] [FLINK-36925][table] Introduce SemiAntiJoinOperator in Join with Async State API [flink] via GitHub
• [jira] [Resolved] (FLINK-36832) Remove deprecated class in flink-connector-kafka Arvid Heise (Jira)
• Re: [PR] Fix typo from MARCO to MACRO [flink] via GitHub
  • Re: [PR] Fix typo from MARCO to MACRO [flink] via GitHub
  • Re: [PR] Fix typo from MARCO to MACRO [flink] via GitHub
• Re: [PR] [FLINK-37553] Make ForStKeyedStateBackend update NamespaceSerializer during restoring state [flink] via GitHub
• [jira] [Updated] (FLINK-36058) OperatorTestHarness is always using checkpointId=0 for state recovery Rodrigo Meneses (Jira)
• Re: [PR] [docs-zh]The description of creating a materialized table does not match the example code,The description states 1 hour, while the code states 10 minutes [flink] via GitHub
  • Re: [PR] [docs-zh]The description of creating a materialized table does not match the example code,The description states 1 hour, while the code states 10 minutes [flink] via GitHub
  • Re: [PR] [docs-zh]The description of creating a materialized table does not match the example code,The description states 1 hour, while the code states 10 minutes [flink] via GitHub
• [jira] [Closed] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ RocMarshal (Jira)
• Re: [PR] [FLINK-37583] Upgrade to Kafka 4.0.0 client. [flink-connector-kafka] via GitHub
• [jira] [Resolved] (FLINK-34554) FLIP-511: Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint Arvid Heise (Jira)
• [jira] [Commented] (FLINK-35811) Add the documentation sections to describe the usage of users-oriented interfaces Ruan Hang (Jira)
• [PR] [FLINK-37104] Refactor transform module, code cleanup [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37104] Refactor transform module, code cleanup [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37104] Refactor transform module, code cleanup [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37104] Refactor transform module, code cleanup [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37104] Refactor transform module, code cleanup [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-35811) Add the documentation sections to describe the usage of users-oriented interfaces Ruan Hang (Jira)
  • [jira] [Updated] (FLINK-35811) Add the documentation sections to describe the usage of users-oriented interfaces Ruan Hang (Jira)
• [jira] [Created] (FLINK-37649) Datagen connector cannot set length for collection type Weijie Guo (Jira)
• Re: [PR] [hotfix] fix ci failure due to code style [flink-cdc] via GitHub
  • Re: [PR] [hotfix] fix ci failure due to code style [flink-cdc] via GitHub
• Re: [PR] [FLINK-37628] Fix reference counting in ForSt file cache [flink] via GitHub
  • Re: [PR] [FLINK-37628] Fix reference counting in ForSt file cache [flink] via GitHub
• Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.4 in /flink-connectors/flink-connector-hive [flink] via GitHub
  • Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.4 in /flink-connectors/flink-connector-hive [flink] via GitHub
  • Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.4 in /flink-connectors/flink-connector-hive [flink] via GitHub
  • Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.4 in /flink-connectors/flink-connector-hive [flink] via GitHub
• [jira] [Closed] (FLINK-37626) Flaky test: ForStFlinkFileSystemTest.testSstFileInCache Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37629) Use Checkpointed Offset while migrating clusters in DynamicKafkaSource Chirag Dewan (Jira)
• [jira] [Updated] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0 Arvid Heise (Jira)
• [jira] [Commented] (FLINK-37626) Flaky test: ForStFlinkFileSystemTest.testSstFileInCache Zakelly Lan (Jira)
• Re: [PR] [FLINK-37298] Added Pluggable Components for BatchStrategy & BufferWrapper in AsyncSinkWriter. [flink] via GitHub
  • Re: [PR] [FLINK-37298] Added Pluggable Components for BatchStrategy & BufferWrapper in AsyncSinkWriter. [flink] via GitHub
• [jira] [Resolved] (FLINK-37407) Add meta information to SQL state connector Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37632) Add ChangelogFunction interface Timo Walther (Jira)
• Re: [PR] [FLINK-37407][state] Add savepoint metadata SQL built-in process function [flink] via GitHub
• [jira] [Updated] (FLINK-37143) Update version of flink-connector-kafka to 4.0-SNAPSHOT Arvid Heise (Jira)
• Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
• [PR] [FLINK-36158][FOLLOWUP] Replace the ZK HA path from jobgraphs to execution-plans [flink] via GitHub
• [jira] [Commented] (FLINK-37553) Make ForStKeyedStateBackend consider namespaceSerializer compatibility when restoring state Zakelly Lan (Jira)
• [PR] [FLINK-37620][state/forst] ForSt Sync mode support remote storage [flink] via GitHub
• [jira] [Created] (FLINK-37633) Improved state management for temporal join operator Hugo Ricateau (Jira)
• [PR] [FLINK-33463][Connector/JDBC] Support the implementation of dynamic source tables based on the new source [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-33463][Connector/JDBC] Support the implementation of dynamic source tables based on the new source [flink-connector-jdbc] via GitHub
• [PR] [FLINK-37649][datagen] Datagen connector cannot set length for collection type [flink] via GitHub
  • Re: [PR] [FLINK-37649][datagen] Datagen connector cannot set length for collection type [flink] via GitHub
  • Re: [PR] [FLINK-37649][datagen] Datagen connector cannot set length for collection type [flink] via GitHub
  • Re: [PR] [FLINK-37649][datagen] Datagen connector cannot set length for collection type [flink] via GitHub
  • Re: [PR] [FLINK-37649][datagen] Datagen connector cannot set length for collection type [flink] via GitHub
  • Re: [PR] [FLINK-37649][datagen] Datagen connector cannot set length for collection type [flink] via GitHub
  • Re: [PR] [FLINK-37649][datagen] Datagen connector cannot set length for collection type [flink] via GitHub
• [jira] [Created] (FLINK-37651) Simplify StaticArgument builders for easier type inference Timo Walther (Jira)
• [PR] [FLINK-34820][mysql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
• [PR] Hive 4 support [flink-connector-hive] via GitHub
  • Re: [PR] Hive 4 support [flink-connector-hive] via GitHub
  • Re: [PR] Hive 4 support [flink-connector-hive] via GitHub
• [PR] [FLINK-35466][table] Implement star expansion in function calls in SE… [flink] via GitHub
  • Re: [PR] [FLINK-35466][table] Implement star expansion in function calls in SE… [flink] via GitHub
  • Re: [PR] [FLINK-35466][table] Implement star expansion in function calls in SE… [flink] via GitHub
  • Re: [PR] [FLINK-35466][table] Implement star expansion in function calls in SE… [flink] via GitHub
  • Re: [PR] [FLINK-35466][table] Implement star expansion in function calls in SE… [flink] via GitHub
  • Re: [PR] [FLINK-35466][table] Implement star expansion in function calls in SE… [flink] via GitHub
• [jira] [Updated] (FLINK-35466) Cannot pass all columns to SQL UDFs using `*` ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-37643) Support partial deletes when converting to external data structures ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-37104) Code simplification and cleaning related to Flink CDC YAML Transform ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-37104) Code simplification and cleaning related to Flink CDC YAML Transform Leonard Xu (Jira)
• Re: [PR] [FLINK-35137][Connectors/JDBC] Update website data for 3.2.0 [flink-connector-jdbc] via GitHub
• [jira] [Resolved] (FLINK-37642) Use the mailboxExecutor for operator in Async state processing Yanfei Lei (Jira)
• Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-37650) Enable Stale PR Github Action for Kafka Connector Thomas Cooper (Jira)
• [PR] Enable Stale PR Github action [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-35404] Report all metrics of KafkaConsumer in new Kafka source [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-35404] Report all metrics of KafkaConsumer in new Kafka source [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-XXXXX][Connectors/Kafka]bump kafka client version to 3.5.2 to use KIP-881 (client.rack) [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-XXXXX][Connectors/Kafka]bump kafka client version to 3.5.2 to use KIP-881 (client.rack) [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-XXXXX][Connectors/Kafka]bump kafka client version to 3.5.2 to use KIP-881 (client.rack) [flink-connector-kafka] via GitHub
• Re: [PR] Bump org.apache.kafka:kafka-clients from 3.4.0 to 3.7.1 [flink-connector-kafka] via GitHub
  • Re: [PR] Bump org.apache.kafka:kafka-clients from 3.4.0 to 3.7.1 [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-37648) Flink Kinesis connector lost track of 1 shard. roland (Jira)
• Re: [PR] [hotfix] sqlserver limit statement support [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix] sqlserver limit statement support [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix] sqlserver limit statement support [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix] sqlserver limit statement support [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix] sqlserver limit statement support [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix] sqlserver limit statement support [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix] sqlserver limit statement support [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix] sqlserver limit statement support [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix] sqlserver limit statement support [flink-connector-jdbc] via GitHub
• Re: [PR] [hotfix] Support dameng database [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix] Support dameng database [flink-connector-jdbc] via GitHub
• [jira] [Updated] (FLINK-37649) Datagen connector cannot set length for collection type Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-37649) Datagen connector cannot set length for collection type Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-37649) Datagen connector cannot set length for collection type ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-37649) Datagen connector cannot set length for collection type Weijie Guo (Jira)
• Re: [PR] [FLINK-36487] Remove deprecated method createTemporaryView StreamTableE… [flink] via GitHub
• [jira] [Resolved] (FLINK-37610) Running Over agg without OrderBy throws IndexOutOfBoundsException Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-37610) Running Over agg without OrderBy throws IndexOutOfBoundsException Sergey Nuyanzin (Jira)
• [jira] [Closed] (FLINK-37603) FLIP-502: QueryOperation SQL Serialization customization Dawid Wysakowicz (Jira)
• [PR] [FLINK-37643] Support partial deletes when converting to external data structures [flink] via GitHub
  • Re: [PR] [FLINK-37643] Support partial deletes when converting to external data structures [flink] via GitHub
  • Re: [PR] [FLINK-37643] Support partial deletes when converting to external data structures [flink] via GitHub
  • Re: [PR] [FLINK-37643] Support partial deletes when converting to external data structures [flink] via GitHub
  • Re: [PR] [FLINK-37643] Support partial deletes when converting to external data structures [flink] via GitHub
  • Re: [PR] [FLINK-37643] Support partial deletes when converting to external data structures [flink] via GitHub
  • Re: [PR] [FLINK-37643] Support partial deletes when converting to external data structures [flink] via GitHub
  • Re: [PR] [FLINK-37643] Support partial deletes when converting to external data structures [flink] via GitHub
• [jira] [Assigned] (FLINK-37642) Use the mailboxExecutor for operator in Async state processing Zakelly Lan (Jira)
• [PR] [FLINK-37642][runtime] Use the mailboxExecutor for operator in Async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37642][runtime] Use the mailboxExecutor for operator in Async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37642][runtime] Use the mailboxExecutor for operator in Async state processing [flink] via GitHub
• Re: [PR] [FLINK-26760][flink-csv] The new CSV source (file system source + CSV… [flink] via GitHub
• Re: [PR] FLINK-36479 remove deprecated method Table getSchema as [flink] via GitHub
• [jira] [Updated] (FLINK-37645) Improve existsUnboundedSource by avoiding duplicate check transformations ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-37647) Add support for NonTimeRowsUnboundedPrecedingFunction for OverAggregate ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-37647] Add NonTimeRowsUnboundedPrecedingFunction for OverAggregate [flink] via GitHub
• Re: [PR] [FLINK-37299][Connector/Pulsar] Flink stateless startup cannot contin… [flink-connector-pulsar] via GitHub
• Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
  • Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
  • [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
  • Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
  • Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
  • Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
  • Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
  • Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
  • Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
  • Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
  • Re: [PR] [postgres] fix when backfill will scan all table schame which match config [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37647) Add support for NonTimeRowsUnboundedPrecedingFunction for OverAggregate Bonnie Varghese (Jira)
• Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34820][postgressql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37646) flink jobmanager oom leishuiyu (Jira)
• Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] via GitHub

• Earlier messages
• Later messages