Messages by Thread
-
Re: [PR] [hotfix][docs] Add documentation for building multiple legacy releases on Windowses on Windows [flink]
via GitHub
-
Re: [PR] [FLINK-38735][connector-file] add restore state check [flink]
via GitHub
-
Re: [PR] [FLINK-38695][table-runtime] Fix wrong metric about left cache request count in DeltaJoinCache [flink]
via GitHub
-
Re: [PR] [hotfix] Fix typos [flink]
via GitHub
-
Re: [PR] [FLINK-34015] fix setting execution.savepoint.ignore-unclaimed-state … [flink]
via GitHub
-
Re: [PR] FLINK-38449: Makes error message for fractional values for MemorySize explicit [flink]
via GitHub
-
Re: [PR] [FLINK-38416] bugfix correct constructor arg order [flink]
via GitHub
-
Re: [PR] [docs] Typo fix [flink]
via GitHub
-
Re: [PR] Update README.md for end-to-end tests [flink]
via GitHub
-
Re: [PR] Add AI Documentation Support [flink]
via GitHub
-
Re: [PR] [FLINK-38382][kafka] Support avro primitive types in Confluent Schema Registry binding [flink]
via GitHub
-
Re: [PR] [FLINK-38266][flink-sql-gateway] SQL Gateway - mask sensitive table and catalog options [flink]
via GitHub
-
Re: [PR] [FLINK-38228][table] Respect state TTL in window operator; prevent do… [flink]
via GitHub
-
Re: [PR] [FLINK-36377] [table-planner] Add LAST_VALUE support for ROW, ARRAY, MAP, and RAW types [flink]
via GitHub
-
Re: [PR] [hotfix] Fix watermark javadoc [flink]
via GitHub
-
Re: [PR] [FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN [flink]
via GitHub
-
Re: [PR] [hotfix][docs] Add Kafka-to-Kafka SQL example to documentation [flink]
via GitHub
-
Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink]
via GitHub
-
[jira] [Commented] (FLINK-38153) Documentation has an error
Zhe Wang (Jira)
-
[jira] [Updated] (FLINK-39875) Restore thread interrupt status in ResultStore.processRecord() after catching InterruptedException
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39875][table-gateway] Restore thread interrupt status in ResultStore [flink]
via GitHub
-
[jira] [Commented] (FLINK-39875) Restore thread interrupt status in ResultStore.processRecord() after catching InterruptedException
Jubin Soni (Jira)
-
[jira] [Created] (FLINK-39875) Restore thread interrupt status in ResultStore.processRecord() after catching InterruptedException
Jubin Soni (Jira)
-
[jira] [Commented] (FLINK-39872) Add `wrapInException` into allowed list
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-39872) Add `wrapInException` into allowed list
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39874) NativeS3RecoverableFsDataOutputStream leaks a temp file when the commit-time part upload fails, and uses non-idempotent deletes
Li Guo (Jira)
-
[jira] [Updated] (FLINK-39873) Add null check for connectedSocket in SocketStreamIterator.notifyOfError()
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39873][streaming] Add null check for connectedSocket in `SocketStreamIterator.notifyOfError()` [flink]
via GitHub
-
[jira] [Commented] (FLINK-39873) Add null check for connectedSocket in SocketStreamIterator.notifyOfError()
Jubin Soni (Jira)
-
[jira] [Created] (FLINK-39873) Add null check for connectedSocket in SocketStreamIterator.notifyOfError()
Jubin Soni (Jira)
-
[jira] [Commented] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules
Diljeet Singh (Jira)
-
[jira] [Resolved] (FLINK-39865) Nightly S3 artifact upload consistently fails: travis-ci artifacts uploader is unavailable
Martijn Visser (Jira)
-
[PR] DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService [flink-connector-kafka]
via GitHub
-
[PR] [FLINK-39872][e2e] Add `wrapInExecutionException` to `common.sh` [flink]
via GitHub
-
[jira] [Commented] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-39872) Add `wrapInException` into allowed list
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39846) IPv6HostnamesITCase runs unconditionally and fails on AdaptiveScheduler after JUnit5 migration
Martijn Visser (Jira)
-
[jira] [Resolved] (FLINK-39846) IPv6HostnamesITCase runs unconditionally and fails on AdaptiveScheduler after JUnit5 migration
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-39872) Add `wrapInException` into allowed list
Sergey Nuyanzin (Jira)
-
[jira] [Comment Edited] (FLINK-20746) Support ignore-first-line option for CSV format
Vishal Kamlapure (Jira)
-
[jira] [Commented] (FLINK-20746) Support ignore-first-line option for CSV format
Vishal Kamlapure (Jira)
-
[PR] FLINK-XXXXX: add GROUP BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY <int literal>, GROUP BY ALL, ORDER BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY ALL support [flink]
via GitHub
-
Re: [PR] FLINK-XXXXX: add GROUP BY ALL support [flink]
via GitHub
-
[jira] [Closed] (FLINK-39858) RestClient.close() can leave in-flight request futures uncompleted, hanging the caller
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-39781) Add operator for LATERAL SNAPSHOT Join
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink]
via GitHub
-
[jira] [Closed] (FLINK-39823) SystemTypeInference infers incorrect partition key
Timo Walther (Jira)
-
[jira] [Resolved] (FLINK-39799) Preserve user-typed query text for materialized table and view definitions
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39799) Preserve user-typed query text for materialized table and view definitions
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39857) Upgrade Pekko to 1.6.0
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-39857) Upgrade Pekko to 1.6.0
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39421) Metadata filter push-down for table sources
Sergey Nuyanzin (Jira)
-
[jira] [Assigned] (FLINK-39679) Implicit type conversion fails in code gen
Timo Walther (Jira)
-
[jira] [Created] (FLINK-39871) MinioTestContainerTest fails on JDK 8 CI agents in a non-UTC timezone because testcontainers cannot parse the +08:00 Network.created timestamp
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-39704) JobMasterServiceLeadershipRunner drops globally-terminal result when leadership is lost mid-completion
Matthias Pohl (Jira)
-
[PR] Rebuild website [flink-web]
via GitHub
-
[jira] [Closed] (FLINK-39761) Missing 'Connection: close' header on '304 Not Modified' responses causes proxy connection pool poisoning
Ferenc Csaky (Jira)
-
[PR] [hotfix] Fix some typos for connector-base, protobuf, runtime, table-planner and tests modules. [flink]
via GitHub
-
[jira] [Created] (FLINK-39870) Validate literal regex delimiters at planning time for STR_TO_MAP
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39869) Validate literal charset at planning time for ENCODE and drop the runtime warning
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39868) Remove per-row logging from PARSE_URL and SUBSTRING runtime
Ramin Gharib (Jira)
-
[jira] [Assigned] (FLINK-39868) Remove per-row logging from PARSE_URL and SUBSTRING runtime
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39867) Harden built-in scalar function runtime: remove hot-path logging and validate constant args
Ramin Gharib (Jira)
-
[jira] [Assigned] (FLINK-39867) Harden built-in scalar function runtime: remove hot-path logging and validate constant args
Ramin Gharib (Jira)
-
[jira] [Resolved] (FLINK-39758) Fix DECIMAL OOB in SchemaMergingUtils
Yanquan Lv (Jira)
-
[jira] [Assigned] (FLINK-39758) Fix DECIMAL OOB in SchemaMergingUtils
Leonard Xu (Jira)
-
[jira] [Created] (FLINK-39866) Remove dead KEYVALUE code from SqlFunctionUtils and StringCallGen
Ramin Gharib (Jira)
-
[jira] [Updated] (FLINK-39865) Nightly S3 artifact upload consistently fails: travis-ci artifacts uploader is unavailable
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39865][ci] Replace abandoned travis-ci artifacts uploader with AWS CLI for nightly S3 upload [flink]
via GitHub
-
[jira] [Created] (FLINK-39865) Nightly S3 artifact upload consistently fails: travis-ci artifacts uploader is unavailable
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-39864) ArchUnit ITCase rule flags non-cluster unit tests in flink-core
Purushottam Sinha (Jira)
-
[jira] [Updated] (FLINK-39861) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-filesystems modules
Purushottam Sinha (Jira)
-
[jira] [Updated] (FLINK-39862) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-formats modules
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-39863) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-connector-files
Purushottam Sinha (Jira)
-
[jira] [Closed] (FLINK-38853) Umbrella: FLIP-352: Enhance the standardization of the REST API JSON schema
Yuepeng Pan (Jira)
-
[jira] [Created] (FLINK-39862) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-formats modules
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-39861) Reduce ArchUnit violations: ITCase MiniCluster rule in flink-filesystems modules
Purushottam Sinha (Jira)
-
[jira] [Commented] (FLINK-39481) [tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets
Martijn Visser (Jira)
-
[jira] [Resolved] (FLINK-39652) Improve documentation for regexp functions
Fabian Hueske (Jira)
-
[jira] [Resolved] (FLINK-39650) REGEXP_REPLACE does not validate literal regex patterns at plan time and logs errors on the hot path
Fabian Hueske (Jira)
-
[jira] [Resolved] (FLINK-39821) Make return type of REGEX_REPLACE nullable
Fabian Hueske (Jira)
-
[PR] Timers [flink]
via GitHub
-
Re: [PR] Timers [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
[jira] [Updated] (FLINK-39652) Improve documentation for regexp functions
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39652][docs] Improve documentation for regexp functions [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39652) Improve documentation for regexp functions
Ramin Gharib (Jira)
-
[jira] [Updated] (FLINK-39306) Align the busy-time TRUE_PROCESSING_RATE numerator estimator with the busy-time aggregator
Dennis-Mircea Ciupitu (Jira)
-
[jira] [Updated] (FLINK-39306) Non-source vertices do not use per-second rate metrics, producing inaccurate scaling decisions
Dennis-Mircea Ciupitu (Jira)
-
[PR] [metric] Add key-value metric group for model and action dimensions (#760) [flink-agents]
via GitHub
-
[PR] [bugfix][examples] Point quickstart FileSource at product_review.txt instead of the resources dir [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-39860) Reduce ArchUnit violations: production code must not call @VisibleForTesting methods
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39860][runtime] Reduce ArchUnit violations: production code must not call @VisibleForTesting methods [flink]
via GitHub
-
[I] [Tech Debt] Prompt SafeFormatter brace handling is undocumented and inconsistent with Python f-string convention [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-39860) Reduce ArchUnit violations: production code must not call @VisibleForTesting methods
Purushottam Sinha (Jira)
-
[I] [Tech Debt] Quickstart process_chat_response silently drops output on JSON parse failure [flink-agents]
via GitHub
-
[I] [Tech Debt] Polish yaml doc: inter-resource references, complete alias table, schema re-export, Java-loader symmetry [flink-agents]
via GitHub
-
[I] [Tech Debt] Polish react_agent doc: imports, runnable-example link, tool prerequisite, prompt and output-schema clarifications [flink-agents]
via GitHub
-
[I] [Tech Debt] Polish integrate_with_flink doc: self-contained snippets and language-scoped notes [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-39823) SystemTypeInference infers incorrect partition key
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39823][table] Fix incorrect type inference for typed PTF table args [flink]
via GitHub