dev  

Messages by Thread

• • 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)
• [Announcement] Flink 2.4 Release Manager Sync Meeting #3 Chanhae Oh
• [jira] [Created] (FLINK-40904) FORWARD-to-REBALANCE downgrade compares producer parallelism with the number of subpartitions instead of the consumer parallelism Rui Fan (Jira)
• [jira] [Created] (FLINK-40903) Add source host info in TM disconnect error Peter Huang (Jira)
• [jira] [Created] (FLINK-40902) LATERAL SNAPSHOT join wrongly rejected when a local filter targets the join key column Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40901) JSON functions return the result of a previous row when JSON_TYPE or JSON_LENGTH is skipped Moritz Manner (Jira)
• [jira] [Created] (FLINK-40899) ON CONFLICT validation masks the NDU error for lookup joins Martijn Visser (Jira)
• [jira] [Created] (FLINK-40900) NDU analyzer does not check predicates pushed into a CDC source Martijn Visser (Jira)
• [jira] [Created] (FLINK-40898) TRY_RESOLVE wrongly rejects non-deterministic filters inside ChangelogNormalize Martijn Visser (Jira)
• [jira] [Created] (FLINK-40891) NDU plan visitor does not propagate determinism requirements through PTFs without REQUIRE_UPDATE_BEFORE Martijn Visser (Jira)
• [jira] [Created] (FLINK-40897) TIMESTAMPDIFF returns wrong results and fails with scala.MatchError for TIME operands sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40896) Add built-in DEDUPLICATE_KEEP_FIRST PTF Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40895) Make use cache in code splitter Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40892) Stale IGNORE override on the changelog PTF tests Martijn Visser (Jira)
• [jira] [Created] (FLINK-40894) Expose counters for unmatched retractions in SinkUpsertMaterializer and KeyedLookupJoinWrapper Martijn Visser (Jira)
• [jira] [Created] (FLINK-40893) Update the determinism page for the current state of the NDU handling Martijn Visser (Jira)
• [jira] [Created] (FLINK-40890) LATERAL SNAPSHOT build side passes TRY_RESOLVE with non-deterministic columns Martijn Visser (Jira)
• [jira] [Created] (FLINK-40889) NDU plan visitor has no branch for VECTOR_SEARCH, TRY_RESOLVE and EXPLAIN PLAN_ADVICE fail Martijn Visser (Jira)
• [jira] [Created] (FLINK-40888) Improve MATCH_RECOGNIZE performance: lazily evaluate DEFINE aggregations and avoid extracting all matched pattern events DongShengHe (Jira)
• [RESULT][VOTE] FLIP-612: Native XML Functions for Flink SQL Moritz Manner
• [jira] [Created] (FLINK-40887) TaskFailureITCase.testJobWithoutObjectReuse fails with "Expecting Optional to contain a value but it was empty" Martijn Visser (Jira)
• [jira] [Created] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Martijn Visser (Jira)
• [jira] [Created] (FLINK-40885) Support LATERAL SNAPSHOT join in the Table API Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40884) Flink configuration breaks when Keystore or Truststore passwords contain specific characters Robert Metzger (Jira)
• [jira] [Created] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction Bonnie Varghese (Jira)
• [jira] [Created] (FLINK-40882) Janino should compile same class only once Sergey Nuyanzin (Jira)
• Release flink-connector-aws [6.1.0] Roberts, Madison via dev
  • Re: Release flink-connector-aws [6.1.0] Ahmed Hamdy
  • Re: Release flink-connector-aws [6.1.0] Andreas Bube via dev
• [jira] [Created] (FLINK-40881) Update Flink wiki with new configs and user guide Peter Huang (Jira)
• [jira] [Created] (FLINK-40880) Support dynamic ratelimit in source coordinator with checkpoint latency control loop Peter Huang (Jira)
• [jira] [Created] (FLINK-40879) Add dynamic ratelimit Flink options Peter Huang (Jira)
• [jira] [Created] (FLINK-40878) Add dynamic rate limit interfaces Peter Huang (Jira)
• [jira] [Created] (FLINK-40877) Support Dynamic Rate Limit in Flink Sources Peter Huang (Jira)
• [jira] [Created] (FLINK-40876) Code splitter should generate same code after repeated runs Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40875) Optimization to let streaming joins fill key-only deletes instead of adding a ChangelogNormalize Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40874) Mini-batch streaming join evaluates non-equi conditions on key-only deletes of folded pairs Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40871) Avoid the UTF-8 round trip when casting strings and decimals to VARIANT Ramin Gharib (Jira)
• [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Ferenc Csaky via dev
  • Re: [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Gustavo de Morais
  • Re: [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Gustavo de Morais
  • Re: [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Mate Czagany
  • Re: [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Gustavo de Morais
  • Re: [DISCUSS] TO_CHANGELOG: Add optional operation column or EXCLUDE projection? Timo Walther
• [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Ferenc Csaky via dev
  • Re: [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Gustavo de Morais
  • Re: [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Krishna Sai
  • Re: [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Ferenc Csaky via dev
  • Re: [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Krishna Sai
  • Re: [DISCUSS] Guidelines for post-FLIP adjustments to built-in PTFs Gustavo de Morais
• [jira] [Created] (FLINK-40873) Fix overlapping config key prefixes in the operator Gyula Fora (Jira)
• [jira] [Created] (FLINK-40872) AsyncExecutionController is never closed. Leak the state backend through the static AsyncRequestBuffer.DELAYER Yordan Pavlov (Jira)
• [jira] [Created] (FLINK-40870) End-to-end test coverage for FlinkMiniCluster Dale Lane (Jira)
• [jira] [Created] (FLINK-40869) Document FlinkMiniCluster and add a MiniCluster example Dale Lane (Jira)
• [jira] [Created] (FLINK-40868) Report operator metrics for FlinkMiniCluster resources Dale Lane (Jira)
• [jira] [Created] (FLINK-40867) Support FlinkStateSnapshot for FlinkMiniCluster jobs Dale Lane (Jira)
• [jira] [Created] (FLINK-40866) Add FlinkMiniClusterController and register the FlinkMiniCluster kind Dale Lane (Jira)
• [jira] [Created] (FLINK-40865) Add the FlinkMiniCluster observer Dale Lane (Jira)
• [jira] [Created] (FLINK-40864) Add the FlinkMiniCluster Flink service and reconciler Dale Lane (Jira)
• [jira] [Created] (FLINK-40863) Derive FlinkMiniCluster memory configuration from spec.resources Dale Lane (Jira)
• [jira] [Created] (FLINK-40862) Generate the MiniCluster pod, Deployment, Service and ConfigMap Dale Lane (Jira)
• [jira] [Created] (FLINK-40861) Add the FlinkMiniCluster custom resource definition and API types Dale Lane (Jira)
• [jira] [Created] (FLINK-40860) Add bin/minicluster.sh to run an application on a MiniCluster Dale Lane (Jira)
• [jira] [Created] (FLINK-40859) FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane (Jira)
• [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Peter Huang
  • Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source David Radley
  • Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Peter Huang
  • Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Zhanghao Chen
  • Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Peter Huang
  • Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Yanquan Lv
  • Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Peter Huang
  • Re: [Discuss] FLIP-XXX: Dynamic Rate Limiting for FLIP-27 Source Weiqing Yang
• [jira] [Created] (FLINK-40853) [postgres] Data loss: LSN commit passes the latest completed checkpoint when the delayed checkpoint has no stream offset kim (Jira)
• [jira] [Created] (FLINK-40858) Streaming join should evaluate non-equi conditions on key-only deletes Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40855) Shut down AWS SDK v1 STS clients after S3 delegation-token acquisition Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40857) Kubernetes Operator always replaces CR status 3 times on reconciliation Mate Czagany (Jira)
• [jira] [Created] (FLINK-40856) Support zip-style multi-column explode in DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40854) Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40852) PARSE_JSON fails with NullPointerException when allowDuplicateKeys is NULL Moritz Manner (Jira)
• [jira] [Created] (FLINK-40851) HybridShuffleITCase NPE in TieredStorageMemoryManagerImpl.release Martijn Visser (Jira)
• [jira] [Created] (FLINK-40850) Fluss sink rejects pre-created primary-key tables with custom bucket keys Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40849) UNION ALL fails for RAW/BITMAP columns with different nullability dylanhz (Jira)
• [jira] [Created] (FLINK-40846) Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase Martijn Visser (Jira)
• [jira] [Created] (FLINK-40847) KafkaDynamicSink#equals/hashCode ignore transactionNamingStrategy Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40848) Derive FlinkDeployment resource usage from pod resource requests Rodrigo Meneses (Jira)
  • Re:[jira] [Created] (FLINK-40848) Derive FlinkDeployment resource usage from pod resource requests z_mmG
• [jira] [Created] (FLINK-40845) VARIANT toString() and result printing still fail on an out-of-range TIME value Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40844) Planner inserting a ghost column when all rows are partition keys Vas Shabu (Jira)
• [jira] [Created] (FLINK-40843) Add StateCatalog documentation Gyula Fora (Jira)
• [jira] [Created] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40841) Streaming outer join with a non-equi condition produces wrong results on upsert input Gustavo de Morais (Jira)
• 来自z_mmG的邮件 z_mmG
• [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Xiqian YU
  • Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Leonard Xu
  • Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Yanquan Lv
  • Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Hang Ruan
  • Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Spoorthi Basu
  • Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Xiqian YU
  • Re: [VOTE] Apache Flink CDC Release 3.7.0, release candidate #1 Lincoln Lee
• [jira] [Created] (FLINK-40840) INSERT with a column list fails when an omitted column is of type BITMAP, RAW or STRUCTURED Ramin Gharib (Jira)
• [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Yanquan Lv
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Hang Ruan
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Krishna Sai
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Zhe Wang
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Zhe Wang
  • Re: [DISCUSS] FLIP-XXX: Store large operator coordinator state outside the checkpoint metadata Spoorthi Basu
• [DISCUSS] FLIP-615: Snapshot Splitters for Table and Database Ingestion Joao Boto
  • Re: [DISCUSS] FLIP-615: Snapshot Splitters for Table and Database Ingestion Krishna Sai
  • Re: [DISCUSS] FLIP-615: Snapshot Splitters for Table and Database Ingestion João Boto
  • Re: [DISCUSS] FLIP-615: Snapshot Splitters for Table and Database Ingestion Krishna Sai
  • Re: [DISCUSS] FLIP-615: Snapshot Splitters for Table and Database Ingestion Chanhae Oh
• [jira] [Created] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP Ramin Gharib (Jira)
• DynamicIcebergSink Open PR - https://github.com/apache/iceberg/pull/17900 Sucheth S
• [jira] [Created] (FLINK-40838) Add a DataStream end-to-end test for the Confluent Schema Registry format Martijn Visser (Jira)
• [jira] [Created] (FLINK-40837) SavepointWriter#changeOperatorIdentifier drops the operator coordinator state Spoorthi Basu (Jira)
• [jira] [Created] (FLINK-40836) Restoring with execution.state-recovery.without-channel-state.checkpoint-id drops operator coordinator state Spoorthi Basu (Jira)
• [jira] [Created] (FLINK-40835) Operator state restore reads state files one byte at a time Spoorthi Basu (Jira)
• [jira] [Created] (FLINK-40830) Reuse jdk getBytes for StringUtf8Utils Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40828) Make VARIANT toString() and result printing never fail Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40833) JobManager and TaskManager logs are rolled at startup with log4j 2.25.2 and later Martijn Visser (Jira)
• [jira] [Created] (FLINK-40834) CI artifacts keep only one of jobmanager.log and jobmanager.log.N for YARN containers Martijn Visser (Jira)
• [jira] [Created] (FLINK-40829) operators hidden by `assign_timestamps_and_watermarks` get no uid, breaking `pipeline.auto-generate-uids: false` Florian Vazelle (Jira)
• [jira] [Created] (FLINK-40832) VariantBuilder.of(BigDecimal) writes malformed or wrong decimals for negative scale or precision/scale > 38 Moritz Manner (Jira)
• [jira] [Created] (FLINK-40831) Mini-batch outer join loses the null-padded row when an input record is updated without UPDATE_BEFORE Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40827) Bump jline to 3.30.17 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40826) Support casting constructed types to VARIANT Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40825) Support casting primitive types to VARIANT Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40824) Support casting to VARIANT Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40823) State Processor API docs do not mention that a checkpoint of a running job can be deleted while it is being read sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40820) Remove the fallback configuration keys from the flink-s3-fs-base module. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40822) Bump maven-compiler-plugin to 3.16.0 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40821) Remove the fallback configuration keys from the flink-avro-confluent-registry module. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40813) Remove the deprecated configuration keys from the flink-clients module. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40819) Remove the fallback configuration keys from the flink-kubernetes module. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40818) Remove the fallback configuration keys from the flink-core module. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40817) Remove the deprecated configuration keys from the flink-yarn module. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40816) Remove the deprecated configuration keys from the flink-kubernetes module. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40814) Remove the deprecated configuration keys from the flink-core module. Yuepeng Pan (Jira)

• Earlier messages
• Later messages