Messages by Thread
-
-
[jira] [Commented] (FLINK-40167) Add EARLY_FIRE join hint surface and option validation
Weiqing Yang (Jira)
-
[jira] [Created] (FLINK-40174) Document the EARLY_FIRE hint for interval joins
Weiqing Yang (Jira)
-
[jira] [Created] (FLINK-40173) Add restore coverage for early-fire interval join
Weiqing Yang (Jira)
-
[jira] [Created] (FLINK-40172) Support processing-time early fire on a row-time interval join
Weiqing Yang (Jira)
-
[jira] [Created] (FLINK-40171) Emit and retract early-fire results in the interval join operator
Weiqing Yang (Jira)
-
[jira] [Created] (FLINK-40170) Infer update-producing changelog mode for early-fire interval join
Weiqing Yang (Jira)
-
[jira] [Updated] (FLINK-40169) Add target option to the EARLY_FIRE hint
Weiqing Yang (Jira)
-
[jira] [Created] (FLINK-40169) Add target option to the EARLY_FIRE hint
Weiqing Yang (Jira)
-
[jira] [Created] (FLINK-40167) Add EARLY_FIRE join hint surface and option validation
Weiqing Yang (Jira)
-
[jira] [Created] (FLINK-40168) Thread the EARLY_FIRE hint into the interval join
Weiqing Yang (Jira)
-
Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink]
via GitHub
-
Re: [PR] [api][integrations] Support models' native structured output (foundation + OpenAI) [flink-agents]
via GitHub
-
Re: [D] [Discussion] Pluggable model routing — API & design (PR #852 follow-up) [flink-agents]
via GitHub
-
Re: [I] [Bug] create_model_from_java_tool_schema_str crashes on a Java tool param without a description [flink-agents]
via GitHub
-
Re: [PR] [FLINK-38997] Fix StateTransitionManager stuck in Transitioning phase on failed transition [flink]
via GitHub
-
Re: [PR] [FLINK-23140][docs] Fix SourceFunction documentation link [flink]
via GitHub
-
Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink]
via GitHub
-
[jira] [Commented] (FLINK-40166) SQL query parsing fails if current catalog is unreachable
Dale Lane (Jira)
-
[jira] [Updated] (FLINK-40166) SQL query parsing fails if current catalog is unreachable
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40166][table] SQL query parsing fails if current catalog unreachable [flink]
via GitHub
-
[jira] [Created] (FLINK-40166) SQL query parsing fails if current catalog is unreachable
Dale Lane (Jira)
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink]
via GitHub
-
Re: [PR] [FLINK-39523] Checkpoint coordination during recovery (memory-based trigger) [flink]
via GitHub
-
[jira] [Comment Edited] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot
Weiqing Yang (Jira)
-
[jira] [Commented] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot
Weiqing Yang (Jira)
-
Re: [PR] [FLINK-37925][table] Reject out-of-range VARIANT casts and make VARIANT-to-string a value cast [flink]
via GitHub
-
[PR] [infra] Add a coding-agent development skill [flink-agents]
via GitHub
-
[I] [Feature] Add a coding-agent development skill for Flink Agents applications [flink-agents]
via GitHub
-
[PR] [BP-2.3][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink]
via GitHub
-
[PR] [BP-2.2][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink]
via GitHub
-
[PR] [BP-2.1][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink]
via GitHub
-
[PR] [BP-2.0][FLINK-40157][state/ForSt] Fix MapState putAll value serialization [flink]
via GitHub
-
Re: [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
-
[jira] [Resolved] (FLINK-39522) Rework StreamTask channel-state recovery into an async future chain; start consumption only after filtering completes
Rui Fan (Jira)
-
[jira] [Commented] (FLINK-40020) Flink 2.3: update reference data for migration tests
David Anderson (Jira)
-
Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents]
via GitHub
-
Re: [PR] [BP-2.0][FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink]
via GitHub