dev  

Messages by Thread

• [jira] [Created] (FLINK-39970) Kubernetes Operator proceeds with cluster resubmission after Deployment deletion wait timeout, causing AlreadyExists / object-is-being-deleted race Bowen Li (Jira)
• [jira] [Created] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• [jira] [Created] (FLINK-39968) [Optimization] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance yyka (Jira)
• [jira] [Created] (FLINK-39967) FlinkStateSnapshot with default backoffLimit=-1 (documented as "unlimited retries") never retries and fails immediately on first error Santwana Verma (Jira)
• [DISCUSS] FLIP-592: First-Class Accelerator Resource Support Yi Zhang
• [jira] [Created] (FLINK-39966) FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only lincoln lee (Jira)
• [VOTE] FLIP-545: Hardening the Event Reporter with an Asynchronous Core Kartikey Pant
  • Re: [VOTE] FLIP-545: Hardening the Event Reporter with an Asynchronous Core Li Wang
• [DISCUSSION] Native GCS Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Aleksandr Iushmanov
  • Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Ryan van Huuksloot via dev
  • Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Poorvank Bhatia
• [jira] [Created] (FLINK-39965) Flink CDC should clear schema state and table-level caches after DropTableEvent Ran Tao (Jira)
• [jira] [Created] (FLINK-39964) Incremental checkpoint taken after a CLAIM-mode restore from a native savepoint is not restorable Aleksandr Savonin (Jira)
• [ANNOUNCE] Apache Flink Agents 0.3.0 released wenjin
• [jira] [Created] (FLINK-39963) Runtime: ExecutionTimeBasedSlowTaskDetectorTest.testBalancedInput flaky Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39962) Runtime: DeclarativeSlotPoolBridgeTest.testAcceptingOfferedSlotsWithoutResourceManagerConnected flaky Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39961) Support routing across models in Flink SQL (ML_PREDICT) Purshotam Shah (Jira)
• [jira] [Created] (FLINK-39960) Remove broken JavaDoc shortcode usage from JDBC datastream docs Dennis-Mircea Ciupitu (Jira)
• [PR] [hotfix] Add `.gitignore` [flink-ci-docker] via GitHub
  • Re: [PR] [hotfix] Add `.gitignore` [flink-ci-docker] via GitHub
• [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re:Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Xuyang
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Xingcan Cui
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Xingcan Cui
• [jira] [Created] (FLINK-39959) Improve the autoscaler context structure and propagation Dennis-Mircea Ciupitu (Jira)
• [RESULT] [VOTE] FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin
• [VOTE] FLIP-588: Support per-job delegation tokens Aleksandr Savonin
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Roman Khachatryan
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Gabor Somogyi
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Rui Fan
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Piotr Nowojski
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens weijie guo
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Sergey Nuyanzin
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Ryan van Huuksloot via dev
  • [RESULT] [VOTE] FLIP-588: Support per-job delegation tokens Aleksandr Savonin
• [RESULT][VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 wenjin
• [jira] [Created] (FLINK-39958) Autoscaler Flink REST client timeout is silently overridden by the operator client timeout Dennis-Mircea Ciupitu (Jira)
• [RESULT][VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-39957) Support EXPLAIN CREATE [OR ALTER] MATERIALIZED TABLE statements Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39956) Expose per-pool heap CollectionUsage gauges Zhenqiu Huang (Jira)
• Request for PMC to get PyPI access Yuepeng Pan
  • Re: Request for PMC to get PyPI access Yuepeng Pan
• [jira] [Created] (FLINK-39955) PTF OutputTypeStrategy can emit time indicator types Fabian Hueske (Jira)
• [RESULT][VOTE] Release 2.3.0, release candidate #4 Yuepeng Pan
• [jira] [Created] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• [jira] [Created] (FLINK-39953) AbstractFlinkService.deleteBlocking() swallows KubernetesClientTimeoutException allowing cluster upgrade to proceed on top of still-running cluster Lucas Borges (Jira)
• [jira] [Created] (FLINK-39952) CallContextMock.isArgumentNull() does not correctly implement interface contract Fabian Hueske (Jira)
• [jira] [Created] (FLINK-39951) [Python] ArrayConstructor uses == for String comparison, silently truncating long array values to int Jubin Soni (Jira)
• [jira] [Created] (FLINK-39950) [sqlserver] scan.incremental.snapshot.chunk.key-column only searches primary key columns instead of all table columns Jubin Soni (Jira)
• [jira] [Created] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Jubin Soni (Jira)
• [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
  • Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Cole Bailey via dev
  • Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Zander Matheson
  • Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Yong Fang
  • Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
  • Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
  • Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
  • Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Zander Matheson
  • Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
  • Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Cole Bailey via dev
  • RE: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Matt Belle via dev
  • Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
  • Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
  • Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
  • Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Cole Bailey via dev
  • Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
  • Re: Re: [DISCUSS] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
• [jira] [Created] (FLINK-39948) The flink-table-planner module failed to compile with JDK 11 reswqa (Jira)
• [jira] [Created] (FLINK-39947) Fix the flaky test case in class TaskExecutorPartitionLifecycleTest Yuepeng Pan (Jira)
• [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 wenjin
  • Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Rich Bowen
  • Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Weiqing Yang
  • Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Xintong Song
  • Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Zhu Zhu
  • Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Dian Fu
  • Re: [VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 Alan Zhang
• [RESULT][VOTE] Release flink-connector-http v1.0.0, release candidate 2 David Radley
• [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer zihao chen
  • Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer Feng Jin
  • Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer 李阳
  • Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer 李阳
  • Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer 李阳
  • Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer weijie guo
  • Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer Junrui Lee
  • Re: [VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer 李阳
• [FLINK-39639] Silent data loss when a split is assigned after a source finishes Spoorthi Basu
• [jira] [Created] (FLINK-39946) Unaligned checkpoint restore can mis-map union input channel state after reordering UIDed sources Bowen Li (Jira)
• [jira] [Created] (FLINK-39945) CAST of DECIMAL changed with Calcite 1.38.0 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39944) Dynamic Kafka source cluster removal is not resilient enough Xin Gao (Jira)
• [jira] [Created] (FLINK-39943) IS [NOT ]JSON changed nullability after upgrade to Calcite 1.38.0 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39942) Add support for frame exclusion in window functions Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39941) Weekly CI fails because pip no longer supports Python 3.8 Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService Bowen Li (Jira)
• [DISCUSS] FLIP-XXX Monotonic Counters support Efrat Levitan
  • Re: [DISCUSS] FLIP-XXX Monotonic Counters support Ryan van Huuksloot via dev
  • Re: [DISCUSS] FLIP-XXX Monotonic Counters support Efrat Levitan
  • Re: [DISCUSS] FLIP-XXX Monotonic Counters support Ryan van Huuksloot via dev
• Future direction of Flink's S3 filesystem implementations Samrat Deb
  • RE: Future direction of Flink's S3 filesystem implementations ctrlaltdilj
  • Re: Future direction of Flink's S3 filesystem implementations Gabor Somogyi
  • Re: Future direction of Flink's S3 filesystem implementations Aleksandr Iushmanov
• [jira] [Created] (FLINK-39939) FLIP-587: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39938) FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu (Jira)
• [RESULT][VOTE] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu
• [RESULT][VOTE] FLIP-587: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu
• [VOTE] FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin
  • Re: [VOTE] FLIP-583: Expose JobInfo on Source contexts Leonard Xu
  • Re: [VOTE] FLIP-583: Expose JobInfo on Source contexts Rui Fan
  • Re: [VOTE] FLIP-583: Expose JobInfo on Source contexts Yanquan Lv
  • Re: [VOTE] FLIP-583: Expose JobInfo on Source contexts Yuepeng Pan
  • Re: [VOTE] FLIP-583: Expose JobInfo on Source contexts Efrat Levitan
• [jira] [Created] (FLINK-39937) Merge jobmanager and taskmanager into the same JVM melin (Jira)
• [jira] [Created] (FLINK-39936) Add flink-s3-fs-native to flink-dist pom file reswqa (Jira)
• [jira] [Created] (FLINK-39935) Allow connectors to override lineage dataset name in TableLineageDatasetImpl Jaskaran Singh Kukreja (Jira)
• [jira] [Created] (FLINK-39934) Postgres pipeline connector reports misleading table format error message Ran Tao (Jira)
• [VOTE] Release 2.3.0, release candidate #4 Yuepeng Pan
  • Re: [VOTE] Release 2.3.0, release candidate #4 Gustavo de Morais
  • Re: [VOTE] Release 2.3.0, release candidate #4 Yuepeng Pan
  • Re: [VOTE] Release 2.3.0, release candidate #4 Yuepeng Pan
  • Re: [VOTE] Release 2.3.0, release candidate #4 Hao Li
  • Re: [VOTE] Release 2.3.0, release candidate #4 Rich Bowen
  • Re: [VOTE] Release 2.3.0, release candidate #4 Rich Bowen
  • Re: [VOTE] Release 2.3.0, release candidate #4 Rich Bowen
  • Re: [VOTE] Release 2.3.0, release candidate #4 David Anderson
  • Re: [VOTE] Release 2.3.0, release candidate #4 Keith Lee
  • Re: [VOTE] Release 2.3.0, release candidate #4 Rui Fan
  • Re: [VOTE] Release 2.3.0, release candidate #4 Samrat Deb
  • Re: [VOTE] Release 2.3.0, release candidate #4 Martijn Visser
  • Re: [VOTE] Release 2.3.0, release candidate #4 weijie guo
  • Re: [VOTE] Release 2.3.0, release candidate #4 Weiqing Yang
  • Re: [VOTE] Release 2.3.0, release candidate #4 Yuepeng Pan
• [jira] [Created] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
• [CANCEL][VOTE] Release 2.3.0, release candidate #3 Yuepeng Pan
• [jira] [Created] (FLINK-39932) [flink-datastream] Merging-Window onRecord Callback Receives Wrong Window Context in DataStream V2 Sameer Devgan (Jira)
• [jira] [Created] (FLINK-39931) Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution Chanhae Oh (Jira)
• [ANNOUNCE] Apache Flink 1.20.5 released Yunfeng Zhou
• [ANNOUNCE] Apache Flink 2.1.3 released Yunfeng Zhou
• [RESULT][VOTE] Release 1.20.5, release candidate #2 Yunfeng Zhou
• [jira] [Created] (FLINK-39930) Fix the flaky test case WindowDistinctAggregateITCase#testHopWindow_Cube Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39929) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Yuepeng Pan (Jira)
• [PR] [FLINK-39739][ci] Add Java 25 to Docker image [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-39739][ci] Add Java 25 to Docker image [flink-ci-docker] via GitHub
• [jira] [Created] (FLINK-39928) If there are changes in tests only then skip non related CI jobs in GHA Sergey Nuyanzin (Jira)
• [DISCUSS] Support Unaligned Checkpoint on Pointwise Edges Gen Luo
• [jira] [Created] (FLINK-39927) Update japicmp configuration post 2.1.3 Yunfeng Zhou (Jira)
• [jira] [Created] (FLINK-39926) Update japicmp configuration post 1.20.5 Yunfeng Zhou (Jira)
• [jira] [Created] (FLINK-39925) Job throughput metrics incorrectly dropping to zero, forcing scale down Trystan (Jira)
• [jira] [Created] (FLINK-39924) Memory fragmentation from jemalloc misconfiguration Keith Lee (Jira)
• [jira] [Created] (FLINK-39923) RocksDB Statistics native memory leaks on state backend rebuild when ticker metrics are enabled Keith Lee (Jira)
• [jira] [Created] (FLINK-39922) Fix the flaky test case AbstractAsyncRunnableStreamOperatorTest#testCheckpointDrain Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39921) Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to exepected ComponentMainThreadExecutor passing. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39920) Increase the timeout for SystemProcessingTimeServiceTest to get stable Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39919) Increase the timeout for SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown to get stable Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39918) KeyedComplexChainTest hangs until the CI watchdog kills the fork: AbstractOperatorRestoreTestBase waits ~2.7h for a job status that can never arrive Martijn Visser (Jira)
• [jira] [Created] (FLINK-39917) JobMasterTriggerSavepointITCase.testDoNotCancelJobIfSavepointFails: "Disconnect job manager" log assertion races the async JM->RM disconnect Martijn Visser (Jira)
• [jira] [Created] (FLINK-39916) Incorrect placeholder used in MySqlDataSourceFactory exception message XiaodongHuan (Jira)
• [DISCUSS] FLIP-590: Introduce Multimodal Data Types: Vector, Tensor, and Image Geng Biao
  • Re: [DISCUSS] FLIP-590: Introduce Multimodal Data Types: Vector, Tensor, and Image Yanquan Lv
  • Re: [DISCUSS] FLIP-590: Introduce Multimodal Data Types: Vector, Tensor, and Image Geng Biao
• [DISCUSS] FLIP-589: Introduce FILE Type for Byte-Content References dylanhz
  • Re: [DISCUSS] FLIP-589: Introduce FILE Type for Byte-Content References Yanquan Lv
• [jira] [Created] (FLINK-39915) Throw a clear validation error when mixing positional and named function arguments Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39914) Fix flaky TaskDeploymentDescriptorFactoryTest#testHybridVertexFinish caused by async TDD creation Chanhae Oh (Jira)
• [jira] [Created] (FLINK-39913) Improve the error message when a foreground query emits an upsert changelog Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39912) Change the Annotation (repeatTest to Test) in ForwardEdgesAdapterTest Chanhae Oh (Jira)
• [jira] [Created] (FLINK-39911) FLIP-584: Support Pluggable Storage Backend for HistoryServer chenzihao (Jira)
• [RESULT][VOTE] FLIP-584: Support Pluggable Storage Backend for HistoryServer zihao chen
• [jira] [Created] (FLINK-39910) "Build documentation" CI step consistently failing Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-39909) Heap state backend savepoint fails with NPE when MapState contains null values Mukul Gupta (Jira)
• [VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Rich Bowen
  • Re: [VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Leonard Xu
  • Re: [VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-39907) Add SQL DDL support for GEOGRAPHY David Chaava (Jira)
• [jira] [Created] (FLINK-39908) Add planner validation for unsupported conversions David Chaava (Jira)
• [jira] [Created] (FLINK-39906) Add parser string and JSON serialization support David Chaava (Jira)
• [jira] [Created] (FLINK-39905) Add DataTypes.GEOGRAPHY Java API David Chaava (Jira)
• [jira] [Created] (FLINK-39904) Add GEOGRAPHY logical type model David Chaava (Jira)
• [jira] [Created] (FLINK-39903) RescaleTimelineITCase.testRescaleTerminatedByResourceRequirementsUpdated is flaky: second resource-requirements update can miss the in-progress rescale Martijn Visser (Jira)
• [jira] [Created] (FLINK-39902) RescaleTimelineITCase.testRescaleTerminatedByJobFinished fails due to race between task unblock and recorded rescale Martijn Visser (Jira)
• [jira] [Created] (FLINK-39901) GitHub Actions nightly: empty surefire excludedGroups fails all JDK 11 test jobs ("list of tag expressions must not be null or empty") Martijn Visser (Jira)
• [jira] [Created] (FLINK-39900) Support configuring the number of threads used in ForStStateDataTransfer Francis (Jira)
• [jira] [Created] (FLINK-39899) Flink SQL Window TVF didn't remove rowtime attribute from original rowtime field Chen Zhang (Jira)
• [jira] [Created] (FLINK-39898) ProcessingTimeService timer callbacks delayed until checkpoint when mini-batch and unaligned checkpoints are enabled ion (Jira)
• [jira] [Created] (FLINK-39897) limit() without an order produces invalid SQL Mika Naylor (Jira)
• [jira] [Created] (FLINK-39896) FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API David Chaava (Jira)
• [jira] [Created] (FLINK-39895) PyFlink tests fail on release-1.20: setuptools 82 removed pkg_resources, breaking the Beam Python harness Martijn Visser (Jira)
• [jira] [Created] (FLINK-39894) Change version in generated REST API specifications yml files when creating a new release branch Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39893) Respect non-monotonic counter accumulation in openTelemetry reporter Efrat Levitan (Jira)
• [jira] [Created] (FLINK-39892) Exactly-once kafka sink reports a negative numBytesOut delta after every checkpoint Efrat Levitan (Jira)
• [jira] [Created] (FLINK-39891) Cancel orphaned session jobs on the session cluster before (re)submitting a FlinkSessionJob lrsb (Jira)
• [jira] [Created] (FLINK-39890) Autoscaler crashes with NumberFormatException computing observed scaling coefficient for idle vertices lrsb (Jira)

• Earlier messages
• Later messages