[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector

[ https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-35232: Description: https://issues.apache.org/jira/browse/FLINK-32877 is tracking

[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector

[ https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-35232: Description: https://issues.apache.org/jira/browse/FLINK-32877 is tracking

[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector

[ https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841267#comment-17841267 ] Oleksandr Nitavskyi commented on FLINK-35232: - [~galenwarren] thanks. We have reduced the

[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector

[ https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-35232: Description: https://issues.apache.org/jira/browse/FLINK-32877 is tracking

[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector

[ https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-35232: Description: https://issues.apache.org/jira/browse/FLINK-32877 is tracking

[jira] [Updated] (FLINK-35232) Support for retry settings on GCS connector

[ https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-35232: Description: https://issues.apache.org/jira/browse/FLINK-32877 is tracking

[jira] [Commented] (FLINK-35210) Give the option to set automatically the parallelism of the KafkaSource to the number of kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-35210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839739#comment-17839739 ] Oleksandr Nitavskyi commented on FLINK-35210: - Thanks [~npfp] for suggestion. I believe what

[jira] [Updated] (FLINK-33376) Extend Curator config option for Zookeeper configuration

[ https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-33376: Component/s: Runtime / Coordination > Extend Curator config option for Zookeeper

[jira] [Updated] (FLINK-33376) Extend Curator config option for Zookeeper configuration

[ https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-33376: Summary: Extend Curator config option for Zookeeper configuration (was: Add

[jira] [Commented] (FLINK-33376) Add AuthInfo config option for Zookeeper configuration

[ https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783220#comment-17783220 ] Oleksandr Nitavskyi commented on FLINK-33376: - Thanks for the detailed listing. It sounds

[jira] [Commented] (FLINK-33376) Add AuthInfo config option for Zookeeper configuration

[ https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780489#comment-17780489 ] Oleksandr Nitavskyi commented on FLINK-33376: - It would be really good to be able to support

[jira] [Commented] (FLINK-33376) Add AuthInfo config option for Zookeeper configuration

[ https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780387#comment-17780387 ] Oleksandr Nitavskyi commented on FLINK-33376: - Thanks for the link. If we really require a

[jira] [Comment Edited] (FLINK-33376) Add AuthInfo config option for Zookeeper configuration

[ https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780387#comment-17780387 ] Oleksandr Nitavskyi edited comment on FLINK-33376 at 10/27/23 1:56 PM:

[jira] [Commented] (FLINK-33376) Add AuthInfo config option for Zookeeper configuration

[ https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780373#comment-17780373 ] Oleksandr Nitavskyi commented on FLINK-33376: - [~mapohl] sure, would be glad to drive this!

[jira] [Commented] (FLINK-33376) Add AuthInfo config option for Zookeeper configuration

[ https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779947#comment-17779947 ] Oleksandr Nitavskyi commented on FLINK-33376: - For implementation we could add an additional

[jira] [Created] (FLINK-33376) Add AuthInfo config option for Zookeeper configuration

Oleksandr Nitavskyi created FLINK-33376: --- Summary: Add AuthInfo config option for Zookeeper configuration Key: FLINK-33376 URL: https://issues.apache.org/jira/browse/FLINK-33376 Project: Flink

[jira] [Updated] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-32203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-32203: Priority: Minor (was: Major) > Potential ClassLoader memory leak due to log4j

[jira] [Commented] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-32203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726626#comment-17726626 ] Oleksandr Nitavskyi commented on FLINK-32203: - [~chesnay] thanks for looking into PR

[jira] [Updated] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-32203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-32203: Description: *Context* We have encountered a memory leak related to ClassLoaders

[jira] [Updated] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-32203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-32203: Description: *Context* We have encountered a memory leak related to ClassLoaders

[jira] [Updated] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-32203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-32203: Attachment: stack_trace_example_with_log4j_creation_on_job_reload.log > Potential

[jira] [Updated] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-32203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-32203: Attachment: classloader_leak.png > Potential ClassLoader memory leak due to log4j

[jira] [Updated] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-32203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-32203: Description: *Context* We have encountered a memory leak related to ClassLoaders

[jira] [Created] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

Oleksandr Nitavskyi created FLINK-32203: --- Summary: Potential ClassLoader memory leak due to log4j configuration Key: FLINK-32203 URL: https://issues.apache.org/jira/browse/FLINK-32203 Project:

[jira] [Updated] (FLINK-31780) Allow users to disable "Ensemble tracking" for ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-31780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-31780: Description: In Apache Curator an option to skip ensemble tracking was added

[jira] [Updated] (FLINK-31780) Allow users to disable "Ensemble tracking" for ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-31780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-31780: Description: In Apache Curator an option to skip ensemble tracking was added

[jira] [Updated] (FLINK-31780) Allow users to disable "Ensemble tracking" for ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-31780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-31780: Description: In Apache Curator an option to skip ensemble tracking was added

[jira] [Updated] (FLINK-31780) Allow users to disable "Ensemble tracking" for ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-31780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-31780: Description: In Apache Curator an option to skip ensemble tracking was added

[jira] [Created] (FLINK-31780) Allow users to enable Ensemble tracking for ZooKeeper

Oleksandr Nitavskyi created FLINK-31780: --- Summary: Allow users to enable Ensemble tracking for ZooKeeper Key: FLINK-31780 URL: https://issues.apache.org/jira/browse/FLINK-31780 Project: Flink

[jira] [Updated] (FLINK-31780) Allow users to disable "Ensemble tracking" for ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-31780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-31780: Summary: Allow users to disable "Ensemble tracking" for ZooKeeper (was: Allow

[jira] (FLINK-29242) Read time out when close write channel [flink-gs-fs-hadoop ]

[ https://issues.apache.org/jira/browse/FLINK-29242 ] Oleksandr Nitavskyi deleted comment on FLINK-29242: - was (Author: oleksandr nitavskyi): While it seems that Flink can do something to be more resilient for such type of errors, here

[jira] [Commented] (FLINK-29242) Read time out when close write channel [flink-gs-fs-hadoop ]

[ https://issues.apache.org/jira/browse/FLINK-29242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706863#comment-17706863 ] Oleksandr Nitavskyi commented on FLINK-29242: - While it seems that Flink can do something to

[jira] [Commented] (FLINK-17505) Merge small files produced by StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-17505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443767#comment-17443767 ] Oleksandr Nitavskyi commented on FLINK-17505: - Another workaround for this problem is

[jira] [Commented] (FLINK-17505) Merge small files produced by StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-17505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138437#comment-17138437 ] Oleksandr Nitavskyi commented on FLINK-17505: - 8. And for sure open question is about the

[jira] [Comment Edited] (FLINK-17505) Merge small files produced by StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-17505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136731#comment-17136731 ] Oleksandr Nitavskyi edited comment on FLINK-17505 at 6/17/20, 10:02 AM:

[jira] [Commented] (FLINK-17505) Merge small files produced by StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-17505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136731#comment-17136731 ] Oleksandr Nitavskyi commented on FLINK-17505: - MergeOperartor (ConsolidationOperator) will

[jira] [Comment Edited] (FLINK-17505) Merge small files produced by StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-17505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136731#comment-17136731 ] Oleksandr Nitavskyi edited comment on FLINK-17505 at 6/16/20, 3:19 PM:

[jira] [Updated] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

[ https://issues.apache.org/jira/browse/FLINK-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-10203: Description: New StreamingFileSink ( introduced in 1.6 Flink version ) use

[jira] [Resolved] (FLINK-11396) MetricStore creates significant GC pressure

[ https://issues.apache.org/jira/browse/FLINK-11396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi resolved FLINK-11396. - Fix Version/s: 1.9.0 Resolution: Fixed > MetricStore creates significant

[jira] [Commented] (FLINK-11396) MetricStore creates significant GC pressure

[ https://issues.apache.org/jira/browse/FLINK-11396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041971#comment-17041971 ] Oleksandr Nitavskyi commented on FLINK-11396: - Sorry, we still didn't migrate anything

[jira] [Commented] (FLINK-15904) Make Kafka Consumer work with activated "disableGenericTypes()"

[ https://issues.apache.org/jira/browse/FLINK-15904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040142#comment-17040142 ] Oleksandr Nitavskyi commented on FLINK-15904: - made a PR, but cannot assign the Jira ticket

[jira] [Comment Edited] (FLINK-11911) KafkaTopicPartition is not a valid POJO

[ https://issues.apache.org/jira/browse/FLINK-11911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17026852#comment-17026852 ] Oleksandr Nitavskyi edited comment on FLINK-11911 at 1/30/20 5:19 PM:

[jira] [Commented] (FLINK-11911) KafkaTopicPartition is not a valid POJO

[ https://issues.apache.org/jira/browse/FLINK-11911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17026852#comment-17026852 ] Oleksandr Nitavskyi commented on FLINK-11911: - Sure, makes sense. What if we try to use

[jira] [Assigned] (FLINK-12489) Flink on Mesos - Parameterize network resources.

[ https://issues.apache.org/jira/browse/FLINK-12489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi reassigned FLINK-12489: --- Assignee: Oleksandr Nitavskyi > Flink on Mesos - Parameterize network

[jira] [Created] (FLINK-12489) Flink on Mesos - Parameterize network resources.

Oleksandr Nitavskyi created FLINK-12489: --- Summary: Flink on Mesos - Parameterize network resources. Key: FLINK-12489 URL: https://issues.apache.org/jira/browse/FLINK-12489 Project: Flink

[jira] [Assigned] (FLINK-12139) Flink on mesos - Parameterize disk space needed.

[ https://issues.apache.org/jira/browse/FLINK-12139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi reassigned FLINK-12139: --- Assignee: Oleksandr Nitavskyi > Flink on mesos - Parameterize disk space

[jira] [Closed] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed

[ https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi closed FLINK-10342. --- Resolution: Fixed > Kafka duplicate topic consumption when topic name is changed >

[jira] [Reopened] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed

[ https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi reopened FLINK-10342: - > Kafka duplicate topic consumption when topic name is changed >

[jira] [Closed] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed

[ https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi closed FLINK-10342. --- Resolution: Won't Fix > Kafka duplicate topic consumption when topic name is

[jira] [Commented] (FLINK-11396) MetricStore creates significant GC pressure

[ https://issues.apache.org/jira/browse/FLINK-11396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746997#comment-16746997 ] Oleksandr Nitavskyi commented on FLINK-11396: - On GC tuning side, G1 ergonomic concluded we

[jira] [Updated] (FLINK-11396) MetricStore creates significant GC pressure

[ https://issues.apache.org/jira/browse/FLINK-11396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-11396: Attachment: GC_parallel_flink_job_manager.log g1.txt

[jira] [Created] (FLINK-11396) MetricStore creates significant GC pressure

Oleksandr Nitavskyi created FLINK-11396: --- Summary: MetricStore creates significant GC pressure Key: FLINK-11396 URL: https://issues.apache.org/jira/browse/FLINK-11396 Project: Flink

[jira] [Updated] (FLINK-11396) MetricStore creates significant GC pressure

[ https://issues.apache.org/jira/browse/FLINK-11396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-11396: Description: On Flink version 1.6.x we observe a significant increase of the

[jira] [Updated] (FLINK-11394) Job UI is not rendered in case of slow back-end

[ https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-11394: Description: In case back-end requests for the job state take longer than

[jira] [Updated] (FLINK-11394) Job UI is not rendered in case of slow back-end

[ https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-11394: Description: In case back-end requests for the job state take longer than

[jira] [Updated] (FLINK-11394) Job UI is not rendered in case of slow back-end

[ https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-11394: Description: In case back-end requests for the job state take longer than

[jira] [Updated] (FLINK-11394) Job UI is not rendered in case of slow back-end

[ https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-11394: Description: In case back-end requests for the job state take longer than

[jira] [Updated] (FLINK-11394) Job UI is not rendered in case of slow back-end

[ https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-11394: Description: In case back-end requests for the job state take longer than

[jira] [Updated] (FLINK-11394) Job UI is not rendered in case of slow back-end

[ https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-11394: Description: In case back-end requests for the job state take longer than

[jira] [Created] (FLINK-11394) Job UI is not rendered in case of slow back-end

Oleksandr Nitavskyi created FLINK-11394: --- Summary: Job UI is not rendered in case of slow back-end Key: FLINK-11394 URL: https://issues.apache.org/jira/browse/FLINK-11394 Project: Flink

[jira] [Updated] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed

[ https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-10342: Priority: Minor (was: Major) > Kafka duplicate topic consumption when topic name

[jira] [Comment Edited] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed

[ https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617172#comment-16617172 ] Oleksandr Nitavskyi edited comment on FLINK-10342 at 9/17/18 11:29 AM:

[jira] [Reopened] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed

[ https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi reopened FLINK-10342: - > Kafka duplicate topic consumption when topic name is changed >

[jira] [Commented] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed

[ https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617172#comment-16617172 ] Oleksandr Nitavskyi commented on FLINK-10342: - Thanks for the comment. I agree that it works

[jira] [Assigned] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed

[ https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi reassigned FLINK-10342: --- Assignee: Oleksandr Nitavskyi > Kafka duplicate topic consumption when

[jira] [Created] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed

Oleksandr Nitavskyi created FLINK-10342: --- Summary: Kafka duplicate topic consumption when topic name is changed Key: FLINK-10342 URL: https://issues.apache.org/jira/browse/FLINK-10342 Project:

[jira] [Created] (FLINK-9762) CoreOptions.TMP_DIRS wrongly managed on Yarn

Oleksandr Nitavskyi created FLINK-9762: -- Summary: CoreOptions.TMP_DIRS wrongly managed on Yarn Key: FLINK-9762 URL: https://issues.apache.org/jira/browse/FLINK-9762 Project: Flink Issue