Messages by Thread
-
-
[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
-
[D] Introduce YAML API [flink-agents]
via GitHub
-
[PR] Bump org.apache.logging.log4j:log4j-core from 2.25.0 to 2.25.4 [flink-connector-kafka]
via GitHub
-
[jira] [Created] (FLINK-39666) Fix TO_TIMESTAMP_LTZ multiple edge-case bugs in precision handling
Ramin Gharib (Jira)
-
[jira] [Updated] (FLINK-39568) Decouple YAML built-in AI Function and model providers
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39568] YAML built-in AI Function and model providers overhaul [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-39464) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Timo Walther (Jira)
-
[PR] [hotfix] Update ci run flink versions [flink-connector-elasticsearch]
via GitHub
-
[jira] [Commented] (FLINK-39224) Support JSON, JSONB types for PostgreSQL
Yuepeng Pan (Jira)
-
Re: [PR] [FLINK-39224] Support PostgreSQL JSON, JSONB type [flink-connector-jdbc]
via GitHub
-
[jira] [Updated] (FLINK-39224) Support JSON, JSONB types for PostgreSQL
Yuepeng Pan (Jira)
-
Re: [PR] [feature] Enable EventLog display in WebUI by default [flink-agents]
via GitHub
-
[jira] [Closed] (FLINK-39644) Upgrade aws sdk version to 2.44.x to add enhanced S3 Transfer Manager performance
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-39644) Upgrade aws sdk version to 2.44.x to add enhanced S3 Transfer Manager performance
Gabor Somogyi (Jira)
-
[jira] [Commented] (FLINK-39644) Upgrade aws sdk version to 2.44.x to add enhanced S3 Transfer Manager performance
Gabor Somogyi (Jira)
-
[jira] [Assigned] (FLINK-39644) Upgrade aws sdk version to 2.44.x to add enhanced S3 Transfer Manager performance
Gabor Somogyi (Jira)
-
[jira] [Updated] (FLINK-39664) Support ALTER MATERIALIZED TABLE ... SET FRESHNESS = ... conversion
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39665) Support ALTER MATERIALIZED TABLE ... SET REFRESH_MODE = FULL | CONTINUOUS conversion
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39664) Support ALTER MATERIALIZED TABLE ... SET FRESHNESS = ... conversion
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39663) Support ALTER MATERIALIZED TABLE ... RESET ('k') conversion
Ramin Gharib (Jira)
-
Re: [PR] [FLINK-39252][pipeline-connector/sqlserver] Add SQL Server pipeline connector [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-39661) Support all converters for standalone ALTER MATERIALIZED TABLE statements
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39662) Support ALTER MATERIALIZED TABLE ... SET ('k' = 'v') conversion
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39661) Support all converters for standalone ALTER MATERIALIZED TABLE statements
Ramin Gharib (Jira)
-
[jira] [Commented] (FLINK-39122) Decimals with incorrect precision lead to null value in PTF
Timo Walther (Jira)
-
[I] [Feature][integration][Java] Java Implementation of Vector Store with Milvus Support [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-37147) The where condition run time advance caused a program error
Qilong Wang (Jira)
-
Re: [D] Agent Skills Investigation [flink-agents]
via GitHub
-
Re: [D] Memory Framework Investigation [flink-agents]
via GitHub
-
Re: [D] Planning Flink Agents 0.2 [flink-agents]
via GitHub
-
Re: [PR] [FLINK-38477][runtime] Add FINISHED watermark status to support proper watermark aggregation [flink]
via GitHub
-
Re: [PR] [FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function [flink]
via GitHub