Messages by Thread
-
[jira] [Resolved] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes
Yuepeng Pan (Jira) via issues
-
[jira] [Created] (FLINK-41358) Streaming OVER window ordered by a non-time column (RANGE frame) drops all equal rows from the aggregate when one of them is retracted
Yaoxuan Wu (Jira) via issues
-
Re: [PR] [BP-2.4][FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to `RexCall` only in case of `AND` [flink]
flinkbot (via GitHub) via issues
-
Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink]
gustavodemorais (via GitHub) via issues
-
[jira] [Closed] (FLINK-41142) Release Testing Instructions: FLIP-578: In-place Table to Materialized Table conversion
Yuepeng Pan (Jira) via issues
-
[PR] [api][java][python] Propagate user context from request events to responses [flink-agents]
HsbcJone (via GitHub) via issues
-
[jira] [Assigned] (FLINK-41345) Add VARIANT_OBJECT, VARIANT_ARRAY, VARIANT_NULL and TO_VARIANT
Ramin Gharib (Jira) via issues
-
[jira] [Commented] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22
Nic Townsend (Jira) via issues
-
[jira] [Comment Edited] (FLINK-41079) Web dashboard: Update Angular to v22 and ng-zorro-antd to v22
Nic Townsend (Jira) via issues
-
[PR] [hotfix][docs] Fix typos in Hive dialect docs [flink]
arvindKandpal-ksolves (via GitHub) via issues
-
[jira] [Assigned] (FLINK-37381) Typo in Join document
Sergey Nuyanzin (Jira) via issues
-
[PR] [FLINK-41362][table] Reject VARIANT in primary key columns [flink]
raminqaf (via GitHub) via issues
-
[jira] [Closed] (FLINK-40954) Force delete pods stuck Terminating on cluster resource cleanup timeout
Gyula Fora (Jira) via issues
-
[jira] [Created] (FLINK-41363) Make ALTER TABLE ADD statements idempotent
Muhammad (Jira) via issues
-
[jira] [Assigned] (FLINK-41361) Bound VARIANT object and array sizes by the value length before allocating
Ramin Gharib (Jira) via issues
-
[PR] [FLINK-38647][connect/postgres] Support changelog-mode=upsert emitting REPLACE events [flink-cdc]
dev-donghwan (via GitHub) via issues
-
[PR] [FLINK-41361][core] Bound VARIANT object and array sizes by the value… [flink]
raminqaf (via GitHub) via issues
-
[jira] [Updated] (FLINK-41361) Bound VARIANT object and array sizes by the value length before allocating
ASF GitHub Bot (Jira) via issues
-
[PR] [BP-2.4][FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink]
raminqaf (via GitHub) via issues
-
[jira] [Closed] (FLINK-41209) Run and control materialized table refresh jobs from any TableEnvironment
Ramin Gharib (Jira) via issues
-
[I] [Tech Debt][api][runtime][java] Decouple external subagent extension APIs from runtime [flink-agents]
wenjin272 (via GitHub) via issues
-
[PR] [hotfix][ci] Do not run disk clean up if e2e is skipped [flink]
snuyanzin (via GitHub) via issues
-
Re: [I] [runtime][python] Support TaskManager reuse across Flink Agents jobs [flink-agents]
HsbcJone (via GitHub) via issues
-
[jira] [Assigned] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions
Rui Fan (Jira) via issues
-
[PR] [FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to `RexCall` only in case of `AND` [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Commented] (FLINK-40799) ClassCastException in FlinkMarkChangelogNormalizeProgram when an upsert source is read twice with the same boolean column filter
Sergey Nuyanzin (Jira) via issues
-
[jira] [Created] (FLINK-41352) [mongodb] Support change events larger than 16MB with $changeStreamSplitLargeEvent
Sonal Maheshwari (Jira) via issues
-
[jira] [Created] (FLINK-41360) 'raw.line-delimiter' leaves a U+FEFF on each value in UTF-16, does not unescape '\n' and splits on an empty value
Ramin Gharib (Jira) via issues
-
[PR] [hotfix][pipeline-connector/doris] Upgrade Doris connector to 26.3.0 [flink-cdc]
ayers-ltd (via GitHub) via issues
-
Re: [PR] [FLINK-39704][runtime/jobmaster] Preserve globally terminal job result across leadership revocation [flink]
mohsenrezaeithe (via GitHub) via issues
-
[PR] [BP-3.7][docs][paimon] Add MySQL CDC Action migration guide [flink-cdc]
lvyanquan (via GitHub) via issues
-
[jira] [Created] (FLINK-41359) ORC format: filter push-down on a DOUBLE column drops rows when the column holds NaN (orc-core 1.5.6, ORC-629)
Yaoxuan Wu (Jira) via issues
-
[jira] [Commented] (FLINK-37381) Typo in Join document
Arvind Kandpal (Jira) via issues
-
[PR] [FLINK-37381][docs] Fix typo in Join document [flink]
arvindKandpal-ksolves (via GitHub) via issues
-
Re: [PR] [FLINK-34368][fs] Update GCS connector to 3.1.18 [flink]
github-actions[bot] (via GitHub) via issues
-
[PR] [hotfix][table] Treat missing predicates in MetadataFilterPushDownSpec as empty [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Created] (FLINK-41337) Add IS_VARIANT_NULL, VARIANT_TYPE, VARIANT_KEYS and VARIANT_EXISTS
Ramin Gharib (Jira) via issues
-
[I] [Bug][runtime] Checkpoint drain waits for slow actions and escalates checkpoint aborts to task failures [flink-agents]
wenjin272 (via GitHub) via issues
-
Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka]
Admaing (via GitHub) via issues
-
[jira] [Assigned] (FLINK-41348) Merge nested VARIANT modification calls into one pass
Ramin Gharib (Jira) via issues
-
[jira] [Assigned] (FLINK-41344) Add VARIANT_CONTAINS with a shared value-equality rule
Ramin Gharib (Jira) via issues
-
Re: [I] [Feature][YAML] Support model router resource declarations [flink-agents]
wenjin272 (via GitHub) via issues
-
Re: [PR] [docs][examples] Add MySQL to Fluss ingestion example [flink-cdc]
leonardBang (via GitHub) via issues
-
[jira] [Created] (FLINK-41357) FLIP-608: Flink on Ray — Ray Resource Backend For Flink
Zhanghao Chen (Jira) via issues
-
[jira] [Closed] (FLINK-37681) Add benchmark for subclass seder with PojoSerializer in Flink benchmark
Zhanghao Chen (Jira) via issues
-
[jira] [Resolved] (FLINK-37681) Add benchmark for subclass seder with PojoSerializer in Flink benchmark
Zhanghao Chen (Jira) via issues
-
[jira] [Closed] (FLINK-37679) Improve the performance of Flink serialization
Zhanghao Chen (Jira) via issues
-
[jira] [Updated] (FLINK-41334) SQL Gateway JSON results and the JDBC driver cannot return a UUID column
Ramin Gharib (Jira) via issues
-
[PR] [FLINK-41356][table] Support early fire in the async state interval join [flink]
minxhe (via GitHub) via issues
-
Re: [PR] [FLINK-41355][table] Introduce async state version of StreamExecIntervalJoin [flink]
minxhe (via GitHub) via issues
-
[jira] [Updated] (FLINK-41355) Introduce async state version of StreamExecIntervalJoin
ASF GitHub Bot (Jira) via issues
-
[jira] [Commented] (FLINK-41329) Restore tests are absent for all seven Python stream ExecNodes, four of them stateful
sepuri sai krishna (Jira) via issues
-
[jira] [Commented] (FLINK-41331) Move python header installation to docker image
Sergey Nuyanzin (Jira) via issues
-
[PR] [runtime] Share execution identity across action state and graph calls [flink-agents]
wenjin272 (via GitHub) via issues
-
Re: [PR] Fix typo 'refering' to 'referring' in TaskExecutorProcessSpec.java [flink]
snuyanzin (via GitHub) via issues
-
Re: [PR] [BP-2.2][FLINK-41331][ci] Move python header installation to flink-ci-docker [flink]
flinkbot (via GitHub) via issues
-
[PR] [BP-2.3][FLINK-41331][ci] Move python header installation to flink-ci-docker [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Commented] (FLINK-39704) JobMasterServiceLeadershipRunner drops globally-terminal result when leadership is lost mid-completion
Mohsen Rezaei (Jira) via issues
-
[jira] [Commented] (FLINK-41285) Release Testing: Verify FLIP-584: Support Pluggable Storage Backend for HistoryServer
Chanhae Oh (Jira) via issues
-
[jira] [Resolved] (FLINK-41291) Bump snappy-java to 1.1.10.12
Rui Fan (Jira) via issues
-
[PR] [hotfix][test] Run testAcceptingOfferedSlotsWithoutResourceManagerConnected on a single threaded main executor [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Assigned] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view
Ferenc Csaky (Jira) via issues
-
[jira] [Commented] (FLINK-40833) JobManager and TaskManager logs are rolled at startup with log4j 2.25.2 and later
Purushottam Sinha (Jira) via issues
-
Re: [PR] [FLINK-41113][Build] Bump jackson, log4j and assertj [flink-connector-pulsar]
boring-cyborg[bot] (via GitHub) via issues
-
[PR] [FLINK-40955] Give up and remove finalizer after cleanup keeps failing [flink-kubernetes-operator]
gyfora (via GitHub) via issues
-
[jira] [Updated] (FLINK-40955) Give up and remove finalizer after cleanup keeps failing with a timeout
ASF GitHub Bot (Jira) via issues
-
[PR] [BP-3.7][docs] Backport Docusaurus migration and documentation updates [flink-cdc]
yuxiqian (via GitHub) via issues
-
Re: [PR] [FLINK-40052][mysql] Roll back assigner status in addSplits to prevent NPE in createBinlogSplit [flink-cdc]
github-actions[bot] (via GitHub) via issues
-
Re: [PR] [FLINK-40195] helm: use static webhook certificate Secret name [flink-kubernetes-operator]
applike-ss (via GitHub) via issues
-
[jira] [Created] (FLINK-41321) A join on an ARRAY<MAP> key returns no rows, although the same two maps compare equal with =
sepuri sai krishna (Jira) via issues
-
[jira] [Created] (FLINK-41327) Binary IN/NOT IN predicates compare byte arrays by identity in SEARCH point sets
Luo Zhengjie (Jira) via issues
-
[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 issues
-
[jira] [Commented] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink
Yuepeng Pan (Jira) via issues
-
[jira] [Resolved] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink
Yuepeng Pan (Jira) via issues
-
Re: [PR] [FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails [flink]
raminqaf (via GitHub) via issues
-
Re: [PR] [FLINK-40962][table-planner] expose LEAD(TIMESTAMP_LTZ)/LAG(TIMESTAMP_LTZ) in batch mode [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Updated] (FLINK-41014) Add an adaptive retry mode to the native S3 connector
Gabor Somogyi (Jira) via issues
-
[jira] [Resolved] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory
Yuepeng Pan (Jira) via issues
-
[PR] [FLINK-40494][docs] Document the UUID type [flink]
raminqaf (via GitHub) via issues
-
Re: [PR] [FLINK-39615] [docs] Translate changelog.md documentation to Chinese [flink]
RocMarshal (via GitHub) via issues
-
[jira] [Updated] (FLINK-41350) A materialized table left SUSPENDED by a failed table conversion cannot be resumed
Ramin Gharib (Jira) via issues
-
[jira] [Updated] (FLINK-40318) Add a validation entry point for a VARIANT binary
Ramin Gharib (Jira) via issues
-
[jira] [Assigned] (FLINK-41347) Add VARIANT_MERGE
Ramin Gharib (Jira) via issues
-
[jira] [Assigned] (FLINK-41349) Document building and editing VARIANT values in Java
Ramin Gharib (Jira) via issues
-
[jira] [Updated] (FLINK-41331) Move python header installation to docker image
ASF GitHub Bot (Jira) via issues
-
[jira] [Created] (FLINK-41331) Move python header installation to docker image
Sergey Nuyanzin (Jira) via issues
-
[jira] [Commented] (FLINK-41323) Add a binary encoding for a VARIANT column in the raw format
Yuepeng Pan (Jira) via issues
-
[PR] [FLINK-41331][ci] Move python header installation to flink-ci-docker [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Created] (FLINK-41341) Add VARIANT_ARRAY_APPEND and TRY_VARIANT_ARRAY_APPEND
Ramin Gharib (Jira) via issues
-
[PR] chore: update JOSDK to v5.6.3 [flink-kubernetes-operator]
csviri (via GitHub) via issues
-
[jira] [Resolved] (FLINK-41323) Add a binary encoding for a VARIANT column in the raw format
Yuepeng Pan (Jira) via issues
-
[jira] [Comment Edited] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes
Yuepeng Pan (Jira) via issues
-
[jira] [Commented] (FLINK-41281) Allow CAST from a VARIANT timestamp to the other temporal types
Yuepeng Pan (Jira) via issues
-
Re: [I] [Feature] Cross-language (Java/Python) agent spec parity test harness [flink-agents]
HsbcJone (via GitHub) via issues
-
[jira] [Updated] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1)
Samrat Deb (Jira) via issues
-
[jira] [Created] (FLINK-41351) Release Testing: Verify FLIP-578: In-place Table to Materialized Table conversion
Ramin Gharib (Jira) via issues
-
[jira] [Created] (FLINK-41350) A materialized table left SUSPENDED by a failed table conversion cannot be resumed
Ramin Gharib (Jira) via issues
-
[jira] [Updated] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429)
Rui Fan (Jira) via issues
-
[jira] [Comment Edited] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429)
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429)
Rui Fan (Jira) via issues
-
Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport #27505) [flink]
1996fanrui (via GitHub) via issues