You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-40871) Avoid the UTF-8 round trip when casting strings and decimals to VARIANT - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/10/01 07:08:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF - posted by Vas Shabu <ks...@hotmail.com> on 2026/10/01 10:26:19 UTC, 3 replies.
- [jira] [Created] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER - posted by "Yordan Pavlov (Jira)" <ji...@apache.org> on 2026/10/01 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40873) Fix overlapping config key prefixes in the operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/10/01 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/10/01 13:04:00 UTC, 0 replies.
- [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs - posted by Ferenc Csaky via dev <de...@flink.apache.org> on 2026/10/01 13:27:59 UTC, 5 replies.
- [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? - posted by Ferenc Csaky via dev <de...@flink.apache.org> on 2026/10/01 13:48:35 UTC, 5 replies.
- [jira] [Created] (FLINK-40875) Optimization to let streaming joins fill key-only deletes instead of adding a ChangelogNormalize - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/10/01 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40876) Code splitter should generate same code after repeated runs - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/01 20:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40877) Support Dynamic Rate Limit in Flink Sources - posted by "Peter Huang (Jira)" <ji...@apache.org> on 2026/10/01 20:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40878) Add dynamic rate limit interfaces - posted by "Peter Huang (Jira)" <ji...@apache.org> on 2026/10/01 20:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40880) Support dynamic ratelimit in source coordinator with checkpoint latency control loop - posted by "Peter Huang (Jira)" <ji...@apache.org> on 2026/10/01 20:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40879) Add dynamic ratelimit Flink options - posted by "Peter Huang (Jira)" <ji...@apache.org> on 2026/10/01 20:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40881) Update Flink wiki with new configs and user guide - posted by "Peter Huang (Jira)" <ji...@apache.org> on 2026/10/01 20:50:00 UTC, 0 replies.
- Release flink-connector-aws [6.1.0] - posted by "Roberts, Madison via dev" <de...@flink.apache.org> on 2026/10/01 21:24:48 UTC, 2 replies.
- [jira] [Created] (FLINK-40882) Janino should compile same class only once - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/01 21:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction - posted by "Bonnie Varghese (Jira)" <ji...@apache.org> on 2026/10/02 04:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40884) Flink configuration breaks when Keystore or Truststore passwords contain specific characters - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2026/10/02 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40885) Support LATERAL SNAPSHOT join in the Table API - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/10/02 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40887) TaskFailureITCase.testJobWithoutObjectReuse fails with "Expecting Optional to contain a value but it was empty" - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 08:49:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-612: Native XML Functions for Flink SQL - posted by Moritz Manner <mo...@gmail.com> on 2026/10/02 09:54:32 UTC, 0 replies.
- [jira] [Created] (FLINK-40888) Improve MATCH_RECOGNIZE performance: lazily evaluate DEFINE aggregations and avoid extracting all matched pattern events - posted by "DongShengHe (Jira)" <ji...@apache.org> on 2026/10/02 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40889) NDU plan visitor has no branch for VECTOR_SEARCH, TRY_RESOLVE and EXPLAIN PLAN_ADVICE fail - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40890) LATERAL SNAPSHOT build side passes TRY_RESOLVE with non-deterministic columns - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40891) NDU plan visitor does not propagate determinism requirements through PTFs without REQUIRE_UPDATE_BEFORE - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40892) Stale IGNORE override on the changelog PTF tests - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40893) Update the determinism page for the current state of the NDU handling - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40894) Expose counters for unmatched retractions in SinkUpsertMaterializer and KeyedLookupJoinWrapper - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40895) Make use cache in code splitter - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/02 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40896) Add built-in DEDUPLICATE_KEEP_FIRST PTF - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/10/02 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40897) TIMESTAMPDIFF returns wrong results and fails with scala.MatchError for TIME operands - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/10/02 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40898) TRY_RESOLVE wrongly rejects non-deterministic filters inside ChangelogNormalize - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40900) NDU analyzer does not check predicates pushed into a CDC source - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40899) ON CONFLICT validation masks the NDU error for lookup joins - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/02 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40901) JSON functions return the result of a previous row when JSON_TYPE or JSON_LENGTH is skipped - posted by "Moritz Manner (Jira)" <ji...@apache.org> on 2026/10/02 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40902) LATERAL SNAPSHOT join wrongly rejected when a local filter targets the join key column - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/10/02 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40903) Add source host info in TM disconnect error - posted by "Peter Huang (Jira)" <ji...@apache.org> on 2026/10/02 17:29:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API - posted by Sergey Nuyanzin <sn...@gmail.com> on 2026/10/02 20:35:33 UTC, 2 replies.
- [jira] [Created] (FLINK-40904) FORWARD-to-REBALANCE downgrade compares producer parallelism with the number of subpartitions instead of the consumer parallelism - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2026/10/02 22:06:00 UTC, 0 replies.
- [Announcement] Flink 2.4 Release Manager Sync Meeting #3 - posted by Chanhae Oh <dh...@gmail.com> on 2026/10/02 23:19:40 UTC, 0 replies.
- Re: [DISCUSS] FLIP-615: Snapshot Splitters for Table and Database Ingestion - posted by Chanhae Oh <dh...@gmail.com> on 2026/10/04 12:48:40 UTC, 0 replies.
- [jira] [Created] (FLINK-40905) Bump Pekko to 1.7.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/04 17:03:00 UTC, 0 replies.
- Re: [DISCUSS][FLINK-40574] Upgrade SLF4J from 1.7 to 2.x - posted by Piotr Przybylski <pi...@gmail.com> on 2026/10/04 17:48:38 UTC, 2 replies.
- [jira] [Created] (FLINK-40906) DataFrameWindowITTests.test_hop_window_aggregation fails with a DispatcherGateway.submitJob timeout - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/05 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40907) HBaseITCase.test cannot build the HBase image, hbase-2.6.6 tarball gone from dlcdn - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/05 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40908) HBaseITCase.test fails with expected: <6> but was: <0> - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/05 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40909) Support filter push down for element access on ARRAY, MAP and VARIANT (ITEM) - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/10/05 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40910) Reject VARIANT where SQL needs equality. Byte comparison gives wrong results in GROUP BY, DISTINCT, joins and = - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/10/05 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40911) Variant builder mishandles a nested variant and a value of exactly 16 MiB - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/10/05 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40912) ExactlyOnceKafkaWriter never closes the AdminClient it creates for the listing abort strategy - posted by "Aleksandr Savonin (Jira)" <ji...@apache.org> on 2026/10/05 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40913) CheckpointSyncPhaseTimeoutITCase failures race - posted by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/10/05 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40914) Support partial updates on LATERAL SNAPSHOT join build side - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/10/05 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40915) Relax non-deterministic join-condition check for LATERAL SNAPSHOT join - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2026/10/05 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations - posted by "Isaac Montenegro Jimenez (Jira)" <ji...@apache.org> on 2026/10/05 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40917) Deeply nested VARIANT values overflow the stack in toJson(), CAST to STRING and the variant builder - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/10/05 14:19:00 UTC, 0 replies.
- [DISCUSS] Maintenance status and plans for several Flink repositories - posted by Aleksandr Savonin <sa...@gmail.com> on 2026/10/05 16:12:02 UTC, 0 replies.
- [jira] [Created] (FLINK-40918) SIGTERM during application-mode HA recovery permanently fails the suspended jobs of a PyFlink application - posted by "Ian Stewart (Jira)" <ji...@apache.org> on 2026/10/05 19:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40919) AVG on INT returns wrong result when the planner rewrites it into SUM/COUNT (INT sum overflows) - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/06 04:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40920) SELECT 1 / (2 + 3) fails with ClassCastException: RexCall cannot be cast to RexLiteral in ExpressionReducer - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/06 04:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40921) Invoke statebackend's close() and dispose() in right order - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2026/10/06 04:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40922) DISTINCT over GROUP BY ROLLUP returns duplicate rows - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/06 04:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40923) `a >= b` on DOUBLE NaN keeps the row in one query but drops it when the input is first written to a table (reflexive comparison simplified to TRUE) - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/06 05:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40924) table.exec.sink.upsert-materialize=NONE silently bypasses the require-on-conflict check - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/10/06 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/06 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40926) Projection push down records a ReadingMetadata ability without metadata keys - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/10/06 13:03:00 UTC, 0 replies.
- Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source - posted by David Radley <da...@uk.ibm.com> on 2026/10/06 17:08:33 UTC, 6 replies.
- [jira] [Created] (FLINK-40927) Inconsistent NaN semantics for FLOAT/DOUBLE across planner and runtime - posted by "Yahya Kisana (Jira)" <ji...@apache.org> on 2026/10/07 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40928) DISTINCT over a cross join with an IS NULL filter returns rows with NULL that are not in the input - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/07 04:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40929) SUM on DECIMAL silently returns a wrong, order-dependent value after an overflow - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/07 04:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40930) MIN/MAX on FLOAT/DOUBLE return NaN only if NaN is the first input row (order-dependent result) - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/07 05:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2026/10/07 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40932) Arm state schema evolution for ListState and MapState of RowData - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2026/10/07 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/07 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40934) Table API row() fails when AS aliases produce duplicate field names - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/10/07 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40935) VAR_SAMP / STDDEV_SAMP return -1 for a group with a single row - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/07 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40936) Built-in functions compare VARIANT array elements and map keys by their binary encoding - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/10/07 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40937) UPDATE fails with IndexOutOfBoundsException when a SET value's type doesn't match the column - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/07 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40938) Support AT_TIMESTAMP feature in DynamDB Streams connector - posted by "Abhi Gupta (Jira)" <ji...@apache.org> on 2026/10/07 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40939) TRY_RESOLVE accepts non-deterministic join keys and join conditions on updating inputs with a unique key - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/10/07 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40941) Add warmup for janino - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/07 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40940) HTTP lookup source drops the row for a failed call with continue-on-error unless the planner calls applyReadableMetadata - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2026/10/07 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40942) NativeS3FileSystem#getFileStatus fails with "Key cannot be empty" for bucket-root paths - posted by "João Boto (Jira)" <ji...@apache.org> on 2026/10/07 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1) - posted by "João Boto (Jira)" <ji...@apache.org> on 2026/10/07 12:08:00 UTC, 0 replies.
- [DISCUSS] config providers for Flink? - posted by Dale Lane via dev <de...@flink.apache.org> on 2026/10/07 13:43:07 UTC, 0 replies.
- [jira] [Created] (FLINK-40944) CPU limit-factor inflates the JVM's availableProcessors() to the CPU limit - posted by "João Boto (Jira)" <ji...@apache.org> on 2026/10/07 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40945) -0.0 and 0.0 are different keys in GROUP BY, DISTINCT, UNION and hash joins - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/07 17:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40946) SUM / AVG on DECIMAL(38, s) over a join are rounded to scale 6 - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/07 17:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40947) ROLLUP / CUBE / GROUPING SETS with () return no grand-total row on an empty input - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/07 17:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/07 17:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null." - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/07 17:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/07 20:07:00 UTC, 0 replies.
- Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 - posted by Leonard Xu <xb...@gmail.com> on 2026/10/08 04:13:36 UTC, 5 replies.
- Re: [DISCUSS] FLIP-608: Flink on Ray, Ray Resource Backend For Flink - posted by Dian Fu <di...@gmail.com> on 2026/10/08 05:58:04 UTC, 3 replies.
- [jira] [Created] (FLINK-40951) Sync Chinese docs of Flink source connectors with English docs - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/10/08 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40952) ForSt: rescale restore never closes the temporary DB's DBOptions copy, leaking the slot-shared block cache - posted by "Yordan Pavlov (Jira)" <ji...@apache.org> on 2026/10/08 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40953) Store the native S3 recoverable writer tail under the target directory - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/10/08 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40954) Force delete pods stuck Terminating on cluster resource cleanup timeout - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/10/08 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40955) Give up and remove finalizer after cleanup keeps failing with a timeout - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/10/08 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40956) Fall back to stateless delete when savepoint on deletion keeps failing - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2026/10/08 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40957) MongoDB CDC encodes spaces as '+' instead of '%20' in credentials - posted by "luana (Jira)" <ji...@apache.org> on 2026/10/08 09:42:00 UTC, 0 replies.
- [VOTE] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF - posted by Vas Shabu <ks...@hotmail.com> on 2026/10/08 09:53:38 UTC, 3 replies.
- [jira] [Created] (FLINK-40958) VARIANT might fail with StackOverflow - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/08 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40959) Batch sort can emit unsorted rows if comparator implementation is long enough to be split - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/10/08 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40960) [JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/10/08 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40961) Support NOTIFY_STATEFUL_SETS - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/10/08 15:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40962) LAG() unsupported for TIMESTAMP_LTZ arguments in batch mode - posted by "Saketh Kurnool (Jira)" <ji...@apache.org> on 2026/10/08 18:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40963) Add support for DATE and TIME conversion to JSON - posted by "Saketh Kurnool (Jira)" <ji...@apache.org> on 2026/10/08 18:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) - posted by "Sumaiya Azad (Jira)" <ji...@apache.org> on 2026/10/08 19:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40965) Treat IF as conditional function in code gen - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/08 21:07:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata - posted by Spoorthi Basu <sp...@gmail.com> on 2026/10/09 01:58:45 UTC, 11 replies.
- [jira] [Created] (FLINK-40966) Reuse Fluss metadata clients across schema operations - posted by "Xiaobing Fang (Jira)" <ji...@apache.org> on 2026/10/09 03:51:00 UTC, 0 replies.
- A New Flink Native Engine StreamFusion Based On DataFusion - posted by Jacky Lau <li...@gmail.com> on 2026/10/09 09:35:16 UTC, 1 replies.
- [jira] [Created] (FLINK-40967) Restore test files of OVER_AGGREGATE_TIME_BOUNDED_NON_PARTITIONED_ROWS_WITH_OUT_OF_ORDER_RECORDS cannot be regenerated - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/09 10:04:00 UTC, 0 replies.
- [DISCUSS] FLIP-616: Materialized Tables support for Table API - posted by Timo Theusner <ti...@gmail.com> on 2026/10/09 15:40:44 UTC, 7 replies.
- [jira] [Created] (FLINK-40968) Accept map() as op_mapping in Table API toChangelog() and fromChangelog() - posted by "Timo Theusner (Jira)" <ji...@apache.org> on 2026/10/09 15:51:00 UTC, 0 replies.
- Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) - posted by Sergio Chong Loo via dev <de...@flink.apache.org> on 2026/10/09 21:36:39 UTC, 1 replies.
- [RESULT][VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 - posted by Xiqian YU <ko...@outlook.com> on 2026/10/10 06:45:21 UTC, 0 replies.
- [DISCUSS] FLIP-617: Support Pluggable REST Handler Extensions - posted by Yunfeng Zhou <yu...@apache.org> on 2026/10/10 08:15:23 UTC, 2 replies.
- [ANNOUNCE] Apache Flink CDC 3.7.0 released - posted by Xiqian YU <ko...@outlook.com> on 2026/10/10 08:33:14 UTC, 2 replies.
- [DISCUSS] Apache Flink 2.3.1 release - posted by Rui Fan <19...@gmail.com> on 2026/10/10 13:59:19 UTC, 0 replies.
- [DISCUSS] Apache Flink 2.2.2 release - posted by Rui Fan <19...@gmail.com> on 2026/10/10 14:00:50 UTC, 0 replies.
- [DISCUSS] Apache Flink 1.20.6 release - posted by Rui Fan <19...@gmail.com> on 2026/10/10 14:01:39 UTC, 0 replies.
- [DISCUSS] Flink Community Skills - posted by Rui Fan <19...@gmail.com> on 2026/10/11 06:49:00 UTC, 3 replies.
- [DISCUSS] FLIP-613 : Remote Artifact Fetch for Session-Mode Job Submission - posted by Dale Lane via dev <de...@flink.apache.org> on 2026/10/11 18:02:19 UTC, 3 replies.
- [SUMMARY] Flink 2.4 Release Sync - 09.10.26 - posted by Sumin Joo <cl...@gmail.com> on 2026/10/12 00:09:32 UTC, 0 replies.
- Help with Confluence account creation - posted by Sumin Joo <cl...@gmail.com> on 2026/10/12 09:38:26 UTC, 2 replies.
- [jira] [Created] (FLINK-40969) Rescale details endpoint returns 404 for latest events evicted from AdaptiveScheduler history - posted by "Hao Yu (Jira)" <ji...@apache.org> on 2026/10/12 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/12 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/12 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40972) In case of IdentityCastRule CodeGen still produces dummy classes - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/12 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40973) Fluss source fails on retriable errors during periodic table discovery - posted by "Xiaobing Fang (Jira)" <ji...@apache.org> on 2026/10/12 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40974) HadoopIOFormatsITCase#testJobWithObjectReuse runs without object reuse - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/12 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40975) FlinkBushyJoinReorderRule drops or misplaces join conditions, producing wrong results - posted by "Hanyu Zheng (Jira)" <ji...@apache.org> on 2026/10/12 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40976) JoinToMultiJoinForReorderRule applies a post-join filter twice when merging joins for reorder - posted by "Hanyu Zheng (Jira)" <ji...@apache.org> on 2026/10/12 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40977) ForSt JUnit 5 migration is incomplete - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/12 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40978) Cast from VARIANT through FromVariantConverter - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/10/12 16:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40980) JsonRowDataSerDeSchemaTest array tests don't cover the JsonParser deserializer - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/12 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40979) HashAggITCase only runs its inherited tests without adaptive local hash aggregation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/12 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40981) ParameterizedTestExtension should fail tests that it does not parameterize - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/12 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40982) Fluss pipeline sink fails to recover when an ADD COLUMN event is replayed - posted by "Xiaobing Fang (Jira)" <ji...@apache.org> on 2026/10/13 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee - posted by "Rango (Jira)" <ji...@apache.org> on 2026/10/13 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40984) Port the batch aggregate ITCases in flink-table-planner to Java - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/13 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40985) [Iceberg] Support per-table location override in Iceberg pipeline sink - posted by "VISHAL B (Jira)" <ji...@apache.org> on 2026/10/13 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40986) Equal named Rows can have different hash values in PyFlink - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2026/10/13 12:05:00 UTC, 0 replies.
- [REMINDER] Flink 2.4 feature freeze planned for 20 October - posted by Sumin Joo <cl...@gmail.com> on 2026/10/13 13:27:05 UTC, 0 replies.
- [jira] [Created] (FLINK-40987) Allow overriding or disabling a table's watermark per table reference via OPTIONS hint - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/10/13 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40988) Bump JUnit to 5.14 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/13 18:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40989) MAP equality compares numeric values by reference - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/13 19:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40990) MySQL CDC source suppresses terminal missing-schema errors and keeps checkpointing without CDC - posted by "Vinay Sagar Gonabavi (Jira)" <ji...@apache.org> on 2026/10/13 22:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation - posted by "Tomoyuki NAKAMURA (Jira)" <ji...@apache.org> on 2026/10/14 04:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40992) Allow spec.job.parallelism to take effect when spec.taskManager.replicas is set, to support standby TaskManagers in standalone mode - posted by "Tomoyuki NAKAMURA (Jira)" <ji...@apache.org> on 2026/10/14 05:22:00 UTC, 0 replies.
- [DISCUSS] A New Flink Native Engine StreamFusion Based On DataFusion - posted by Jacky Lau <li...@gmail.com> on 2026/10/14 09:04:38 UTC, 0 replies.
- [jira] [Created] (FLINK-40993) State Processor API writes an unrestorable savepoint from a checkpoint taken with file merging - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/10/14 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40994) Upgrade paimon to 2.1.0 - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/10/14 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40995) Draft pull requests are not excluded from the community review label scan - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/10/14 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40996) Make TRY_PARSE_JSON, PARSE_JSON reuse parsed json - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/14 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40997) Streaming join picks a random state key among equal-length upsert keys - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2026/10/14 18:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40998) Web dashboard: Update dependencies with open Dependabot advisories - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/14 21:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-40999) [cdc-composer] Factory JAR path resolution fails with "URI is not hierarchical" for relative usrlib paths in application mode - posted by "wind.wang (Jira)" <ji...@apache.org> on 2026/10/15 02:28:00 UTC, 0 replies.
- [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject - posted by Jacky Lau <li...@gmail.com> on 2026/10/15 03:13:54 UTC, 4 replies.
- [jira] [Created] (FLINK-41000) Pulsar 5.0 support - posted by "Hongbo Miao (Jira)" <ji...@apache.org> on 2026/10/15 03:51:00 UTC, 0 replies.
- [DISCUSS] Release flink-connector-pulsar v5.0.0 - posted by Ferenc Csaky via dev <de...@flink.apache.org> on 2026/10/15 05:00:13 UTC, 3 replies.
- [DISCUSS] Flink CDC 3.8 Kick Off - posted by Yanquan Lv <ku...@apache.org> on 2026/10/15 06:03:00 UTC, 2 replies.
- [jira] [Created] (FLINK-41001) OpenAI model provider rejects compatible string input types - posted by "Liu Liu (Jira)" <ji...@apache.org> on 2026/10/15 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41002) Move test-only defaults out of MiniClusterConfiguration - posted by "Dale Lane (Jira)" <ji...@apache.org> on 2026/10/15 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41003) Bump Pulsar version to 4.0.14 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2026/10/15 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41004) Column expansion does not work with REQUIRE_ON_TIME trait - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/10/15 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41005) MiniCluster should clean up partially started services when start() fails - posted by "Dale Lane (Jira)" <ji...@apache.org> on 2026/10/15 14:43:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views - posted by Gustavo de Morais <gu...@gmail.com> on 2026/10/15 14:55:18 UTC, 0 replies.
- [jira] [Created] (FLINK-41006) upgrade starrocks connector to 1.2.16 - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/10/15 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41007) ON CONFLICT clause is silently ignored when table.exec.sink.upsert-materialize is NONE - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/10/15 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41008) Support multi-table transaction stream load in StarRocks pipeline connector - posted by "peiyu (Jira)" <ji...@apache.org> on 2026/10/15 16:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41009) Use a single Pulsar transaction per checkpoint in the Pulsar sink - posted by "Yubiao Feng (Jira)" <ji...@apache.org> on 2026/10/15 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41010) [cdc-base] NPE in HybridSplitAssigner.createStreamSplit when failed snapshot splits are re-added after assigner finished - posted by "tchivs (Jira)" <ji...@apache.org> on 2026/10/16 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41011) [pipeline-connector/doris] Auto-created Doris table drops NOT NULL constraint of source columns - posted by "tchivs (Jira)" <ji...@apache.org> on 2026/10/16 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41012) Schema change apply failure leads to unrecoverable crash loop: redundant skip + null evolved schema leak after job restart - posted by "zhanglu153 (Jira)" <ji...@apache.org> on 2026/10/16 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41013) Use a hash consistent with SQL equality to match MAP keys and array elements - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/10/16 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41014) Add an adaptive retry mode to the native S3 connector - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2026/10/16 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41015) [JUnit5 Migration] Migrate the remaining of the junit4 testing class to junit5 of flink-test-utils module. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/10/16 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41016) Missing uids on the operators PyFlink adds for key_by, partition_custom and KeyedStream can prevent submission with auto-generated UIDs disabled - posted by "Sangkyoon Nam (Jira)" <ji...@apache.org> on 2026/10/17 19:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41017) Use DecimalData#isCompact while casting - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/17 22:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41018) Introduce BIT_COUNT as a built-in function for SQL and Table API - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/10/18 04:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41019) COMPILE PLAN does not record table.exec.sink.nested-constraint-enforcer, so EXECUTE PLAN uses the cluster's value - posted by "sepuri sai krishna (Jira)" <ji...@apache.org> on 2026/10/18 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41020) PyFlink docs: Update dependencies with open Dependabot advisories - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/18 17:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41021) Update commons-beanutils to 1.11.0 and jsoup to 1.23.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/18 17:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41022) Update lz4-java to 1.12.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/18 17:15:00 UTC, 0 replies.
- [Flink CDC][Bug] MongoDB CDC recreates change stream cursor from the task's starting offset - posted by Sonal Maheshwari <ga...@gmail.com> on 2026/10/19 06:30:45 UTC, 1 replies.
- [jira] [Created] (FLINK-41024) Upgrade PyFlink docs to Sphinx 9.1 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/19 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41023) Build English and Chinese PyFlink docs from one lockfile - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/19 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41025) Add config option to control enableServiceLinks of JobManager and TaskManager pods - posted by "Guotao Ding (Jira)" <ji...@apache.org> on 2026/10/19 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41026) [format/avro] Convert timestamps above precision 3 as microseconds in both directions - posted by "Pritam Kumar (Jira)" <ji...@apache.org> on 2026/10/19 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41027) [format/avro] Add an option to map time-millis and time-micros to INT and BIGINT - posted by "Pritam Kumar (Jira)" <ji...@apache.org> on 2026/10/19 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41028) Support data lake table properties in the Fluss pipeline sink - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/10/19 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41029) Close operator-owned executors and metric reporters on operator shutdown - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/10/19 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41030) Close operator-owned executors and metric reporters on operator shutdown - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/10/19 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41031) Close operator-owned executors and metric reporters on operator shutdown - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/10/19 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2026/10/19 14:39:00 UTC, 0 replies.
- Cobble-Flink adds async state support for Apache Flink 2.x - posted by Zakelly Lan <za...@gmail.com> on 2026/10/19 14:58:39 UTC, 0 replies.
- [jira] [Created] (FLINK-41033) Savepoint history cleanup disposes the savepoint referenced by status.jobStatus.upgradeSavepointPath, causing restore failures (FileNotFoundException) - posted by "Saurabh Kanawade (Jira)" <ji...@apache.org> on 2026/10/19 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/10/19 18:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41035) Operator health probe reports "All informers are unhealthy" when a single event source fails with stop-on-informer-error=false - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/10/19 19:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41036) [postgres-cdc] Restoring from a checkpoint taken inside a large transaction runs out of heap - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2026/10/19 20:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41037) DISTINCT over a FULL OUTER JOIN drops a row when the grouping key is NULL (batch mode) - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/19 21:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41038) WHERE CAST(x AS DECIMAL(10, 2)) IS NULL returns NULL for x when the cast overflows - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/19 21:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/19 21:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41040) State-Processing SQL reader fails to convert BinaryRowData - posted by "Muhammad (Jira)" <ji...@apache.org> on 2026/10/20 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41041) Maven waits until the time budget after a JDK 8 surefire fork crashes with SIGSEGV in libjvm.so - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41042) TaskExecutorTest.testHeartbeatTimeoutWithJobManager fails in teardown with Boxed InterruptedException - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41044) CommonDataStreamTests.test_logging_msg fails with external log debug-level msg not found - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41043) NettyShuffleMaster.registerJob fails with "HashMap$Node cannot be cast to HashMap$TreeNode" when jobs start concurrently - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41045) unning Kerberized YARN application on Docker test (custom fs plugin)' fails with NoResourceAvailableException because two of three TaskManager containers never register - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41046) HBaseConnectorITCase.testTableSinkDisabledBufferFlush expected [+I[1, 6]] but was [+I[1, 1]] - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41050) Canary health checks revert canary metadata changes and restart a healthy operator - posted by "Dennis-Mircea Ciupitu (Jira)" <ji...@apache.org> on 2026/10/20 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41051) JDBC Table source and lookup function derive the lineage dataset name by parsing SQL - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41052) Helm chart: recreate the operator pod on ConfigMap changes and support annotations on the operator Deployment - posted by "Gerk Elznik (Jira)" <ji...@apache.org> on 2026/10/20 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41053) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint cannot find chk-1 on restore on release-1.20 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/20 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41054) Metrics of finished source splits are never removed from the REST API's metric store - posted by "Diljeet Singh (Jira)" <ji...@apache.org> on 2026/10/20 17:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41055) StreamingMultiJoinOperator stores rows with a NULL join key in state, even though they can never match - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/10/20 18:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41056) Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/20 20:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41057) Iceberg append-only tables incorrectly append before-images from UPDATE and DELETE events - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2026/10/21 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41058) Fluss pipeline sink ignores table options defined in transform rules - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2026/10/21 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41059) FineGrainedSlotManager schedules requirement checks into the main thread after suspend() - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/21 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/21 08:48:00 UTC, 0 replies.
- [REQUEST] Creating versions 2.4.1 and 2.5.0 in Jira - posted by Mika Naylor via dev <de...@flink.apache.org> on 2026/10/21 08:54:06 UTC, 1 replies.
- [jira] [Created] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark - posted by "Han Yin (Jira)" <ji...@apache.org> on 2026/10/21 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41062) PARSE_XML and TRY_PARSE_XML can run out of memory for large documents - posted by "Moritz Manner (Jira)" <ji...@apache.org> on 2026/10/21 09:33:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Ramin Gharib - posted by Timo Walther <tw...@apache.org> on 2026/10/21 10:05:44 UTC, 10 replies.
- [jira] [Created] (FLINK-41063) DataStream large-record sorting unnecessarily falls back to Kryo for payload serialization - posted by "Dominik Dębowczyk (Jira)" <ji...@apache.org> on 2026/10/21 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41064) 'State TTL Heap backend end-to-end test' fails on a "Trying to access closed classloader" log4j error in the TaskManager .out files - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/21 12:44:00 UTC, 0 replies.
- [REQUEST] Unassigned bug/flaky test issues for 2.4 - posted by Mika Naylor via dev <de...@flink.apache.org> on 2026/10/21 13:37:08 UTC, 0 replies.
- [jira] [Created] (FLINK-41065) Improve TypeInferenceUtil for built-in PTFs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2026/10/21 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41066) MultiJoin produces wrong results when an upsert input replaces a record without UPDATE_BEFORE - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/10/21 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41067) Window and interval joins store rows whose join key can never match - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/10/21 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2026/10/21 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41069) Add support for Flink 2.2 to flink-connector-aws - posted by "Muhammad (Jira)" <ji...@apache.org> on 2026/10/21 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41070) Cassandra connector CI fails downloading the Flink 1.19.0 binary - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/21 17:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41071) Upgrade Testcontainers to 1.21.4 in the Cassandra connector to support Docker 29 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/21 17:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41072) Test configuration randomization on GitHub Actions always uses the same seed - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/21 17:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41073) Checkpoint acknowledgement that fails shared state registration is dropped and the checkpoint waits for its timeout - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/21 17:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41074) Blue/green deployment can retire the active deployment using readiness from an older candidate revision - posted by "Luca Castelli (Jira)" <ji...@apache.org> on 2026/10/21 18:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41075) Kill each e2e timeout watchdog when its command ends - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/21 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41076) Bump Netty to 4.2.17.Final in flink-shaded release-21.0 - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/10/21 18:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41077) RpcEndpoint.MainThreadExecutor#schedule swallows exceptions thrown by the scheduled task - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/21 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41078) FineGrainedSlotManager stops scheduling delayed checks after one of them threw - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/21 19:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22 - posted by "Purushottam Sinha (Jira)" <ji...@apache.org> on 2026/10/21 19:29:00 UTC, 0 replies.
- [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink-ci-docker] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2026/10/21 19:35:58 UTC, 5 replies.
- [jira] [Created] (FLINK-41080) [UMBRELLA] Polish Flink CDC docs and enrich contents - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/10/22 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41081) Provide EN / ZH bilingual docs for Flink CDC - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/10/22 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41082) Polish Flink CDC docs and fix format issues - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/10/22 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41083) Add quickstart examples and best practice for Flink CDC docs - posted by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/10/22 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41084) Common & Source-Specific Metrics - posted by "sukang (Jira)" <ji...@apache.org> on 2026/10/22 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41085) AppendOnlyTopNFunction emits an inconsistent changelog after cache eviction when sorting on NaN - posted by "Bettle (Jira)" <ji...@apache.org> on 2026/10/22 07:29:02 UTC, 0 replies.
- [DISCUSS] Trying out the new Apache Trusted Releases by releasing a new Flink-Kafka connector - posted by Martijn Visser <ma...@apache.org> on 2026/10/22 07:29:34 UTC, 2 replies.
- [jira] [Created] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/10/22 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41087) TRY_PARSE_JSON builds the PARSE_JSON error for every row it rejects - posted by "Ramin Gharib (Jira)" <ji...@apache.org> on 2026/10/22 09:23:00 UTC, 0 replies.
- [VOTE] FLIP-616: Materialized Tables support for Table API - posted by Timo Theusner <ti...@gmail.com> on 2026/10/22 13:16:17 UTC, 3 replies.
- [DISCUSS] FLIP-618: Edit, Inspect and Build VARIANT Values - posted by Ramin Gharib <ra...@gmail.com> on 2026/10/22 15:36:33 UTC, 0 replies.
- [DISCUSS] Supporting Flink 2.2/2.3 for flink-connector-aws - posted by M Junaid <m_...@live.com> on 2026/10/22 17:09:05 UTC, 0 replies.
- [jira] [Created] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2026/10/22 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41089) Make cleanup of docker image parallel - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2026/10/22 20:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41090) Operator coordinators of uninitialized vertices are never closed - posted by "Utkarsh Vashishtha (Jira)" <ji...@apache.org> on 2026/10/22 20:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41091) Honor null-entry removal and reject null maps in ForSt asyncPutAll - posted by "Aaron He (Jira)" <ji...@apache.org> on 2026/10/22 21:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41092) RocksDB restore fails with ClassCastException when restoring KEY_VALUE_V2 state metadata from async ForSt - posted by "Aaron He (Jira)" <ji...@apache.org> on 2026/10/22 21:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41093) AsyncKeyedStateBackendAdaptor ignores the TTL config of State V2 descriptors - posted by "Aaron He (Jira)" <ji...@apache.org> on 2026/10/22 22:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41094) ForSt async MapState operations ignore RocksIterator#status() on invalid iterators and close batch iterators across threads - posted by "Aaron He (Jira)" <ji...@apache.org> on 2026/10/22 22:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41095) MapStateAdaptor does not remove keys mapped to null in asyncPut and asyncPutAll - posted by "Aaron He (Jira)" <ji...@apache.org> on 2026/10/22 22:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-41096) Wrong result when a Table with a non-equi correlated scalar subquery is used twice in one query - posted by "Yaoxuan Wu (Jira)" <ji...@apache.org> on 2026/10/22 22:28:00 UTC, 0 replies.