Messages by Thread
-
-
[jira] [Created] (FLINK-40509) Move operator defaults out of the Helm chart so config.yaml carries only user-supplied content
Gerk Elznik (Jira)
-
[jira] [Closed] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies
Gabor Somogyi (Jira)
-
[jira] [Commented] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies
Gabor Somogyi (Jira)
-
[PR] [hotfix][docs] Fix AzureTableConfiguration class name casing in Azure Table Storage doc [flink]
via GitHub
-
[PR] Db2 pipeline [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-40508) Support DB2 pipeline connector
suntectec (Jira)
-
Re: [D] [Discussion] Memory Observation Capability Design [flink-agents]
via GitHub
-
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
-
Re: [D] Introduce YAML API [flink-agents]
via GitHub
-
Re: [D] Agent Skills Integration Design [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39977][runtime] Recovery of merged channel state handles [flink]
via GitHub
-
[I] [Bug][runtime] Do not retry or persist interrupted chat calls during job cancellation [flink-agents]
via GitHub
-
[PR] [FLINK-39218] Add CLI tool to manage lingering Kafka transactions [flink-connector-kafka]
via GitHub
-
[D] Design proposal for #1066: dry-run / replay via savepoints [flink-agents]
via GitHub
-
Re: [I] [Feature] Parallel Tool Call Execution [flink-agents]
via GitHub
-
[I] [Feature] Add Agent Trace recording to Event Log [flink-agents]
via GitHub
-
[I] [Feature] Per-agent token/cost budget guardrail (enforcement, not just reporting) [flink-agents]
via GitHub
-
[I] [Feature] Dry-run / replay mode for validating agent behavior against production-shaped state before deploying [flink-agents]
via GitHub
-
[I] [Feature] Human-in-the-loop approval as a first-class, checkpointed Action primitive [flink-agents]
via GitHub
-
[I] [Feature] Cross-language (Java/Python) agent spec parity test harness [flink-agents]
via GitHub
-
[PR] [integrations][java][python] Update stale Anthropic default model to claude-sonnet-4-5 [flink-agents]
via GitHub
-
Re: [PR] [FLINK-39438][MaxCompute] Add support for sink operation types in MaxCompute options [flink-cdc]
via GitHub
-
[jira] [Resolved] (FLINK-40498) Adjust tests to call SNAPSHOT without TABLE keyword
Fabian Hueske (Jira)
-
[jira] [Updated] (FLINK-36605) Upgrade Debezium version to 2.7.x
ASF GitHub Bot (Jira)
-
[PR] [FLINK-36605] Bump debezium to last 2.x version [flink-cdc]
via GitHub
-
[PR] [FLINK-40507] Upgrade paimon to 2.0.0 [flink-cdc]
via GitHub
-
[PR] [hotfix] Remove redundant autoscaler Plugin discovery [flink-kubernetes-operator]
via GitHub
-
[I] [Umbrella] Pluggable model routing (MODEL_ROUTER): delivery status, Python parity, documentation, and follow-ups [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-40507) upgrade paimon to 2.0.0
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-40467) Flink 2.3 Application Mode managed by the kubernetes operator can start without submitting the new job after savepoint redeploy
ASF GitHub Bot (Jira)
-
[jira] [Commented] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support
Nithish (Jira)
-
[jira] [Commented] (FLINK-20578) Cannot create empty array using ARRAY[]
Nithish (Jira)
-
[PR] [FLINK-40467] Randomise application result store paths [flink-kubernetes-operator]
via GitHub
-
[jira] [Resolved] (FLINK-40241) Support VARIANT as column type in the 'raw' format
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3
James Kan (Jira)
-
[jira] [Created] (FLINK-40507) upgrade paimon to 2.0.0
peiyu (Jira)
-
[PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator]
via GitHub
-
[PR] [FLINK-40506][s3] Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies [flink]
via GitHub
-
[PR] [FLINK-40486][table] Introduce the UUID logical type [flink]
via GitHub
-
[jira] [Closed] (FLINK-40366) INSERT INTO with a column list or static partition fails for set-semantic PTFs
Gustavo de Morais (Jira)
-
[jira] [Commented] (FLINK-40241) Support VARIANT as column type in the 'raw' format
Sergey Nuyanzin (Jira)
-
Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka]
via GitHub
-
[jira] [Updated] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR
ASF GitHub Bot (Jira)
-
[jira] [Assigned] (FLINK-40505) SourceCoordinator never removes failed or reset subtasks from watermark-alignment aggregation
Martijn Visser (Jira)
-
[PR] [FLINK-40497][table] Allow materialized tables to default to ON CONFLICT DO ERROR [flink]
via GitHub
-
[jira] [Updated] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies
Gabor Somogyi (Jira)
-
[jira] [Created] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies
Gabor Somogyi (Jira)
-
[jira] [Assigned] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies
Gabor Somogyi (Jira)
-
[PR] [FLINK-40505][runtime] Prune failed subtasks from watermark alignment [flink]
via GitHub
-
[jira] [Assigned] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40503) WatermarksWithIdleness effective timeout is idleTimeout plus up to 3 probe intervals, contradicting the withIdleness documentation
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40503][core] Document effective idleness detection timing [flink]
via GitHub
-
[jira] [Updated] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-40505) SourceCoordinator never removes failed or reset subtasks from watermark-alignment aggregation
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink]
via GitHub
-
[jira] [Updated] (FLINK-37666) Address CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation
Roman Khachatryan (Jira)
-
[jira] [Closed] (FLINK-37666) Address CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation
Roman Khachatryan (Jira)
-
[jira] [Updated] (FLINK-40197) Add sql bindings to DataFrame API
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40197][python] Add sql() to the DataFrame API [flink]
via GitHub
-
[jira] [Updated] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40503) WatermarksWithIdleness effective timeout is idleTimeout plus up to 2× the periodic probe interval, contradicting the withIdleness documentation
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40505) SourceCoordinator never removes failed or reset subtasks from watermark-alignment aggregation
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40502) scan.watermark.idle-timeout is silently ignored for connectors without watermark pushdown; SOURCE_WATERMARK() ignores idle-timeout entirely
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40500) DataStream V2 idleness detection is not backpressure-aware - FLIP-471 was never applied to ExtractEventTimeProcessFunction
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40501) WatermarkStatus overtakes queued watermarks in AsyncWaitOperator, causing watermark loss downstream
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE
Martijn Visser (Jira)
-
Re: [PR] [FLINK-40357][table] Add ARRAY_FLATTEN function to Flink SQL [flink]
via GitHub
-
[jira] [Updated] (FLINK-40498) Adjust tests to call SNAPSHOT without TABLE keyword
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40498][tests] Adjust LateralSnapshotJoin tests for optional TABLE keyword [flink]
via GitHub
-
[jira] [Updated] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE ignores query column position, silently producing a schema whose column order disagrees with the query (ALTER ... AS is correct)
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40496][table-planner] CREATE OR ALTER MATERIALIZED TABLE honors query column position [flink]
via GitHub
-
[jira] [Created] (FLINK-40498) Adjust tests to call SNAPSHOT without TABLE keyword
Fabian Hueske (Jira)
-
Re: [PR] [FLINK-39789] AvroSchemaConverter updates for local-timestamp-* and timestamp-nanos logical types [flink]
via GitHub
-
[jira] [Assigned] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE ignores query column position, silently producing a schema whose column order disagrees with the query (ALTER ... AS is correct)
Arvid Heise (Jira)
-
[jira] [Resolved] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x
Martijn Visser (Jira)
-
[jira] [Resolved] (FLINK-39780) Make TABLE keyword optional in LATERAL context
Fabian Hueske (Jira)
-
[jira] [Updated] (FLINK-40422) Add slicing APIs to DataFrame API
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40422][python] Add slicing APIs to DataFrame API [flink]
via GitHub
-
Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents]
via GitHub
-
[PR] Multimodal content blocks [flink-agents]
via GitHub
-
[PR] [ci][integrations] Consolidate vector store tests [flink-agents]
via GitHub
-
[I] [Feature] Multimodal content blocks in ChatMessage [flink-agents]
via GitHub