dev  

Messages by Thread

• [jira] [Created] (FLINK-39483) Bump dependency check maven plugin Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39482) Support configurable maxConnections in S3ClientProvider Samrat Deb (Jira)
• [jira] [Created] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ featzhang (Jira)
• [jira] [Created] (FLINK-39480) Python wheel on MacOS fails for all 2.x branches Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39479) Add fromChangelog() to Python Table API Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39478) Newly-added tables become ghost tables after job restart during initial snapshot phase Vinay Sagar Gonabavi (Jira)
• [QUESTION] How to enable Azure nightly jobs for 1.20? Sergey Nuyanzin
• [VOTE] Release 1.20.4, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 1.20.4, release candidate #1 Ramin Gharib
  • Re: [VOTE] Release 1.20.4, release candidate #1 Ramin Gharib
• Azure CI needs update for release-2.3 David Anderson
• [jira] [Created] (FLINK-39477) Clarify how Flink accepts and supports AI-Assisted Contributions and AI Tooling Support Martijn Visser (Jira)
• [VOTE] FLIP-574 Metadata Filter Push-Down for Table Sources Jim Hughes via dev
  • Re: [VOTE] FLIP-574 Metadata Filter Push-Down for Table Sources Gustavo de Morais
  • Re: [VOTE] FLIP-574 Metadata Filter Push-Down for Table Sources Ramin Gharib
  • Re: [VOTE] FLIP-574 Metadata Filter Push-Down for Table Sources Leonard Xu
  • Re: [VOTE] FLIP-574 Metadata Filter Push-Down for Table Sources Timo Walther
  • Re: [VOTE] FLIP-574 Metadata Filter Push-Down for Table Sources Samrat Deb
  • Re: [VOTE] FLIP-574 Metadata Filter Push-Down for Table Sources Sergey Nuyanzin
• [jira] [Created] (FLINK-39476) Release Testing Instructions: FLIP-561: Restructure Flink documentation Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39475) Release Testing Instructions: FLINK-35661: MiniBatchGroupAggFunction can silently drop records under certain conditions Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39474) Release Testing Instructions: FLINK-37399: Watermark alignment can prevent backlogged jobs from using all available resources Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39473) Release Testing Instructions: FLIP-560: Application Capability Enhancement Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39472) Release Testing Instructions: FLIP-555: Native S3 FileSystem Samrat Deb (Jira)
• [jira] [Created] (FLINK-39471) Release Testing Instructions: FLIP-553: Robust OTel gRPC metric exporter Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39470) Release Testing Instructions: FLIP-549: Support Application Management Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39469) Release Testing Instructions: FLIP-547: Support checkpoint during recovery Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39468) Release Testing Instructions: FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39467) Release Testing Instructions: FLIP-495: Support AdaptiveScheduler record and store the rescale history Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39466) elease Testing Instructions: FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39465) Release Testing Instructions: FLIP-555: Flink Native S3 FileSystem Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39464) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39463) Release Testing Instructions: FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39462) Release Testing Instructions: FLIP-559: Add ARTIFACT keyword option in CREATE FUNCTION's USING clause Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39461) Release Testing Instructions: FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39460) Release Testing Instructions: FLIP-557: Granular Control over Data Reprocessing in Materialized Table Evolution Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39459) Release Testing Instructions: FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39458) Move DataStructureConverter into new flink-table-type-utils module Mika Naylor (Jira)
• [jira] [Created] (FLINK-39457) Upgrade version tag from '2.3-SNAPSHOT' to '2.4-SNAPSHOT' in docs/static/generated/rest_vX files to fix CI failure Yuepeng Pan (Jira)
• [DISCUSS] FLINK-39455: Add support for Java based AssociativeMergeOperator via JNI  Soumitra Kumar
  • Re: [DISCUSS] FLINK-39455: Add support for Java based AssociativeMergeOperator via JNI  Zakelly Lan
  • Re: [DISCUSS] FLINK-39455: Add support for Java based AssociativeMergeOperator via JNI  Soumitra Kumar
• [jira] [Created] (FLINK-39456) Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar (Jira)
• [jira] [Created] (FLINK-39455) Add support for Java based AssociativeMergeOperator via JNI Soumitra Kumar (Jira)
• [ANNOUNCE] Flink 2.3 Release Branch Cut David Anderson
• [jira] [Created] (FLINK-39454) [Umbrella] Test Flink Release 2.3 David Anderson (Jira)
• [jira] [Created] (FLINK-39453) [release-2.3] Add release notes David Anderson (Jira)
• [jira] [Created] (FLINK-39452) [release-2.3] Verify that no exclusions were erroneously added to the japicmp plugin David Anderson (Jira)
• [jira] [Created] (FLINK-39451) Review and update documentation David Anderson (Jira)
• [jira] [Created] (FLINK-39450) [release-2.3] Triage release blockers in JIRA David Anderson (Jira)
• [jira] [Created] (FLINK-39449) [release-2.3] Cross-team testing David Anderson (Jira)
• [jira] [Created] (FLINK-39448) Review release notes in JIRA David Anderson (Jira)
• [jira] [Created] (FLINK-39447) Prepare RC0 release David Anderson (Jira)
• [jira] [Created] (FLINK-39446) Create release branch David Anderson (Jira)
• [jira] [Created] (FLINK-39445) Select executing release manager David Anderson (Jira)
• [jira] [Created] (FLINK-39444) Create new version in Jira David Anderson (Jira)
• [jira] [Created] (FLINK-39443) Prepare Flink 2.3 release David Anderson (Jira)
• 取消订阅 Eleanore Jin
• [jira] [Created] (FLINK-39442) Add toChangelog() to Python Table API Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39441) Table configuration inside Flink config is not applying at runtime Nic Townsend (Jira)
• [VOTE] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization Jiangang Liu
• [jira] [Created] (FLINK-39440) Support Thorne (Jira)
• [jira] [Created] (FLINK-39439) Savepoint history entry removed from status before dispose succeeds Gabor Somogyi (Jira)
• [DISCUSS] FLIP-XXX: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
• [DISUCUSS] FLIP-XXX: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
• FLIP-XXX: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
• [jira] [Created] (FLINK-39438) Add configurable sink operation (upsert/append) for MaxCompute sink in Flink CDC Dion Ricky Saputra (Jira)
• [DISCUSS] FLINK-39404: HardwareDescription cpuCores - int to double breaking change Dennis-Mircea Ciupitu
• [jira] [Created] (FLINK-39437) Support interruptible timers in PTFs Timo Walther (Jira)
• [jira] [Created] (FLINK-39436) Allow late data to enter PTF Timo Walther (Jira)
• [jira] [Created] (FLINK-39435) [flink-connector-kafka] Switching Kafka topics via Savepoint restore causes dual-topic consumption AND new topic consumed from earliest instead of configured offset sherlock-lin (Jira)
• [jira] [Created] (FLINK-39434) Transform table-options changes are not propagated to existing downstream tables on savepoint restart Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-39433) Consolidate scattered Hive reflection calls into HiveShim for type safety Jayesh Lalwani (Jira)
• [DISCUSS] Hive 3.1 connector broken on Java 11+ (URLClassLoader cast in SessionState) Lalwani, Jayesh
  • Re: [DISCUSS] Hive 3.1 connector broken on Java 11+ (URLClassLoader cast in SessionState) Martijn Visser
  • Re: [DISCUSS] Hive 3.1 connector broken on Java 11+ (URLClassLoader cast in SessionState) Ferenc Csaky
  • Re: [DISCUSS] Hive 3.1 connector broken on Java 11+ (URLClassLoader cast in SessionState) Lalwani, Jayesh
  • Re: [DISCUSS] Hive 3.1 connector broken on Java 11+ (URLClassLoader cast in SessionState) Ferenc Csaky
• [RESULT][VOTE] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais
• [DISCUSS] FLIP-XXX: Scaling Executor Plugin SPI for Flink Autoscaler Dennis-Mircea Ciupitu
  • Re: [DISCUSS] FLIP-XXX: Scaling Executor Plugin SPI for Flink Autoscaler gyula . fora
• [DISCUSS] FLINK-39320: Include Kafka record metadata in deserialization error message Pritesh Gudge via dev
• [jira] [Created] (FLINK-39432) Add option to delete session with running session jobs Gyula Fora (Jira)
• [DISCUSS] JDBC Sink: reWriteBatchedInserts=true incompatible with INSERT … ON CONFLICT DO UPDATE when batch contains duplicate keys Christian Stein
• [jira] [Created] (FLINK-39431) The s3 connector is not able to be configured due to config name collision Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-39430) Add `invalid_op_handling` parameter to FROM_CHANGELOG PTF Ramin Gharib (Jira)
• [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases Sergey Nuyanzin
  • Re: [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases Gustavo de Morais
  • Re: [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases Rui Fan
  • Re: [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases Ferenc Csaky
  • Re: [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases weijie guo
  • Re: [DISCUSS] Flink 1.20.4, 2.0.2, 2.1.2, 2.2.1 releases Leonard Xu
• [jira] [Created] (FLINK-39429) NoClassDefFoundError for flink-shaded-guava31 in IncrementalSourceStreamFetcher (Flink 2.2 / CDC 3.6.0) Jira
• [jira] [Created] (FLINK-39428) MDC 对于有些线程池是缺失的 lizhiqiang (Jira)
• [jira] [Created] (FLINK-39427) Use Apache Parent POM 35 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39426) Flink 2.0 and Connector version compatibility issue Xueyan Wang (Jira)
• [jira] [Created] (FLINK-39425) [flink-metrics-otel] OpenTelemetryEventReporter ignores service.name and service.version config Sameer Devgan (Jira)
• [jira] [Created] (FLINK-39424) Setting LIKE does not support default escape characters. Qilong Wang (Jira)
• [DISCUSS] FLIP-573: Kafka Share Groups for Queue-Like Event Processing in Flink Connector Kafka Shekhar Rajak
  • Re: [DISCUSS] FLIP-573: Kafka Share Groups for Queue-Like Event Processing in Flink Connector Kafka Shekhar Rajak
• [jira] [Created] (FLINK-39423) Fix PseudoRandomValueSelector.randomize() producing identical values for all boolean config options Rui Fan (Jira)
• [jira] [Created] (FLINK-39422) [FLINK][OpenAPI] OpenApiSpecGenerator produces incorrect schemas for types with custom Jackson serializers Nikhil S (Jira)
• [DISCUSS] FLIP-574: Metadata Filter Push-Down for Table Sources Jim Hughes via dev
  • Re: [DISCUSS] FLIP-574: Metadata Filter Push-Down for Table Sources Timo Walther
  • Re: [DISCUSS] FLIP-574: Metadata Filter Push-Down for Table Sources Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-574: Metadata Filter Push-Down for Table Sources Timo Walther
  • Re: [DISCUSS] FLIP-574: Metadata Filter Push-Down for Table Sources Jim Hughes via dev
• [jira] [Created] (FLINK-39421) Metadata filter push-down for table sources Jim Hughes (Jira)
• [jira] [Created] (FLINK-39420) Temporal joins on non-lookup tables in batch mode produce a confusing internal error Jim Hughes (Jira)
• [jira] [Created] (FLINK-39419) Support TO_CHANGELOG: Any stream -> flat records with partial and full deletes (4.2.2.5, 4.2.2.6) Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39418) YAML pipeline supports decimal with 19+ precision and scale Xiqian Yu (Jira)
• [jira] [Created] (FLINK-39417) YAML Pipeline could not [de]serialize GenericRecordData Xiqian Yu (Jira)
• [jira] [Created] (FLINK-39416) Fix link address errors in documents peiyu (Jira)
• [jira] [Created] (FLINK-39415) [flink-cdc-postgres] TIMESTAMPTZ type mapping causes NumberFormatException in Pipeline connector with Iceberg sink Avichay Marciano (Jira)
• [DISCUSS][FLINK-35321] CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation - request for approval Piotr Rudnicki
• [jira] [Created] (FLINK-39414) TaskExecutorPartitionLifecycleTest#testEnableBatchJobRecoveryAnd* take long time to complete Matthias Pohl (Jira)
• [jira] [Created] (FLINK-39413) TaskExecutorSubmissionTest#testRemotePartitionNotFound needs 20s to finish Matthias Pohl (Jira)
• [jira] [Created] (FLINK-39412) AddColumnEvent fails with duplicate field names when schema change events are replayed after failover kianwee (Jira)
• [jira] [Created] (FLINK-39411) PTF code generation uses wrong type for table arguments — METADATA VIRTUAL columns inaccessible Natea Eshetu Beshada (Jira)
• [DISCUSS] Adding Apache Hive 4.x support to flink-connector-hive Lalwani, Jayesh
  • Re: [DISCUSS] Adding Apache Hive 4.x support to flink-connector-hive Lalwani, Jayesh
• [SUMMARY] Flink 2.3 release sync (Apr 7) David Anderson
• [jira] [Created] (FLINK-39410) The `flink-cdc-pipeline-connector-elasticsearch` module offers better compatibility with Flink 1.20 and Flink 2.x. peiyu (Jira)
• ???????? ????
• [jira] [Created] (FLINK-39409) Support tables without primary key for incremental snapshot Di Wu (Jira)
• [jira] [Created] (FLINK-39408) TestNameProvider broken after JUnit 5 migration Rui Fan (Jira)
• [jira] [Created] (FLINK-39407) CreateTableEvent failed in MySQL to Paimon pipeline Edward Zhang (Jira)
• 来自王珂的邮件 王珂
• [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Xintong Song
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Geng Biao
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Gustavo de Morais
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Weiqing Yang
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Yash Anand via dev
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Eugene
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Samrat Deb
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Amos Aidoo
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie 吴晓军
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Yuan Mei
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Hang Ruan
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Yanquan Lv
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Jiangang Liu
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Hongshun Wang
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie dylanhz
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Jacky Lau
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Yuepeng Pan
  • Re: [ANNOUNCE] New Apache Flink Committer - Wenjie Xie Ramin Gharib
• [jira] [Created] (FLINK-39406) Can not read partition table in oracle connector Jia Fan (Jira)
• [jira] [Created] (FLINK-39405) Fix default escape character document display errors Qilong Wang (Jira)
• [DISCUSS] FLIP-XXX: Support Window Stagger in FlinkSQL and introduce KEY_BASED deterministic stagger zihao chen
• [jira] [Created] (FLINK-39404) HardwareDescription reports incorrect CPU cores in containerized environments with fractional CPU limits Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39403) Postgres snapshotting phase might cause transaction leak Levani Kokhreidze (Jira)
• [jira] [Created] (FLINK-39402) Fix LIKE quick path ignoring default escape character '\' Qilong Wang (Jira)
• [jira] [Created] (FLINK-39401) [format] Extend Raw Format to Support Line Delimiter and Multi-Row Splitting featzhang (Jira)
• [jira] [Created] (FLINK-39400) Fix multiple documentation bugs in English and Chinese docs Aleksandr Savonin (Jira)
• [Discuss] FLIP-314: Behavioral Expectation of JobStatusChangedListener Instantiation in Application Mode Swapna Marru
• [jira] [Created] (FLINK-39399) Integer overflow in HyperLogLogPlusPlus.query() causes APPROX_COUNT_DISTINCT undercount at high cardinality Jim Hughes (Jira)
• [jira] [Created] (FLINK-39398) Handle duplicate key errors in MongoWriter bulk write retry loop Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39397) postgres pk table encounted an error when delete a record Tao Wang (Jira)
• [jira] [Created] (FLINK-39396) Simplify early return condition in SqlLikeChainChecker.check() Qilong Wang (Jira)
• [FLINK-31942] Looking for review — Conditional Writes in DynamoDB connector Tomasz Kaczmarek
• [jira] [Created] (FLINK-39395) Add spotless upToDateChecking Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39394) Job overview metrics (business/backpressure/data skew) are showing N/A when some nodes are finished Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-39393) Add StartMode tableChange Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39392) Support conditional traits for PTFs Gustavo de Morais (Jira)
• [ANNOUNCE] Apache Auron (Incubating) Flink kafka source is now available Mang Zhang
• [jira] [Created] (FLINK-39391) scan.snapshot.fetch.size is not propagated to Debezium properties in Oracle/SqlServer/DB2/Postgres connectors, causing severe snapshot performance degradation tianfy (Jira)
• [jira] [Created] (FLINK-39390) Add Extensibility to Autoscaler Components via the Plugin Mechanism Dennis-Mircea Ciupitu (Jira)
• HTTP connector David Radley
  • Re: HTTP connector Pedro Mázala
  • Re: HTTP connector David Anderson
  • Re: HTTP connector Pedro Mázala
  • RE: HTTP connector David Radley
  • RE: HTTP connector Ferenc Csaky
• [jira] [Created] (FLINK-39389) Investigate updating the Apache HTTP connector to support java 8. David Radley (Jira)
• [jira] [Created] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter featzhang (Jira)
• [jira] [Created] (FLINK-39387) Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation Liu (Jira)
• [jira] [Created] (FLINK-39386) For Flink 2.x+, support limit the rate at the source peiyu (Jira)
• [jira] [Created] (FLINK-39385) Timestampdiff for time fails with scala.MatchError: (TIME_WITHOUT_TIME_ZONE,TIME_WITHOUT_TIME_ZONE) (of class scala.Tuple2) Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed Chris MacGregor (Jira)
• [jira] [Created] (FLINK-39383) [Docs] Improve scan.incremental.snapshot.chunk.key-column documentation for MySQL/PostgreSQL/Oracle/DB2/SQLServer connectors ericzeng (Jira)
• [jira] [Created] (FLINK-39382) [Docs][Kafka] Clarify properties.auto.offset.reset support in SQL connector Kumar Mallikarjuna (Jira)
• [jira] [Created] (FLINK-39381) Add user facing documentation for ProcessTableFunctionTestHarness Mika Naylor (Jira)
• [jira] [Created] (FLINK-39380) Add support for test snapshotting/restoration to ProcessTableFunctionTestHarness Mika Naylor (Jira)
• [jira] [Created] (FLINK-39379) Add support for state in ProcessTableFunctionTestHarness Mika Naylor (Jira)
• [jira] [Created] (FLINK-39378) Add support for timers in ProcessTableFunctionTestHarness Mika Naylor (Jira)
• [jira] [Created] (FLINK-39377) Initial ProcessTableFunctionTestHarness implementation Mika Naylor (Jira)
• [jira] [Created] (FLINK-39376) Show TaskManager IP address in Checkpoint Subtask Statistics jingzi (Jira)
• [jira] [Created] (FLINK-39375) Add explicit serialVersionUID to WatermarkAlignmentParams Liu (Jira)
• [jira] [Created] (FLINK-39374) Rename KuduWriterConfig.maxBufferSize to maxMutationBufferOps Marton Greber (Jira)
• [jira] [Created] (FLINK-39373) An error occurred when modifying the default value of a column while executing the StarRocks Pipeline Sink operation Yanquan Lv (Jira)
• [jira] [Created] (FLINK-39372) Potential MySQL Binlog offset comparison failure after mysql-bin.999999 Xiqian Yu (Jira)
• [jira] [Created] (FLINK-39371) CurrentDatabase fails for some patterns Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39370) In-place scaling check only inspects K8s resource spec for adaptive scheduler, ignoring JM running configuration Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39369) ChangelogNormalize Operator In WAL Image Mode with Fluss Giannis Polyzos (Jira)
• [jira] [Created] (FLINK-39368) [connector-http] Add User-Agent configuration support for HTTP sink and lookup featzhang (Jira)
• [jira] [Created] (FLINK-39367) [connector-http] Add configurable error logging with detailed context featzhang (Jira)
• [jira] [Created] (FLINK-39366) [connector-http] Add retry support with exponential backoff for HTTP Sink featzhang (Jira)
• [jira] [Created] (FLINK-39365) [CONNECTOR-HTTP] 支持自定义 HTTP HEADERS VIA CONFIGOPTION featzhang (Jira)
• [jira] [Created] (FLINK-39364) [CONNECTOR-HTTP] Add request timeout as typed ConfigOption for HTTP lookup source and sink featzhang (Jira)

• Earlier messages