[jira] [Commented] (FLINK-32025) Make job cancellation button on UI configurable

[ https://issues.apache.org/jira/browse/FLINK-32025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720362#comment-17720362 ] Echo Lee commented on FLINK-32025: -- It is already possible to hide the 'cancel job' button by setting

[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-30371: - Description: When writing to the target table fails for some reason, for example, the target table

[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-30371: - Description: When writing to the target table fails for some reason, for example, the target table

[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-30371: - Description: When writing to the target table fails for some reason, for example, the target table

[jira] [Commented] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645992#comment-17645992 ] Echo Lee commented on FLINK-30371: -- CC [~martijnvisser]  Can you assign this ticket to me? >

[jira] [Created] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

Echo Lee created FLINK-30371: Summary: JdbcOutputFormat is at risk of database connection leaks Key: FLINK-30371 URL: https://issues.apache.org/jira/browse/FLINK-30371 Project: Flink Issue Type:

[jira] (FLINK-27176) FLIP-220: Binary Sorted State

[ https://issues.apache.org/jira/browse/FLINK-27176 ] Echo Lee deleted comment on FLINK-27176: -- was (Author: echo lee): Hi [~danderson]  Is there any progress on this feature? We want to optimize temporal join operator. I think this idea is very

[jira] [Commented] (FLINK-27176) FLIP-220: Temporal State

[ https://issues.apache.org/jira/browse/FLINK-27176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17601105#comment-17601105 ] Echo Lee commented on FLINK-27176: -- Hi [~danderson]  Is there any progress on this feature? We want to

[jira] [Commented] (FLINK-25360) Add State Desc to CheckpointMetadata

[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581598#comment-17581598 ] Echo Lee commented on FLINK-25360: -- [~liufangqi] Thank you very much for coming up with this idea. We

[jira] [Commented] (FLINK-28576) Kafka's two source api performance differences

[ https://issues.apache.org/jira/browse/FLINK-28576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17567828#comment-17567828 ] Echo Lee commented on FLINK-28576: -- [~martijnvisser] Thanks for your reply, I just print the time spent

[jira] [Commented] (FLINK-28576) Kafka's two source api performance differences

[ https://issues.apache.org/jira/browse/FLINK-28576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17567563#comment-17567563 ] Echo Lee commented on FLINK-28576: -- CC [~martijnvisser] Can you help explain this difference? thanks.

[jira] [Created] (FLINK-28576) Kafka's two source api performance differences

Echo Lee created FLINK-28576: Summary: Kafka's two source api performance differences Key: FLINK-28576 URL: https://issues.apache.org/jira/browse/FLINK-28576 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-27349) The timeout of some methods such as JobMaster#requestJobXXX(Time timeout) does not take effect

[ https://issues.apache.org/jira/browse/FLINK-27349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-27349: - Description: The timeout of some methods such as *JobMaster#requestJobXXX(Time timeout)* does not take

[jira] [Created] (FLINK-27349) The timeout of some methods such as JobMaster#requestJobXXX(Time timeout) does not take effect

Echo Lee created FLINK-27349: Summary: The timeout of some methods such as JobMaster#requestJobXXX(Time timeout) does not take effect Key: FLINK-27349 URL: https://issues.apache.org/jira/browse/FLINK-27349

[jira] [Updated] (FLINK-27315) [docs] Fix the demo of MemoryStateBackendMigration

[ https://issues.apache.org/jira/browse/FLINK-27315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-27315: - Summary: [docs] Fix the demo of MemoryStateBackendMigration (was: Fix the demo of

[jira] [Commented] (FLINK-27315) Fix the demo of MemoryStateBackendMigration

[ https://issues.apache.org/jira/browse/FLINK-27315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524649#comment-17524649 ] Echo Lee commented on FLINK-27315: -- CC [~yunta]  > Fix the demo of MemoryStateBackendMigration >

[jira] [Updated] (FLINK-27315) Fix the demo of MemoryStateBackendMigration

[ https://issues.apache.org/jira/browse/FLINK-27315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-27315: - Priority: Minor (was: Major) > Fix the demo of MemoryStateBackendMigration >

[jira] [Created] (FLINK-27315) Fix the demo of MemoryStateBackendMigration

Echo Lee created FLINK-27315: Summary: Fix the demo of MemoryStateBackendMigration Key: FLINK-27315 URL: https://issues.apache.org/jira/browse/FLINK-27315 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-26169) There is a typo in the annotation for the WatermarkAlignmentParams class

[ https://issues.apache.org/jira/browse/FLINK-26169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494471#comment-17494471 ] Echo Lee commented on FLINK-26169: -- CC [~pnowojski]  > There is a typo in the annotation for the

[jira] [Created] (FLINK-26169) There is a typo in the annotation for the WatermarkAlignmentParams class

Echo Lee created FLINK-26169: Summary: There is a typo in the annotation for the WatermarkAlignmentParams class Key: FLINK-26169 URL: https://issues.apache.org/jira/browse/FLINK-26169 Project: Flink

[jira] [Comment Edited] (FLINK-25561) Execution mode of batch mode job web ui shows pipeline

[ https://issues.apache.org/jira/browse/FLINK-25561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470398#comment-17470398 ] Echo Lee edited comment on FLINK-25561 at 1/7/22, 7:56 AM: --- Yes, maybe

[jira] [Commented] (FLINK-25561) Execution mode of batch mode job web ui shows pipeline

[ https://issues.apache.org/jira/browse/FLINK-25561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470398#comment-17470398 ] Echo Lee commented on FLINK-25561: -- Yes, Maybe ExecutionConfigInfo#executionMode should be changed to

[jira] [Created] (FLINK-25561) Execution mode of batch mode job web ui shows pipeline

Echo Lee created FLINK-25561: Summary: Execution mode of batch mode job web ui shows pipeline Key: FLINK-25561 URL: https://issues.apache.org/jira/browse/FLINK-25561 Project: Flink Issue Type:

[jira] [Commented] (FLINK-19002) Support to only read changelogs of specific database and table for canal-json format

[ https://issues.apache.org/jira/browse/FLINK-19002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469791#comment-17469791 ] Echo Lee commented on FLINK-19002: -- Hi [~jark] Does this mean that each table corresponds to a Kafka

[jira] [Closed] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee closed FLINK-20641. Resolution: Not A Bug > flink-connector-elasticsearch6 will deadlock >

[jira] [Closed] (FLINK-20643) flink-connector-elasticsearch7 causes Direct buffer memory OOM

[ https://issues.apache.org/jira/browse/FLINK-20643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee closed FLINK-20643. Resolution: Not A Bug > flink-connector-elasticsearch7 causes Direct buffer memory OOM >

[jira] [Closed] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee closed FLINK-24891. Resolution: Fixed > PrometheusPushGatewayReporter support filter label keys >

[jira] [Commented] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443569#comment-17443569 ] Echo Lee commented on FLINK-24891: -- [~wangyang0918] Yes, this is exactly what i want. Thanks, I will

[jira] [Commented] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443508#comment-17443508 ] Echo Lee commented on FLINK-24891: -- Hi [~chesnay] Can you take a look at it, and if it is worth doing,

[jira] [Updated] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-24891: - Description: Sometimes, we don’t care some label keys, such as host, tm_id, etc. At the same time, we

[jira] [Updated] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-24891: - Description: Sometimes, we don’t care some label keys, such as host, tm_id, etc. At the same time, we

[jira] [Updated] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-24891: - Description: Sometimes, we don’t care some label keys, such as host, tm_id, etc. At the same time, we

[jira] [Updated] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-24891: - Description: Sometimes, we don’t care some label keys, such as host, tm_id, etc. At the same time, we

[jira] [Updated] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-24891: - Description: Sometimes, we don’t care some label keys. At the same time, we can make the label very

[jira] [Created] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

Echo Lee created FLINK-24891: Summary: PrometheusPushGatewayReporter support filter label keys Key: FLINK-24891 URL: https://issues.apache.org/jira/browse/FLINK-24891 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20414) 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist

[ https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434784#comment-17434784 ] Echo Lee commented on FLINK-20414: -- Hi [~zhisheng] [~jark] I also encountered this problem, is because

[jira] [Commented] (FLINK-20228) ESsink accur thread blocked

[ https://issues.apache.org/jira/browse/FLINK-20228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265650#comment-17265650 ] Echo Lee commented on FLINK-20228: -- [~liqi316] You can look at 

[jira] [Created] (FLINK-20643) flink-connector-elasticsearch7 causes Direct buffer memory OOM

Echo Lee created FLINK-20643: Summary: flink-connector-elasticsearch7 causes Direct buffer memory OOM Key: FLINK-20643 URL: https://issues.apache.org/jira/browse/FLINK-20643 Project: Flink

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink version: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink version: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Attachment: jstack > flink-connector-elasticsearch6 will deadlock >

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink version: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink version: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink version: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink vision: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[jira] [Created] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

Echo Lee created FLINK-20641: Summary: flink-connector-elasticsearch6 will deadlock Key: FLINK-20641 URL: https://issues.apache.org/jira/browse/FLINK-20641 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20545) SQLClientSchemaRegistryITCase compilation failed

[ https://issues.apache.org/jira/browse/FLINK-20545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246391#comment-17246391 ] Echo Lee commented on FLINK-20545: -- [~dwysakowicz] Thank you for the link. Now the problem is solved.

[jira] [Created] (FLINK-20545) SQLClientSchemaRegistryITCase compilation failed

Echo Lee created FLINK-20545: Summary: SQLClientSchemaRegistryITCase compilation failed Key: FLINK-20545 URL: https://issues.apache.org/jira/browse/FLINK-20545 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-19005) used metaspace grow on every execution

[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183904#comment-17183904 ] Echo Lee commented on FLINK-19005: -- Yes, I turned on JMX in order to monitor the changes of Metaspace

[jira] [Commented] (FLINK-19005) used metaspace grow on every execution

[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183887#comment-17183887 ] Echo Lee commented on FLINK-19005: -- [~chesnay] Wordcount.jar is not easy to reproduce this issue, but

[jira] [Updated] (FLINK-19005) used metaspace grow on every execution

[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-19005: - Attachment: heap_dump_echo_lee.tar.xz > used metaspace grow on every execution >

[jira] [Commented] (FLINK-19005) used metaspace grow on every execution

[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17182968#comment-17182968 ] Echo Lee commented on FLINK-19005: -- [~chesnay] Is there any new progress on this issue?  > used

[jira] [Commented] (FLINK-19005) used metaspace grow on every execution

[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181737#comment-17181737 ] Echo Lee commented on FLINK-19005: -- [~chesnay] I also encountered this problem, which I raised in the

[jira] [Comment Edited] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180929#comment-17180929 ] Echo Lee edited comment on FLINK-16408 at 8/20/20, 2:37 AM: [~trohrmann] 

[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180929#comment-17180929 ] Echo Lee commented on FLINK-16408: -- [~trohrmann]  [~sewen]  I also found another phenomenon. We submit

[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180311#comment-17180311 ] Echo Lee commented on FLINK-16408: -- [~trohrmann]  Yes, The problem I currently encounter is that

[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180215#comment-17180215 ] Echo Lee commented on FLINK-16408: -- [~trohrmann] I tested it with Wordcount.jar and submitted it to the

[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178863#comment-17178863 ] Echo Lee commented on FLINK-16408: -- Thanks for your answer [~trohrmann] According to my understanding,

[jira] [Comment Edited] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178758#comment-17178758 ] Echo Lee edited comment on FLINK-16408 at 8/17/20, 6:44 AM: Hi [~trohrmann]  

[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178758#comment-17178758 ] Echo Lee commented on FLINK-16408: -- Hi [~trohrmann]  If I cancel and submit the same application and

[jira] [Updated] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-16408: - Attachment: Metaspace-OOM.png > Bind user code class loader to lifetime of a slot >

[jira] [Updated] (FLINK-18601) TaskManager shut down often in standalone cluster

[ https://issues.apache.org/jira/browse/FLINK-18601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-18601: - Summary: TaskManager shut down often in standalone cluster (was: Taskmanager shut down often in

[jira] [Created] (FLINK-18601) Taskmanager shut down often in standalone cluster

Echo Lee created FLINK-18601: Summary: Taskmanager shut down often in standalone cluster Key: FLINK-18601 URL: https://issues.apache.org/jira/browse/FLINK-18601 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-18510) Job Listener Interface failed

[ https://issues.apache.org/jira/browse/FLINK-18510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153421#comment-17153421 ] Echo Lee commented on FLINK-18510: -- [~linweilun]  You can see

[jira] [Commented] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17150847#comment-17150847 ] Echo Lee commented on FLINK-18449: --   I agree with [~fsk119] , but the naming is a little different.

[jira] [Created] (FLINK-18424) How does standalone mode not rely on distributed state storage

Echo Lee created FLINK-18424: Summary: How does standalone mode not rely on distributed state storage Key: FLINK-18424 URL: https://issues.apache.org/jira/browse/FLINK-18424 Project: Flink

[jira] [Comment Edited] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142724#comment-17142724 ] Echo Lee edited comment on FLINK-18211 at 6/23/20, 11:13 AM: - [~fly_in_gis]

[jira] [Comment Edited] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142724#comment-17142724 ] Echo Lee edited comment on FLINK-18211 at 6/23/20, 11:09 AM: - [~fly_in_gis]

[jira] [Comment Edited] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142724#comment-17142724 ] Echo Lee edited comment on FLINK-18211 at 6/23/20, 10:50 AM: - [~fly_in_gis]

[jira] [Comment Edited] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142776#comment-17142776 ] Echo Lee edited comment on FLINK-18211 at 6/23/20, 10:49 AM: - We can see the

[jira] [Comment Edited] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142724#comment-17142724 ] Echo Lee edited comment on FLINK-18211 at 6/23/20, 10:47 AM: - [~fly_in_gis]

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142776#comment-17142776 ] Echo Lee commented on FLINK-18211: -- We can see the BlobLibraryCacheManager#createUserCodeClassLoader

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142724#comment-17142724 ] Echo Lee commented on FLINK-18211: -- [~fly_in_gis] I just verified it in standalone mode, It seems that

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142522#comment-17142522 ] Echo Lee commented on FLINK-18211: -- OK [~kkl0u], I have closed PR, do I need to close this issue? >

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141999#comment-17141999 ] Echo Lee commented on FLINK-18211: -- Thanks [~fly_in_gis]. > Dynamic properties setting 'pipeline.jars'

[jira] [Comment Edited] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141921#comment-17141921 ] Echo Lee edited comment on FLINK-18211 at 6/22/20, 12:09 PM: - [~kkl0u] 

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141921#comment-17141921 ] Echo Lee commented on FLINK-18211: -- [~kkl0u] [~fly_in_gis] I think it's a good idea! > Dynamic

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141779#comment-17141779 ] Echo Lee commented on FLINK-18211: -- [~kkl0u] I agree with you. {{GenericCLI}} is better than other cli,

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136234#comment-17136234 ] Echo Lee commented on FLINK-18211: -- [~fly_in_gis] Yes, I mean to combine the user configured 

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129044#comment-17129044 ] Echo Lee commented on FLINK-18211: -- CC [~kkl0u] If this is a problem, can you assign it to me? >

[jira] [Created] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

Echo Lee created FLINK-18211: Summary: Dynamic properties setting 'pipeline.jars' will be overwritten Key: FLINK-18211 URL: https://issues.apache.org/jira/browse/FLINK-18211 Project: Flink

[jira] [Commented] (FLINK-17744) StreamContextEnvironment#execute cannot be call JobListener#onJobExecuted

[ https://issues.apache.org/jira/browse/FLINK-17744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117690#comment-17117690 ] Echo Lee commented on FLINK-17744: -- Hi [~kkl0u] I have modified the PR according to your suggestion,

[jira] [Commented] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117572#comment-17117572 ] Echo Lee commented on FLINK-17935: -- [~fly_in_gis] Yes, I agree with this unified solution. But first

[jira] [Commented] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117221#comment-17117221 ] Echo Lee commented on FLINK-17935: -- [~kkl0u] You are right. Because of business needs, we have

[jira] [Commented] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116699#comment-17116699 ] Echo Lee commented on FLINK-17935: -- [~fly_in_gis] There is really a problem here. Our approach is to

[jira] [Closed] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee closed FLINK-17745. Resolution: Not A Problem > PackagedProgram' extractedTempLibraries and jarfiles may be duplicate >

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112719#comment-17112719 ] Echo Lee commented on FLINK-17745: -- [~fly_in_gis] Yes, this is not a problem. [~kkl0u] Ok, i will 

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111697#comment-17111697 ] Echo Lee commented on FLINK-17745: -- [~kkl0u] [~fly_in_gis] So, I think you're right. I didn't think

[jira] [Comment Edited] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110805#comment-17110805 ] Echo Lee edited comment on FLINK-17745 at 5/19/20, 3:08 AM: [~kkl0u] I don't

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110805#comment-17110805 ] Echo Lee commented on FLINK-17745: -- [~kkl0u] I don't think nested jar should be removed, because in