[jira] [Created] (FLINK-35641) ParquetSchemaConverter should correctly handle field optionality

Alex Sorokoumov created FLINK-35641: --- Summary: ParquetSchemaConverter should correctly handle field optionality Key: FLINK-35641 URL: https://issues.apache.org/jira/browse/FLINK-35641 Project: Flink

[jira] [Created] (FLINK-31620) ReducingUpsertWriter does not flush the wrapped writer

Alex Sorokoumov created FLINK-31620: --- Summary: ReducingUpsertWriter does not flush the wrapped writer Key: FLINK-31620 URL: https://issues.apache.org/jira/browse/FLINK-31620 Project: Flink

[jira] [Created] (FLINK-31600) Fix producer leaks in flink-connector-kafka tests

Alex Sorokoumov created FLINK-31600: --- Summary: Fix producer leaks in flink-connector-kafka tests Key: FLINK-31600 URL: https://issues.apache.org/jira/browse/FLINK-31600 Project: Flink Issue

[jira] [Created] (FLINK-31599) Update Kafka dependency in flink-connector-kafka to 3.4.0

Alex Sorokoumov created FLINK-31599: --- Summary: Update Kafka dependency in flink-connector-kafka to 3.4.0 Key: FLINK-31599 URL: https://issues.apache.org/jira/browse/FLINK-31599 Project: Flink

[jira] [Created] (FLINK-31408) Add EXACTLY_ONCE support to upsert-kafka

Alex Sorokoumov created FLINK-31408: --- Summary: Add EXACTLY_ONCE support to upsert-kafka Key: FLINK-31408 URL: https://issues.apache.org/jira/browse/FLINK-31408 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-30564) Select from a new table with Kafka LogStore crashes with UnknownTopicOrPartitionException

Alex Sorokoumov created FLINK-30564: --- Summary: Select from a new table with Kafka LogStore crashes with UnknownTopicOrPartitionException Key: FLINK-30564 URL: https://issues.apache.org/jira/browse/FLINK-30564

[jira] [Created] (FLINK-30326) SQL Client should not create table directory structure

Alex Sorokoumov created FLINK-30326: --- Summary: SQL Client should not create table directory structure Key: FLINK-30326 URL: https://issues.apache.org/jira/browse/FLINK-30326 Project: Flink

[jira] [Created] (FLINK-30317) Create table in FTS catalog with s3 warehouse throws DatabaseNotExistException

Alex Sorokoumov created FLINK-30317: --- Summary: Create table in FTS catalog with s3 warehouse throws DatabaseNotExistException Key: FLINK-30317 URL: https://issues.apache.org/jira/browse/FLINK-30317

[jira] [Created] (FLINK-30091) mvn package verify fails with "Error creating shaded jar: duplicate entry"

Alex Sorokoumov created FLINK-30091: --- Summary: mvn package verify fails with "Error creating shaded jar: duplicate entry" Key: FLINK-30091 URL: https://issues.apache.org/jira/browse/FLINK-30091 Proj

[jira] [Created] (FLINK-29850) Flink Table Store quick start guide does not work

Alex Sorokoumov created FLINK-29850: --- Summary: Flink Table Store quick start guide does not work Key: FLINK-29850 URL: https://issues.apache.org/jira/browse/FLINK-29850 Project: Flink Issue