[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] [Commented] (FLINK-31600) Fix producer leaks in flink-connector-kafka tests

[ https://issues.apache.org/jira/browse/FLINK-31600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704379#comment-17704379 ] Alex Sorokoumov commented on FLINK-31600: - Patches: *

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

[ https://issues.apache.org/jira/browse/FLINK-31599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704378#comment-17704378 ] Alex Sorokoumov commented on FLINK-31599: - Patch -

[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

[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:

[jira] [Commented] (FLINK-30419) Allow tuning of transaction timeout

[ https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678429#comment-17678429 ] Alex Sorokoumov commented on FLINK-30419: - > Do you mean we can have a default value for table

[jira] [Commented] (FLINK-30419) Allow tuning of transaction timeout

[ https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17675768#comment-17675768 ] Alex Sorokoumov commented on FLINK-30419: - Thank you for the feedback [~lzljs3620320]! I looked

[jira] [Commented] (FLINK-30419) Allow tuning of transaction timeout

[ https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655593#comment-17655593 ] Alex Sorokoumov commented on FLINK-30419: - The 1h default comes from

[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] [Commented] (FLINK-30326) SQL Client should not create table directory structure

[ https://issues.apache.org/jira/browse/FLINK-30326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646256#comment-17646256 ] Alex Sorokoumov commented on FLINK-30326: - Hey [Jingsong

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

[ https://issues.apache.org/jira/browse/FLINK-30326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644323#comment-17644323 ] Alex Sorokoumov commented on FLINK-30326: - [~lzljs3620320] [~TsReaper] Could you please comment

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

[ https://issues.apache.org/jira/browse/FLINK-30326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644312#comment-17644312 ] Alex Sorokoumov edited comment on FLINK-30326 at 12/7/22 12:57 PM: --- I

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

[ https://issues.apache.org/jira/browse/FLINK-30326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644312#comment-17644312 ] Alex Sorokoumov commented on FLINK-30326: - I used the following example to conclude that the SQL

[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] [Commented] (FLINK-29876) Explicitly throw exception from Table Store sink when unaligned checkpoint is enabled

[ https://issues.apache.org/jira/browse/FLINK-29876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638252#comment-17638252 ] Alex Sorokoumov commented on FLINK-29876: - Hey [~TsReaper] , Could you please explain why FTS

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

[ https://issues.apache.org/jira/browse/FLINK-29850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Sorokoumov closed FLINK-29850. --- Resolution: Not A Problem > Flink Table Store quick start guide does not work >

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

[ https://issues.apache.org/jira/browse/FLINK-30091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Sorokoumov updated FLINK-30091: Labels: pull-request-available (was: ) > mvn package verify fails with "Error creating

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

[ https://issues.apache.org/jira/browse/FLINK-30091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635943#comment-17635943 ] Alex Sorokoumov commented on FLINK-30091: - PR -

[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

[jira] [Commented] (FLINK-29987) PartialUpdateITCase.testForeignKeyJo is unstable

[ https://issues.apache.org/jira/browse/FLINK-29987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635751#comment-17635751 ] Alex Sorokoumov commented on FLINK-29987: - Thanks! I'll make a PR in the next couple of days.

[jira] [Commented] (FLINK-29987) PartialUpdateITCase.testForeignKeyJo is unstable

[ https://issues.apache.org/jira/browse/FLINK-29987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632274#comment-17632274 ] Alex Sorokoumov commented on FLINK-29987: - As far I understand the flakiness is caused by

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

[ https://issues.apache.org/jira/browse/FLINK-29850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628998#comment-17628998 ] Alex Sorokoumov commented on FLINK-29850: - After debugging this for a bit, I know why this error

[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