Messages by Date
-
2024/11/06
Re: [ANNOUNCE] Apache Flink 2.0 Preview released
Zakelly Lan
-
2024/11/06
Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode?
yuanfeng hu
-
2024/11/05
Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode?
Gyula Fóra
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Yuepeng Pan
-
2024/11/05
[DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode?
Yuepeng Pan
-
2024/11/05
Re: Flink Kubernetes operator
Gyula Fóra
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Xia Sun
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Zakelly Lan
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Feng Jin
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Rui Fan
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Guowei Ma
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Shengkai Fang
-
2024/11/05
Planned release dates for 1.19.2 and 1.20.1
Prasanna kumar
-
2024/11/05
Flink Kubernetes operator
santhosh venkat
-
2024/11/05
Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2
Hong Liang
-
2024/11/05
Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2
Danny Cranmer
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Lincoln Lee
-
2024/11/05
[jira] [Created] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL
lincoln lee (Jira)
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Zhanghao Chen
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Biao Geng
-
2024/11/05
Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li
Lijie Wang
-
2024/11/05
[ANNOUNCE] New Apache Flink Committer - Junrui Li
Zhu Zhu
-
2024/11/05
Re: [DISCUSS] Optimize the processing logic of TopNFunction to avoid the expiration of downstream operator states when state TTL is set
Feng Jin
-
2024/11/05
Re: [DISCUSS] AdaptiveScheduler slots assignment strategy optimization
Yuepeng Pan
-
2024/11/05
Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1
Lorenzo Nicora
-
2024/11/05
Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1
Yanquan Lv
-
2024/11/05
Re: Micro batching with flink
Arvid Heise
-
2024/11/05
Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2
Yanquan Lv
-
2024/11/04
[jira] [Created] (FLINK-36661) the managed memory setting is relatively small, resulting in duplicate processing results for batch tasks
Jira
-
2024/11/04
Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2
Hong Liang
-
2024/11/04
Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2
Yanquan Lv
-
2024/11/04
[jira] [Created] (FLINK-36660) Release flink-connector-elasticsearch vx.x.x for Flink 2.0
LvYanquan (Jira)
-
2024/11/04
Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1
Xintong Song
-
2024/11/04
Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2
Xintong Song
-
2024/11/04
[jira] [Created] (FLINK-36659) Release flink-connector-jdbc vx.x.x for Flink 2.0
LvYanquan (Jira)
-
2024/11/04
[jira] [Created] (FLINK-36658) Support and Release Connectors for Flink 2.0
LvYanquan (Jira)
-
2024/11/04
Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1
weijie guo
-
2024/11/04
Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2
weijie guo
-
2024/11/04
Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Shengkai Fang
-
2024/11/04
[DISCUSS] AdaptiveScheduler slots assignment strategy optimization
Yuepeng Pan
-
2024/11/04
Re: Kafka connector releases
Yanquan Lv
-
2024/11/04
Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Lincoln Lee
-
2024/11/04
Re: Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Shengkai Fang
-
2024/11/04
[VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1
Hong Liang
-
2024/11/04
[VOTE] Release flink-connector-aws v5.0.0, release candidate #2
Hong Liang
-
2024/11/04
Re: Micro batching with flink
Gabor Somogyi
-
2024/11/04
[jira] [Created] (FLINK-36657) Release Flink 1.20
Matyas Orhidi (Jira)
-
2024/11/04
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Fabian Hüske
-
2024/11/04
Flink technical debt.
David Radley
-
2024/11/04
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Timo Walther
-
2024/11/04
Re:Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Ferenc Csaky
-
2024/11/04
Re:[DISCUSS] Optimize the processing logic of TopNFunction to avoid the expiration of downstream operator states when state TTL is set
Xuyang
-
2024/11/04
[jira] [Created] (FLINK-36656) Flink CDC treats MySQL Sharding table with boolean type conversion error
Leonard Xu (Jira)
-
2024/11/04
[jira] [Created] (FLINK-36655) using flink state processor api to process big state in rocksdb is very slow
guanghua pi (Jira)
-
2024/11/04
Re:Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Xuyang
-
2024/11/04
[jira] [Created] (FLINK-36654) Decimal divide Integer reports Null pointer exception
Shuai Xu (Jira)
-
2024/11/03
[jira] [Created] (FLINK-36653) OnlineLogisticRegressionModel not updating servable and prediction result
Yunfeng Zhou (Jira)
-
2024/11/03
Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Shengkai Fang
-
2024/11/03
[jira] [Created] (FLINK-36652) Upgrade Apache ORC to 1.9.4
Yuchi Duan (Jira)
-
2024/11/02
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Shengkai Fang
-
2024/11/02
[jira] [Created] (FLINK-36651) Fix CI tests for ElasticSearch Connector
Ahmed Hamdy (Jira)
-
2024/11/01
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
David Anderson
-
2024/11/01
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Timo Walther
-
2024/11/01
[jira] [Created] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists
Jerome Gagnon (Jira)
-
2024/11/01
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
David Anderson
-
2024/11/01
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Timo Walther
-
2024/11/01
[jira] [Created] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed
Di Wu (Jira)
-
2024/10/31
Re:Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Xuyang
-
2024/10/31
[jira] [Created] (FLINK-36648) bump flink version to 2.0-preview1 for Kafka connector
LvYanquan (Jira)
-
2024/10/31
[jira] [Created] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform
Wenkai Qi (Jira)
-
2024/10/31
Re: JSON-Path CVEs
Sergey Nuyanzin
-
2024/10/31
[jira] [Created] (FLINK-36646) Support Java 17+ job images more conveniently in the operator
Rob Young (Jira)
-
2024/10/31
[jira] [Created] (FLINK-36645) Gracefully handle null execution plan from autoscaler
Sai Sharath Dandi (Jira)
-
2024/10/31
[jira] [Created] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability
Thomas Cooper (Jira)
-
2024/10/31
[jira] [Created] (FLINK-36644) TIMESTAMPDIFF can not be string serialized
Dawid Wysakowicz (Jira)
-
2024/10/31
[jira] [Created] (FLINK-36642) Table API expressions with several built-in functions are not correctly serialized to SQL
Fabian Hueske (Jira)
-
2024/10/31
JSON-Path CVEs
Tom Cooper
-
2024/10/31
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Timo Walther
-
2024/10/31
Re: [DISCUSS] Release HBase connector with partial JDK support
Leonard Xu
-
2024/10/31
[jira] [Created] (FLINK-36641) Support and Release Connectors for Flink 1.20
LvYanquan (Jira)
-
2024/10/31
[jira] [Created] (FLINK-36640) Provide an easy way to reset autoscaling
Matyas Orhidi (Jira)
-
2024/10/31
[jira] [Created] (FLINK-36639) Use table aliases in Table API asSerializableString
Dawid Wysakowicz (Jira)
-
2024/10/31
[jira] [Created] (FLINK-36638) Remove legacy bounded blocking shuffle
Weijie Guo (Jira)
-
2024/10/31
Re: [DISCUSS] Release HBase connector with partial JDK support
Yanquan Lv
-
2024/10/31
[jira] [Created] (FLINK-36637) Fix ListShards for Kinesis streams with large number of shards
Elphas Toringepi (Jira)
-
2024/10/31
Re:Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Xuyang
-
2024/10/31
[jira] [Created] (FLINK-36636) Timestamp data can not be compared in cdc pipeline transform
Wenkai Qi (Jira)
-
2024/10/31
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Junrui Lee
-
2024/10/30
*TemporarySystemFunction API without ignoreIfExists option
Venkatakrishnan Sowrirajan
-
2024/10/30
[jira] [Created] (FLINK-36635) PhysicalSlotRequestBulkImpl is not used and can be removed
Yi Zhang (Jira)
-
2024/10/30
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Shengkai Fang
-
2024/10/30
[jira] [Created] (FLINK-36634) Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime
xingbe (Jira)
-
2024/10/30
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Ron Liu
-
2024/10/30
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Shengkai Fang
-
2024/10/30
[jira] [Created] (FLINK-36633) Add support for Flink 1.20 in Flink OpenSearch connector
Andriy Redko (Jira)
-
2024/10/30
Re: [DISCUSS] FlinkCDC bump version to Flink 1.19
Leonard Xu
-
2024/10/30
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Timo Walther
-
2024/10/30
Re: [DISCUSS] FlinkCDC bump version to Flink 1.19
Yanquan Lv
-
2024/10/30
[jira] [Created] (FLINK-36632) When scan.startup.mode is not initial and restart with savepoint, newly add-table will not synchronize snapshot data
MOBIN (Jira)
-
2024/10/30
[jira] [Created] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN
Di Wu (Jira)
-
2024/10/30
[jira] [Created] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment
Alberto Lago (Jira)
-
2024/10/30
[jira] [Created] (FLINK-36629) Introducing the AdaptiveSkewedJoinOptimizationStrategy
Lei Yang (Jira)
-
2024/10/29
[jira] [Created] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP
Weijie Guo (Jira)
-
2024/10/29
Re: Micro batching with flink
Anil Dasari
-
2024/10/29
Re: Micro batching with flink
Venkatakrishnan Sowrirajan
-
2024/10/29
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Feng Jin
-
2024/10/29
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Ron Liu
-
2024/10/29
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Ron Liu
-
2024/10/29
[DISCUSS][FLINK-36547] Add option to retain `RowKind` sematics for cdc formats
Yubin Li
-
2024/10/29
[jira] [Created] (FLINK-36627) Failure to process a CSV file in Flink due to a character encoding mismatch: the file is in ISO-8859 and the application expects UTF-8.
Hector Miuler Malpica Gallegos (Jira)
-
2024/10/29
kafka-connector random WakeupException after enabling watermark alignment
Alberto Lago
-
2024/10/29
Micro batching with flink
Anil Dasari
-
2024/10/29
[jira] [Created] (FLINK-36626) Flink SQL JOINs behavior change from Flink 1.15 to Flink 1.18+
Eduardo Breijo (Jira)
-
2024/10/29
[jira] [Created] (FLINK-36625) Add helper classes for Lineage integration in connectors
Zhenqiu Huang (Jira)
-
2024/10/29
[ANNOUNCE] Apache Flink Kubernetes Operator 1.10.0 released
Őrhidi Mátyás
-
2024/10/29
[jira] [Created] (FLINK-36624) Log JobID in SourceCoordinator
Piotr Nowojski (Jira)
-
2024/10/29
Re: [DISCUSS] Release HBase connector with partial JDK support
Márton Balassi
-
2024/10/29
Re: [DISCUSS] Elasticsearch v3.1 release
Ahmed Hamdy
-
2024/10/29
[jira] [Created] (FLINK-36623) Improve logging in DefaultStateTransitionManager
Roman Khachatryan (Jira)
-
2024/10/29
[jira] [Created] (FLINK-36622) Remove the dependency of StateBenchmark on RocksDBKeyedStateBackend APIs.
Han Yin (Jira)
-
2024/10/29
[jira] [Created] (FLINK-36621) Build failure: StatefulSink not found
Piotr Nowojski (Jira)
-
2024/10/29
[jira] [Created] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats
zjjiang (Jira)
-
2024/10/29
[DISCUSS] Optimize the processing logic of TopNFunction to avoid the expiration of downstream operator states when state TTL is set
李阳
-
2024/10/28
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Shengkai Fang
-
2024/10/28
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Shengkai Fang
-
2024/10/28
[jira] [Created] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added
linqigeng (Jira)
-
2024/10/28
[jira] [Created] (FLINK-36618) Improve PostgresDialect.discoverDataCollections to reduce the start time of Postgres CDC
Hongshun Wang (Jira)
-
2024/10/28
[jira] [Created] (FLINK-36617) Migrate kryo package
Siddharth R (Jira)
-
2024/10/28
[jira] [Created] (FLINK-36616) Null pointer in PubSub's GcpPublisherConfig
Jira
-
2024/10/28
Re: [DISCUSS] Release HBase connector with partial JDK support
Ferenc Csaky
-
2024/10/28
[jira] [Created] (FLINK-36615) Support LEAD/LAG functions in Table API
Dawid Wysakowicz (Jira)
-
2024/10/28
[jira] [Created] (FLINK-36614) mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase
Youle (Jira)
-
2024/10/28
[jira] [Created] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP
Sergey Nuyanzin (Jira)
-
2024/10/28
[jira] [Created] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok
Hong Liang Teoh (Jira)
-
2024/10/28
[jira] [Created] (FLINK-36611) Add schema info to output of Kafka sink
LvYanquan (Jira)
-
2024/10/28
[jira] [Created] (FLINK-36610) MySQL CDC supports parsing gh-ost generated schema changes
yux (Jira)
-
2024/10/28
Re: [DISCUSS] FlinkCDC bump version to Flink 1.19
Hang Ruan
-
2024/10/28
Re: [DISCUSS] FlinkCDC bump version to Flink 1.19
Leonard Xu
-
2024/10/27
[jira] [Created] (FLINK-36609) Protobuf Format not support proto3
Hongshun Wang (Jira)
-
2024/10/27
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Hongshun Wang
-
2024/10/27
[jira] [Created] (FLINK-36608) Support dynamic StreamGraph optimization for AdaptiveBroadcastJoinOperator
xingbe (Jira)
-
2024/10/27
[jira] [Created] (FLINK-36607) Introduce AdaptiveBroadcastJoinProcessor to inject adaptive broadcast join
xingbe (Jira)
-
2024/10/27
[jira] [Created] (FLINK-36606) TimestampITCase generates test artifacts outside of tmp folder
Sergey Nuyanzin (Jira)
-
2024/10/26
Re: Slack access
Shengbo
-
2024/10/26
[jira] [Created] (FLINK-36605) Upgrade Debezium version to 2.7.x
Anil Dasari (Jira)
-
2024/10/25
[jira] [Created] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh
Mingliang Liu (Jira)
-
2024/10/25
[RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1
Őrhidi Mátyás
-
2024/10/25
Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1
Maximilian Michels
-
2024/10/25
[jira] [Created] (FLINK-36603) Inconsistent spelling of "behavior" across the API
Lorenzo Nicora (Jira)
-
2024/10/25
[jira] [Created] (FLINK-36602) Upgrade Calcite version to 1.38.0
Thomas Cooper (Jira)
-
2024/10/25
Re: [DISCUSS] FLIP-480: Support to deploy script in application mode
Feng Jin
-
2024/10/25
Re: [jira] [Created] (FLINK-36476) Remove all deprecated methods under public APIs in table modules
Shiwei Wang
-
2024/10/25
Re: Consequences of removing per-job mode in Flink 2.0
Ferenc Csaky
-
2024/10/25
Re: Consequences of removing per-job mode in Flink 2.0
weijie guo
-
2024/10/25
Re: Consequences of removing per-job mode in Flink 2.0
Shengkai Fang
-
2024/10/24
[jira] [Created] (FLINK-36601) Add JobID property to FlinkResultSet
Yi Cai (Jira)
-
2024/10/24
[jira] [Created] (FLINK-36600) Implement java.sql.Wrapper interface.
Yi Cai (Jira)
-
2024/10/24
[jira] [Created] (FLINK-36599) Correct the name of the config which enables response codes group
Alan Zhang (Jira)
-
2024/10/24
[jira] [Created] (FLINK-36598) [state/forst] Refactor initialization of ForSt db core
Zakelly Lan (Jira)
-
2024/10/24
[DISCUSS] FLIP-480: Support to deploy script in application mode
Shengkai Fang
-
2024/10/24
[jira] [Created] (FLINK-36597) Optimize SnapshotSplitAssigner error log output
MOBIN (Jira)
-
2024/10/24
[jira] [Created] (FLINK-36596) YAML Pipeline fails to schema change with no projection fields specified
yux (Jira)
-
2024/10/24
Re: [ANNOUNCE] Apache Flink 2.0 Preview released
weijie guo
-
2024/10/23
Backporting array_agg from 1.20 to 1.18
Hanyu (Peter) Zheng
-
2024/10/23
RE: https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw
Hanyu (Peter) Zheng
-
2024/10/23
[jira] [Created] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20
Aleksandr Pilipenko (Jira)
-
2024/10/23
https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw
Hanyu (Peter) Zheng
-
2024/10/23
Re: Backporting array_agg from 1.20 to 1.18
Hanyu (Peter) Zheng
-
2024/10/23
Re: Backporting array_agg from 1.20 to 1.18
Hanyu (Peter) Zheng
-
2024/10/23
Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1
Márton Balassi
-
2024/10/23
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Jim Hughes
-
2024/10/23
[jira] [Created] (FLINK-36594) HiveCatalog should set HiveConf.hiveSiteLocation back
slankka (Jira)
-
2024/10/23
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Konstantin Knauf
-
2024/10/23
Re: [DISCUSS] Release HBase connector with partial JDK support
Ferenc Csaky
-
2024/10/23
[jira] [Created] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE
Thomas Cooper (Jira)
-
2024/10/23
[ANNOUNCE] Apache Flink 2.0 Preview released
Xintong Song
-
2024/10/23
[jira] [Created] (FLINK-36592) Support file cache for ForStStateBackend
Yanfei Lei (Jira)
-
2024/10/23
[jira] [Created] (FLINK-36591) WikipediaEditsSourceTest fails in all cases
Martijn Visser (Jira)
-
2024/10/22
[jira] [Created] (FLINK-36590) Flink CDC does not Support MySQL > 8.0.x
yux (Jira)
-
2024/10/22
Re: [DISCUSS] Flink external connector bump version
Yanquan Lv
-
2024/10/22
[jira] [Created] (FLINK-36589) Decouple the initialization of sync and async keyed statebackend
Zakelly Lan (Jira)
-
2024/10/22
[jira] [Created] (FLINK-36588) flink catalog is supported in cdc yaml
ouyangwulin (Jira)
-
2024/10/22
Re: [DISCUSS] Release HBase connector with partial JDK support
Yanquan Lv
-
2024/10/22
Re: [DISCUSS] Release HBase connector with partial JDK support
Yanquan Lv
-
2024/10/22
[jira] [Created] (FLINK-36587) Postgres-cdc: Add support to override connector.class
Anil Dasari (Jira)
-
2024/10/22
[jira] [Created] (FLINK-36586) Upgrade Flink CDC dependency to Flink 1.19+
ZhengYu Chen (Jira)
-
2024/10/22
[jira] [Created] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop.
Jiangjie Qin (Jira)
-
2024/10/22
[jira] [Created] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots
Anil Dasari (Jira)
-
2024/10/22
[jira] [Created] (FLINK-36583) Add Slow Request Kube Client Metrics
Matyas Orhidi (Jira)
-
2024/10/22
[jira] [Created] (FLINK-36582) sql client hang when querying a parquet table
Lu Niu (Jira)
-
2024/10/22
Re: [DISCUSS] Release HBase connector with partial JDK support
Márton Balassi
-
2024/10/22
[DISCUSS] Release HBase connector with partial JDK support
Ferenc Csaky
-
2024/10/22
[jira] [Created] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters
LvYanquan (Jira)
-
2024/10/22
[jira] [Created] (FLINK-36580) Using debezium.column.exclude.list causes job failure
MOBIN (Jira)
-
2024/10/22
[jira] [Created] (FLINK-36579) mysql cdc charset collation sort not equals java string compare.
LIU (Jira)
-
2024/10/21
[RESULT][VOTE] FLIP-478: Introduce Config Option Scope
Junrui Lee
-
2024/10/21
[jira] [Created] (FLINK-36578) Fixed bug when converting json to string
Lee SeungMin (Jira)
-
2024/10/21
Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1
Mate Czagany
-
2024/10/21
Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)
Dawid Wysakowicz
-
2024/10/21
[jira] [Created] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD
Mate Czagany (Jira)