Messages by Thread
-
-
Re: [I] [Feature][Java] Support Mem0 Long-Term Memory backend in Java. [flink-agents]
via GitHub
-
Re: [I] [Api][Integration] Support using flink-agents vector store in mem0. [flink-agents]
via GitHub
-
Re: [I] [api][python] Support Agent Skills in python [flink-agents]
via GitHub
-
Re: [PR] [FLINK-39410] The `flink-cdc-pipeline-connector-elasticsearch` module offers better compatibility with Flink 1.20 and Flink 2.x [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-39310][web-ui] Use programArgsList in JSON body instead of program-args query parameter [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39494) Release Testing: Verify FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39386) For Flink 2.x+, support limit the rate at the source
peiyu (Jira)
-
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
-
[PR] [release-0.2][runtime] Backport prune state corner cases around checkpoints [flink-agents]
via GitHub
-
[jira] [Comment Edited] (FLINK-33306) Use observed true processing rate when source metrics are incorrect
Trystan (Jira)
-
[jira] [Commented] (FLINK-33306) Use observed true processing rate when source metrics are incorrect
Trystan (Jira)
-
[jira] [Commented] (FLINK-39625) Support GPU-based model inference via sidecar/actor pattern
Yaroslav Tkachenko (Jira)
-
[jira] [Commented] (FLINK-39626) Extend ResourceProfile to declare GPU resources on TaskManager
featzhang (Jira)
-
[jira] [Commented] (FLINK-39631) Integrate GPU sidecar inference with Table/SQL and provide end-to-end example
featzhang (Jira)
-
[jira] [Commented] (FLINK-39630) Schedule GPU-affinity operators via ResourceManager
featzhang (Jira)
-
[jira] [Commented] (FLINK-39629) Add Async I/O operator that invokes GPU sidecar from DataStream API
featzhang (Jira)
-
[jira] [Commented] (FLINK-39628) Implement asynchronous batched inference RPC in GPU sidecar
featzhang (Jira)
-
[jira] [Commented] (FLINK-39627) Introduce flink-gpu-sidecar module with service skeleton
featzhang (Jira)
-
[jira] [Created] (FLINK-39631) Integrate GPU sidecar inference with Table/SQL and provide end-to-end example
featzhang (Jira)
-
[jira] [Created] (FLINK-39630) Schedule GPU-affinity operators via ResourceManager
featzhang (Jira)
-
[jira] [Created] (FLINK-39628) Implement asynchronous batched inference RPC in GPU sidecar
featzhang (Jira)
-
[jira] [Created] (FLINK-39627) Introduce flink-gpu-sidecar module with service skeleton
featzhang (Jira)
-
[jira] [Created] (FLINK-39626) Extend ResourceProfile to declare GPU resources on TaskManager
featzhang (Jira)
-
[jira] [Created] (FLINK-39625) Support GPU-based model inference via sidecar/actor pattern
featzhang (Jira)
-
[jira] [Created] (FLINK-39629) Add Async I/O operator that invokes GPU sidecar from DataStream API
featzhang (Jira)
-
[jira] [Resolved] (FLINK-39558) LogicalUnnestRule produces incorrect TableFunctionScan rowType, masking nullability and breaking LEFT JOIN UNNEST
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39558) LogicalUnnestRule produces incorrect TableFunctionScan rowType, masking nullability and breaking LEFT JOIN UNNEST
Sergey Nuyanzin (Jira)
-
Re: [PR] [FLINK-39558][table] LogicalUnnestRule: use Calcite Uncollect rowType instead of LogicalType round-trip [flink]
via GitHub
-
Re: [PR] [FLINK-39320] Include Kafka record metadata in deserialization error message [flink-connector-kafka]
via GitHub
-
[PR] Unnest projection and filter pushdown [flink]
via GitHub
-
[jira] [Updated] (FLINK-39624) `TtlListState.asyncGet()` returns a non-null wrapper around a null inner iterator, causing NPE in `onNext`/`isEmpty` when the state is empty
Jira
-
[jira] [Created] (FLINK-39624) `TtlListState.asyncGet()` returns a non-null wrapper around a null inner iterator, causing NPE in `onNext`/`isEmpty` when the state is empty
Jira
-
[jira] [Updated] (FLINK-39607) Add missing Nullable annotation and precondition for config
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39607][s3] Add missing Nullable annotation and precondition for config [flink]
via GitHub
-
Re: [PR] [FLINK-39605][Flink-Formats] Add avro variant confluent format [flink]
via GitHub
-
Re: [PR] [FLINK-39036][formats] Honor microsecond Avro timestamp logical types [flink]
via GitHub
-
[jira] [Commented] (FLINK-39614) Support TO_CHANGELOG: retract stream -> retract stream with set semantics
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-39614) Support TO_CHANGELOG: retract stream -> retract stream with set semantics
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation
Sergey Nuyanzin (Jira)
-
[jira] [Assigned] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-39623) Strict UTF-8 validation in CAST(BYTES AS STRING)
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39623][table-planner] Make CAST(BYTES AS STRING) strict on invalid UTF-8 [flink]
via GitHub
-
[jira] [Created] (FLINK-39623) Strict UTF-8 validation in CAST(BYTES AS STRING)
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39622) [postgres] CustomPostgresSchema re-reads JDBC metadata for every split, causing O(N²) snapshot startup
Jira
-
Re: [PR] [FLINK-39281] Flink Connector redis stream Source [flink-connector-redis-streams]
via GitHub
-
[jira] [Closed] (FLINK-39225) Add retry with default value fallback for triton inference failures
Dian Fu (Jira)
-
Re: [PR] [FLINK-39225][model] Add retry with default value fallback for triton inference failures [flink]
via GitHub
-
Re: [PR] [FLINK-39366][connector-http] Add retry support with exponential backoff for HTTP Sink [flink-connector-http]
via GitHub
-
Re: [PR] [runtime] Fix prune state corner cases around checkpoints [flink-agents]
via GitHub
-
Re: [PR] [tools]Import Wizard for Installation Setup [flink-agents]
via GitHub
-
Re: [PR] [runtime] Support per-event-type configurable log levels for event log [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39450) [release-2.3] Triage release blockers in JIRA
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39448) [release-2.3] Review release notes in JIRA
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39447) [release-2.3] Prepare RC0 release
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39453) [release-2.3] Add release notes
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39452) [release-2.3] Verify that no exclusions were erroneously added to the japicmp plugin
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39449) [release-2.3] Cross-team testing
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39451) [release-2.3] Review and update documentation
Yuepeng Pan (Jira)
-
[PR] [hotfix][build] Bump netty to 4.2.13.Final (CVEs) [flink]
via GitHub
-
Re: [PR] [FLINK-39026][runtime] Remove misleading TODO about isAvailable() overhead [flink]
via GitHub
-
Re: [PR] [optimize] Add isWarnEnabled guard for expensive log construction [flink]
via GitHub
-
Re: [PR] Override Fysnc Calls for HDFS [flink]
via GitHub
-
Re: [PR] [hotfix][docs] Add documentation for building multiple legacy releases on Windowses on Windows [flink]
via GitHub
-
Re: [PR] [FLINK-34015] fix setting execution.savepoint.ignore-unclaimed-state … [flink]
via GitHub
-
Re: [PR] [FLINK-38266][flink-sql-gateway] SQL Gateway - mask sensitive table and catalog options [flink]
via GitHub
-
Re: [PR] [DOCS] List 3rd Party connector for NATS [flink]
via GitHub
-
Re: [PR] [FLINK-38231][python] Standardise use of uv for PyFlink building, testing & linting [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] Bump @modelcontextprotocol/sdk and @angular/cli in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
Re: [PR] [FLINK-38751][runtime] Fix incorrect lastTriggeringTsState cleanup in RowTimeRangeBoundedPrecedingFunction [flink]
via GitHub
-
Re: [PR] [FLINK-39028][state] Use ByteBuffer API to reduce GC pressure in RocksDB state backend [flink]
via GitHub
-
Re: [PR] [FLINK-38783][runtime] Improved TieredStorageResourceRegistry Thread-Safety/Concurrency [flink]
via GitHub
-
Re: [PR] [FLINK-38870] Uninformative error message when job is suspended due to JobManager leadership loss [flink]
via GitHub
-
Re: [PR] [FLINK-36456] feat: Add support to pass Datadog API Key as environment variable [flink]
via GitHub
-
Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink]
via GitHub
-
Re: [PR] [FLINK-38826][table] Add new ArgumentStrategy to support array with specified element type [flink]
via GitHub
-
Re: [PR] [FLINK-38841][table] Enforce expected nullability in FamilyArgumentStrategy [flink]
via GitHub
-
Re: [PR] [FLINK-38735][connector-file] add restore state check [flink]
via GitHub
-
Re: [PR] [FLINK-38793][table] Reuse result of functions if ther are used multiple times as input for other functions [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-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] 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-38253] Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes [flink]
via GitHub
-
Re: [PR] Update README.md for end-to-end tests [flink]
via GitHub
-
Re: [PR] [FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN [flink]
via GitHub
-
Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink]
via GitHub
-
Re: [PR] [hotfix][docs] Add Kafka-to-Kafka SQL example to documentation [flink]
via GitHub
-
Re: [PR] [FLINK-39491][runtime] move lineage Listener creation to Dispatcher [flink]
via GitHub
-
[jira] [Updated] (FLINK-39621) Incremental-snapshot based sources may get stuck in binlog-backfill stage
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39621] Fix incremental-snapshot based sources may get stuck in binlog-backfill stage [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-39621) Incremental-snapshot based sources may get stuck in binlog-backfill stage
Xiqian Yu (Jira)
-
[jira] [Updated] (FLINK-39620) Cumulative window re-emits old windows after recovery due to stale InternalTimerService.currentWatermark in GlobalAggCombiner
haiqingchen (Jira)
-
[jira] [Created] (FLINK-39620) Cumulative window re-emits old windows after recovery due to stale InternalTimerService.currentWatermark in GlobalAggCombiner
haiqingchen (Jira)
-
[PR] [FLINK-39619][docs] Add release notes for Flink 2.3 [flink]
via GitHub