Messages by Thread
-
[jira] [Created] (FLINK-37463) Make ForStMapState Serializer ThreadLocal
Yue Ma (Jira)
-
[jira] [Created] (FLINK-37462) Unstable test case in FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-37461) Unstable test case in MySqlToPaimonE2eITCase#testSyncWholeDatabase
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-37444) Migrate ArrowSourceFunction to SourceV2
Poorvank Bhatia (Jira)
-
[jira] [Created] (FLINK-37429) Map each original column name to a new name and support column name containing '-'
Xiao Huang (Jira)
-
[jira] [Created] (FLINK-37448) status.taskManager.replicas to show actual TaskManager count
Robert Metzger (Jira)
-
[jira] [Created] (FLINK-37434) Incremental checkpoint not configurable for ForSt's sync mode
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-37428) Add JDK21 to Docker build matrix
Weijie Guo (Jira)
-
[jira] [Created] (FLINK-37446) Support asArgument in Table API
Timo Walther (Jira)
-
[jira] [Created] (FLINK-37447) [Flink CDC] Supports Variant type in YAML API
Leonard Xu (Jira)
-
[VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it
Dawid Wysakowicz
-
[jira] [Created] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException
Grzegorz Liter (Jira)
-
[VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)
Gyula Fóra
-
[jira] [Created] (FLINK-37455) Create error Event when job goes into FAILED state
Gyula Fora (Jira)
-
[jira] [Created] (FLINK-37459) Document correction - 1.9.0
Shalini M (Jira)
-
[jira] [Created] (FLINK-37457) Support asArgument in Python Table API
Timo Walther (Jira)
-
[jira] [Created] (FLINK-37456) Stream data for SQL state connector in case of List and Map state
Gabor Somogyi (Jira)
-
[jira] [Created] (FLINK-37454) Unit Tests (mongodb6) / compile_and_test (8, generic) is not stable
Leonard Xu (Jira)
-
[jira] [Created] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed
Leonard Xu (Jira)
-
[jira] [Created] (FLINK-37451) Document correction - 1.10.0
Shalini M (Jira)
-
[jira] [Created] (FLINK-37452) Add support for writing to Paimon Append only table.
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-37450) Document correction
Shalini M (Jira)
-
[VOTE] FLIP-509 Pluggable Batching For Async Sink
Poorvank Bhatia
-
[jira] [Created] (FLINK-37449) Postgres don't commit lsn when taskmanager failover
Xin Gong (Jira)
-
[RESULT][VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner
xiangyu feng
-
[jira] [Created] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API
Poorvank Bhatia (Jira)
-
[VOTE] Release 2.0.0, release candidate #2
Xintong Song
-
Re: [VOTE] Release 2.0.0, release candidate #2
Zakelly Lan
-
Re: [VOTE] Release 2.0.0, release candidate #2
weijie guo
-
Re: [VOTE] Release 2.0.0, release candidate #2
Yuepeng Pan
-
Re: [VOTE] Release 2.0.0, release candidate #2
Ferenc Csaky
-
Re: [VOTE] Release 2.0.0, release candidate #2
Jark Wu
-
Re: [VOTE] Release 2.0.0, release candidate #2
Dian Fu
-
Re: [VOTE] Release 2.0.0, release candidate #2
Lincoln Lee
-
Re: [VOTE] Release 2.0.0, release candidate #2
Leonard Xu
-
Re: [VOTE] Release 2.0.0, release candidate #2
Xiqian YU
-
Re: [VOTE] Release 2.0.0, release candidate #2
Xuannan Su
-
Re: [VOTE] Release 2.0.0, release candidate #2
Yuan Mei
-
Re: [VOTE] Release 2.0.0, release candidate #2
Yunfeng Zhou
-
Re: [VOTE] Release 2.0.0, release candidate #2
Xintong Song
-
Re: [VOTE] Release 2.0.0, release candidate #2
Yanquan Lv
-
[jira] [Created] (FLINK-37443) Add returns() method to DataStream V2 API for specifying output types with lambda expressions
Nil Madhab (Jira)
-
[DISCUSS] - Ongoing development of Flink Statefun
frans.king
-
[jira] [Created] (FLINK-37442) Properly delete the directories for ForSt remote storage
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-37441) Improve the code for TypeExtractor
Jiaan Geng (Jira)
-
[jira] [Created] (FLINK-37440) Fix the bug that parallelism.default do not always adopts 1 as the default value.
Jiaan Geng (Jira)
-
[jira] [Created] (FLINK-37439) Missing file creation with overwrite semantic in ForSt wrapped file system
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-37438) Improve the createLocalEnvironment by reduce duplicate create of Configuration
Jiaan Geng (Jira)
-
[DISCUSS] Optimizing metrics refresh: fetch metrics by name
Francesco D
-
[jira] [Created] (FLINK-37437) ForSt checkpoint failure due to file not visible when writing
Zakelly Lan (Jira)
-
2025/03/06 CHI Western time zone workgroup meeting minutes
David Radley
-
[jira] [Created] (FLINK-37436) flink-connector-pulsar used a incorrect API when dynamically creating topics by DynamicTopicRouter
Yubiao Feng (Jira)
-
[jira] [Created] (FLINK-37435) Kryo related perf regression since March 5th
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-37433) Schema Registry is busy now, waiting for next request...
vertern (Jira)
-
[jira] [Created] (FLINK-37432) Add release note for release 2.0
Weijie Guo (Jira)
-
upgrade DebeziumJsonDeserializationSchema
Semen Pavelko
-
[jira] [Created] (FLINK-37431) We should use guava Lists instead of curator shade Lists to avoid unnecessary error
zlzhang0122 (Jira)
-
[jira] [Created] (FLINK-37430) Operator hides the actual error on deployment issues
Gyula Fora (Jira)
-
[jira] [Created] (FLINK-37427) incorrect NPE message in StandaloneHaServices constructor
LuJiang (Jira)
-
[ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released
Gyula Fóra
-
[jira] [Created] (FLINK-37426) FLIP-481: Introduce Event Reporting
Piotr Nowojski (Jira)
-
[jira] [Created] (FLINK-37425) Sanity check before ForSt cache created
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-37424) Using JDK17 for the binary convenience release
Weijie Guo (Jira)
-
[jira] [Created] (FLINK-37423) Add support for PTFs in Table API
Timo Walther (Jira)
-
[SUMMARY] Flink 2.0 Release Sync 03/05/2025
Xintong Song
-
Question on usage of SQL Gateway with a remote Flink cluster
Ammu P
-
[jira] [Created] (FLINK-37422) Typo in streaming analytics zh document
ronghangye (Jira)
-
[jira] [Created] (FLINK-37421) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the deployment
Julian (Jira)
-
[jira] [Created] (FLINK-37420) AbstractAggregatingState add may return wrong result
Yue Ma (Jira)
-
[jira] [Created] (FLINK-37419) ForStMapState serializeValue may get wrong result
Yue Ma (Jira)
-
[jira] [Created] (FLINK-37418) caugth array out of index exception while using RowData.getArray method
Spongebob (Jira)
-
[jira] [Created] (FLINK-37417) Implement better exception message to explain why KinesisSource doesn't support partial recovery
Hong Liang Teoh (Jira)
-
[jira] [Created] (FLINK-37416) DDB Streams connector flink state inconsistency issue
Abhi Gupta (Jira)
-
[KINDLY REMINDER] Flink 2.0 Release Sync 03/05/2025
Xintong Song
-
[jira] [Created] (FLINK-37415) [Release-2.0] Prepare RC1 release
Xintong Song (Jira)
-
[jira] [Created] (FLINK-37414) Java heap space OOM in test_cron_azure core
Weijie Guo (Jira)
-
[jira] [Created] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API
Piotr Nowojski (Jira)
-
[RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.11.0, release candidate #1
Gyula Fóra
-
[jira] [Created] (FLINK-37412) Add slot allocation strategy to for selecting TMs first that have already slots assigned
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-37411) Introduce the rollback mechanism for Autoscaler
Rui Fan (Jira)
-
[DISCUSS] Split-level Watermark Metrics
אפרת לויטן
-
[jira] [Created] (FLINK-37410) Split-level Watermark Metrics
Efrat Levitan (Jira)
-
[jira] [Created] (FLINK-37409) Catch throwable in BinlogSplitReader to exit reading binlog when error occurs
Xiao Huang (Jira)
-
Flink vs beam-flink-runner benchmark
Taher Koitawala
-
[jira] [Created] (FLINK-37408) Update all docker-compose references to docker compose in documentation
Nil Madhab (Jira)
-
[DISCUSS] FLIP-512: Add meta information to SQL state connector
Gabor Somogyi
-
[jira] [Created] (FLINK-37407) Add meta information to SQL state connector
Gabor Somogyi (Jira)
-
Minutes of the 2025/02/27 CHI Eastern time zone workgroup meeting
David Radley
-
[DISCUSS] FLIP-511: Support transaction id pooling in Kafka connector
Arvid Heise
-
[jira] [Created] (FLINK-37406) Add support for structured YAML config in FlinkDeployment CRD
Gyula Fora (Jira)
-
[jira] [Created] (FLINK-37405) Perform upstream YAML config validation for Flink 2.x
Gyula Fora (Jira)
-
[jira] [Created] (FLINK-37404) Reenable Migration Tests for Filnk 2.x
Kurt Ostfeld (Jira)
-
[jira] [Created] (FLINK-37403) Support retractions/updates for IntervalJoin operator
Bonnie Varghese (Jira)
-
[jira] [Created] (FLINK-37402) SQL testing sources produce incorrect watermarks
Timo Walther (Jira)
-
[jira] [Created] (FLINK-37401) Add Job ID to logging context of slotmanager classes
Aleksandr Savonin (Jira)
-
[jira] [Created] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources
Piotr Nowojski (Jira)
-
[jira] [Created] (FLINK-37398) State processor API blows up with cryptic error when changelog used
Gabor Somogyi (Jira)
-
[jira] [Created] (FLINK-37397) Python wheel builds broken in nightly
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-37396) Kafka connector python test fail
Hongshun Wang (Jira)
-
[jira] [Created] (FLINK-37395) [BUG] When scan.startup.mode = latest-offset, an NullPointerException will be triggered
zexin gong (Jira)
-
[RESULT][VOTE] FLIP-491: BundledAggregateFunction for batched aggregation
Alan Sheinberg
-
[jira] [Created] (FLINK-37394) Update CI Flink versions to 1.19 and 1.20 in Kudu connector
Ferenc Csaky (Jira)
-
[jira] [Created] (FLINK-37393) Abnormally Long Checkpoint Duration After Full Checkpoint Completion
Rafael Zimmermann (Jira)
-
[jira] [Created] (FLINK-37392) Kubernetes Operator UpgradeFailureException: HA metadata not available to restore from last state
junzhong qin (Jira)
-
[jira] [Created] (FLINK-37391) Change watchNamespace config in operator is not respected while running
Fabian Paul (Jira)
-
[jira] [Created] (FLINK-37388) [BUG] Field names must be unique.
zexin gong (Jira)
-
[jira] [Created] (FLINK-37390) Push filter into ChangelogNormalize
Dawid Wysakowicz (Jira)
-
[jira] [Created] (FLINK-37389) Add "flink-sql-connector-kudu" module
Ferenc Csaky (Jira)
-
[SUMMARY] Flink 2.0 Release Sync 02/26/2025
Xintong Song
-
[jira] [Created] (FLINK-37387) License check behaves differently for different jdk versions
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-37386) Avoid sending too much CreateTableEvents when job failover
Yanquan Lv (Jira)
-
Kubernetes operator questions
santhosh venkat
-
[jira] [Created] (FLINK-37385) Add support for smile format in flink main repo
Sergey Nuyanzin (Jira)