issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2025/03/04
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/04
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/04
[PR] [FLINK-37365][pyflink] Add API stability decorators for PyFlink APIs [flink]
via GitHub
2025/03/04
[jira] [Assigned] (FLINK-37420) AbstractAggregatingState add may return wrong result
Zakelly Lan (Jira)
2025/03/04
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/04
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/04
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/04
[jira] [Commented] (FLINK-35343) NullPointerException in SourceReaderBase
Nil Madhab (Jira)
2025/03/04
Re: [PR] [FLINK-36630][Connectors/Kafka] Wrap consumer.position in retryOnWakeup [flink-connector-kafka]
via GitHub
2025/03/04
Re: [PR] [FLINK-36630][Connectors/Kafka] Wrap consumer.position in retryOnWakeup [flink-connector-kafka]
via GitHub
2025/03/04
[jira] [Commented] (FLINK-27641) Create view lost Time attribute in Hive Catalog
Jira
2025/03/04
[jira] [Comment Edited] (FLINK-35145) Add timeout for cluster termination
Nishita Pattanayak (Jira)
2025/03/04
[jira] [Comment Edited] (FLINK-35145) Add timeout for cluster termination
Nishita Pattanayak (Jira)
2025/03/04
[jira] [Commented] (FLINK-35145) Add timeout for cluster termination
Nishita Pattanayak (Jira)
2025/03/04
Re: [PR] [FLINK-37420] fix AbstractAggregatingState add may return wrong result [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/04
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/04
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/04
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/04
Re: [PR] Draft PR for plugin based approach for evaluation hook for scaling metric evaluation [flink-kubernetes-operator]
via GitHub
2025/03/04
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/04
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/04
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/04
[jira] [Commented] (FLINK-8929) "UnknownTaskExecutorException: No TaskExecutor registered" when having tab open for taskmanager that does not exist (anymore)
Seung Eun Choi (Jira)
2025/03/04
Re: [PR] [FLINK-36172][metrics][rest] Optimize transient metric cleanup [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37420] fix AbstractAggregatingState add may return wrong result [flink]
via GitHub
2025/03/04
Re: [PR] [backport][FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter chill companion library which is abandoned. [flink]
via GitHub
2025/03/04
[PR] [FLINK-37420] fix AbstractAggregatingState add may return wrong result [flink]
via GitHub
2025/03/04
[jira] [Updated] (FLINK-37420) AbstractAggregatingState add may return wrong result
ASF GitHub Bot (Jira)
2025/03/04
[jira] [Created] (FLINK-37420) AbstractAggregatingState add may return wrong result
Yue Ma (Jira)
2025/03/04
[jira] [Closed] (FLINK-3154) Update Kryo version from 2.24.0 to latest Kryo LTS version
Gyula Fora (Jira)
2025/03/04
Re: [PR] [FLINK-37419] fix the problem that ForStMapState serializeValue may g… [flink]
via GitHub
2025/03/04
[jira] [Updated] (FLINK-37418) caugth array out of index exception while using RowData.getArray method
Spongebob (Jira)
2025/03/04
[jira] [Updated] (FLINK-37419) ForStMapState serializeValue may get wrong result
ASF GitHub Bot (Jira)
2025/03/04
[PR] [FLINK-37419] fix the problem that ForStMapState serializeValue may g… [flink]
via GitHub
2025/03/04
[jira] [Created] (FLINK-37419) ForStMapState serializeValue may get wrong result
Yue Ma (Jira)
2025/03/04
Re: [PR] [FLINK-34554] Introduce transaction strategies [flink-connector-kafka]
via GitHub
2025/03/04
[jira] [Created] (FLINK-37418) caugth array out of index exception while using RowData.getArray method
Spongebob (Jira)
2025/03/04
Re: [PR] Bump org.apache.zookeeper:zookeeper from 3.6.4 to 3.7.2 in /flink-shaded-zookeeper-parent/flink-shaded-zookeeper-36 [flink-shaded]
via GitHub
2025/03/04
Re: [PR] Bump org.apache.zookeeper:zookeeper from 3.6.4 to 3.7.2 in /flink-shaded-zookeeper-parent/flink-shaded-zookeeper-36 [flink-shaded]
via GitHub
2025/03/04
Re: [PR] Bump org.apache.zookeeper:zookeeper from 3.6.4 to 3.7.2 in /flink-shaded-zookeeper-parent/flink-shaded-zookeeper-36 [flink-shaded]
via GitHub
2025/03/04
Re: [PR] Bump org.apache.zookeeper:zookeeper from 3.5.10 to 3.7.2 in /flink-shaded-zookeeper-parent/flink-shaded-zookeeper-35 [flink-shaded]
via GitHub
2025/03/04
Re: [PR] Bump org.apache.zookeeper:zookeeper from 3.5.10 to 3.7.2 in /flink-shaded-zookeeper-parent/flink-shaded-zookeeper-35 [flink-shaded]
via GitHub
2025/03/04
Re: [PR] Bump org.apache.zookeeper:zookeeper from 3.5.10 to 3.7.2 in /flink-shaded-zookeeper-parent/flink-shaded-zookeeper-35 [flink-shaded]
via GitHub
2025/03/04
Re: [PR] [FLINK-34558][state] Support tracking state size [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations. [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations. [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations. [flink]
via GitHub
2025/03/04
[PR] Draft PR for plugin based approach for evalution hook for scaling metric evaluation [flink-kubernetes-operator]
via GitHub
2025/03/04
Re: [PR] [FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations. [flink]
via GitHub
2025/03/04
[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle
Zakelly Lan (Jira)
2025/03/04
[jira] [Resolved] (FLINK-33734) Merge unaligned checkpoint state handle
Zakelly Lan (Jira)
2025/03/04
[jira] [Commented] (FLINK-37379) Lack of state cache load for ForSt after recovery
Zakelly Lan (Jira)
2025/03/04
Re: [PR] [FLINK-33734] Merge unaligned checkpoint state handle [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations. [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations. [flink]
via GitHub
2025/03/04
[jira] [Created] (FLINK-37417) Implement better exception message to explain why KinesisSource doesn't support partial recovery
Hong Liang Teoh (Jira)
2025/03/04
Re: [PR] [FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations. [flink]
via GitHub
2025/03/04
[jira] [Commented] (FLINK-25986) Add FLIP-190 new API methods to python
Mika Naylor (Jira)
2025/03/04
Re: [PR] [FLINK-34554] Introduce transaction strategies [flink-connector-kafka]
via GitHub
2025/03/04
[jira] [Commented] (FLINK-36826) Default configurations fail to start Flink java 17 images
Fabian Paul (Jira)
2025/03/04
Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-33734] Merge unaligned checkpoint state handle [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-37162][hotfix][docs] Update some inaccurate descriptions. [flink]
via GitHub
2025/03/04
[jira] [Closed] (FLINK-21912) Introduce Schema and ResolvedSchema in Python API
Timo Walther (Jira)
2025/03/04
Re: [PR] [FLINK-21912][pyflink] Introduce ResolvedSchema in Python Table API [flink]
via GitHub
2025/03/04
Re: [PR] [BP-2.0][FLINK-37387][build] Enable license check for jdk17 and jdk21 [flink]
via GitHub
2025/03/04
[jira] [Updated] (FLINK-37416) DDB Streams connector flink state inconsistency issue
Abhi Gupta (Jira)
2025/03/04
Re: [PR] [backport][FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter chill companion library which is abandoned. [flink]
via GitHub
2025/03/04
[jira] [Created] (FLINK-37416) DDB Streams connector flink state inconsistency issue
Abhi Gupta (Jira)
2025/03/04
[PR] [hotfix] fix NOTICE file in order to fix java 11 license check [flink]
via GitHub
2025/03/04
Re: [PR] Bump io.netty:netty-common from 4.1.46.Final to 4.1.118.Final in /flink-end-to-end-tests/flink-end-to-end-tests-hive [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-30371] Fix the problem of JdbcOutputFormat database connection leak [flink-connector-jdbc]
via GitHub
2025/03/04
[PR] [backport][FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter chill companion library which is abandoned. [flink]
via GitHub
2025/03/04
Re: [PR] [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter … [flink]
via GitHub
2025/03/04
[jira] [Closed] (FLINK-36826) Default configurations fail to start Flink java 17 images
Fabian Paul (Jira)
2025/03/04
[jira] [Updated] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss
Weijie Guo (Jira)
2025/03/03
Re: [PR] [FLINK-37204] Add missing StarRocks connector options for 1.2.10. [flink-cdc]
via GitHub
2025/03/03
[PR] [hotfix][tests] Fix MySQL test case failure in exact UTC timezone [flink-cdc]
via GitHub
2025/03/03
Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc]
via GitHub
2025/03/03
[jira] [Updated] (FLINK-37414) Java heap space OOM in test_cron_azure core
Weijie Guo (Jira)
2025/03/03
[jira] [Commented] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry
Weijie Guo (Jira)
2025/03/03
Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc]
via GitHub
2025/03/03
Re: [PR] [hotfix] make SplitFetcherManager honor job configuration [flink-connector-aws]
via GitHub
2025/03/03
[PR] [hotfix] make SplitFetcherManager honor job configuration [flink-connector-aws]
via GitHub
2025/03/03
[jira] [Closed] (FLINK-37038) [Release-2.0] Cross team testing
Xintong Song (Jira)
2025/03/03
[jira] [Created] (FLINK-37415) [Release-2.0] Prepare RC1 release
Xintong Song (Jira)
2025/03/03
[jira] [Closed] (FLINK-37035) [Release-2.0] Create a release branch
Xintong Song (Jira)
2025/03/03
[jira] [Closed] (FLINK-37036) [Release-2.0] Prepare RC0 release
Xintong Song (Jira)
2025/03/03
[jira] [Updated] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry
Weijie Guo (Jira)
2025/03/03
[jira] [Closed] (FLINK-37034) [Release-2.0] Select executing Release Manager
Xintong Song (Jira)
2025/03/03
[jira] [Updated] (FLINK-3154) Update Kryo version from 2.24.0 to latest Kryo LTS version
Xintong Song (Jira)
2025/03/03
[jira] [Updated] (FLINK-3154) Update Kryo version from 2.24.0 to latest Kryo LTS version
Xintong Song (Jira)
2025/03/03
[jira] [Commented] (FLINK-37414) Java heap space OOM in test_cron_azure core
Weijie Guo (Jira)
2025/03/03
[jira] [Updated] (FLINK-37379) Lack of state cache load for ForSt after recovery
Xintong Song (Jira)
2025/03/03
[jira] [Closed] (FLINK-36437) Hive connector failed to compile with JDK 11
Weijie Guo (Jira)
2025/03/03
[jira] [Updated] (FLINK-36437) Hive connector failed to compile with JDK 11
Weijie Guo (Jira)
2025/03/03
[jira] [Updated] (FLINK-37414) Java heap space OOM in test_cron_azure core
Weijie Guo (Jira)
2025/03/03
[jira] [Updated] (FLINK-37414) Java heap space OOM in test_cron_azure core
Weijie Guo (Jira)
2025/03/03
[jira] [Created] (FLINK-37414) Java heap space OOM in test_cron_azure core
Weijie Guo (Jira)
2025/03/03
[jira] [Updated] (FLINK-37414) Java heap space OOM in test_cron_azure core
Weijie Guo (Jira)
2025/03/03
[jira] [Closed] (FLINK-37043) [Umbrella] Test Flink Release 2.0
Xintong Song (Jira)
2025/03/03
Re: [PR] [FLINK-35810] Fix AsyncWaitOperatorTest missing endInput bug [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink]
via GitHub
2025/03/03
[PR] [FLINK-35810] Fix AsyncWaitOperatorTest missing endInput bug [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter … [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter … [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter … [flink]
via GitHub
2025/03/03
[jira] [Commented] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry
Yunfeng Zhou (Jira)
2025/03/03
[jira] [Assigned] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry
Weijie Guo (Jira)
2025/03/03
Re: [PR] [FLINK-35810] Fix AsyncWaitOperatorTest missing endInput bug [flink]
via GitHub
2025/03/03
[PR] [FLINK-35810] Fix AsyncWaitOperatorTest missing endInput bug [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc]
via GitHub
2025/03/03
Re: [PR] [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-34558][state] Support tracking state size [flink]
via GitHub
2025/03/03
[PR] Add Flink 2.0.0 release [flink-web]
via GitHub
2025/03/03
Re: [PR] [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload [flink]
via GitHub
2025/03/03
Re: [PR] [hotfix][tests] Use Junit5 import in FileSinkTest. [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter … [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter … [flink]
via GitHub
2025/03/03
[jira] [Commented] (FLINK-37412) Add slot allocation strategy to for selecting TMs first that have already slots assigned
Liu (Jira)
2025/03/03
[jira] [Updated] (FLINK-37410) [FLIP-513] Split-level Watermark Metrics
Piotr Nowojski (Jira)
2025/03/03
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/03
[jira] [Assigned] (FLINK-37407) Add meta information to SQL state connector
Gabor Somogyi (Jira)
2025/03/03
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] [cdc-connector][sqlserver]Flink cdc pipeline support sqlserver source [flink-cdc]
via GitHub
2025/03/03
Re: [PR] SQL Server CDC support - fixing the issues in the outstanding pull request by another author [flink-cdc]
via GitHub
2025/03/03
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/03
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/03
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/03
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/03
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/03
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/03
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/03
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/03
Re: [PR] [FLINK-36855] Source API implementation [flink-connector-kudu]
via GitHub
2025/03/03
[jira] [Assigned] (FLINK-37410) Split-level Watermark Metrics
Piotr Nowojski (Jira)
2025/03/03
[jira] [Updated] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API
Piotr Nowojski (Jira)
2025/03/03
Re: [PR] Kubernetes Operator 1.11.0 release [flink-web]
via GitHub
2025/03/03
Re: [PR] [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 [flink]
via GitHub
2025/03/03
[jira] [Closed] (FLINK-37402) SQL testing sources produce incorrect watermarks
Timo Walther (Jira)
2025/03/03
Re: [PR] [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-37402][table] Emit watermarks after record in TestSourceFunction and TestValuesRuntimeFunctions [flink]
via GitHub
2025/03/03
[jira] [Commented] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API
Piotr Nowojski (Jira)
2025/03/03
[jira] [Assigned] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API
Piotr Nowojski (Jira)
2025/03/03
[jira] [Created] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API
Piotr Nowojski (Jira)
2025/03/03
Re: [PR] [hotfix][tests] Use Junit5 import. [flink]
via GitHub
2025/03/03
Re: [PR] [hotfix][tests] Use Junit5 import. [flink]
via GitHub
2025/03/03
[jira] [Commented] (FLINK-36673) Operator is not properly handling failed deployments without savepoints
Gyula Fora (Jira)
2025/03/03
Re: [PR] [FLINK-37005][table] Make StreamExecDeduplicate ouput insert only where possible [flink]
via GitHub
2025/03/03
[jira] [Closed] (FLINK-36673) Operator is not properly handling failed deployments without savepoints
Gyula Fora (Jira)
2025/03/03
Re: [PR] [FLINK-37203] Alter table comment or column comment [flink-cdc]
via GitHub
2025/03/03
[jira] [Commented] (FLINK-37411) Introduce the rollback mechanism for Autoscaler
Gyula Fora (Jira)
2025/03/03
Re: [PR] [FLINK-37380] Change TransactionalIdPrefix to a required option if Exactly once [flink-connector-kafka]
via GitHub
2025/03/03
Re: [PR] [FLINK-37352] Write full changelog to PaimonSink. [flink-cdc]
via GitHub
2025/03/03
[jira] [Updated] (FLINK-37352) Write full changelog to Paimon Sink.
ASF GitHub Bot (Jira)
2025/03/03
[jira] [Created] (FLINK-37412) Add slot allocation strategy to for selecting TMs first that have already slots assigned
Matthias Pohl (Jira)
2025/03/03
[jira] [Closed] (FLINK-37005) Make StreamExecDeduplicate ouput insert only where possible
Piotr Nowojski (Jira)
2025/03/03
Re: [PR] [FLINK-37005][table] Make StreamExecDeduplicate ouput insert only where possible [flink]
via GitHub
2025/03/03
[jira] [Created] (FLINK-37411) Introduce the rollback mechanism for Autoscaler
Rui Fan (Jira)
2025/03/03
Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws]
via GitHub
2025/03/03
[PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] Update table_api.md with modern Docker Compose syntax [flink]
via GitHub
2025/03/03
Re: [PR] Update table_api.md with modern Docker Compose syntax [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc]
via GitHub
2025/03/03
Re: [PR] [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter … [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-36827] CDC quickstart tidyup [flink-cdc]
via GitHub
2025/03/03
[jira] [Commented] (FLINK-37352) Write full changelog to Paimon Sink.
Yanquan Lv (Jira)
2025/03/03
Re: [PR] [FLINK-36827] CDC quickstart tidyup [flink-cdc]
via GitHub
2025/03/03
Re: [PR] a lame attempt to introduce cdc benchmark [flink-cdc]
via GitHub
2025/03/03
[PR] a lame attempt to introduce cdc benchmark [flink-cdc]
via GitHub
2025/03/03
Re: [PR] [FLINK-32097][Connectors/Kinesis] Implement support for Kinesis deaggregation [flink-connector-aws]
via GitHub
2025/03/03
Re: [PR] [FLINK-37402][table] Emit watermarks after record in TestSourceFunction and TestValuesRuntimeFunctions [flink]
via GitHub
2025/03/03
[jira] [Resolved] (FLINK-37387) License check behaves differently for different jdk versions
Sergey Nuyanzin (Jira)
2025/03/03
[jira] [Assigned] (FLINK-37387) License check behaves differently for different jdk versions
Sergey Nuyanzin (Jira)
2025/03/03
[jira] [Commented] (FLINK-37387) License check behaves differently for different jdk versions
Sergey Nuyanzin (Jira)
2025/03/03
Re: [PR] [FLINK-37387][build] Enable license check for jdk17 and jdk21 [flink]
via GitHub
2025/03/03
Re: [PR] [FLINK-36931][cdc] FlinkCDC YAML supports batch mode [flink-cdc]
via GitHub
2025/03/02
Re: [PR] [FLINK-36611][pipeline-connector][kafka] Add schema info to output of Kafka sink [flink-cdc]
via GitHub
2025/03/02
Re: [PR] [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload [flink]
via GitHub
2025/03/02
Re: [PR] [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload [flink]
via GitHub
2025/03/02
Re: [PR] Update table_api.md with modern Docker Compose syntax [flink]
via GitHub
2025/03/02
Re: [PR] [FLINK-37380] Change TransactionalIdPrefix to a required option if Exactly once [flink-connector-kafka]
via GitHub
Earlier messages
Later messages