dev  

Messages by Thread

• [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 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-41051) JDBC Table source and lookup function derive the lineage dataset name by parsing SQL Martijn Visser (Jira)
• [jira] [Created] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart Martijn Visser (Jira)
• [jira] [Created] (FLINK-41055) StreamingMultiJoinOperator stores rows with a NULL join key in state, even though they can never match Rion Williams (Jira)
• [jira] [Created] (FLINK-41054) Metrics of finished source splits are never removed from the REST API's metric store Diljeet Singh (Jira)
• [jira] [Created] (FLINK-41052) Helm chart: recreate the operator pod on ConfigMap changes and support annotations on the operator Deployment Gerk Elznik (Jira)
• [jira] [Created] (FLINK-41043) NettyShuffleMaster.registerJob fails with "HashMap$Node cannot be cast to HashMap$TreeNode" when jobs start concurrently Martijn Visser (Jira)
• [jira] [Created] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Martijn Visser (Jira)
• [jira] [Created] (FLINK-41053) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint cannot find chk-1 on restore on release-1.20 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41050) Canary health checks revert canary metadata changes and restart a healthy operator Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused Martijn Visser (Jira)
• [jira] [Created] (FLINK-41046) HBaseConnectorITCase.testTableSinkDisabledBufferFlush expected [+I[1, 6]] but was [+I[1, 1]] Martijn Visser (Jira)
• [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 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41044) CommonDataStreamTests.test_logging_msg fails with external log debug-level msg not found Martijn Visser (Jira)
• [jira] [Created] (FLINK-41042) TaskExecutorTest.testHeartbeatTimeoutWithJobManager fails in teardown with Boxed InterruptedException Martijn Visser (Jira)
• [jira] [Created] (FLINK-41041) Maven waits until the time budget after a JDK 8 surefire fork crashes with SIGSEGV in libjvm.so Martijn Visser (Jira)
• [jira] [Created] (FLINK-41040) State-Processing SQL reader fails to convert BinaryRowData Muhammad (Jira)
• [jira] [Created] (FLINK-41026) [format/avro] Convert timestamps above precision 3 as microseconds in both directions Pritam Kumar (Jira)
• [jira] [Created] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41038) WHERE CAST(x AS DECIMAL(10, 2)) IS NULL returns NULL for x when the cast overflows Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41037) DISTINCT over a FULL OUTER JOIN drops a row when the grouping key is NULL (batch mode) Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty Biao Geng (Jira)
• [jira] [Created] (FLINK-41036) [postgres-cdc] Restoring from a checkpoint taken inside a large transaction runs out of heap Mohsen Rezaei (Jira)
• [jira] [Created] (FLINK-41031) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41030) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41035) Operator health probe reports "All informers are unhealthy" when a single event source fails with stop-on-informer-error=false Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41027) [format/avro] Add an option to map time-millis and time-micros to INT and BIGINT Pritam Kumar (Jira)
• [jira] [Created] (FLINK-41029) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match Rion Williams (Jira)
• [jira] [Created] (FLINK-41033) Savepoint history cleanup disposes the savepoint referenced by status.jobStatus.upgradeSavepointPath, causing restore failures (FileNotFoundException) Saurabh Kanawade (Jira)
• Cobble-Flink adds async state support for Apache Flink 2.x Zakelly Lan
• [jira] [Created] (FLINK-41024) Upgrade PyFlink docs to Sphinx 9.1 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41023) Build English and Chinese PyFlink docs from one lockfile Martijn Visser (Jira)
• [jira] [Created] (FLINK-41028) Support data lake table properties in the Fluss pipeline sink Hongshun Wang (Jira)
• [jira] [Created] (FLINK-41025) Add config option to control enableServiceLinks of JobManager and TaskManager pods Guotao Ding (Jira)
• [Flink CDC][Bug] MongoDB CDC recreates change stream cursor from the task's starting offset Sonal Maheshwari
  • Re: [Flink CDC][Bug] MongoDB CDC recreates change stream cursor from the task's starting offset Xiqian YU
• [jira] [Created] (FLINK-41021) Update commons-beanutils to 1.11.0 and jsoup to 1.23.2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41022) Update lz4-java to 1.12.0 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41020) PyFlink docs: Update dependencies with open Dependabot advisories Martijn Visser (Jira)
• [jira] [Created] (FLINK-41019) COMPILE PLAN does not record table.exec.sink.nested-constraint-enforcer, so EXECUTE PLAN uses the cluster's value sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-41018) Introduce BIT_COUNT as a built-in function for SQL and Table API Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41017) Use DecimalData#isCompact while casting Sergey Nuyanzin (Jira)
• [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 Sangkyoon Nam (Jira)
• [jira] [Created] (FLINK-41013) Use a hash consistent with SQL equality to match MAP keys and array elements Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41015) [JUnit5 Migration] Migrate the remaining of the junit4 testing class to junit5 of flink-test-utils module. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41014) Add an adaptive retry mode to the native S3 connector Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-41012) Schema change apply failure leads to unrecoverable crash loop: redundant skip + null evolved schema leak after job restart zhanglu153 (Jira)
• [jira] [Created] (FLINK-41011) [pipeline-connector/doris] Auto-created Doris table drops NOT NULL constraint of source columns tchivs (Jira)
• [jira] [Created] (FLINK-41010) [cdc-base] NPE in HybridSplitAssigner.createStreamSplit when failed snapshot splits are re-added after assigner finished tchivs (Jira)
• [jira] [Created] (FLINK-41009) Use a single Pulsar transaction per checkpoint in the Pulsar sink Yubiao Feng (Jira)
• [jira] [Created] (FLINK-41008) Support multi-table transaction stream load in StarRocks pipeline connector peiyu (Jira)
• [jira] [Created] (FLINK-41007) ON CONFLICT clause is silently ignored when table.exec.sink.upsert-materialize is NONE sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-41006) upgrade starrocks connector to 1.2.16 peiyu (Jira)
• [jira] [Created] (FLINK-41005) MiniCluster should clean up partially started services when start() fails Dale Lane (Jira)
• [jira] [Created] (FLINK-41004) Column expansion does not work with REQUIRE_ON_TIME trait Timo Walther (Jira)
• [jira] [Created] (FLINK-41003) Bump Pulsar version to 4.0.14 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-41002) Move test-only defaults out of MiniClusterConfiguration Dale Lane (Jira)
• [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject Jacky Lau
  • Re: [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject Zhang Chaoming
  • Re: [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject Ran Tao
  • Re: [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject Jacky Lau
  • Re: [DISCUSS] Flink Native Engine StreamFusion Based On DataFusion As Flink SubProject Yong Liu
• [jira] [Created] (FLINK-41001) OpenAI model provider rejects compatible string input types Liu Liu (Jira)
• [DISCUSS] Flink CDC 3.8 Kick Off Yanquan Lv
  • Re: [DISCUSS] Flink CDC 3.8 Kick Off Xiqian YU
  • Re: [DISCUSS] Flink CDC 3.8 Kick Off Leonard Xu
• [jira] [Created] (FLINK-40997) Streaming join picks a random state key among equal-length upsert keys Mate Czagany (Jira)
• [DISCUSS] Release flink-connector-pulsar v5.0.0 Ferenc Csaky via dev
  • Re: [DISCUSS] Release flink-connector-pulsar v5.0.0 Mate Czagany
  • Re: [DISCUSS] Release flink-connector-pulsar v5.0.0 Leonard Xu
  • Re: [DISCUSS] Release flink-connector-pulsar v5.0.0 Ferenc Csaky via dev
• [jira] [Created] (FLINK-41000) Pulsar 5.0 support Hongbo Miao (Jira)
• [jira] [Created] (FLINK-40999) [cdc-composer] Factory JAR path resolution fails with "URI is not hierarchical" for relative usrlib paths in application mode wind.wang (Jira)
• [jira] [Created] (FLINK-40998) Web dashboard: Update dependencies with open Dependabot advisories Martijn Visser (Jira)
• [jira] [Created] (FLINK-40996) Make TRY_PARSE_JSON, PARSE_JSON reuse parsed json Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40995) Draft pull requests are not excluded from the community review label scan sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40994) Upgrade paimon to 2.1.0 peiyu (Jira)
• [jira] [Created] (FLINK-40993) State Processor API writes an unrestorable savepoint from a checkpoint taken with file merging sepuri sai krishna (Jira)
• [DISCUSS] A New Flink Native Engine StreamFusion Based On DataFusion Jacky Lau
• [jira] [Created] (FLINK-40992) Allow spec.job.parallelism to take effect when spec.taskManager.replicas is set, to support standby TaskManagers in standalone mode Tomoyuki NAKAMURA (Jira)
• [jira] [Created] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Tomoyuki NAKAMURA (Jira)
• [jira] [Created] (FLINK-40990) MySQL CDC source suppresses terminal missing-schema errors and keeps checkpointing without CDC Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-40988) Bump JUnit to 5.14 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40989) MAP equality compares numeric values by reference Martijn Visser (Jira)
• [jira] [Created] (FLINK-40987) Allow overriding or disabling a table's watermark per table reference via OPTIONS hint Gustavo de Morais (Jira)
• [REMINDER] Flink 2.4 feature freeze planned for 20 October Sumin Joo
• [jira] [Created] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Biao Geng (Jira)
• [jira] [Created] (FLINK-40985) [Iceberg] Support per-table location override in Iceberg pipeline sink VISHAL B (Jira)
• [jira] [Created] (FLINK-40984) Port the batch aggregate ITCases in flink-table-planner to Java Martijn Visser (Jira)
• [jira] [Created] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee Rango (Jira)
• [jira] [Created] (FLINK-40982) Fluss pipeline sink fails to recover when an ADD COLUMN event is replayed Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks Martijn Visser (Jira)
• [jira] [Created] (FLINK-40978) Cast from VARIANT through FromVariantConverter Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40975) FlinkBushyJoinReorderRule drops or misplaces join conditions, producing wrong results Hanyu Zheng (Jira)
• [jira] [Created] (FLINK-40977) ForSt JUnit 5 migration is incomplete Martijn Visser (Jira)
• [jira] [Created] (FLINK-40973) Fluss source fails on retriable errors during periodic table discovery Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40974) HadoopIOFormatsITCase#testJobWithObjectReuse runs without object reuse Martijn Visser (Jira)
• [jira] [Created] (FLINK-40979) HashAggITCase only runs its inherited tests without adaptive local hash aggregation Martijn Visser (Jira)
• [jira] [Created] (FLINK-40981) ParameterizedTestExtension should fail tests that it does not parameterize Martijn Visser (Jira)
• [jira] [Created] (FLINK-40980) JsonRowDataSerDeSchemaTest array tests don't cover the JsonParser deserializer Martijn Visser (Jira)
• [jira] [Created] (FLINK-40976) JoinToMultiJoinForReorderRule applies a post-join filter twice when merging joins for reorder Hanyu Zheng (Jira)
• [jira] [Created] (FLINK-40972) In case of IdentityCastRule CodeGen still produces dummy classes Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases Martijn Visser (Jira)
• [jira] [Created] (FLINK-40969) Rescale details endpoint returns 404 for latest events evicted from AdaptiveScheduler history Hao Yu (Jira)
• Help with Confluence account creation Sumin Joo
  • Re: Help with Confluence account creation Rui Fan
  • Re: Help with Confluence account creation Sumin Joo
• [SUMMARY] Flink 2.4 Release Sync - 09.10.26 Sumin Joo
• [DISCUSS] Flink Community Skills Rui Fan
  • Re: [DISCUSS] Flink Community Skills Purushottam Sinha
  • Re: [DISCUSS] Flink Community Skills Krishna Sai
  • Re: [DISCUSS] Flink Community Skills Gustavo de Morais
• [ANNOUNCE] Apache Flink CDC 3.7.0 released Xiqian YU
  • Re: [ANNOUNCE] Apache Flink CDC 3.7.0 released Leonard Xu
  • Re: [ANNOUNCE] Apache Flink CDC 3.7.0 released Yanquan Lv
• [RESULT][VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Xiqian YU
• [DISCUSS] Apache Flink 1.20.6 release Rui Fan
• [DISCUSS] Apache Flink 2.2.2 release Rui Fan
• [DISCUSS] Apache Flink 2.3.1 release Rui Fan
• [DISCUSS] FLIP-617: Support Pluggable REST Handler Extensions Yunfeng Zhou
  • Re: [DISCUSS] FLIP-617: Support Pluggable REST Handler Extensions Gen Luo
  • Re: [DISCUSS] FLIP-617: Support Pluggable REST Handler Extensions Yunfeng Zhou
• [jira] [Created] (FLINK-40968) Accept map() as op_mapping in Table API toChangelog() and fromChangelog() Timo Theusner (Jira)
• [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner
  • Re:[DISCUSS] FLIP-616: Materialized Tables support for Table API Xuyang
  • Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner
  • Re:Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Xuyang
  • Re: Re: [DISCUSS] FLIP-616: Materialized Tables support for Table API Timo Theusner
• [jira] [Created] (FLINK-40967) Restore test files of OVER_AGGREGATE_TIME_BOUNDED_NON_PARTITIONED_ROWS_WITH_OUT_OF_ORDER_RECORDS cannot be regenerated Martijn Visser (Jira)
• A New Flink Native Engine StreamFusion Based On DataFusion Jacky Lau
  • Re: A New Flink Native Engine StreamFusion Based On DataFusion Jacky Lau
• [jira] [Created] (FLINK-40966) Reuse Fluss metadata clients across schema operations Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40965) Treat IF as conditional function in code gen Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) Sumaiya Azad (Jira)
• [jira] [Created] (FLINK-40963) Add support for DATE and TIME conversion to JSON Saketh Kurnool (Jira)
• [jira] [Created] (FLINK-40962) LAG() unsupported for TIMESTAMP_LTZ arguments in batch mode Saketh Kurnool (Jira)
• [jira] [Created] (FLINK-40956) Fall back to stateless delete when savepoint on deletion keeps failing Gyula Fora (Jira)
• [jira] [Created] (FLINK-40961) Support NOTIFY_STATEFUL_SETS Timo Walther (Jira)
• [jira] [Created] (FLINK-40960) [JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40959) Batch sort can emit unsorted rows if comparator implementation is long enough to be split Mate Czagany (Jira)
• [VOTE] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Vas Shabu
  • Re: [VOTE] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Gustavo de Morais
  • Re: [VOTE] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Timo Walther
  • Re: [VOTE] FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Fabian Hueske
• [jira] [Created] (FLINK-40958) VARIANT might fail with StackOverflow Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40957) MongoDB CDC encodes spaces as '+' instead of '%20' in credentials luana (Jira)
• [jira] [Created] (FLINK-40955) Give up and remove finalizer after cleanup keeps failing with a timeout Gyula Fora (Jira)
• [jira] [Created] (FLINK-40954) Force delete pods stuck Terminating on cluster resource cleanup timeout Gyula Fora (Jira)
• [jira] [Created] (FLINK-40953) Store the native S3 recoverable writer tail under the target directory Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-40952) ForSt: rescale restore never closes the temporary DB's DBOptions copy, leaking the slot-shared block cache Yordan Pavlov (Jira)
• [jira] [Created] (FLINK-40951) Sync Chinese docs of Flink source connectors with English docs peiyu (Jira)
• [jira] [Created] (FLINK-40950) EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with unexpected output Martijn Visser (Jira)
• [jira] [Created] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null." Martijn Visser (Jira)
• [jira] [Created] (FLINK-40948) Planner crashes with "Type mismatch" when a window aggregate groups on the nullable side of an outer window join Martijn Visser (Jira)
• [jira] [Created] (FLINK-40947) ROLLUP / CUBE / GROUPING SETS with () return no grand-total row on an empty input Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40946) SUM / AVG on DECIMAL(38, s) over a join are rounded to scale 6 Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40945) -0.0 and 0.0 are different keys in GROUP BY, DISTINCT, UNION and hash joins Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40936) Built-in functions compare VARIANT array elements and map keys by their binary encoding Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40944) CPU limit-factor inflates the JVM's availableProcessors() to the CPU limit Jira
• [DISCUSS] config providers for Flink? Dale Lane via dev
• [jira] [Created] (FLINK-40937) UPDATE fails with IndexOutOfBoundsException when a SET value's type doesn't match the column Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40941) Add warmup for janino Sergey Nuyanzin (Jira)
• [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) Jira
• [jira] [Created] (FLINK-40942) NativeS3FileSystem#getFileStatus fails with "Key cannot be empty" for bucket-root paths Jira
• [jira] [Created] (FLINK-40940) HTTP lookup source drops the row for a failed call with continue-on-error unless the planner calls applyReadableMetadata Arvid Heise (Jira)
• [jira] [Created] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Mohsen Rezaei (Jira)
• [jira] [Created] (FLINK-40938) Support AT_TIMESTAMP feature in DynamDB Streams connector Abhi Gupta (Jira)
• [jira] [Created] (FLINK-40939) TRY_RESOLVE accepts non-deterministic join keys and join conditions on updating inputs with a unique key Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40935) VAR_SAMP / STDDEV_SAMP return -1 for a group with a single row Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40934) Table API row() fails when AS aliases produce duplicate field names Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40932) Arm state schema evolution for ListState and MapState of RowData Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40929) SUM on DECIMAL silently returns a wrong, order-dependent value after an overflow Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40930) MIN/MAX on FLOAT/DOUBLE return NaN only if NaN is the first input row (order-dependent result) Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40928) DISTINCT over a cross join with an IS NULL filter returns rows with NULL that are not in the input Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40927) Inconsistent NaN semantics for FLOAT/DOUBLE across planner and runtime Yahya Kisana (Jira)
• [jira] [Created] (FLINK-40926) Projection push down records a ReadingMetadata ability without metadata keys Arvid Heise (Jira)
• [jira] [Created] (FLINK-40925) JobVertexBackPressureHandler throws NoSuchElementException when execution attempts are pruned concurrently Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40924) table.exec.sink.upsert-materialize=NONE silently bypasses the require-on-conflict check sepuri sai krishna (Jira)
• [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) Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40922) DISTINCT over GROUP BY ROLLUP returns duplicate rows Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40921) Invoke statebackend's close() and dispose() in right order Zakelly Lan (Jira)
• [jira] [Created] (FLINK-40920) SELECT 1 / (2 + 3) fails with ClassCastException: RexCall cannot be cast to RexLiteral in ExpressionReducer Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40919) AVG on INT returns wrong result when the planner rewrites it into SUM/COUNT (INT sum overflows) Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-40918) SIGTERM during application-mode HA recovery permanently fails the suspended jobs of a PyFlink application Ian Stewart (Jira)
• [DISCUSS] Maintenance status and plans for several Flink repositories Aleksandr Savonin
• [jira] [Created] (FLINK-40917) Deeply nested VARIANT values overflow the stack in toJson(), CAST to STRING and the variant builder Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations Isaac Montenegro Jimenez (Jira)
• [jira] [Created] (FLINK-40915) Relax non-deterministic join-condition check for LATERAL SNAPSHOT join Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40914) Support partial updates on LATERAL SNAPSHOT join build side Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40913) CheckpointSyncPhaseTimeoutITCase failures race Efrat Levitan (Jira)
• [jira] [Created] (FLINK-40912) ExactlyOnceKafkaWriter never closes the AdminClient it creates for the listing abort strategy Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40911) Variant builder mishandles a nested variant and a value of exactly 16 MiB Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40910) Reject VARIANT where SQL needs equality. Byte comparison gives wrong results in GROUP BY, DISTINCT, joins and = Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40909) Support filter push down for element access on ARRAY, MAP and VARIANT (ITEM) Arvid Heise (Jira)
• [jira] [Created] (FLINK-40908) HBaseITCase.test fails with expected: <6> but was: <0> Martijn Visser (Jira)
• [jira] [Created] (FLINK-40907) HBaseITCase.test cannot build the HBase image, hbase-2.6.6 tarball gone from dlcdn Martijn Visser (Jira)
• [jira] [Created] (FLINK-40906) DataFrameWindowITTests.test_hop_window_aggregation fails with a DispatcherGateway.submitJob timeout Martijn Visser (Jira)
• [jira] [Created] (FLINK-40905) Bump Pekko to 1.7.1 Sergey Nuyanzin (Jira)

• Earlier messages