issues  

Messages by Thread

• Re: [PR] [FLINK-36742][cdc-base][oracle] Filter unacked split for no capture tables when task restore from state [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-37664) Integrate Kudu connector docs Ferenc Csaky (Jira)
• Re: [PR] [FLINK-35566] Promote TypeSerializer from PublicEvolving to Public [flink] via GitHub
• Re: [PR] [FLINK-33390][runtime] Support slot balancing at TM level for Adaptive Scheduler [flink] via GitHub
  • Re: [PR] [FLINK-33390][runtime] Support slot balancing at TM level for Adaptive Scheduler [flink] via GitHub
• [jira] [Commented] (FLINK-37594) Remove targetColumns in DynamicTableSink/Sink/SinkRuntimeProviderContext Atul Sharma (Jira)
• [jira] [Updated] (FLINK-37664) Integrate Kudu connector docs Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-37664) Intergra Kudu connector docs ASF GitHub Bot (Jira)
• [PR] [FLINK-37664][docs] Integrate Kudu connector docs [flink] via GitHub
  • Re: [PR] [1.19][FLINK-37664][docs] Integrate Kudu connector docs [flink] via GitHub
  • Re: [PR] [1.19][FLINK-37664][docs] Integrate Kudu connector docs [flink] via GitHub
  • Re: [PR] [1.19][FLINK-37664][docs] Integrate Kudu connector docs [flink] via GitHub
  • [PR] [FLINK-37664][docs] Integrate Kudu connector docs [flink] via GitHub
  • Re: [PR] [1.20][FLINK-37664][docs] Integrate Kudu connector docs [flink] via GitHub
  • Re: [PR] [1.20][FLINK-37664][docs] Integrate Kudu connector docs [flink] via GitHub
  • Re: [PR] [1.20][FLINK-37664][docs] Integrate Kudu connector docs [flink] via GitHub
• [jira] [Created] (FLINK-37664) Intergra Kudu connector docs Ferenc Csaky (Jira)
• [PR] [FLINK-37663] [connector-base] Address potential sync issue in FutureCompletingBlockingQueue wakeup [flink] via GitHub
  • Re: [PR] [FLINK-37663] [connector-base] Address potential sync issue in FutureCompletingBlockingQueue wakeup [flink] via GitHub
• [jira] [Updated] (FLINK-37663) Thread Synchronization Issue in FutureCompletingBlockingQueue <> Connector Split Fetching Herbert Wang (Jira)
  • [jira] [Updated] (FLINK-37663) Thread Synchronization Issue in FutureCompletingBlockingQueue <> Connector Split Fetching ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37663) Thread Synchronization Issue in FutureCompletingBlockingQueue <> Connector Split Fetching Herbert Wang (Jira)
• Re: [PR] [FLINK-35458][test][type] Add serializer upgrade test for set serializer [flink] via GitHub
• [jira] [Updated] (FLINK-37662) Allow configuration of init/side car containers Thomas Weise (Jira)
• [jira] [Updated] (FLINK-37660) Reenable Kryo serializer upgrade tests ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-37660] Reenable Kryo serializer upgrade tests [flink] via GitHub
• [jira] [Updated] (FLINK-37661) Remove Kryo serializer reference data from version 1.x ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-35458) Flink 2.1: Add serializer upgrade test for set serializer ASF GitHub Bot (Jira)
• [PR] [FLINK-37661] Remove Kryo serializer reference data from version 1.x [flink] via GitHub
  • Re: [PR] [FLINK-37661] Remove Kryo serializer reference data from version 1.x [flink] via GitHub
• [jira] [Created] (FLINK-37662) Allow configuration of side car containers Thomas Weise (Jira)
• [jira] [Created] (FLINK-37661) Remove Kryo serializer reference data from version 1.x Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-37660) Reenable Kryo serializer upgrade tests Zhanghao Chen (Jira)
• [PR] [FLINK-37659][release] Generate reference data for state migration tests based on release-2.0.0 [flink] via GitHub
  • Re: [PR] [FLINK-37659][release] Generate reference data for state migration tests based on release-2.0.0 [flink] via GitHub
• [jira] [Updated] (FLINK-37659) Flink 2.0: update reference data for Migration Tests Zhanghao Chen (Jira)
  • [jira] [Updated] (FLINK-37659) Flink 2.0: update reference data for Migration Tests Zhanghao Chen (Jira)
  • [jira] [Updated] (FLINK-37659) Flink 2.0: update reference data for Migration Tests Zhanghao Chen (Jira)
  • [jira] [Updated] (FLINK-37659) Flink 2.0: update reference data for Migration Tests Zhanghao Chen (Jira)
  • [jira] [Updated] (FLINK-37659) Flink 2.0: update reference data for Migration Tests ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37659) Flink 2.0: update reference data for Migration Tests Zhanghao Chen (Jira)
• [jira] [Updated] (FLINK-37657) Helm chart references invalid image repository ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37657) Helm chart references invalid image repository Nick Caballero (Jira)
• [jira] [Commented] (FLINK-37658) Improve the Datagen connector documentation david radley (Jira)
• [jira] [Updated] (FLINK-37658) Improve the Datagen connector documentation david radley (Jira)
• [PR] [FLINK-37657] Fix default image repository in Helm chart [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-37658) Improve the Datagen connector documentation david radley (Jira)
• [jira] [Updated] (FLINK-37656) Introduce FromValues in Python Table API Mika Naylor (Jira)
• [jira] [Created] (FLINK-37656) Introduce FromValues in Python Table API Mika Naylor (Jira)
• [jira] [Closed] (FLINK-37646) flink jobmanager oom leishuiyu (Jira)
• Re: [PR] [FLINK-37096][cdc-connect] fix The purpose of the issue is to change the value of the delay curve from 20098d to -1ms in the full phase. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37096][cdc-connect] fix The purpose of the issue is to change the value of the delay curve from 20098d to -1ms in the full phase. [flink-cdc] via GitHub
• Re: [PR] [FLINK-37481] Add new multi way join operator [flink] via GitHub
  • Re: [PR] [FLINK-37481] Add new multi way join operator [flink] via GitHub
  • Re: [PR] [FLINK-37481] Add new multi way join operator [flink] via GitHub
  • Re: [PR] [FLINK-37481] Add new multi way join operator [flink] via GitHub
  • Re: [PR] [FLINK-37481] Add new multi way join operator [flink] via GitHub
  • Re: [PR] [FLINK-37481] Add new multi way join operator [flink] via GitHub
  • Re: [PR] [FLINK-37481] Add new multi way join operator [flink] via GitHub
  • Re: [PR] [FLINK-37481] Add new multi way join operator [flink] via GitHub
  • Re: [PR] [FLINK-37481] Add new multi way join operator [flink] via GitHub
• [PR] [FLINK-37655][runtime] Convert WindowStagger into an interface for ea… [flink] via GitHub
  • Re: [PR] [FLINK-37655][runtime] Convert WindowStagger into an interface [flink] via GitHub
  • Re: [PR] [FLINK-37655][runtime] Convert WindowStagger into an interface [flink] via GitHub
  • Re: [PR] [FLINK-37655][runtime] Convert WindowStagger into an interface [flink] via GitHub
  • Re: [PR] [FLINK-37655][runtime] Convert WindowStagger into an interface [flink] via GitHub
• [jira] [Resolved] (FLINK-37644) flink-sql-connector-kafka leaks Guava dependency Arvid Heise (Jira)
• [jira] [Updated] (FLINK-37655) Convert WindowStagger into an interface for easy extensibility ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37655) Convert WindowStagger into an interface for easy extensibility Prashant Bhardwaj (Jira)
• [jira] [Commented] (FLINK-37554) Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend Yue Ma (Jira)
• [jira] [Updated] (FLINK-37554) Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend ASF GitHub Bot (Jira)
• [PR] [FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend [flink] via GitHub
  • Re: [PR] [FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend [flink] via GitHub
  • Re: [PR] [FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend [flink] via GitHub
  • Re: [PR] [FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend [flink] via GitHub
  • Re: [PR] [FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend [flink] via GitHub
  • Re: [PR] [FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend [flink] via GitHub
  • Re: [PR] [FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend [flink] via GitHub
  • Re: [PR] [FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend [flink] via GitHub
  • Re: [PR] [FLINK-37554] Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend [flink] via GitHub
• [jira] [Closed] (FLINK-37643) Support partial deletes when converting to external data structures Dawid Wysakowicz (Jira)
• [PR] [FLINK-37653] Refactor incremental snapshot framework to support multiple stream splits [flink-cdc] via GitHub
• [PR] [FLINK-37654][docs][pipeline-connector/doris] Enhance Doris Documentation with Configuration Details and Type Compatibility [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-37654) [docs]Enhance Doris Documentation with Configuration Details and Type Compatibility vinlee19 (Jira)
  • [jira] [Updated] (FLINK-37654) [docs]Enhance Doris Documentation with Configuration Details and Type Compatibility ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-37654) [docs]Enhance Doris Documentation with Configuration Details and Type Compatibility vinlee19 (Jira)
• [jira] [Created] (FLINK-37654) [docs]Enhance Apache Doris documentation with comprehensive loading configuration descriptions vinlee19 (Jira)
• Re: [PR] [FLINK-37383][flink-examples]Correct throttling logic on ThrottledIterator [flink] via GitHub
• [jira] [Commented] (FLINK-37644) flink-sql-connector-kafka leaks Guava dependency Arvid Heise (Jira)
  • [jira] [Commented] (FLINK-37644) flink-sql-connector-kafka leaks Guava dependency Arvid Heise (Jira)
  • [jira] [Commented] (FLINK-37644) flink-sql-connector-kafka leaks Guava dependency Arvid Heise (Jira)
• Re: [PR] [hotfix][docs] Fix Apache Avro Specification Link [flink] via GitHub
• Re: [PR] [FLINK-36992][table] Migrate SplitAggregateRule to java [flink] via GitHub
• Re: [PR] [FLINK-xx][table] Remove RelBuilder [flink] via GitHub
• [jira] [Assigned] (FLINK-37644) flink-sql-connector-kafka leaks Guava dependency Arvid Heise (Jira)
• [jira] [Updated] (FLINK-37644) flink-sql-connector-kafka leaks Guava dependency Arvid Heise (Jira)
  • [jira] [Updated] (FLINK-37644) flink-sql-connector-kafka leaks Guava dependency Arvid Heise (Jira)
• Re: [PR] [FLINK-37644] Straighten dependencies [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss ASF GitHub Bot (Jira)
• [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] via GitHub
• [jira] [Commented] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE Hongshun Wang (Jira)
• [jira] [Updated] (FLINK-37653) Incremental snapshot framework supports assigning multiple StreamSplit yux (Jira)
  • [jira] [Updated] (FLINK-37653) Incremental snapshot framework supports assigning multiple StreamSplit ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-37652) [Connectors/Opensearch] Move to Flink to 2.0.0 Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-37653) Incremental snapshot framework supports assigning multiple StreamSplit Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-37623) Async state support for `process()` in Datastream API Yanfei Lei (Jira)
• [jira] [Created] (FLINK-37653) Incremental snapshot framework supports assigning multiple StreamSplit yux (Jira)
• [jira] [Commented] (FLINK-37652) [Connectors/Opensearch] Move to Flink to 2.0.0 Andriy Redko (Jira)
  • [jira] [Commented] (FLINK-37652) [Connectors/Opensearch] Move to Flink to 2.0.0 Sergey Nuyanzin (Jira)
• Re: [PR] [hotfix][doc] Fix typo in 'Full Window Partition Processing on DataStream' example code [flink] via GitHub
• [jira] [Updated] (FLINK-37652) [Connectors/Opensearch] Move to Flink to 2.0.0 Andriy Redko (Jira)
  • [jira] [Updated] (FLINK-37652) [Connectors/Opensearch] Move to Flink to 2.0.0 ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37652) [Connectors/Opensearch] Move to Flink to 2.0.0 Andriy Redko (Jira)
• Re: [PR] [BP-1.19][FLINK-35241][table]Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ [flink] via GitHub
• [jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks Ruan Hang (Jira)
• Re: [PR] Fix flaky tests in classes PartitionableSourceTest and PushPartitionIntoTableSourceScanRuleTest [flink] via GitHub
• Re: [PR] Test [flink] via GitHub
• [jira] [Updated] (FLINK-36516) Migrate deprecated SinkV2 API to new API introduced in FLIP-372 Arvid Heise (Jira)
• [jira] [Updated] (FLINK-37625) PyFlink Table API skips validation for Rows created with positional arguments ASF GitHub Bot (Jira)
• [jira] [Closed] (FLINK-37407) Add meta information to SQL state connector Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37642) Use the mailboxExecutor for operator in Async state processing Zakelly Lan (Jira)
• Re: [PR] [FLINK-36061][iceberg] Add Iceberg Sink. [flink-cdc] via GitHub
• Re: [PR] [FLINK-36679][runtime] Add a metric to track checkpoint _metadata size [flink] via GitHub
• [jira] [Updated] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc Ruan Hang (Jira)
• [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
• [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
• [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
• [jira] [Closed] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ RocMarshal (Jira)
• [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
• [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] 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] [Commented] (FLINK-37626) Flaky test: ForStFlinkFileSystemTest.testSstFileInCache Zakelly Lan (Jira)
• [jira] [Resolved] (FLINK-37407) Add meta information to SQL state connector Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37632) Add ChangelogFunction interface Timo Walther (Jira)
• [PR] [FLINK-36158][FOLLOWUP] Replace the ZK HA path from jobgraphs to execution-plans [flink] via GitHub
  • Re: [PR] [FLINK-36158][FOLLOWUP] Replace the ZK HA path from jobgraphs to execution-plans [flink] via GitHub
  • Re: [PR] [FLINK-36158][FOLLOWUP] Replace the ZK HA path from jobgraphs to execution-plans [flink] via GitHub
• [PR] [FLINK-37620][state/forst] ForSt Sync mode support remote storage [flink] via GitHub
  • Re: [PR] [FLINK-37620][state/forst] ForSt Sync mode support remote storage [flink] via GitHub
  • Re: [PR] [FLINK-37620][state/forst] ForSt Sync mode support remote storage [flink] via GitHub
  • Re: [PR] [FLINK-37620][state/forst] ForSt Sync mode support remote storage [flink] via GitHub
  • Re: [PR] [FLINK-37620][state/forst] ForSt Sync mode support remote storage [flink] via GitHub
  • Re: [PR] [FLINK-37620][state/forst] ForSt Sync mode support remote storage [flink] via GitHub
  • Re: [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
• [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
• [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)
• 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)
• [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
• [jira] [Created] (FLINK-37648) Flink Kinesis connector lost track of 1 shard. roland (Jira)
• 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)

• Earlier messages