[jira] [Commented] (FLINK-38143) Pyflink flat YAML based config support is broken

[ https://issues.apache.org/jira/browse/FLINK-38143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010107#comment-18010107 ] Gabor Somogyi commented on FLINK-38143: --- [{{e92ba2d}}|https://github.com/apache/fl

[jira] [Closed] (FLINK-38143) Pyflink flat YAML based config support is broken

[ https://issues.apache.org/jira/browse/FLINK-38143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-38143. - > Pyflink flat YAML based config support is broken > ---

[jira] [Resolved] (FLINK-38143) Pyflink flat YAML based config support is broken

[ https://issues.apache.org/jira/browse/FLINK-38143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-38143. --- Resolution: Fixed > Pyflink flat YAML based config support is broken > -

[jira] [Commented] (FLINK-38143) Pyflink flat YAML based config support is broken

[ https://issues.apache.org/jira/browse/FLINK-38143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010108#comment-18010108 ] Gabor Somogyi commented on FLINK-38143: --- [{{7f0a676}}|https://github.com/apache/fl

[jira] [Commented] (FLINK-38143) Pyflink flat YAML based config support is broken

[ https://issues.apache.org/jira/browse/FLINK-38143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18009958#comment-18009958 ] Gabor Somogyi commented on FLINK-38143: --- FYI [~fcsaky]  > Pyflink flat YAML based

[jira] [Created] (FLINK-38143) Pyflink flat YAML based config support is broken

Gabor Somogyi created FLINK-38143: - Summary: Pyflink flat YAML based config support is broken Key: FLINK-38143 URL: https://issues.apache.org/jira/browse/FLINK-38143 Project: Flink Issue Type

[jira] [Updated] (FLINK-38143) Pyflink flat YAML based config support is broken

[ https://issues.apache.org/jira/browse/FLINK-38143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38143: -- Priority: Critical (was: Major) > Pyflink flat YAML based config support is broken >

[jira] [Assigned] (FLINK-38143) Pyflink flat YAML based config support is broken

[ https://issues.apache.org/jira/browse/FLINK-38143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-38143: - Assignee: Gabor Somogyi > Pyflink flat YAML based config support is broken > --

[jira] [Closed] (FLINK-38018) Migrate state processor API from sink API v1 to sink API v2

[ https://issues.apache.org/jira/browse/FLINK-38018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-38018. - Fix Version/s: 2.2.0 Resolution: Fixed [{{d24c746}}|https://github.com/apache/flink/commi

[jira] [Commented] (FLINK-38023) State Restoration fails when using GenericRecord with new Avro schema

[ https://issues.apache.org/jira/browse/FLINK-38023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17987069#comment-17987069 ] Gabor Somogyi commented on FLINK-38023: --- Can you please give a minimal test in Fli

[jira] [Commented] (FLINK-38004) Release Testing Instructions: Verify FLIP-522: Add generalized type information to SQL state connector

[ https://issues.apache.org/jira/browse/FLINK-38004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17987062#comment-17987062 ] Gabor Somogyi commented on FLINK-38004: --- There are automated tests for this which

[jira] [Commented] (FLINK-38003) Release Testing Instructions: Verify FLIP-512:Add meta information to SQL state connector

[ https://issues.apache.org/jira/browse/FLINK-38003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17987063#comment-17987063 ] Gabor Somogyi commented on FLINK-38003: --- There are automated tests for this which

[jira] [Commented] (FLINK-38002) Release Testing Instructions: Verify FLIP-496: SQL connector for keyed savepoint data

[ https://issues.apache.org/jira/browse/FLINK-38002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17987064#comment-17987064 ] Gabor Somogyi commented on FLINK-38002: --- There are automated tests for this which

[jira] [Updated] (FLINK-36929) SQL connector for keyed savepoint data

[ https://issues.apache.org/jira/browse/FLINK-36929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-36929: -- Release Note: SQL Connector for Reading Keyed Savepoint State As part of this release, Flink

[jira] [Assigned] (FLINK-38018) Migrate state processor API from sink API v1 to source API v2

[ https://issues.apache.org/jira/browse/FLINK-38018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-38018: - Assignee: Gabor Somogyi > Migrate state processor API from sink API v1 to source API v2

[jira] [Created] (FLINK-38018) Migrate state processor API from sink API v1 to source API v2

Gabor Somogyi created FLINK-38018: - Summary: Migrate state processor API from sink API v1 to source API v2 Key: FLINK-38018 URL: https://issues.apache.org/jira/browse/FLINK-38018 Project: Flink

[jira] [Updated] (FLINK-38018) Migrate state processor API from sink API v1 to sink API v2

[ https://issues.apache.org/jira/browse/FLINK-38018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-38018: -- Summary: Migrate state processor API from sink API v1 to sink API v2 (was: Migrate state proc

[jira] [Closed] (FLINK-37851) Migrate state processor API from source API v1 to source API v2

[ https://issues.apache.org/jira/browse/FLINK-37851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37851. - > Migrate state processor API from source API v1 to source API v2 >

[jira] [Resolved] (FLINK-37851) Migrate state processor API from source API v1 to source API v2

[ https://issues.apache.org/jira/browse/FLINK-37851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37851. --- Fix Version/s: 2.2.0 Resolution: Fixed [{{99e4594}}|https://github.com/apache/flink/c

[jira] [Commented] (FLINK-37953) Add OBF password obfuscation support for SSL configurations

[ https://issues.apache.org/jira/browse/FLINK-37953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17970350#comment-17970350 ] Gabor Somogyi commented on FLINK-37953: --- I've added a comment to the PR. I'm wonde

[jira] [Resolved] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master

[ https://issues.apache.org/jira/browse/FLINK-37884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37884. --- Fix Version/s: 2.1.0 Resolution: Fixed > ArchitectureTest ConnectorRules.CONNECTOR_CL

[jira] [Closed] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master

[ https://issues.apache.org/jira/browse/FLINK-37884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37884. - > ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API > fails on master > -

[jira] [Commented] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master

[ https://issues.apache.org/jira/browse/FLINK-37884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17956731#comment-17956731 ] Gabor Somogyi commented on FLINK-37884: --- [{{7a1cc51}}|https://github.com/apache/fl

[jira] [Created] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master

Gabor Somogyi created FLINK-37884: - Summary: ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master Key: FLINK-37884 URL: https://issues.apache.org/jira/browse/FLINK-37884

[jira] [Assigned] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master

[ https://issues.apache.org/jira/browse/FLINK-37884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37884: - Assignee: Gabor Somogyi > ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND

[jira] [Resolved] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data

[ https://issues.apache.org/jira/browse/FLINK-37857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37857. --- Resolution: Fixed > Add a DSV2 sink implementation to tests which can collect data > ---

[jira] [Closed] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data

[ https://issues.apache.org/jira/browse/FLINK-37857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37857. - > Add a DSV2 sink implementation to tests which can collect data > -

[jira] [Updated] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data

[ https://issues.apache.org/jira/browse/FLINK-37857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-37857: -- Fix Version/s: 2.1.0 > Add a DSV2 sink implementation to tests which can collect data > --

[jira] [Commented] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data

[ https://issues.apache.org/jira/browse/FLINK-37857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954864#comment-17954864 ] Gabor Somogyi commented on FLINK-37857: --- [{{a4e3084}}|https://github.com/apache/fl

[jira] [Closed] (FLINK-37858) Migrate state processor API from source v1 to source v2 API

[ https://issues.apache.org/jira/browse/FLINK-37858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37858. - Resolution: Duplicate > Migrate state processor API from source v1 to source v2 API > --

[jira] [Created] (FLINK-37858) Migrate state processor API from source v1 to source v2 API

Gabor Somogyi created FLINK-37858: - Summary: Migrate state processor API from source v1 to source v2 API Key: FLINK-37858 URL: https://issues.apache.org/jira/browse/FLINK-37858 Project: Flink

[jira] [Created] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data

Gabor Somogyi created FLINK-37857: - Summary: Add a DSV2 sink implementation to tests which can collect data Key: FLINK-37857 URL: https://issues.apache.org/jira/browse/FLINK-37857 Project: Flink

[jira] [Created] (FLINK-37851) Migrate state processor API from source API v1 to source API v2

Gabor Somogyi created FLINK-37851: - Summary: Migrate state processor API from source API v1 to source API v2 Key: FLINK-37851 URL: https://issues.apache.org/jira/browse/FLINK-37851 Project: Flink

[jira] [Updated] (FLINK-37411) Introduce the rollback mechanism for Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-37411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-37411: -- Fix Version/s: kubernetes-operator-1.13.0 (was: kubernetes-operator-1.12

[jira] [Closed] (FLINK-36767) Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0

[ https://issues.apache.org/jira/browse/FLINK-36767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-36767. - Resolution: Fixed > Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0 > --

[jira] [Assigned] (FLINK-36767) Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0

[ https://issues.apache.org/jira/browse/FLINK-36767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-36767: - Assignee: Siddharth R > Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0 > -

[jira] [Resolved] (FLINK-37674) Add generalized type information to SQL state connector

[ https://issues.apache.org/jira/browse/FLINK-37674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37674. --- Fix Version/s: 2.1.0 Resolution: Fixed [{{79254c1}}|https://github.com/apache/flink/c

[jira] [Closed] (FLINK-37674) Add generalized type information to SQL state connector

[ https://issues.apache.org/jira/browse/FLINK-37674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37674. - > Add generalized type information to SQL state connector >

[jira] [Created] (FLINK-37674) Add generalized type information to SQL state connector

Gabor Somogyi created FLINK-37674: - Summary: Add generalized type information to SQL state connector Key: FLINK-37674 URL: https://issues.apache.org/jira/browse/FLINK-37674 Project: Flink Iss

[jira] [Assigned] (FLINK-37674) Add generalized type information to SQL state connector

[ https://issues.apache.org/jira/browse/FLINK-37674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37674: - Assignee: Gabor Somogyi > Add generalized type information to SQL state connector > ---

[jira] [Closed] (FLINK-37407) Add meta information to SQL state connector

[ https://issues.apache.org/jira/browse/FLINK-37407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37407. - > Add meta information to SQL state connector > --- > >

[jira] [Resolved] (FLINK-37407) Add meta information to SQL state connector

[ https://issues.apache.org/jira/browse/FLINK-37407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37407. --- Fix Version/s: 2.1.0 Resolution: Fixed > Add meta information to SQL state connector

[jira] [Updated] (FLINK-37626) Flaky test: ForStFlinkFileSystemTest.testSstFileInCache

[ https://issues.apache.org/jira/browse/FLINK-37626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-37626: -- Description: https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/re

[jira] [Created] (FLINK-37626) Flaky test: ForStFlinkFileSystemTest.testSstFileInCache

Gabor Somogyi created FLINK-37626: - Summary: Flaky test: ForStFlinkFileSystemTest.testSstFileInCache Key: FLINK-37626 URL: https://issues.apache.org/jira/browse/FLINK-37626 Project: Flink Iss

[jira] [Commented] (FLINK-36457) Python DataStream API: calling add_jars or add_classpaths results in corrupted execution config

[ https://issues.apache.org/jira/browse/FLINK-36457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940393#comment-17940393 ] Gabor Somogyi commented on FLINK-36457: --- a3a82ae8ace3ff4e9816e4afb48f5b19099ae8a6

[jira] [Resolved] (FLINK-36457) Python DataStream API: calling add_jars or add_classpaths results in corrupted execution config

[ https://issues.apache.org/jira/browse/FLINK-36457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-36457. --- Resolution: Duplicate > Python DataStream API: calling add_jars or add_classpaths results in

[jira] [Closed] (FLINK-36457) Python DataStream API: calling add_jars or add_classpaths results in corrupted execution config

[ https://issues.apache.org/jira/browse/FLINK-36457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-36457. - > Python DataStream API: calling add_jars or add_classpaths results in > corrupted execution config

[jira] [Commented] (FLINK-36457) Python DataStream API: calling add_jars or add_classpaths results in corrupted execution config

[ https://issues.apache.org/jira/browse/FLINK-36457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941242#comment-17941242 ] Gabor Somogyi commented on FLINK-36457: --- This has been resolved in FLINK-37505 so

[jira] [Commented] (FLINK-37504) Handle TLS Certificate Renewal

[ https://issues.apache.org/jira/browse/FLINK-37504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937315#comment-17937315 ] Gabor Somogyi commented on FLINK-37504: --- Since this impacts hearth of the whole au

[jira] [Resolved] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37460. --- Fix Version/s: 1.20.2 2.0.1 Resolution: Fixed > Using State Proces

[jira] [Updated] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-37460: -- Priority: Critical (was: Major) > Using State Processor API and Kafka Sink with Exactly once

[jira] [Closed] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37460. - > Using State Processor API and Kafka Sink with Exactly once delivery leads to > org.apache.kafka.c

[jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937157#comment-17937157 ] Gabor Somogyi commented on FLINK-37460: --- [{{e24c477}}|https://github.com/apache/fl

[jira] [Resolved] (FLINK-37505) Pyflink is not able to handle the new YAML based configs

[ https://issues.apache.org/jira/browse/FLINK-37505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37505. --- Fix Version/s: 1.20.2 2.0.1 Resolution: Fixed > Pyflink is not abl

[jira] [Closed] (FLINK-37505) Pyflink is not able to handle the new YAML based configs

[ https://issues.apache.org/jira/browse/FLINK-37505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37505. - > Pyflink is not able to handle the new YAML based configs > ---

[jira] [Commented] (FLINK-37505) Pyflink is not able to handle the new YAML based configs

[ https://issues.apache.org/jira/browse/FLINK-37505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937145#comment-17937145 ] Gabor Somogyi commented on FLINK-37505: --- [{{a3a82ae}}|https://github.com/apache/fl

[jira] [Commented] (FLINK-37505) Pyflink is not able to handle the new YAML based configs

[ https://issues.apache.org/jira/browse/FLINK-37505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937096#comment-17937096 ] Gabor Somogyi commented on FLINK-37505: --- [{{b1c3209}}|https://github.com/apache/fl

[jira] [Created] (FLINK-37505) Pyflink is not able to handle the new YAML based configs

Gabor Somogyi created FLINK-37505: - Summary: Pyflink is not able to handle the new YAML based configs Key: FLINK-37505 URL: https://issues.apache.org/jira/browse/FLINK-37505 Project: Flink Is

[jira] [Updated] (FLINK-37505) Pyflink is not able to handle the new YAML based configs

[ https://issues.apache.org/jira/browse/FLINK-37505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-37505: -- Description: Steps to repro: * pipeline.jars = ['file:/flink/opt/flink-python-2.0.0.jar'] * In

[jira] [Assigned] (FLINK-37505) Pyflink is not able to handle the new YAML based configs

[ https://issues.apache.org/jira/browse/FLINK-37505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37505: - Assignee: Gabor Somogyi > Pyflink is not able to handle the new YAML based configs > --

[jira] [Closed] (FLINK-37480) Jpicmp gives false positive

[ https://issues.apache.org/jira/browse/FLINK-37480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37480. - > Jpicmp gives false positive > --- > > Key: FLINK-37480 >

[jira] [Commented] (FLINK-37480) Jpicmp gives false positive

[ https://issues.apache.org/jira/browse/FLINK-37480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936166#comment-17936166 ] Gabor Somogyi commented on FLINK-37480: --- [{{f3d9681}}|https://github.com/apache/fl

[jira] [Resolved] (FLINK-37480) Jpicmp gives false positive

[ https://issues.apache.org/jira/browse/FLINK-37480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37480. --- Fix Version/s: 1.20.2 2.1.0 Resolution: Fixed > Jpicmp gives false

[jira] [Created] (FLINK-37480) Jpicmp gives false positive

Gabor Somogyi created FLINK-37480: - Summary: Jpicmp gives false positive Key: FLINK-37480 URL: https://issues.apache.org/jira/browse/FLINK-37480 Project: Flink Issue Type: Bug Compo

[jira] [Assigned] (FLINK-37480) Jpicmp gives false positive

[ https://issues.apache.org/jira/browse/FLINK-37480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37480: - Assignee: Gabor Somogyi > Jpicmp gives false positive > --- > >

[jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17935428#comment-17935428 ] Gabor Somogyi commented on FLINK-37460: --- [{{c89c416}}|https://github.com/apache/fl

[jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933895#comment-17933895 ] Gabor Somogyi commented on FLINK-37445: --- Sounds great! Thanks for your efforts🙂 >

[jira] [Assigned] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37460: - Assignee: Gabor Somogyi > Using State Processor API and Kafka Sink with Exactly once de

[jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934231#comment-17934231 ] Gabor Somogyi commented on FLINK-37460: --- [~martijnvisser] thanks for the context,

[jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934265#comment-17934265 ] Gabor Somogyi commented on FLINK-37460: --- Just filed it, plz report back. > Using

[jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934258#comment-17934258 ] Gabor Somogyi commented on FLINK-37460: --- [~gliter] thanks for the detailed explana

[jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934230#comment-17934230 ] Gabor Somogyi commented on FLINK-37460: --- This sounds severe, can you confirm that

[jira] [Created] (FLINK-37456) Stream data for SQL state connector in case of List and Map state

Gabor Somogyi created FLINK-37456: - Summary: Stream data for SQL state connector in case of List and Map state Key: FLINK-37456 URL: https://issues.apache.org/jira/browse/FLINK-37456 Project: Flink

[jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933862#comment-17933862 ] Gabor Somogyi commented on FLINK-37445: --- Migration requires quite some efforts bec

[jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933830#comment-17933830 ] Gabor Somogyi commented on FLINK-37445: --- Since this is deprecated what is the plan

[jira] [Assigned] (FLINK-37407) Add meta information to SQL state connector

[ https://issues.apache.org/jira/browse/FLINK-37407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37407: - Assignee: Gabor Somogyi > Add meta information to SQL state connector > ---

[jira] [Created] (FLINK-37407) Add meta information to SQL state connector

Gabor Somogyi created FLINK-37407: - Summary: Add meta information to SQL state connector Key: FLINK-37407 URL: https://issues.apache.org/jira/browse/FLINK-37407 Project: Flink Issue Type: Imp

[jira] [Closed] (FLINK-37398) State processor API blows up with cryptic error when changelog used

[ https://issues.apache.org/jira/browse/FLINK-37398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37398. - > State processor API blows up with cryptic error when changelog used >

[jira] [Resolved] (FLINK-37398) State processor API blows up with cryptic error when changelog used

[ https://issues.apache.org/jira/browse/FLINK-37398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37398. --- Fix Version/s: 2.1.0 Resolution: Fixed [{{940d746}}|https://github.com/apache/flink/c

[jira] [Created] (FLINK-37398) State processor API blows up with cryptic error when changelog used

Gabor Somogyi created FLINK-37398: - Summary: State processor API blows up with cryptic error when changelog used Key: FLINK-37398 URL: https://issues.apache.org/jira/browse/FLINK-37398 Project: Flink

[jira] [Assigned] (FLINK-37398) State processor API blows up with cryptic error when changelog used

[ https://issues.apache.org/jira/browse/FLINK-37398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37398: - Assignee: Gabor Somogyi > State processor API blows up with cryptic error when changelo

[jira] [Commented] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues

[ https://issues.apache.org/jira/browse/FLINK-37378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930335#comment-17930335 ] Gabor Somogyi commented on FLINK-37378: --- > I even did not create pr for Flink. Th

[jira] [Closed] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues

[ https://issues.apache.org/jira/browse/FLINK-37378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37378. - Resolution: Invalid Cloudera internals don't need apache jira. > Yarn log aggregation fails wit

[jira] [Resolved] (FLINK-37363) Make state.backend.type config optional for state SQL connector

[ https://issues.apache.org/jira/browse/FLINK-37363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37363. --- Fix Version/s: 2.1.0 Resolution: Fixed [{{4deb3a1}}|https://github.com/apache/flink/c

[jira] [Updated] (FLINK-37363) Make state.backend.type config optional for state SQL connector

[ https://issues.apache.org/jira/browse/FLINK-37363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-37363: -- Summary: Make state.backend.type config optional for state SQL connector (was: Remove confusi

[jira] [Closed] (FLINK-37363) Make state.backend.type config optional for state SQL connector

[ https://issues.apache.org/jira/browse/FLINK-37363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37363. - > Make state.backend.type config optional for state SQL connector >

[jira] [Commented] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17929114#comment-17929114 ] Gabor Somogyi commented on FLINK-33155: --- Since it's pluggable it's possible. One t

[jira] [Updated] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-31238: -- Fix Version/s: 2.0-preview (was: 1.20.0) > Use IngestDB to speed up Roc

[jira] [Updated] (FLINK-37363) Remove confusing and duplicated state.backend.type config from state SQL connector

[ https://issues.apache.org/jira/browse/FLINK-37363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-37363: -- Affects Version/s: 2.0-preview > Remove confusing and duplicated state.backend.type config fro

[jira] [Created] (FLINK-37363) Remove confusing and duplicated state.backend.type config from state SQL connector

Gabor Somogyi created FLINK-37363: - Summary: Remove confusing and duplicated state.backend.type config from state SQL connector Key: FLINK-37363 URL: https://issues.apache.org/jira/browse/FLINK-37363

[jira] [Commented] (FLINK-37344) setup_hugo.sh should install the hugo binary only

[ https://issues.apache.org/jira/browse/FLINK-37344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928169#comment-17928169 ] Gabor Somogyi commented on FLINK-37344: --- [{{9a1e986}}|https://github.com/apache/fl

[jira] [Created] (FLINK-37344) setup_hugo.sh should install the hugo binary only

Gabor Somogyi created FLINK-37344: - Summary: setup_hugo.sh should install the hugo binary only Key: FLINK-37344 URL: https://issues.apache.org/jira/browse/FLINK-37344 Project: Flink Issue Typ

[jira] [Closed] (FLINK-19303) Disable WAL in RocksDB recovery

[ https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-19303. - > Disable WAL in RocksDB recovery > --- > > Key: FLINK-1

[jira] [Resolved] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load

[ https://issues.apache.org/jira/browse/FLINK-17288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-17288. --- Resolution: Duplicate > Speedup loading from savepoints into RocksDB by bulk load >

[jira] [Commented] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load

[ https://issues.apache.org/jira/browse/FLINK-17288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927997#comment-17927997 ] Gabor Somogyi commented on FLINK-17288: --- FLINK-31238 has added such functionality

[jira] [Resolved] (FLINK-17971) Speed up RocksDB bulk loading with SST generation and ingestion

[ https://issues.apache.org/jira/browse/FLINK-17971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-17971. --- Resolution: Duplicate > Speed up RocksDB bulk loading with SST generation and ingestion > --

[jira] [Resolved] (FLINK-19303) Disable WAL in RocksDB recovery

[ https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-19303. --- Resolution: Fixed > Disable WAL in RocksDB recovery > --- > >

[jira] [Commented] (FLINK-17971) Speed up RocksDB bulk loading with SST generation and ingestion

[ https://issues.apache.org/jira/browse/FLINK-17971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927993#comment-17927993 ] Gabor Somogyi commented on FLINK-17971: --- FLINK-31238 has added such functionality

[jira] [Closed] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-31238. - > Use IngestDB to speed up Rocksdb rescaling recovery > ---

[jira] [Resolved] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-31238. --- Fix Version/s: 1.20.0 Resolution: Fixed > Use IngestDB to speed up Rocksdb rescaling

  1   2   3   4   5   6   7   8   >