Messages by Thread
-
[jira] [Created] (FLINK-41509) [historyserver] Web dashboard static assets are written flat into historyserver.web.tmpdir instead of a dedicated subdirectory
Chanhae Oh (Jira) via dev
-
[jira] [Created] (FLINK-41508) Support multiple bounded RANGE OVER windows with shared state in streaming SQL
Junfan Zhang (Jira) via dev
-
[jira] [Created] (FLINK-41507) Streaming MAX / MIN above a LEFT JOIN with append-only inputs are planned without retraction and keep retracted values
Yaoxuan Wu (Jira) via dev
-
[jira] [Created] (FLINK-41506) Batch sliding group window planned as a one-phase SortWindowAggregate reads the pane time at the input row's time index
Yaoxuan Wu (Jira) via dev
-
[jira] [Created] (FLINK-41505) Loss-tolerant OperatorEvent that hits a finished task fails the coordinator checkpoint
Rion Williams (Jira) via dev
-
[jira] [Created] (FLINK-41502) Add unit tests for LinkedOptionalMapSerializer
Jubin Soni (Jira) via dev
-
[jira] [Created] (FLINK-41501) Add unit tests for IntArrayList, LongArrayList and BooleanArrayList
Jubin Soni (Jira) via dev
-
[jira] [Created] (FLINK-41504) Add unit tests for the subtask index, flame graph type and termination mode REST query parameters
Jubin Soni (Jira) via dev
-
[jira] [Created] (FLINK-41503) Add unit tests pinning MurmurHashUtil hash values
Jubin Soni (Jira) via dev
-
[jira] [Created] (FLINK-41500) Reject a negative maxExceptions query parameter with 400 instead of failing with 500
Jubin Soni (Jira) via dev
-
[jira] [Created] (FLINK-41499) FLOOR of a TIMESTAMP before 1970 to MONTH, QUARTER, YEAR or WEEK returns a value after the input
Jubin Soni (Jira) via dev
-
[jira] [Created] (FLINK-41498) OceanBase pipeline sink ignores lenient mode and exclude.schema.changes, dropping and truncating target tables
Jubin Soni (Jira) via dev
-
[jira] [Created] (FLINK-41497) flink-python: NOTICE doesn't credit the third-party code bundled in Netty
Purushottam Sinha (Jira) via dev
-
[2.4 Release][summary] sync meeting
Chanhae Oh
-
[jira] [Created] (FLINK-41496) Python Table API thread mode overwrites ROW values inside ARRAY and MAP
Sangkyoon Nam (Jira) via dev
-
[DISCUSS] Flink support for the proposed Parquet SERIALIZED_VALUE type
Neelesh Salian
-
[jira] [Created] (FLINK-41494) Description of table.exec.uid.generation doesn't mention that PTFs always use their uid
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41495) Translate the Table API & SQL state compatibility docs to Chinese
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41493) PTF state restore silently swaps values when POJO fields of the same type change position
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41492) ./mvnw fails the Maven distribution SHA-256 check on macOS in release-1.20, release-2.2 and release-2.3
Sangkyoon Nam (Jira) via dev
-
[VOTE] Release 2.3.1, release candidate #2
fanrui.apache.org via dev
-
[jira] [Created] (FLINK-41490) Support IF EXISTS for ALTER TABLE DROP COLUMN
Muhammad (Jira) via dev
-
[jira] [Created] (FLINK-41491) Support IF EXISTS for ALTER TABLE RENAME COLUMN
Muhammad (Jira) via dev
-
[jira] [Created] (FLINK-41489) Ensure ALTER TABLE SQL commands are idempotent
Muhammad (Jira) via dev
-
[jira] [Created] (FLINK-41485) [mysql][pipeline] Column reordering is not propagated, causing silent field misalignment
Yanquan Lv (Jira) via dev
-
[jira] [Created] (FLINK-41488) Bump OpenLineage, Guava, jackson-bom and the Spanner driver, and remove unneeded dependency pins
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41486) Flink HA checkpoint state handles are published without fsync before node power loss
Elliot Bancroft (Jira) via dev
-
[VOTE] Release 2.2.2, release candidate #2
fanrui.apache.org via dev
-
[jira] [Created] (FLINK-41487) Protobuf options do not support some patterns
Sergey Nuyanzin (Jira) via dev
-
[VOTE] Release 1.20.6, release candidate #3
Rui Fan
-
[jira] [Created] (FLINK-41484) Fix TIMESTAMP_LTZ handling in nested Pandas conversions and thread-mode Python UDFs
Dian Fu (Jira) via dev
-
[jira] [Created] (FLINK-41482) Support AsyncScalarFunction in batch mode
Yiyu Tian (Jira) via dev
-
[jira] [Created] (FLINK-41483) MongoDB Connector does not propagate ordered-writes and bypass-document-validation table options
Jiabao Sun (Jira) via dev
-
[jira] [Created] (FLINK-41481) Add host info into failure enricher
Peter Huang (Jira) via dev
-
[jira] [Created] (FLINK-41480) FailureEnricherUtils logs "[%s]" instead of the duplicate output key
Arvind Kandpal (Jira) via dev
-
[VOTE] FLIP-610: Dynamic Ratelimit in Flink Source
Peter Huang
-
[jira] [Created] (FLINK-41479) Fix typos in user-facing exception messages and config option descriptions
Arvind Kandpal (Jira) via dev
-
[jira] [Created] (FLINK-41478) Change the default of table.exec.sink.require-on-conflict to false
Gustavo de Morais (Jira) via dev
-
[jira] [Created] (FLINK-41477) Overload resolution for overlapping signatures changes between JVM runs
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41476) Calling a procedure with primitive varargs fails with ArrayStoreException
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41471) Add sequence_by to DEDUPLICATE
Gustavo de Morais (Jira) via dev
-
[jira] [Created] (FLINK-41475) Add inactivity to DEDUPLICATE_WINDOW
Gustavo de Morais (Jira) via dev
-
[jira] [Created] (FLINK-41474) Add DEDUPLICATE_WINDOW PTF
Gustavo de Morais (Jira) via dev
-
[jira] [Created] (FLINK-41460) Bump MongoDB 8.0.4 to 8.0.38 to fix CI failure
Jiabao Sun (Jira) via dev
-
[jira] [Created] (FLINK-41473) Add state_ttl and reset_ttl_on_duplicate to DEDUPLICATE
Gustavo de Morais (Jira) via dev
-
[jira] [Created] (FLINK-41470) Add DEDUPLICATE PTF for insert-only input
Gustavo de Morais (Jira) via dev
-
[jira] [Created] (FLINK-41472) Support updating input in DEDUPLICATE
Gustavo de Morais (Jira) via dev
-
[jira] [Created] (FLINK-41465) Health probe reports healthy while the informer receives no events
Dennis-Mircea Ciupitu (Jira) via dev
-
[jira] [Created] (FLINK-41463) Connectors / MongoDB: MongoE2ECase fails intermittently with "pull access denied for flink-configured-taskmanager"
Purushottam Sinha (Jira) via dev
-
[jira] [Created] (FLINK-41467) PyFlink apache-flink package is missing the NOTICE file
Rui Fan (Jira) via dev
-
[jira] [Created] (FLINK-41469) Reduce CI tasks for MongoDB connector
Jiabao Sun (Jira) via dev
-
[jira] [Created] (FLINK-41468) Converting table to materialized table with different partition keys makes existing data unreadable
Mika Naylor (Jira) via dev
-
[jira] [Created] (FLINK-41466) Restored savepoint's CheckpointProperties always report CANONICAL format, regardless of the actual savepoint format
Anton Kalashnikov (Jira) via dev
-
[jira] [Created] (FLINK-41464) JavaCodeSplitter is slow for large generated code
Sergey Nuyanzin (Jira) via dev
-
[jira] [Created] (FLINK-41462) Support MongoDB 9.0
Jiabao Sun (Jira) via dev
-
[jira] [Created] (FLINK-41461) Remove outdated Ryuk image overrides in Elasticsearch connector tests
Wenjin Xie (Jira) via dev
-
[jira] [Created] (FLINK-41458) Autoscaler: Support Max Parallelism For Sources Other Than Kafka And Pulsar
Giannis Polyzos (Jira) via dev
-
[jira] [Created] (FLINK-41459) Documentation Does Not Match The Behaviour Of Health Checks, Periodic Savepoints And Disabling The Autoscaler
Giannis Polyzos (Jira) via dev
-
[jira] [Created] (FLINK-41457) Support configuring refresh policy for bulk requests in Elasticsearch sink
chenzihao (Jira) via dev
-
[jira] [Created] (FLINK-41456) In-flight data of an unaligned checkpoint is silently dropped when its exchange becomes chained after a parallelism change
Guotao Ding (Jira) via dev
-
[jira] [Created] (FLINK-41455) TaskExecutorPartitionLifecycleTest.testEnableBatchJobRecoveryAndNotRetainPartitions depends on the RPC timer firing late
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41454) JDBC backwards compatibility workflow fails because Flink 2.0 and 2.1 SNAPSHOTs are no longer published
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41451) Release Testing: Verify FLIP-497: Early Fire Support for Flink SQL Interval Join
Weiqing Yang (Jira) via dev
-
[jira] [Created] (FLINK-41453) [Phase 3] Native s3 Filesystem
Samrat Deb (Jira) via dev
-
[jira] [Created] (FLINK-41452) Multi-Flink-version compatibility refactor
peiyu (Jira) via dev
-
[jira] [Created] (FLINK-41446) EARLY_FIRE hint makes batch queries fail with "Unknown join strategy : EARLY_FIRE"
Weiqing Yang (Jira) via dev
-
[jira] [Created] (FLINK-41450) Release Testing: Verify FLIP-485: Add UDF Metrics
Weiqing Yang (Jira) via dev
-
[jira] [Created] (FLINK-41449) Two functions with the same name from different databases return the same result in one query
Weiqing Yang (Jira) via dev
-
[jira] [Created] (FLINK-41448) UDF metric group name follows how the function is spelled in the query, so one function can get several groups
Weiqing Yang (Jira) via dev
-
[jira] [Created] (FLINK-41447) An invalid table.exec.udf-metric.sample-interval is accepted at planning and puts the job in a restart loop
Weiqing Yang (Jira) via dev
-
[jira] [Created] (FLINK-41445) Restore and semantic tests skip per-record watermarks when a test schema writes "WATERMARK for" in lower case
Weiqing Yang (Jira) via dev
-
[jira] [Created] (FLINK-41444) Upgrade Cassandra Java Driver to 4.x version
Madhavan (Jira) via dev
-
[jira] [Created] (FLINK-41443) Inner lookup join keeps a stale row when an update moves the join key to a row the lookup table doesn't have
Anton Borisov (Jira) via dev
-
[jira] [Created] (FLINK-41441) Operator silently runs on the JDK HTTP client instead of OkHttp
Dennis-Mircea Ciupitu (Jira) via dev
-
[jira] [Created] (FLINK-41442) Unaligned checkpoint trigger overtakes queued AddSplitEvent, splits lost on restore
Kaivalya Apte (Jira) via dev
-
[jira] [Created] (FLINK-41440) Invalid InputProperty for various StreamExecNodes
Timo Walther (Jira) via dev
-
[jira] [Created] (FLINK-41438) ARRAY, MAP and ROW element access returns -1 instead of NULL when the element type is NOT NULL
Ramin Gharib (Jira) via dev
-
[jira] [Created] (FLINK-41439) XML_STRING can run out of memory for a variant within the size limit
Moritz Manner (Jira) via dev
-
[jira] [Created] (FLINK-41437) Wait until a cancelled materialized table refresh job has stopped
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41436) Planning time grows exponentially with the depth of nested catalog views because CatalogManager re-parses unresolved views on every lookup
Arvid Heise (Jira) via dev
-
[jira] [Created] (FLINK-41435) SecurityUtils.install should be idempotent for equivalent security configurations
LuChengxiang (Jira) via dev
-
[jira] [Created] (FLINK-41434) Fluss CDC source rebuilds the column mapping for every record with an older schema
Xiaobing Fang (Jira) via dev
-
[jira] [Created] (FLINK-41433) Add pages for the regular expression, cast, conditional, window and utility functions
Ramin Gharib (Jira) via dev
-
[jira] [Created] (FLINK-41432) Invalid value for materialized-table.default-start-mode fails with MissingFormatArgumentException
Moritz Manner (Jira) via dev
-
[jira] [Created] (FLINK-41431) RocksDB manual compaction native calls can race with backend disposal
Feifan Wang (Jira) via dev
-
[jira] [Created] (FLINK-41429) Reads are not pinned to an ETag.
Samrat Deb (Jira) via dev
-
[jira] [Created] (FLINK-41430) Add the FlinkError framework and the first TableErrors
Moritz Manner (Jira) via dev
-
[ANNOUNCE] New Apache Flink PMC Member - Yuepeng Pan(RocMarshal)
Rui Fan
-
[jira] [Created] (FLINK-41428) FLIP-620: Structured errors for Table API and SQL
Moritz Manner (Jira) via dev
-
[jira] [Created] (FLINK-41427) s3.upload.max.concurrent.uploads has no effect - multipart part uploads are synchronous
Samrat Deb (Jira) via dev
-
[jira] [Created] (FLINK-41426) Python Table API thread mode fails to convert null ROW fields
Dian Fu (Jira) via dev
-
[jira] [Created] (FLINK-41425) Drop Azure cron build from nightly
Sergey Nuyanzin (Jira) via dev
-
[jira] [Created] (FLINK-41424) ForSt: support dropping keyed state for removed state descriptors
Francis (Jira) via dev
-
[jira] [Created] (FLINK-41423) SinkUpsertMaterializer compares upsert keys with SQL equality instead of bytes and drops rows
Gustavo de Morais (Jira) via dev
-
[jira] [Created] (FLINK-41419) FLIP-622: Add built-in DEDUPLICATE, DEDUPLICATE_WINDOW PTF
Vas Shabu (Jira) via dev
-
[jira] [Created] (FLINK-41420) "Job failed during initialization of JobManager" alert can no longer appear
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41418) TaskManager page keeps showing "no longer registered" after switching to another TaskManager
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41422) Remove the built-in DEDUPLICATE_KEEP_FIRST process table function
Vas Shabu (Jira) via dev
-
[jira] [Created] (FLINK-41415) CommonTestUtils.getLatestCompletedCheckpointPath can return a subsumed checkpoint
Martijn Visser (Jira) via dev
-
[DISCUSS] FLIP-622: Add built-in DEDUPLICATE and DEDUPLICATE_WINDOW PTFs
Vas Shabu
-
[jira] [Created] (FLINK-41421) StateCatalog database names can resolve outside the configured snapshot directories
Luca Castelli (Jira) via dev
-
[jira] [Created] (FLINK-41416) StateFutureUtils#toIterable throws ClassCastException for list and map state with TTL
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41417) TtlMapState async iterators always report isEmpty() as false
Martijn Visser (Jira) via dev
-
[2.4] Release sync meeting summary – 6 November 2026
Sumin Joo
-
[jira] [Created] (FLINK-41414) Add AGENTS.md guidance for adding a built-in function
Ramin Gharib (Jira) via dev
-
[jira] [Created] (FLINK-41413) Connectors / MongoDB: Bump mongodb8.version to 8.0.37+ so CI works on ubuntu-26.04
Purushottam Sinha (Jira) via dev
-
[jira] [Created] (FLINK-41396) Inspect a materialized table's continuous refresh job
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41395) Explain materialized table declarations and refresh pipelines
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41412) Support IF EXISTS for ALTER VIEW, DATABASE, CATALOG and MATERIALIZED TABLE
sepuri sai krishna (Jira) via dev
-
[jira] [Created] (FLINK-41385) Documentation: flink-sql-connector-hive-3.1.3_2.12-2.3.0.jar link in Flink 2.x docs points to non-existent artifact
Yao Zhang (Jira) via dev
-
[jira] [Created] (FLINK-41400) Refresh a materialized table from the Table API
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41411) GROUP BY, DISTINCT and COUNT(DISTINCT) on a BITMAP column are rejected in batch but work in streaming
sepuri sai krishna (Jira) via dev
-
[jira] [Created] (FLINK-41394) Read and derive from a materialized table handle
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41397) Alter a materialized table's query and options with alter()
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41405) Comparing a VARIANT expression with itself bypasses the no-equality check
Ramin Gharib (Jira) via dev
-
[jira] [Created] (FLINK-41410) Push nested field accesses below joins to reduce join shuffle and state size
Fabian Hueske (Jira) via dev
-
[jira] [Created] (FLINK-41409) A view that selects CURRENT_DATE or LOCALTIME without an alias cannot be queried
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41408) Watermark on a computed column inherited through CREATE TABLE LIKE fails validation
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41388) flink-s3-fs-native doesn't list the third-party code bundled in Netty
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41398) Suspend, resume and drop a materialized table through its handle
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41390) Clean up after materialized table refresh-job failures in CREATE and SUSPEND
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41402) Change a materialized table's distribution with alter()
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41406) VARIANT mixed with another type in UNION ALL, CASE or VALUES is cast implicitly
Ramin Gharib (Jira) via dev
-
[jira] [Created] (FLINK-41403) Blue/Green child FlinkDeployments do not inherit the parent's labels, so a label-selector-scoped operator never reconciles them
Noa Ramon (Jira) via dev
-
[jira] [Created] (FLINK-41407) Fix code examples in the documentation that don't work on master
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41404) Blue/Green: after an aborted transition the retry restores the aborted attempt's state instead of the serving deployment's fresh savepoint
Noa Ramon (Jira) via dev
-
[jira] [Created] (FLINK-41401) Evolve a materialized table's schema with alter()
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41399) Convert an existing table into a materialized table with materializeInto
Timo Theusner (Jira) via dev
-
[jira] [Created] (FLINK-41393) Remove the Hadoop 2 compatibility code
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41391) YarnFileStageTestS3ITCase never runs
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41392) Run the YARN Kerberos e2e tests again
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41389) flink-rpc-akka bundles a second copy of the shaded Netty
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41387) Reduce unnecessary ADD COLUMN requests in the Fluss pipeline sink
Xiaobing Fang (Jira) via dev
-
[jira] [Created] (FLINK-41386) Decorrelation fails when a correlated scalar subquery projects a field of a ROW expression
dylanhz (Jira) via dev
-
[jira] [Created] (FLINK-41384) Extra parse methods for JSON and XML functions in CASE branches
Sergey Nuyanzin (Jira) via dev
-
[jira] [Created] (FLINK-41383) REGEXP, REGEXP_EXTRACT and REGEXP_REPLACE look up a constant pattern for every row
Sergey Nuyanzin (Jira) via dev
-
[jira] [Created] (FLINK-41382) Split generated methods can still be too large to be JIT-compiled
Sergey Nuyanzin (Jira) via dev
-
[jira] [Created] (FLINK-41332) COMPILE PLAN fails for a query with a UUID literal
Ramin Gharib (Jira) via dev
-
[jira] [Created] (FLINK-41354) Dispatcher never terminates when it is stopped while a cleanup retry is pending, so the next leader never starts
Mohsen Rezaei (Jira) via dev
-
[jira] [Created] (FLINK-41331) Move python header installation to docker image
Sergey Nuyanzin (Jira) via dev
-
[RESULT][VOTE] FLIP-618: Edit, Inspect and Build VARIANT Values
Ramin Gharib
-
[jira] [Created] (FLINK-41329) Restore tests are absent for all seven Python stream ExecNodes, four of them stateful
sepuri sai krishna (Jira) via dev
-
[jira] [Created] (FLINK-41361) Bound VARIANT object and array sizes by the value length before allocating
Ramin Gharib (Jira) via dev
-
[jira] [Created] (FLINK-41328) GROUP BY, DISTINCT, UNION and a join on a MAP column split one value into several in streaming mode
sepuri sai krishna (Jira) via dev
-
[jira] [Created] (FLINK-41355) Introduce async state version of StreamExecIntervalJoin
Aaron He (Jira) via dev
-
[jira] [Created] (FLINK-41337) Add IS_VARIANT_NULL, VARIANT_TYPE, VARIANT_KEYS and VARIANT_EXISTS
Ramin Gharib (Jira) via dev
-
[PR] [hotfix] Reduce image size [flink-ci-docker]
snuyanzin (via GitHub) via dev
-
[jira] [Created] (FLINK-41362) Reject VARIANT in primary key columns
Ramin Gharib (Jira) via dev
-
[jira] [Created] (FLINK-41381) Use indexed seq for generation the digest of a Calc
Sergey Nuyanzin (Jira) via dev
-
[jira] [Created] (FLINK-41380) Make generated code in case of CASE ... WHEN friendlier to code splitter
Sergey Nuyanzin (Jira) via dev
-
[jira] [Created] (FLINK-41379) Flink on YARN doesn't report missing Kerberos credentials with Hadoop 3
Martijn Visser (Jira) via dev
-
[jira] [Created] (FLINK-41378) Raise the minimum supported Hadoop version to 3.4.3
Martijn Visser (Jira) via dev
-
[DISCUSS] FLIP-621: Add TO_APPEND built-in PTF
Gustavo de Morais
-
[jira] [Created] (FLINK-41303) Web UI job submission fails with long program arguments
sanqingleo (Jira) via dev
-
[jira] [Created] (FLINK-41375) JobManager crash loops are detected only in the back-off phase and reported without the termination reason
Dennis-Mircea Ciupitu (Jira) via dev
-
[jira] [Created] (FLINK-41377) Connectors/Elasticsearch: Update Flink versions in the weekly CI matrix
Purushottam Sinha (Jira) via dev
-
[jira] [Created] (FLINK-41376) Connectors/Elasticsearch: Upgrade Testcontainers so ITCases run on ubuntu-26.04 runners
Purushottam Sinha (Jira) via dev
-
[DISCUSS] FLIP-620: Structured errors for Table API and SQL
Timo Walther via dev