Messages by Thread
-
-
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
-
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
-
Re: [I] [Feature] Support FileEventLog to be stored by default in the FLINK_LOG_DIR directory [flink-agents]
via GitHub
-
[jira] [Comment Edited] (FLINK-39224) Support JSON, JSONB types for PostgreSQL
Yuepeng Pan (Jira)
-
[jira] [Resolved] (FLINK-39224) Support JSON, JSONB types for PostgreSQL
Chanhae Oh (Jira)
-
Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-39589) Window TVF aggregation emits incorrect results with RocksDB state backend
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39589][table] Fix incorrect TVF aggregation results with RocksDB [flink]
via GitHub
-
Re: [PR] [FLINK-30514] Fix HybridSourceReader's method calling order for underlying subsources during source switch [flink]
via GitHub
-
[jira] [Updated] (FLINK-39672) Update doc about Java Records
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39672][docs] Document Java records as supported POJO types [flink]
via GitHub
-
[jira] [Updated] (FLINK-32940) Support projection pushdown to table source for column projections through UDTF
ASF GitHub Bot (Jira)
-
[jira] [Created] (FLINK-39672) Update doc about Java Records
Mingliang Liu (Jira)
-
[PR] Add Kafka Connector 5.0.0 [flink-web]
via GitHub
-
[jira] [Updated] (FLINK-37818) Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings.
Ferenc Csaky (Jira)
-
[jira] [Updated] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause
Ferenc Csaky (Jira)
-
[jira] [Closed] (FLINK-38790) Update Flink Connector Kafka to use Flink 2.2
Ferenc Csaky (Jira)
-
[jira] [Commented] (FLINK-38790) Update Flink Connector Kafka to use Flink 2.2
Ferenc Csaky (Jira)
-
[PR] [FLINK-39660][Connectors/Kinesis] Fix Netty event loop threads blocki… [flink-connector-aws]
via GitHub
-
[jira] [Updated] (FLINK-39670) Bump Flink-controlled Java dependencies to resolve CVEs Part 2 (kafka-clients, okhttp, wiremock)
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-39671) Adopt jackson-bom in flink-model-triton for unified version management
Purushottam Sinha (Jira)
-
[jira] [Updated] (FLINK-39670) Bump Flink-controlled Java dependencies to resolve CVEs Part 2 (kafka-clients, okhttp, zookeeper, wiremock)
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-39670) Bump Flink-controlled Java dependencies to resolve CVEs Part 2 (kafka-clients, okhttp, zookeeper, wiremock)
Purushottam Sinha (Jira)
-
Re: [PR] [FLINK-38233] Adds support to StreamNonDeterministicUpdatePlanVisitor for PTF changelogs [flink]
via GitHub
-
[jira] [Updated] (FLINK-39655) Remove deprecated CatalogLock and ManagedTable APIs (FLIP-346)
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39655][hive] Remove deprecated CatalogLock and ManagedTable APIs (FLIP-346) [flink-connector-hive]
via GitHub
-
[jira] [Updated] (FLINK-39669) BatchPhysicalCorrelateRule / StreamPhysicalCorrelateRule drop right-side projection when a Calc sits between Correlate and TableFunctionScan
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39669][table-planner] BatchPhysicalCorrelateRule / StreamPhysicalCorrelateRule drop right-side projection when a Calc sits between Correlate and TableFunctionScan [flink]
via GitHub
-
[jira] [Created] (FLINK-39669) BatchPhysicalCorrelateRule / StreamPhysicalCorrelateRule drop right-side projection when a Calc sits between Correlate and TableFunctionScan
Venkata krishnan Sowrirajan (Jira)
-
[PR] [build] Bump Flink-controlled deps for CVE fixes (jackson, kafka-clients, okhttp, zookeeper, wiremock) [flink]
via GitHub
-
Re: [PR] [build] Bump Flink-controlled deps for CVE fixes (jackson, kafka-clients, okhttp, zookeeper, wiremock) [flink]
via GitHub
-
Re: [PR] [FLINK-39670][build] Bump Flink-controlled deps for CVE fixes (kafka-clients, okhttp, wiremock) [flink]
via GitHub
-
Re: [PR] [FLINK-39670][build] Bump Flink-controlled deps for CVE fixes (kafka-clients, okhttp, wiremock) [flink]
via GitHub
-
Re: [PR] [build] Update test-scope dependencies (kafka-clients, okhttp, wiremock) [flink]
via GitHub
-
Re: [PR] [build] Update test-scope dependencies (kafka-clients, okhttp, wiremock) [flink]
via GitHub
-
Re: [PR] [build] Update test-scope dependencies (kafka-clients, okhttp, wiremock) [flink]
via GitHub
-
[PR] Add optional_maven_profiles input to python_ci workflow [flink-connector-shared-utils]
via GitHub
-
[jira] [Resolved] (FLINK-39649) REGEXP_EXTRACT plan-time validation and hot-path log cleanup
Sergey Nuyanzin (Jira)
-
[jira] [Assigned] (FLINK-39649) REGEXP_EXTRACT plan-time validation and hot-path log cleanup
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39649) REGEXP_EXTRACT plan-time validation and hot-path log cleanup
Sergey Nuyanzin (Jira)
-
Re: [PR] [Flink-39425] [flink-metrics-otel] OpenTelemetryEventReporter logger fix for missing service.name [flink]
via GitHub
-
Re: [PR] [FLINK-39590] connection catalog manager changes [flink]
via GitHub
-
[jira] [Updated] (FLINK-39656) Remove legacy getTableFactory() override
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39656][hive] Remove deprecated HiveCatalog.getTableFactory() override [flink-connector-hive]
via GitHub
-
[jira] [Assigned] (FLINK-39632) Add fromChangelog() / toChangelog() convenience methods to PartitionedTable
Fabian Hueske (Jira)
-
[jira] [Resolved] (FLINK-39632) Add fromChangelog() / toChangelog() convenience methods to PartitionedTable
Fabian Hueske (Jira)
-
[jira] [Updated] (FLINK-39657) Migrate CatalogTable.of() to CatalogTable.newBuilder()
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-36594][hive]HiveCatalog should set HiveConf.hiveSiteLocation back [flink-connector-hive]
via GitHub
-
[jira] [Assigned] (FLINK-39461) Release Testing Instructions: FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder
Yuepeng Pan (Jira)
-
[PR] [FLINK-39657][hive] Migrate CatalogTable.of() to CatalogTable.newBuilder() [flink-connector-hive]
via GitHub
-
[jira] [Updated] (FLINK-39668) Add get kafka offsets SQL table function
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39668] Add get kafka offsets SQL table function [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-39578][python] Include py.typed in PyFlink distribution [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39668) Add get kafka offsets SQL table function
Gabor Somogyi (Jira)
-
[jira] [Created] (FLINK-39668) Add get kafka offsets SQL table function
Gabor Somogyi (Jira)
-
[PR] [FLINK-39666][table] Fix edge-case bugs in TO_TIMESTAMP_LTZ precision handling [flink]
via GitHub
-
[jira] [Updated] (FLINK-39666) Fix TO_TIMESTAMP_LTZ multiple edge-case bugs in precision handling
ASF GitHub Bot (Jira)
-
[PR] [hotfix] Make PackagingITCase Windows-friendly [flink-connector-opensearch]
via GitHub
-
Re: [PR] [FLINK-28109][elasticsearch] Remove dead .id(key) call in RowElasticsearchEmitter [flink-connector-elasticsearch]
via GitHub
-
[PR] [FLINK-38790] Update to Flink 2.2 [flink-connector-kafka]
via GitHub
-
[jira] [Created] (FLINK-39667) NGINX Ingress Retirement
Dominik (Jira)
-
[PR] [Feature][Integration][Java] Add Milvus vector store integration [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-36781) Flink SQL REPL Remote Gateway lag
ASF GitHub Bot (Jira)
-
[PR] [FLINK-36781][table] Fix SQL REPL lag when using remote gateways [flink]
via GitHub
-
[jira] [Commented] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal
Taranpreet Kaur (Jira)
-
[jira] [Updated] (FLINK-36847) Table API toDataStream() cannot be converted to an enum type field
ASF GitHub Bot (Jira)
-
[PR] [FLINK-36847][table] Fix enum field conversion in Table API to DataStream [flink]
via GitHub