[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-09-26 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938381#comment-16938381 ] Zili Chen commented on FLINK-13417: --- Thanks for your information [~trohrmann]. FYI I

[jira] [Created] (FLINK-14237) No need to rename shipped Flink jar

2019-09-26 Thread Zili Chen (Jira)
Zili Chen created FLINK-14237: - Summary: No need to rename shipped Flink jar Key: FLINK-14237 URL: https://issues.apache.org/jira/browse/FLINK-14237 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-14237) No need to rename shipped Flink jar

2019-09-26 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14237: -- Description: Currently, when we ship Flink jar configured by -yj, we always rename it as {{flink.jar}

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939671#comment-16939671 ] Zili Chen commented on FLINK-13992: --- Thanks for your review [~azagrebin]! master via

[jira] [Closed] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-13992. - Resolution: Fixed > Refactor Optional parameter in InputGateWithMetrics#updateMetrics >

[jira] [Commented] (FLINK-14252) Encapsulate Dispatcher services in DispatcherServices container

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939711#comment-16939711 ] Zili Chen commented on FLINK-14252: --- Make sense to me. A more general issue related i

[jira] [Commented] (FLINK-14261) Add support for permanently fenced RpcEndpoints

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939723#comment-16939723 ] Zili Chen commented on FLINK-14261: --- Permanently Fenced RpcEndpoint could be a good in

[jira] [Created] (FLINK-14263) Extract static method from ClusterClient to ClientUtils

2019-09-27 Thread Zili Chen (Jira)
Zili Chen created FLINK-14263: - Summary: Extract static method from ClusterClient to ClientUtils Key: FLINK-14263 URL: https://issues.apache.org/jira/browse/FLINK-14263 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-14130) Remove ClusterClient.run() methods

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-14130: - Assignee: Zili Chen > Remove ClusterClient.run() methods > -- >

[jira] [Commented] (FLINK-14130) Remove ClusterClient.run() methods

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939842#comment-16939842 ] Zili Chen commented on FLINK-14130: --- Base on FLINK-14263 it is obviously how we can ex

[jira] [Commented] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939847#comment-16939847 ] Zili Chen commented on FLINK-14250: --- Vote for this. I second that {{if (!programOption

[jira] [Commented] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939848#comment-16939848 ] Zili Chen commented on FLINK-14250: --- Actually I am thinking of making {{CliFrontend}}

[jira] [Comment Edited] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939848#comment-16939848 ] Zili Chen edited comment on FLINK-14250 at 9/28/19 4:49 AM:

[jira] [Comment Edited] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939848#comment-16939848 ] Zili Chen edited comment on FLINK-14250 at 9/28/19 4:50 AM:

[jira] [Updated] (FLINK-14050) Refactor YarnClusterDescriptor inheritance

2019-09-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14050: -- Description: Currently, the inheritance looks like AbstractYarnClusterDescriptor -> YarnClusterDescri

[jira] [Assigned] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-28 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-14179: - Assignee: Canbin Zheng > Wrong description of SqlCommand.SHOW_FUNCTIONS > -

[jira] [Commented] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-28 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940254#comment-16940254 ] Zili Chen commented on FLINK-14179: --- Hi [~felixzheng] I've assigned the issue to you.

[jira] [Assigned] (FLINK-13827) shell variable should be escaped in start-scala-shell.sh

2019-09-28 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-13827: - Assignee: Zili Chen > shell variable should be escaped in start-scala-shell.sh > --

[jira] [Commented] (FLINK-14282) Simplify DispatcherResourceManagerComponent

2019-09-30 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941459#comment-16941459 ] Zili Chen commented on FLINK-14282: --- Nice to have! The difference between {{JobCluster

[jira] [Commented] (FLINK-14282) Simplify DispatcherResourceManagerComponent

2019-09-30 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941460#comment-16941460 ] Zili Chen commented on FLINK-14282: --- Well I misunderstand so we still have multiple {{

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-10-02 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942545#comment-16942545 ] Zili Chen commented on FLINK-13417: --- For your information, I created {{flink-shaded-zo

[jira] [Commented] (FLINK-13827) shell variable should be escaped in start-scala-shell.sh

2019-10-02 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942754#comment-16942754 ] Zili Chen commented on FLINK-13827: --- master via 865cc4c7a39f7aa610a02cc4a0f41424edcd62

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-10-02 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942853#comment-16942853 ] Zili Chen commented on FLINK-13417: --- Run against master repo but it seems not trigger

[jira] [Comment Edited] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-10-02 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942853#comment-16942853 ] Zili Chen edited comment on FLINK-13417 at 10/2/19 2:20 PM:

[jira] [Commented] (FLINK-14315) NPE with JobMaster.disconnectTaskManager

2019-10-02 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942975#comment-16942975 ] Zili Chen commented on FLINK-14315: --- It looks like {{JobMaster#suspend}} races with {{

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-10-03 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16943594#comment-16943594 ] Zili Chen commented on FLINK-13417: --- Hello Stephan, the situation is actually flink-ru

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-10-03 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944254#comment-16944254 ] Zili Chen commented on FLINK-13417: --- Another option to avoid dependency to bump curato

[jira] [Commented] (FLINK-14237) No need to rename shipped Flink jar

2019-10-07 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946565#comment-16946565 ] Zili Chen commented on FLINK-14237: --- Hi [~trohrmann], {{flink.jar}} is shipped as fli

[jira] [Created] (FLINK-14343) Remove uncompleted YARNHighAvailabilityService

2019-10-08 Thread Zili Chen (Jira)
Zili Chen created FLINK-14343: - Summary: Remove uncompleted YARNHighAvailabilityService Key: FLINK-14343 URL: https://issues.apache.org/jira/browse/FLINK-14343 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-11632) Make TaskManager automatic bind address picking more explicit (by default) and more configurable

2019-10-08 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946664#comment-16946664 ] Zili Chen commented on FLINK-11632: --- Hi [~trohrmann] & [~1u0] I'll appreciate it if yo

[jira] [Assigned] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

2019-10-08 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-14118: - Assignee: Yingjie Cao > Reduce the unnecessary flushing when there is no data available for flu

[jira] [Commented] (FLINK-11632) Make TaskManager automatic bind address picking more explicit (by default) and more configurable

2019-10-08 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946965#comment-16946965 ] Zili Chen commented on FLINK-11632: --- Thanks for your information [~trohrmann]. I wonde

[jira] [Updated] (FLINK-14149) Introduce ZooKeeperLeaderElectionServiceNG

2019-10-10 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14149: -- Description: Subsequent to the discussion in FLINK-10333, we reach a consensus that refactor ZK based

[jira] [Issue Comment Deleted] (FLINK-13567) Avro Confluent Schema Registry nightly end-to-end test failed on Travis

2019-10-10 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-13567: -- Comment: was deleted (was: [~till.rohrmann] you can try out the patch attached. I don't have a test e

[jira] [Updated] (FLINK-13567) Avro Confluent Schema Registry nightly end-to-end test failed on Travis

2019-10-10 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-13567: -- Attachment: (was: patch.diff) > Avro Confluent Schema Registry nightly end-to-end test failed on T

[jira] [Commented] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

2019-10-10 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948773#comment-16948773 ] Zili Chen commented on FLINK-14347: --- Thanks for reporting this issue [~TsReaper] and y

[jira] [Assigned] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

2019-10-10 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-14347: - Assignee: Zili Chen > YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with > p

[jira] [Commented] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

2019-10-10 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949064#comment-16949064 ] Zili Chen commented on FLINK-14347: --- Thanks for your information [~fly_in_gis]! > YAR

[jira] [Commented] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

2019-10-10 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949065#comment-16949065 ] Zili Chen commented on FLINK-14347: --- [~trohrmann] PR submitted. > YARNSessionFIFOITCa

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

2019-10-10 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949076#comment-16949076 ] Zili Chen commented on FLINK-13417: --- Hi [~sewen], [here|https://github.com/apache/flin

[jira] [Created] (FLINK-14392) Introduce JobClient API(FLIP-74)

2019-10-14 Thread Zili Chen (Jira)
Zili Chen created FLINK-14392: - Summary: Introduce JobClient API(FLIP-74) Key: FLINK-14392 URL: https://issues.apache.org/jira/browse/FLINK-14392 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-14392) Introduce JobClient API(FLIP-74)

2019-10-14 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14392: -- Issue Type: New Feature (was: Task) > Introduce JobClient API(FLIP-74) >

[jira] [Updated] (FLINK-14392) Introduce JobClient API(FLIP-74)

2019-10-14 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14392: -- Issue Type: Task (was: New Feature) > Introduce JobClient API(FLIP-74) >

[jira] [Updated] (FLINK-14392) Introduce JobClient API(FLIP-74)

2019-10-14 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14392: -- Component/s: (was: Command Line Client) > Introduce JobClient API(FLIP-74) > -

[jira] [Assigned] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

2019-10-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-13856: - Assignee: andrew.D.lin > Reduce the delete file api when the checkpoint is completed >

[jira] [Assigned] (FLINK-33357) add Apache Software License 2

2023-10-24 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-33357: - Assignee: 蔡灿材 > add Apache Software License 2 > - > >

[jira] [Created] (FLINK-33602) Pulsar connector should be compatible with Flink 1.18

2023-11-20 Thread Zili Chen (Jira)
Zili Chen created FLINK-33602: - Summary: Pulsar connector should be compatible with Flink 1.18 Key: FLINK-33602 URL: https://issues.apache.org/jira/browse/FLINK-33602 Project: Flink Issue Type: B

[jira] [Closed] (FLINK-33400) Pulsar connector doesn't compile for Flink 1.18 due to Archunit update

2023-12-12 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-33400. - Fix Version/s: pulsar-4.1.0 Assignee: Zili Chen (was: Martijn Visser) Resolution: Fixed

[jira] [Updated] (FLINK-33970) Add necessary checks for connector document

2024-01-03 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-33970: -- Fix Version/s: pulsar-4.2.0 pulsar-4.1.1 > Add necessary checks for connector docum

[jira] [Closed] (FLINK-33970) Add necessary checks for connector document

2024-01-03 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-33970. - Resolution: Fixed master via 5b70da8f88e21057a5c590d139eab558f87e5dca Thanks a lot [~gongzhongqiang]!

[jira] [Resolved] (FLINK-34629) Pulsar source lost topic subscribe

2024-04-14 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-34629. --- Fix Version/s: pulsar-4.2.0 Resolution: Fixed Master via https://github.com/apache/flink-con

[jira] [Resolved] (FLINK-33884) Update Pulsar dependency to 3.0.2 in Pulsar Connector

2024-04-14 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-33884. --- Fix Version/s: pulsar-4.2.0 Resolution: Fixed Master via https://github.com/apache/flink-con

[jira] [Resolved] (FLINK-34962) flink-connector-pulsa starts failed due to incorrect use of Pulsar API: LookupService. getPartitionedTopicMetadata

2024-04-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-34962. --- Fix Version/s: pulsar-4.2.0 Resolution: Fixed master via https://github.com/apache/flink-con

[jira] [Updated] (FLINK-34962) flink-connector-pulsa starts failed due to incorrect use of Pulsar API: LookupService. getPartitionedTopicMetadata

2024-04-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-34962: -- Affects Version/s: (was: pulsar-4.1.1) > flink-connector-pulsa starts failed due to incorrect use

[jira] [Updated] (FLINK-34962) flink-connector-pulsa starts failed due to incorrect use of Pulsar API: LookupService. getPartitionedTopicMetadata

2024-04-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-34962: -- Affects Version/s: (was: pulsar-4.2.0) > flink-connector-pulsa starts failed due to incorrect use

[jira] [Resolved] (FLINK-32645) Flink pulsar sink is having poor performance

2024-04-15 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-32645. --- Resolution: Fixed > Flink pulsar sink is having poor performance > -

[jira] [Resolved] (FLINK-35182) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector

2024-05-03 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-35182. --- Fix Version/s: pulsar-4.2.0 Assignee: Zhongqiang Gong Resolution: Fixed master via

[jira] [Commented] (FLINK-33019) Pulsar tests hangs during nightly builds

2023-09-06 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762412#comment-17762412 ] Zili Chen commented on FLINK-33019: --- [~martijnvisser] It seems all for the SNAPSHOT ve

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-07 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762599#comment-17762599 ] Zili Chen commented on FLINK-33053: --- The recipe in use is {{TreeCache}}, which doesn't

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-07 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762657#comment-17762657 ] Zili Chen commented on FLINK-33053: --- Perhaps you can enable debug logs and check "Remo

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-07 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762965#comment-17762965 ] Zili Chen commented on FLINK-33053: --- The log seems trimed. I saw: 2023-09-08 11:09:03

[jira] [Commented] (FLINK-33019) Pulsar tests hangs during nightly builds

2023-09-11 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763587#comment-17763587 ] Zili Chen commented on FLINK-33019: --- It seems we can sometimes pass the test https://

[jira] [Comment Edited] (FLINK-33019) Pulsar tests hangs during nightly builds

2023-09-11 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763587#comment-17763587 ] Zili Chen edited comment on FLINK-33019 at 9/11/23 7:57 AM:

[jira] [Comment Edited] (FLINK-33019) Pulsar tests hangs during nightly builds

2023-09-11 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763587#comment-17763587 ] Zili Chen edited comment on FLINK-33019 at 9/11/23 7:57 AM:

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-13 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764702#comment-17764702 ] Zili Chen commented on FLINK-33053: --- I noticed that the {{TreeCache}}'s close call {{r

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-13 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764721#comment-17764721 ] Zili Chen commented on FLINK-33053: --- See https://lists.apache.org/thread/3b9hn9j4c05yf

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-13 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764723#comment-17764723 ] Zili Chen commented on FLINK-33053: --- But we don't have other shared watchers so we can

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-13 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764948#comment-17764948 ] Zili Chen commented on FLINK-33053: --- No. Both {{CuratorCache}} and {{TreeCache}} doesn

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-13 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764950#comment-17764950 ] Zili Chen commented on FLINK-33053: --- But it's possible to add an option to explicitly

[jira] [Commented] (FLINK-33111) Flink Pulsar Connector to Pulsar Client Version Mismatch

2023-09-20 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767131#comment-17767131 ] Zili Chen commented on FLINK-33111: --- We upgrade the Pulsar client version in https://

[jira] [Assigned] (FLINK-32938) flink-connector-pulsar should remove all `PulsarAdmin` calls

2023-09-20 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-32938: - Assignee: Neng Lu > flink-connector-pulsar should remove all `PulsarAdmin` calls >

[jira] [Resolved] (FLINK-32938) flink-connector-pulsar should remove all `PulsarAdmin` calls

2023-09-20 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-32938. --- Fix Version/s: pulsar-4.1.0 Resolution: Fixed master via 78d00ea9e3e278d4ce2fbb0c8a8d380abef7

[jira] [Assigned] (FLINK-20424) The percent of acknowledged checkpoint seems incorrect

2020-12-03 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-20424: - Assignee: Andrew.D.lin > The percent of acknowledged checkpoint seems incorrect > -

[jira] [Commented] (FLINK-20424) The percent of acknowledged checkpoint seems incorrect

2020-12-03 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242998#comment-17242998 ] Zili Chen commented on FLINK-20424: --- @andrew_lin Go ahead and remember update status w

[jira] [Created] (FLINK-20139) Enrich logs when MiniDispatcher shutting down

2020-11-12 Thread Zili Chen (Jira)
Zili Chen created FLINK-20139: - Summary: Enrich logs when MiniDispatcher shutting down Key: FLINK-20139 URL: https://issues.apache.org/jira/browse/FLINK-20139 Project: Flink Issue Type: Improveme

[jira] [Closed] (FLINK-20139) Enrich logs when MiniDispatcher shutting down

2020-11-13 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-20139. - Fix Version/s: 1.13.0 Resolution: Fixed master via 3dc43e6fa66d1253a37e8a4bcf242b6865e340a5 > En

[jira] [Commented] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069163#comment-17069163 ] Zili Chen commented on FLINK-16626: --- Could you reproduce that issue and share DEBUG le

[jira] [Comment Edited] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069163#comment-17069163 ] Zili Chen edited comment on FLINK-16626 at 3/28/20, 1:19 AM: -

[jira] [Updated] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-16626: -- Attachment: jobmanager.log > Exception encountered when cancelling a job in yarn per-job mode > --

[jira] [Commented] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069184#comment-17069184 ] Zili Chen commented on FLINK-16626: --- I've submitted a local YARN testing log, which in

[jira] [Commented] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069188#comment-17069188 ] Zili Chen commented on FLINK-16626: --- For coming developer: you can duplicate {{YARNITC

[jira] [Commented] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069221#comment-17069221 ] Zili Chen commented on FLINK-16626: --- I found that {{org.apache.flink.runtime.rest.han

[jira] [Updated] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-16626: -- Attachment: jobmanager.log > Exception encountered when cancelling a job in yarn per-job mode > --

[jira] [Updated] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-16626: -- Attachment: patch.diff > Exception encountered when cancelling a job in yarn per-job mode > --

[jira] [Updated] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-16626: -- Attachment: (was: jobmanager.log) > Exception encountered when cancelling a job in yarn per-job mo

[jira] [Commented] (FLINK-16637) Flink per job mode terminates before serving job cancellation result

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069225#comment-17069225 ] Zili Chen commented on FLINK-16637: --- [~gjy] I checked the code and did some tests(see

[jira] [Commented] (FLINK-16637) Flink per job mode terminates before serving job cancellation result

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069226#comment-17069226 ] Zili Chen commented on FLINK-16637: --- I think I find the problem, we register the cance

[jira] [Comment Edited] (FLINK-16637) Flink per job mode terminates before serving job cancellation result

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069226#comment-17069226 ] Zili Chen edited comment on FLINK-16637 at 3/28/20, 4:54 AM: -

[jira] [Commented] (FLINK-16637) Flink per job mode terminates before serving job cancellation result

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069227#comment-17069227 ] Zili Chen commented on FLINK-16637: --- The solution should be straightforward: we ensure

[jira] [Commented] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069232#comment-17069232 ] Zili Chen commented on FLINK-16626: --- link to the analysis https://issues.apache.org/j

[jira] [Closed] (FLINK-16637) Flink per job mode terminates before serving job cancellation result

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-16637. - Fix Version/s: (was: 1.10.1) (was: 1.11.0) Resolution: Duplicate > Fli

[jira] [Updated] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-27 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-16626: -- Fix Version/s: 1.11.0 1.10.1 > Exception encountered when cancelling a job in yarn

[jira] [Commented] (FLINK-16637) Flink per job mode terminates before serving job cancellation result

2020-03-31 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072312#comment-17072312 ] Zili Chen commented on FLINK-16637: --- [~gjy] >The solution should be straightforward:

[jira] [Updated] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-31 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-16626: -- Priority: Blocker (was: Major) > Exception encountered when cancelling a job in yarn per-job mode > -

[jira] [Assigned] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-31 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-16626: - Assignee: Weike Dong > Exception encountered when cancelling a job in yarn per-job mode > -

[jira] [Commented] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-31 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072315#comment-17072315 ] Zili Chen commented on FLINK-16626: --- [~kyledong] Thanks for your interest. I've assign

[jira] [Commented] (FLINK-16915) Cannot find compatible factory for specified execution.target (=local)

2020-04-01 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072628#comment-17072628 ] Zili Chen commented on FLINK-16915: --- I think it is fixed by FLINK-16834, please take a

[jira] [Closed] (FLINK-16737) Remove KubernetesUtils#getContentFromFile

2020-04-01 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-16737. - Resolution: Fixed master(1.11) via 0622ef7cac7d4e882e6a0f9df137e06400053e93 > Remove KubernetesUtils#ge

[jira] [Commented] (FLINK-16737) Remove KubernetesUtils#getContentFromFile

2020-04-01 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073330#comment-17073330 ] Zili Chen commented on FLINK-16737: --- [~csbliss] the next time you're interested in a t

[jira] [Closed] (FLINK-16749) Support to set node selector for JM/TM pod

2020-04-07 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-16749. - Resolution: Fixed master(1.11) via 5b54a2580172a7f3c518211c1bfc5f987ebbadba > Support to set node selec

  1   2   3   4   5   6   7   8   >