Messages by Thread
-
-
[jira] [Created] (FLINK-39676) Add documentation for specifying Query Creators
Nic Townsend (Jira)
-
[PR] [FLINK-36665][table] Fix WINDOW_START and WINDOW_END to return input … [flink]
via GitHub
-
[PR] [FLINK-35856][table] Upgrade Calcite to 1.37.0 [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39675) http-generic-json-url query param configuration not required.
David Radley (Jira)
-
[jira] [Created] (FLINK-39675) http-generic-json-url query param configuration not required.
David Radley (Jira)
-
[jira] [Commented] (FLINK-22543) layout of exception history tab isn't very usable with Flink SQL
Aleksandr Iushmanov (Jira)
-
[jira] [Updated] (FLINK-22543) layout of exception history tab isn't very usable with Flink SQL
ASF GitHub Bot (Jira)
-
[PR] [FLINK-22543][runtime-web] Fix Exception History table layout broken by long exception strings [flink]
via GitHub
-
Re: [PR] [hotfix][flink-tests] Fix duplicated dependency & plugin [flink]
via GitHub
-
[PR] [runtime] CDC YAML supports inline Python UDF definition [flink-cdc]
via GitHub
-
Re: [PR] [hotfix][flink-connector-base] Fix duplicated dependency & plugin [flink]
via GitHub
-
[jira] [Updated] (FLINK-39674) flink-avro-confluent-registry uses an obsolete schema registry client
Alex Rovner (Jira)
-
[jira] [Created] (FLINK-39674) flink-avro-confluent-registry uses an obsolete schema registry client
Alex Rovner (Jira)
-
[PR] [hotfix] Register all resource types added via Agent.addResource [flink-agents]
via GitHub
-
[jira] [Assigned] (FLINK-39635) [security] Support comma-separated list in security.ssl.protocol
Robert Metzger (Jira)
-
[jira] [Updated] (FLINK-39673) SQL jobs may ignore user-configured claim mode with deprecated config key
Han Yin (Jira)
-
[jira] [Commented] (FLINK-39635) [security] Support comma-separated list in security.ssl.protocol
Robert Metzger (Jira)
-
[jira] [Assigned] (FLINK-39670) Bump Flink-controlled Java dependencies to resolve CVEs Part 2 (kafka-clients, okhttp, wiremock)
Robert Metzger (Jira)
-
[jira] [Assigned] (FLINK-39671) Adopt jackson-bom in flink-model-triton for unified version management
Robert Metzger (Jira)
-
[PR] Update Dockerfiles for 2.2.1 release [flink-docker]
via GitHub
-
[jira] [Closed] (FLINK-39607) Add missing Nullable annotation and precondition for config
Gabor Somogyi (Jira)
-
[jira] [Commented] (FLINK-39607) Add missing Nullable annotation and precondition for config
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-39607) Add missing Nullable annotation and precondition for config
Gabor Somogyi (Jira)
-
[PR] Add GPG key for 2.2.1 release [flink-docker]
via GitHub
-
Re: [PR] [FLINK-38944][benchmark] Introduce a benchmark on adaptive partition selection for RescalePartitioner and RebalancePartitioner [flink-benchmarks]
via GitHub
-
[jira] [Updated] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-39072] Handle InvalidPidMappingException as known failure in KafkaCommitter [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-30068][runtime] Add configurable commit failure strategy for S… [flink]
via GitHub
-
[jira] [Created] (FLINK-39673) SQL jobs may ignore user-configured claim mode with deprecated config key
Han Yin (Jira)
-
[PR] [runtime] Handle notifyCheckpointAborted to stop leaking checkpoint entries [flink-agents]
via GitHub
-
[PR] [runtime] Lock null-store symmetry invariant in DurableExecutionManager [flink-agents]
via GitHub
-
[I] [Bug][runtime] DurableExecutionManager leaks checkpointIdToSeqNums entries on aborted checkpoints [flink-agents]
via GitHub
-
[PR] [infra] Skip spotless in non-lint CI jobs to isolate code-style failures [flink-agents]
via GitHub
-
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