issues  

Messages by Date

• 2025/01/14 Re: [PR] [FLINK-8483][DataStream] Implement and expose outer joins [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-8482][DataStream] Allow users to choose from different timestamp strategies for interval join [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-9598] Refine java-doc about the min pause between checkpoints [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-10037] [Documentation] Add Event Time Details documentation page [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-9907] [table] Add CRC32 support [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-7050][table] Add support of RFC compliant CSV parser for Table Source [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-9931][ui] watermark display bug. [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-8302] [table] Add SHIFT_LEFT and SHIFT_RIGHT [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-9407] [hdfs connector] Support orc rolling sink writer [flink] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-9078) End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed ASF GitHub Bot (Jira)
• 2025/01/14 Re: [PR] [FLINK-9675] [fs] Avoid FileInputStream/FileOutputStream [flink] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-5944) Flink should support reading Snappy Files ASF GitHub Bot (Jira)
• 2025/01/14 [jira] [Updated] (FLINK-6345) Migrate from Java serialization for ContinuousFileReaderOperator's state ASF GitHub Bot (Jira)
• 2025/01/14 Re: [PR] [FLINK-5944] Support reading of Snappy files [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-9078][E2ETests] Add test that verifies correct avro behaviour [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-8297] [flink-rocksdb] Optionally store elements of ListState as multiple key-values in rocksdb [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-7009] dogstatsd mode in statds reporter [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-6345] [Streaming] Migrate from Java serialization for Continuo… [flink] via GitHub
• 2025/01/14 Re: [PR] [Flink-6072] TestCase CheckpointStateRestoreTest::testSetState should be fail [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-37121][docs] Fix syntax and examples in create table statement doc [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-37098] Fix selecting time attribute from a view [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36503][table] Remove deprecated method FunctionDefinitionFactory#createFunctionDefinition [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink] via GitHub
• 2025/01/14 [jira] [Closed] (FLINK-36707) Integrate PTF TypeInference into Calcite validator Timo Walther (Jira)
• 2025/01/14 [jira] [Commented] (FLINK-36707) Integrate PTF TypeInference into Calcite validator Timo Walther (Jira)
• 2025/01/14 Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
• 2025/01/14 [jira] [Commented] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1. ChaomingZhang (Jira)
• 2025/01/14 [jira] [Assigned] (FLINK-37093) The catalog that failed validation due to no type still exists in catalogStoreHolder Leonard Xu (Jira)
• 2025/01/14 [jira] [Assigned] (FLINK-37121) Wrong syntax and examples in create table statement doc Leonard Xu (Jira)
• 2025/01/14 [jira] [Commented] (FLINK-37121) Wrong syntax and examples in create table statement doc Mingcan Wang (Jira)
• 2025/01/14 Re: [PR] [FLINK-37112] Support Event Time Extension in DataStream V2 [flink] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-37121) Wrong syntax and examples in create table statement doc ASF GitHub Bot (Jira)
• 2025/01/14 [PR] [FLINK-37121][docs] Fix syntax and examples in create table statement doc [flink] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1. ChaomingZhang (Jira)
• 2025/01/14 [jira] [Created] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1. ChaomingZhang (Jira)
• 2025/01/14 Re: [PR] Fixed a typo in state_backends.md [flink] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-37121) Wrong syntax and examples in create table statement doc Mingcan Wang (Jira)
• 2025/01/14 [jira] [Created] (FLINK-37121) Fix syntax and examples in create table statement doc Mingcan Wang (Jira)
• 2025/01/14 Re: [PR] [FLINK-36794] [cdc-composer/cli] pipeline cdc connector support multiple data sources [flink-cdc] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-35634) Add a CDC quickstart utility Leonard Xu (Jira)
• 2025/01/14 [jira] [Resolved] (FLINK-35634) Add a CDC quickstart utility Leonard Xu (Jira)
• 2025/01/14 [jira] [Updated] (FLINK-35634) Add a CDC quickstart utility Leonard Xu (Jira)
• 2025/01/14 Re: [PR] [FLINK-35387][cdc-connector][postgres] PG CDC source support heart beat. [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] [FLINK-35634] Add CdcUp playground CLI scripts [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] [FLINK-37112] Support Event Time Extension in DataStream V2 [flink] via GitHub
• 2025/01/14 Re: [PR] Fixed the problem of using the same executor to process schema change requests and flush event requests, resulting in blocking timeout. [flink-cdc] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor. Leonard Xu (Jira)
• 2025/01/14 [jira] [Resolved] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor. Leonard Xu (Jira)
• 2025/01/14 Re: [PR] [FLINK-37011] Improve get source field value by column name in PreTransformProcessor. [flink-cdc] via GitHub
• 2025/01/14 [jira] [Comment Edited] (FLINK-37093) The catalog that failed validation due to no type still exists in catalogStoreHolder Mingcan Wang (Jira)
• 2025/01/14 Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
• 2025/01/14 [jira] [Closed] (FLINK-36629) Introducing the AdaptiveSkewedJoinOptimizationStrategy Zhu Zhu (Jira)
• 2025/01/14 Re: [PR] [FLINK-36629][table-planner] Introducing the AdaptiveSkewedJoinOptimizationStrategy [flink] via GitHub
• 2025/01/14 [jira] [Resolved] (FLINK-37026) Enable Stale PR Github Action Rui Fan (Jira)
• 2025/01/14 [jira] [Resolved] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig Zakelly Lan (Jira)
• 2025/01/14 [jira] [Commented] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig Zakelly Lan (Jira)
• 2025/01/14 Re: [PR] [FLINK-37115] Fix compile error related with SerializerConfig [flink-benchmarks] via GitHub
• 2025/01/14 Re: [PR] [FLINK-37026] Add Stale PR GitHub Action workflow [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-37026] Add Stale PR GitHub Action workflow [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36979][rpc] Reverting pekko version bump in Flink 1.20 [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-35282][python] Upgrade Apache Beam > 2.54 [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-37065]: MySQL cdc fix method 'fixRestoredGtidSet' to support gt… [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-37026] Add Stale PR GitHub Action workflow [flink] via GitHub
• 2025/01/14 [PR] Fixed the problem of using the same executor to process schema change requests and flush event requests, resulting in blocking timeout. [flink-cdc] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-36739) Update NodeJS to v22 (LTS) Alexander Fedulov (Jira)
• 2025/01/14 [jira] [Comment Edited] (FLINK-36739) Update NodeJS to v22 (LTS) Alexander Fedulov (Jira)
• 2025/01/14 [jira] [Comment Edited] (FLINK-36739) Update NodeJS to v22 (LTS) Alexander Fedulov (Jira)
• 2025/01/14 Re: [PR] [FLINK-36496][table] Remove deprecated method CatalogFunction#isGeneric [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36739] Update the NodeJS to v22.11.0 (LTS) [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
• 2025/01/14 [PR] [FLINK-36496][table] Remove deprecated method CatalogFunction#isGeneric [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36504][table]Remove all deprecated methods ModuleFactory [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36496][table]Remove deprecated method `CatalogFunction#isGeneric` [flink] via GitHub
• 2025/01/14 [jira] [Resolved] (FLINK-36700) Elasticsearch pipeline sink support authentication Leonard Xu (Jira)
• 2025/01/14 [jira] [Updated] (FLINK-36700) Elasticsearch pipeline sink support authentication ASF GitHub Bot (Jira)
• 2025/01/14 [jira] [Assigned] (FLINK-36700) Elasticsearch pipeline sink support authentication Leonard Xu (Jira)
• 2025/01/14 Re: [PR] [FLINK-36700][pipeline-connector][elasticsearch] Elasticsearch pipeline sink support authentication [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36974]support overwrite flink config by command line [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch pipeline sink support authentication [flink-cdc] via GitHub
• 2025/01/14 [jira] [Assigned] (FLINK-36193) Allow applying new SchemaChangeEvents to sink connectors Leonard Xu (Jira)
• 2025/01/14 [jira] [Updated] (FLINK-36193) Allow applying new SchemaChangeEvents to sink connectors Leonard Xu (Jira)
• 2025/01/14 [jira] [Resolved] (FLINK-36193) Allow applying new SchemaChangeEvents to sink connectors Leonard Xu (Jira)
• 2025/01/14 Re: [PR] [FLINK-36926][table] Introduce window join operator with async state api [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36193] Supports applying TRUNCATE / DROP table ddl... [flink-cdc] via GitHub
• 2025/01/14 [jira] [Resolved] (FLINK-36863) Use the maximum parallelism in the past scale-down.interval window when scaling down Rui Fan (Jira)
• 2025/01/14 [jira] [Updated] (FLINK-37110) When source generate metadata events in parallel for each table,There is a problem of timeout waiting for flush to complete. Jira
• 2025/01/14 Re: [PR] [FLINK-36863][autoscaler] Use the maximum parallelism in the past scale-down.interval window when scaling down [flink-kubernetes-operator] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36863][autoscaler] Use the maximum parallelism in the past scale-down.interval window when scaling down [flink-kubernetes-operator] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36979][rpc] Reverting pekko version bump in Flink 1.20 [flink] via GitHub
• 2025/01/14 [jira] [Reopened] (FLINK-37110) When the database and schema names of the regular expression are the same, the results of table selector filtering will be incorrect. Jira
• 2025/01/14 Re: [PR] [FLINK-37119] Bump the version of Paimon flink to 1.0.0. [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36967] [cdc-connector] [paimon] Bump dependency of Paimon Pipeline connector to 0.9.0 [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36967] [cdc-connector] [paimon] Bump dependency of Paimon Pipeline connector to 0.9.0 [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] Fixed a typo in state_backends.md [flink] via GitHub
• 2025/01/14 Re: [PR] [WIP] Introduce Join extension for DataStream V2 [flink] via GitHub
• 2025/01/14 [PR] Fixed a typo in state_backends.md [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36967] [cdc-connector] [paimon] Bump dependency of Paimon Pipeline connector to 0.9.0 [flink-cdc] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-37119) Bump the version of Paimon flink to 1.0.0 ASF GitHub Bot (Jira)
• 2025/01/14 [PR] [FLINK-37119] Bump the version of Paimon flink to 1.0.0. [flink-cdc] via GitHub
• 2025/01/14 Re: [PR] [FLINK-35014] SqlNode to operation conversion for models [flink] via GitHub
• 2025/01/14 [jira] [Commented] (FLINK-37119) Bump the version of Paimon flink to 1.0.0 Yanquan Lv (Jira)
• 2025/01/14 Re: [PR] [FLINK-35014] SqlNode to operation conversion for models [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-35014] SqlNode to operation conversion for models [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-35014] SqlNode to operation conversion for models [flink] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-37120) MySqlSnapshotSplitAssigner assign the ending chunk early to avoid TaskManager OOM JunboWang (Jira)
• 2025/01/14 [jira] [Assigned] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor. Leonard Xu (Jira)
• 2025/01/14 [jira] [Commented] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor. Leonard Xu (Jira)
• 2025/01/14 Re: [PR] [FLINK-36926][table] Introduce window join operator with async state api [flink] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig ASF GitHub Bot (Jira)
• 2025/01/14 [jira] [Updated] (FLINK-37120) MySqlSnapshotSplitAssigner assign the ending chunk early to avoid TaskManager OOM JunboWang (Jira)
• 2025/01/14 [jira] [Commented] (FLINK-36009) Architecture tests refactor Jira
• 2025/01/14 [jira] [Updated] (FLINK-37120) MySqlSnapshotSplitAssigner assign the ending chunk early to avoid TaskManager OOM JunboWang (Jira)
• 2025/01/14 [jira] [Updated] (FLINK-37120) MySqlSnapshotSplitAssigner assign the enging chunk early to avoid TaskManager OOM JunboWang (Jira)
• 2025/01/14 Re: [PR] [FLINK-36499][table]Remove deprecated method `SupportsProjectionPushDown#applyProjection` [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-37103] The parameters passed when calling method FactoryUtil.createDynamicTableSource are inconsistent [flink-connector-hive] via GitHub
• 2025/01/14 [jira] [Created] (FLINK-37120) MySqlSnapshotSplitAssigner assign the enging chunk early to avoid TaskManager OOM JunboWang (Jira)
• 2025/01/14 Re: [PR] [FLINK-36887][hive] Bumping to 1.20.0 [flink-connector-hive] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36831][table] Introduce AppendOnlyTopNFunction in Rank with Async State API [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36831][table] Introduce AppendOnlyTopNFunction in Rank with Async State API [flink] via GitHub
• 2025/01/14 [jira] [Created] (FLINK-37119) Bump the version of Paimon flink to 1.0.0 Yanquan Lv (Jira)
• 2025/01/14 Re: [PR] [FLINK-36499][table]Remove deprecated method `SupportsProjectionPushDown#applyProjection` [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-36503][table] Remove deprecated method FunctionDefinitionFactory#createFunctionDefinition [flink] via GitHub
• 2025/01/14 Re: [PR] [FLINK-35802][mysql] clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method. [flink-cdc] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-36503) Remove deprecated method `FunctionDefinitionFactory#createFunctionDefinition` ASF GitHub Bot (Jira)
• 2025/01/14 [jira] [Commented] (FLINK-36503) Remove deprecated method `FunctionDefinitionFactory#createFunctionDefinition` xuyang (Jira)
• 2025/01/14 [PR] [FLINK-36503][table] Remove deprecated method FunctionDefinitionFactory#createFunctionDefinition [flink] via GitHub
• 2025/01/14 [jira] [Created] (FLINK-37118) Enhance flink cdc metrics melin (Jira)
• 2025/01/14 [jira] [Created] (FLINK-37117) Add docs for async state SQL operator in 2.0 xuyang (Jira)
• 2025/01/14 Re: [PR] [FLINK-37112] Support Event Time Extension in DataStream V2 [flink] via GitHub
• 2025/01/14 [jira] [Updated] (FLINK-37117) Add docs for async state SQL operators in 2.0 xuyang (Jira)
• 2025/01/13 Re: [PR] [FLINK-35387][cdc-connector][postgres] PG CDC source support heart beat. [flink-cdc] via GitHub
• 2025/01/13 [jira] [Updated] (FLINK-37112) FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 ASF GitHub Bot (Jira)
• 2025/01/13 [PR] [FLINK-37112] Support Event Time Extension in DataStream V2 [flink] via GitHub
• 2025/01/13 [jira] [Commented] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor. ChaomingZhang (Jira)
• 2025/01/13 Re: [PR] [FLINK-36926][table] Introduce window join operator with async state api [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-35634] Add CdcUp playground CLI scripts [flink-cdc] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36754][transform] when projection is empty or null, it is treated as an asterisk [flink-cdc] via GitHub
• 2025/01/13 [jira] [Resolved] (FLINK-37042) Unify option names using kebab-case in MaxComputeDataSinkOptions Leonard Xu (Jira)
• 2025/01/13 Re: [PR] [FLINK-37042][maxcompute-pipeline-connector] Rename maxcompute pipieline connector options with kebab-case [flink-cdc] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36926][table] Introduce window join operator with async state api [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-37042][maxcompute-pipeline-connector] Rename maxcompute pipieline connector options with kebab-case [flink-cdc] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36926][table] Introduce window join operator with async state api [flink] via GitHub
• 2025/01/13 [jira] [Commented] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates Gabor Somogyi (Jira)
• 2025/01/13 Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
• 2025/01/13 [jira] [Assigned] (FLINK-37116) Add release notes for all breaking changes in 2.0.0 lincoln lee (Jira)
• 2025/01/13 [jira] [Created] (FLINK-37116) Add release notes for all breaking changes in 2.0.0 lincoln lee (Jira)
• 2025/01/13 Re: [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [1.19] [flink] via GitHub
• 2025/01/13 [jira] [Closed] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError" Arvid Heise (Jira)
• 2025/01/13 [jira] [Commented] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError" Arvid Heise (Jira)
• 2025/01/13 Re: [PR] [FLINK-36927][table] Introduce slicing & one stage Window Aggregate with Async State API [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [1.20] [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
• 2025/01/13 [jira] [Assigned] (FLINK-37114) Flink CDC Postgres Connector subsribe regular expression will be slow Leonard Xu (Jira)
• 2025/01/13 [jira] [Commented] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig Zakelly Lan (Jira)
• 2025/01/13 [jira] [Updated] (FLINK-37114) Flink CDC Postgres Connector subsribe regular expression will be slow Leonard Xu (Jira)
• 2025/01/13 [jira] [Updated] (FLINK-37114) Flink CDC Postgres Connector subsribe regular expression will be slow Leonard Xu (Jira)
• 2025/01/13 [jira] [Updated] (FLINK-37114) Flink CDC Postgres Connector subsribe regular expression will be slow Leonard Xu (Jira)
• 2025/01/13 [jira] [Assigned] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig Zakelly Lan (Jira)
• 2025/01/13 [jira] [Commented] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig Weijie Guo (Jira)
• 2025/01/13 [jira] [Assigned] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig Zakelly Lan (Jira)
• 2025/01/13 Re: [PR] [minor][doc] Fix link display. [flink] via GitHub
• 2025/01/13 [jira] [Created] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig Zakelly Lan (Jira)
• 2025/01/13 [jira] [Updated] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig Zakelly Lan (Jira)
• 2025/01/13 Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink] via GitHub
• 2025/01/13 [PR] [minor][doc] Fix link display. [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-35387][cdc-connector][postgres] PG CDC source support heart beat. [flink-cdc] via GitHub
• 2025/01/13 [jira] [Updated] (FLINK-37114) Flink CDC Postgres Connector subsribe regular expression will be slow hql0312 (Jira)
• 2025/01/13 Re: [PR] [hotfix][postgres] Flink CDC Postgres Connector subsribe regular expression [flink-cdc] via GitHub
• 2025/01/13 [jira] [Created] (FLINK-37114) Flink CDC Postgres Connector subsribe regular expression will be slow hql0312 (Jira)
• 2025/01/13 Re: [PR] [hotfix][postgres] Flink CDC Postgres Connector subsribe regular expression [flink-cdc] via GitHub
• 2025/01/13 [jira] [Updated] (FLINK-34124) Disable Kyro by default Weijie Guo (Jira)
• 2025/01/13 [jira] [Closed] (FLINK-34124) Disable Kyro by default Weijie Guo (Jira)
• 2025/01/13 [jira] [Updated] (FLINK-34124) Disable Kyro by default Weijie Guo (Jira)
• 2025/01/13 [jira] [Resolved] (FLINK-35068) Introduce built-in serialization support for Set Weijie Guo (Jira)
• 2025/01/13 [jira] [Commented] (FLINK-35068) Introduce built-in serialization support for Set Weijie Guo (Jira)
• 2025/01/13 Re: [PR] [FLINK-35802][mysql] clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method. [flink-cdc] via GitHub
• 2025/01/13 [jira] [Created] (FLINK-37113) Introduce document for datastream api v2 Weijie Guo (Jira)
• 2025/01/13 [jira] [Commented] (FLINK-36356) HadoopRecoverableWriterTest.testRecoverWithState due to IOException xuyang (Jira)
• 2025/01/13 Re: [PR] [FLINK-36926][table] Introduce window join operator with async state api [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36493][TABLE API] Remove all deprecated methods in MapView [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36492][TABLE API] Remove all deprecated methods in ListView [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink] via GitHub
• 2025/01/13 [PR] [hotfix][postgres] PostgresSourceFetchTaskContext log do not output P… [flink-cdc] via GitHub
• 2025/01/13 Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
• 2025/01/13 Re: [PR] [hotfix][postgres] Flink CDC Postgres Connector subsribe regular expr… [flink-cdc] via GitHub
• 2025/01/13 Re: [PR] [hotfix][postgres] Flink CDC Postgres Connector subsribe regular expr… [flink-cdc] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36497][table]Remove all deprecated methods `CatalogTable` [flink] via GitHub
• 2025/01/13 Re: [PR] [FLINK-36497][table]Remove all deprecated methods `CatalogTable` [flink] via GitHub

• Earlier messages
• Later messages