Messages by Thread
-
Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-40639) Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default
sepuri sai krishna (Jira)
-
Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink]
via GitHub
-
Re: [PR] [FLINK-39668] Add get kafka offsets SQL table function [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-39928][ci] If there are changes in tests only then skip non related CI jobs in GHA [flink]
via GitHub
-
[jira] [Commented] (FLINK-40435) Add explode support to DataFrame API
Bettle (Jira)
-
[jira] [Commented] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes
Bettle (Jira)
-
[jira] [Updated] (FLINK-40420) Add set operations to DataFrame API
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40420][python] Add set operations to DataFrame API [flink]
via GitHub
-
Re: [PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-opensearch]
via GitHub
-
[jira] [Commented] (FLINK-40508) Support DB2 pipeline connector
suntectec (Jira)
-
[PR] [FLINK-40637][table] Expand catalog views hermetically against the view's own database [flink]
via GitHub
-
Re: [PR] [FLINK-20746][csv] Add csv.ignore-first-line for filesystem CSV connector [flink]
via GitHub
-
[jira] [Updated] (FLINK-40637) Catalog view expansion falls back to the session database for unresolved references
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink]
via GitHub
-
[PR] [FLINK-40418][python] Support attribute-based column access on DataFrame [flink]
via GitHub
-
[jira] [Updated] (FLINK-40418) Support attribute-based column access on DataFrame
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-35012][table] Fix flaky ChangelogNormalizeRestoreTest by adding padding records to prevent mini-batch merging [flink]
via GitHub
-
Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka]
via GitHub
-
[jira] [Created] (FLINK-40634) E2E are extremely slow in Azure
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40636) Add Maven/Aether connection timeouts to shared connector CI to avoid 50-minute hangs
Sylwester Lachiewicz (Jira)
-
[jira] [Updated] (FLINK-40638) Add optional custom URL handlers for JobManager and TaskManager logs in the history server
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-40398) flink-connector-kafka DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flakiness
ASF GitHub Bot (Jira)
-
Re: [PR] [runtime][java][skills] Bound download and extraction size [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-40633) Make download-crt-jars.sh maven command agnostic
ASF GitHub Bot (Jira)
-
[jira] [Resolved] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID)
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator
Bob Thomson (Jira)
-
[jira] [Closed] (FLINK-40197) Add sql bindings to DataFrame API
Dian Fu (Jira)
-
[jira] [Updated] (FLINK-30277) Allow PYTHONPATH of Python Worker configurable
Bob Thomson (Jira)
-
[PR] [FLINK-40632][s3] Annotate native-s3-fs to PublicEvolving [flink]
via GitHub
-
[jira] [Updated] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder
Bob Thomson (Jira)
-
[jira] [Closed] (FLINK-34246) Allow only archive failed job to history server
Robert Metzger (Jira)
-
[jira] [Updated] (FLINK-40551) FileMergingChannelStateITCase is very flaky
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-40632) Remove Experimental Annotation of Native S3
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-38262][table] show create connection operation [flink]
via GitHub
-
Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink]
via GitHub
-
[jira] [Updated] (FLINK-17037) add e2e tests for reading array data types from postgres with JDBCTableSource and PostgresCatalog
Bob Thomson (Jira)
-
[jira] [Created] (FLINK-40638) Add optional custom URL handlers for JobManager and TaskManager logs in the history server
Archit Goyal (Jira)
-
[jira] [Assigned] (FLINK-40633) Make download-crt-jars.sh maven command agnostic
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-34246) Allow only archive failed job to history server
Robert Metzger (Jira)
-
[jira] [Commented] (FLINK-40420) Add set operations to DataFrame API
Dian Fu (Jira)
-
[jira] [Created] (FLINK-40633) Make download-crt-jars.sh maven command agnostic
Gabor Somogyi (Jira)
-
[PR] [FLINK-40398][connector/kafka] Inject a clock for retention expiry [flink-connector-kafka]
via GitHub
-
[jira] [Assigned] (FLINK-40592) PrometheusPushGatewayReporter fails to initialize with basic authentication
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40637) Catalog view expansion falls back to the session database for unresolved references
Talat Uyarer (Jira)
-
[jira] [Created] (FLINK-40632) Remove Experimental Annotation of Native S3
Samrat Deb (Jira)
-
[jira] [Updated] (FLINK-40636) Add Maven/Aether connection timeouts to shared connector CI to avoid 50-minute hangs
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-40636][ci] Add Maven and Aether connection timeouts to avoid 50-minute hangs [flink-connector-shared-utils]
via GitHub
-
[jira] [Updated] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom
Purushottam Sinha (Jira)
-
Re: [PR] [FLINK-40557][table] Make operation column optional in `TO_CHANGELOG`… [flink]
via GitHub
-
Re: [PR] [FLINK-40179] Support windowed states in state catalog [flink]
via GitHub
-
[jira] [Updated] (FLINK-39786) closeForCommit() leaks orphan multipart uploads on upload failure
Bob Thomson (Jira)
-
[jira] [Assigned] (FLINK-40420) Add set operations to DataFrame API
Dian Fu (Jira)
-
[jira] [Commented] (FLINK-40197) Add sql bindings to DataFrame API
Dian Fu (Jira)
-
[jira] [Comment Edited] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update
Martijn Visser (Jira)
-
[PR] [FLINK-40493][table] Support casting from VARIANT to UUID [flink]
via GitHub
-
Re: [PR] [FLINK-40617] Bump jackson-bom, log4j, avro, commons, archunit, docker-java-api, guava, javassist, objenesis, snakeyaml, snappy-java [flink-connector-kafka]
via GitHub
-
[jira] [Assigned] (FLINK-40493) VARIANT CAST for UUID (code 20)
Ramin Gharib (Jira)
-
[jira] [Closed] (FLINK-40424) Add windowing TVF support to DataFrame API
Dian Fu (Jira)
-
[PR] [FLINK-40633][s3] Allow overriding the Maven executable in download-crt-jars.sh [flink]
via GitHub
-
[jira] [Updated] (FLINK-33100) Implement YarnJobFetcher for Standalone Autoscaler
Bob Thomson (Jira)
-
[jira] [Updated] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue
Bob Thomson (Jira)
-
[jira] [Created] (FLINK-40635) Test CalcRestoreTest>RestoreTestBase.testRestore failing
Samrat Deb (Jira)
-
[PR] [FLINK-40551][tests] Select the checkpoint to restore by content in FileMergingChannelStateITCase [flink]
via GitHub
-
[jira] [Updated] (FLINK-22091) env.java.home option didn't take effect in resource negotiator
Bob Thomson (Jira)
-
[jira] [Updated] (FLINK-30375) SqlClient leaks flink-table-planner jar under /tmp
Bob Thomson (Jira)
-
[jira] [Updated] (FLINK-30377) CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream
Bob Thomson (Jira)
-
[jira] [Updated] (FLINK-31518) HighAvailabilityServiceUtils resolves wrong webMonitorAddress in Standalone mode
Bob Thomson (Jira)
-
[jira] [Updated] (FLINK-33101) Add the integration test for standalone autoscaler
Bob Thomson (Jira)
-
[jira] [Updated] (FLINK-39581) Document the available config params in a single place for s3 native connector
Bob Thomson (Jira)
-
[jira] [Resolved] (FLINK-40600) Web dashboard: finish Vitest smoke-test coverage and tighten thin specs
Martijn Visser (Jira)
-
Re: [PR] [FLINK-40277][connector-http] Add HTTP sink status-code handling and retries [flink-connector-http]
via GitHub
-
[jira] [Assigned] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID)
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID)
Sergey Nuyanzin (Jira)
-
[PR] [FLINK-40634][ci] Reuse mirror list to prepare faster image [flink]
via GitHub
-
[PR] [hotfix][connect/mysql] Fix potential comparison failure when PK is VARBINARY [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-40634) E2E are extremely slow in Azure
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-40147) Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation
Bob Thomson (Jira)
-
Re: [PR] [FLINK-40597][core] Fix input type validation for Types.UUID [flink]
via GitHub
-
[jira] [Commented] (FLINK-38798) Add Helm chart provenance (.prov) files for flink-kubernetes-operator releases
yongfu.gao (Jira)
-
[PR] [hotfix][runtime] Fix unable to take __data_event_type__ from REPLACE events [flink-cdc]
via GitHub
-
Re: [I] [Feature] Add OpenAI embedding model (Java) [flink-agents]
via GitHub
-
Re: [I] [Feature] Add PostgreSQL pgvector vector store (Java) [flink-agents]
via GitHub
-
[PR] [FLINK-40631][table] Pin `serialVersionUID` in `Variant` [flink]
via GitHub