dev  

Messages by Thread

• [jira] [Created] (FLINK-40111) Keyless upsert sink should fall back to retract when the input has no upsert key Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40112) Report a changelog mode mismatch instead of a generic planning error Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40110) Connectors/OpenSearch: Bump flink.version to 2.1.2 in flink-connector-opensearch Purushottam Sinha (Jira)
• [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Fabian Hueske
  • Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Timo Walther
  • Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Sergey Nuyanzin
  • Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input dylanhz
  • Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Fabian Hueske
  • Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input dylanhz
  • Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Gustavo de Morais
  • Re: [DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input Fabian Hueske
• [jira] [Created] (FLINK-40109) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab check runs before the YARN application is killed Martijn Visser (Jira)
• [jira] [Created] (FLINK-40108) Add Splitters for snapshot a table or database Jira
• [jira] [Created] (FLINK-40107) Group example modules under an examples aggregator pom Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-40106) Move FlinkResourceValidator and FlinkResourceMutator to the api module Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-40105) Support configuring Kubernetes memory request factor for JobManager and TaskManager xiechenling (Jira)
• [jira] [Created] (FLINK-40104) Logging framework JARs are placed under $FLINK_HOME/log instead of the operator lib directory Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-40103) Upgrade operator to Java Operator SDK version 5.4 Jira
• Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
  • Re: [DISCUSS] State Schema Evolution for RowData Shengkai Fang
  • Re: [DISCUSS] State Schema Evolution for RowData Leonard Xu
  • Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
  • RE: [DISCUSS] State Schema Evolution for RowData David Radley
  • Re: [DISCUSS] State Schema Evolution for RowData Weiqing Yang
• [jira] [Created] (FLINK-40102) MySQL CDC Source: Support batch emitting CreateTableEvents to reduce schema coordination overhead ericzeng (Jira)
• [jira] [Created] (FLINK-40101) Watermark forwarding can stall indefinitely under interruptible timers with a large due-timer backlog Piotr Nowojski (Jira)
• [DISCUSS] FLIP-601: Cloud-Agnostic Client-Side Encryption for SDK-Native Filesystems Aleksandr Iushmanov
• [jira] [Created] (FLINK-40100) Reduce ArchUnit violations: remove direct usage of Flink-internal/shaded APIs in flink-connector-http Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40099) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab log check reads a killed TaskManager's log Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40098) Add FailingCheckpointedSource test utility for exactly-once source tests Martijn Visser (Jira)
• [jira] [Created] (FLINK-40097) FLIP-585: Introduce Lazy Loading for HistoryServer chenzihao (Jira)
• [RESULT][VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer zihao chen
• [jira] [Created] (FLINK-40096) Migrate EXPLAIN CTAS/RTAS Explain tests to Java Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40095) JSON aggregation functions failing in group window aggregate Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-40094) DynamicKafkaSource should mark removed split outputs idle before release Xin Gao (Jira)
• [jira] [Created] (FLINK-40093) Race condition between watermark alignment and idleness detection locks split in idle Efrat Levitan (Jira)
• [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Yuepeng Pan
  • Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Weiqing Yang
  • Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Yuepeng Pan
  • Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Chanhae Oh
  • Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 João Boto
  • Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Yuepeng Pan
  • Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 João Boto
  • Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3 Yuepeng Pan
• [jira] [Created] (FLINK-40092) BlueGreen transition should finalize immediately after deleting previous deployment Calico Shop (Jira)
• [jira] [Created] (FLINK-40091) upgrade paimon to 1.4.2 peiyu (Jira)
• [jira] [Created] (FLINK-40090) Modernize cryptography export notice in distribution README Martijn Visser (Jira)
• [jira] [Created] (FLINK-40089) Add JSON_LENGTH function Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429) Martijn Visser (Jira)
• [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion 주수민
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion ChanBin Oh
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Youngil Kim
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Leonard Xu
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion João Boto
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Leonard Xu
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Leonard Xu
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Leonard Xu
  • Re: [DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
• [jira] [Created] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xin Gong (Jira)
• [jira] [Created] (FLINK-40086) Harden Execution#transitionState implementation by guarding preCompletionAction Matthias Pohl (Jira)
• [jira] [Created] (FLINK-40085) Introduce e2e test for es8 sink reswqa (Jira)
• [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region 熊饶饶
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Guowei Ma
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Yuan Mei
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Gen Luo
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Roman Khachatryan
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region zihao chen
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Rui Fan
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Zakelly Lan
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Weiqing Yang
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region yue ma
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Charles Zhang
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Leonard Xu
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Yuepeng Pan
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region Zhu Zhu
  • Re: [VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region 熊饶饶
• [jira] [Created] (FLINK-40084) maven-shade-plugin does not respect multi release jars Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Chris Lu (Jira)
• [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #2 Yuepeng Pan
  • Re: [VOTE] Release flink-connector-jdbc v3.4.0, release candidate #2 Yuepeng Pan
• [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3 Yuepeng Pan
  • Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3 Chanhae Oh
  • Re: [VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3 Yuepeng Pan
• Help Needed for JDBC Release v3.4.0 Yuepeng Pan
  • Re: Help Needed for JDBC Release v3.4.0 Ferenc Csaky
  • Re: Help Needed for JDBC Release v3.4.0 Weiqing Yang
  • Re: Help Needed for JDBC Release v3.4.0 Yuepeng Pan
• [jira] [Created] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Fred Teunissen (Jira)
• [jira] [Created] (FLINK-40081) Enable the spilling backend for checkpointing during recovery Rui Fan (Jira)
• [jira] [Created] (FLINK-40080) Drain spilled channel state into input channels and replay spilled slices into checkpoints Rui Fan (Jira)
• [jira] [Created] (FLINK-40079) Enforce disableSystemArguments consistently for all PTF translation paths Fabian Hueske (Jira)
• [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Dennis-Mircea Ciupitu
  • Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Gyula Fóra
  • Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Francis Altomare
  • Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Dennis-Mircea Ciupitu
  • Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Maximilian Michels
  • Re: [DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign Dennis-Mircea Ciupitu
• [jira] [Created] (FLINK-40078) Lost non-loss-tolerant OperatorEvent to an already-failing task triggers a failover that masks the original failure cause Martijn Visser (Jira)
• [jira] [Created] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause Martijn Visser (Jira)
• [jira] [Created] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale Martijn Visser (Jira)
• [jira] [Created] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator dylanhz (Jira)
• [jira] [Created] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory) Martijn Visser (Jira)
• [jira] [Created] (FLINK-40073) Delete and Force Push Protections for Default and Release Branches Harshit Gupta (Jira)
• [jira] [Created] (FLINK-40072) request.timeout is declared as a Duration option but parsed as integer seconds, crashing at query time on any unit-suffixed value Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40071) Bump jackson-bom to 2.21.4 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file Martijn Visser (Jira)
• [jira] [Created] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race Martijn Visser (Jira)
• [jira] [Created] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager Martijn Visser (Jira)
• [jira] [Created] (FLINK-40067) RescaleTimelineITCase.testRescaleTerminatedByJobFinished fails due to race between cooldown-driven rescale termination and job finish Martijn Visser (Jira)
• [jira] [Created] (FLINK-40066) flink-connector-mongodb: update flink-connector-parent to 2.0.0 and flink.version to 2.1.2 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1. Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40064) Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink and re-enable it Martijn Visser (Jira)
• [jira] [Created] (FLINK-40063) Tests: migrate JUnit 5 (Jupiter) to JUnit 6 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• [ANNOUNCE] Apache flink-connector-http v1.0.0 released David Radley
• [jira] [Created] (FLINK-40061) Update parent version and flink.version in flink-connector-jdbc pom.xml ChanBin OH (Jira)
• [jira] [Created] (FLINK-40060) Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility Sumin Joo (Jira)
• [jira] [Created] (FLINK-40059) StateMachineExample.jar bundles a Kafka connector incompatible with Flink 2.x Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40058) cron_snapshot_deployment nightly jobs run out of disk space on hosted agents Martijn Visser (Jira)
• [jira] [Created] (FLINK-40057) DefaultSlotAssigner over-picks slots from the boundary TaskManager when minimal-TaskManager placement is enabled ericzeng (Jira)
• [jira] [Created] (FLINK-40056) Support anchor navigation for pyflink configuration options chenzihao (Jira)
• [jira] [Created] (FLINK-40055) Operator serializes managed-deployment config in its own YAML dialect, breaking Flink 1.x deployments when the operator itself runs on standard config.yaml Gerk Elznik (Jira)
• [jira] [Created] (FLINK-40054) Update aircompressor to 2.0.3 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40053) Log4j 2.26.1 bump Martijn Visser (Jira)
• [jira] [Created] (FLINK-40052) NullPointerException in MySqlHybridSplitAssigner.createBinlogSplit when snapshot split reader fails after assigner status has reached FINISHED SkylerLin (Jira)
• [jira] [Created] (FLINK-40051) erorr: No coordinator registered for operator when set operator.uid.prefix in mysql to hudi pipeline yaml lisa (Jira)
• [jira] [Created] (FLINK-40050) flink-ci/flink-mirror isn't mirroring commits anymore Martijn Visser (Jira)
• [jira] [Created] (FLINK-40049) Changes for Flink-connector-Prometheus for Flink2.x Taranpreet Kaur (Jira)
• [jira] [Created] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test Martijn Visser (Jira)
• [jira] [Created] (FLINK-40047) Flink Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+ Marc Demierre (Jira)
• [jira] [Created] (FLINK-40046) Upgrade @antv/g2 to v5 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40045) Upgrade d3-flame-graph to v5 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism peiyu (Jira)
• [jira] [Created] (FLINK-40042) Update JDBC connector version to 4.1.0 Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40041) Update JDBC connector version to 3.4.0 Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40040) SchemaRegistry loses coordination responses when a failure's cause is a user-classloader-only class (e.g. a JDBC driver exception), causing the job to hang until rpcTimeout and enter a restart loop Jiyong Wang (Jira)
• [jira] [Created] (FLINK-40039) CTAS/RTAS do not work for PTFs with set semantics and PARTITION BY Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40038) [mysql][pipeline] Incremental sync throughput is low in hotspot UPDATE workloads due to deserialization overhead Jira
• [jira] [Created] (FLINK-40037) Local RocksDB working directory leaked (with all file handles held open) when an async-state-v2 task is redeployed onto the same TaskManager after a job restart Grzegorz Liter (Jira)
• [jira] [Created] (FLINK-40036) Support injecting a custom MockEnvironment into multi-input operator test harnesses Kaivalya Apte (Jira)
• [jira] [Created] (FLINK-40035) Add smoke-level component specs for the web-dashboard Martijn Visser (Jira)
• [jira] [Created] (FLINK-40034) Refresh web-dashboard lint tooling to prettier 3 and stylelint 17 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40033) Modernize web-dashboard visualization libraries Martijn Visser (Jira)
• [jira] [Created] (FLINK-40031) Exceptions view crashes (NG04008) navigating to an unassigned TaskManager Martijn Visser (Jira)
• [jira] [Created] (FLINK-40032) Migrate web-dashboard eslint to v9 (flat config) Martijn Visser (Jira)
• [jira] [Created] (FLINK-40030) Add architecture tests to flink-connector-http Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40029) Use Hadoop 3.4.3 in nightly tests Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40028) Update Angular to v21 and ng-zorro-antd to v21 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40027) Align SavepointKeyFilter with the State Processor API generic convention Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-40026) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table Stepan Stepanishchev (Jira)
• [jira] [Created] (FLINK-40025) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table Stepan Stepanishchev (Jira)
• [jira] [Created] (FLINK-40024) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table Stepan Stepanishchev (Jira)
• [jira] [Created] (FLINK-40023) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table Stepan Stepanishchev (Jira)
• [jira] [Created] (FLINK-40022) Table API client hangs when batch query returns an empty result Timo Theusner (Jira)
• [jira] [Created] (FLINK-40021) AND for pushdown filters should be in uppercase Sergey Nuyanzin (Jira)
• [DISCUSS] Model routing for ML_PREDICT (FLINK-39961) Purshotam Shah via dev
• [jira] [Created] (FLINK-40020) Flink 2.3: update migration data for tests David Anderson (Jira)
• [jira] [Created] (FLINK-40019) FLIP-588: Support per-job delegation tokens Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40018) PTF changelog inference silently drops an unsatisfiable table input, causing IndexOutOfBoundsException Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40017) Introduce Seaweedfs in native-s3-fs Samrat Deb (Jira)
• [jira] [Created] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Martijn Visser (Jira)
• [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Han Yin
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Dennis-Mircea Ciupitu
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Dennis-Mircea Ciupitu
  • Re: [DISCUSS] FLIP-599: State Catalog Zakelly Lan
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Roman Khachatryan
  • Re: [DISCUSS] FLIP-599: State Catalog Shengkai Fang
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Roman Khachatryan
  • Re: [DISCUSS] FLIP-599: State Catalog Jingsong Li
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Jingsong Li
  • Re: [DISCUSS] FLIP-599: State Catalog Weiqing Yang
  • Re: [DISCUSS] FLIP-599: State Catalog gyula . fora
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Weiqing Yang
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Shengkai Fang
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
• [jira] [Created] (FLINK-40015) Wrap atomic PTF output in Row partition-key prepend & rowtime append in PTF Test Harness Mika Naylor (Jira)
• [jira] [Created] (FLINK-40014) Reject null entries/keys in list/map view in PTF Test Harness Mika Naylor (Jira)
• [jira] [Created] (FLINK-40013) Correctly clear state in ctx.clearState in PTF Test Harness Mika Naylor (Jira)
• [jira] [Created] (FLINK-40012) Inject context into scalar only PTF invocation in PTF Test Harness Mika Naylor (Jira)
• [jira] [Created] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered Martijn Visser (Jira)
• [jira] [Created] (FLINK-40010) RescaleTimelineITCase.testRescaleTerminatedByNoResourcesOrNoParallelismsChange is flaky: requirements-update can miss the in-progress rescale Martijn Visser (Jira)
• [jira] [Created] (FLINK-40009) RescaleTimelineITCase Martijn Visser (Jira)
• [jira] [Created] (FLINK-40008) Replace fixed delegation token renewal retry backoff with exponential backoff Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-40007) Postgres CDC ignores scan.snapshot.fetch.size during snapshot, causing OOM on wide tables Di Wu (Jira)

• Earlier messages
• Later messages