[jira] [Closed] (FLINK-15365) Introduce streaming task using rocksDB backend e2e tests for Mesos

2020-03-23 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-15365. -- > Introduce streaming task using rocksDB backend e2e tests for Mesos >

[jira] [Resolved] (FLINK-15364) Introduce streaming task using heap backend e2e tests for Mesos

2020-03-23 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo resolved FLINK-15364. Resolution: Won't Fix > Introduce streaming task using heap backend e2e tests for Mesos >

[jira] [Updated] (FLINK-15364) Introduce streaming task using heap backend e2e tests for Mesos

2020-03-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15364: --- Description: [As

[jira] [Comment Edited] (FLINK-16605) Add max limitation to the total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059919#comment-17059919 ] Yangze Guo edited comment on FLINK-16605 at 3/16/20, 3:06 AM: -- [~trohrmann]

[jira] [Commented] (FLINK-16605) Add max limitation to the total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059919#comment-17059919 ] Yangze Guo commented on FLINK-16605: Could some kindly assign this to me? I'd like to work for it,

[jira] [Updated] (FLINK-16605) Add max limitation to the total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16605: --- Description: As discussed in FLINK-15527 and FLINK-15959, we propose to add the max limit to the

[jira] [Updated] (FLINK-16605) Add max limitation to the total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16605: --- Description: As discussed in FLINK-15527 and FLINK-15959, we propose to add the max limit to the

[jira] [Updated] (FLINK-15959) Add min number of slots configuration to limit total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15959: --- Summary: Add min number of slots configuration to limit total number of slots (was: Add min/max

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-03-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059911#comment-17059911 ] Yangze Guo commented on FLINK-15959: FYI: As there is no response for nearly two weeks. I open

[jira] [Created] (FLINK-16605) Add max limitation to the total number of slots

2020-03-15 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-16605: -- Summary: Add max limitation to the total number of slots Key: FLINK-16605 URL: https://issues.apache.org/jira/browse/FLINK-16605 Project: Flink Issue Type:

[jira] [Updated] (FLINK-16548) [Requirement] Consistent id to identify jm/tm in different cluster modes

2020-03-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16548: --- Parent: FLINK-15679 Issue Type: Sub-task (was: Wish) > [Requirement] Consistent id to

[jira] [Commented] (FLINK-16548) [Requirement] Consistent id to identify jm/tm in different cluster modes

2020-03-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057757#comment-17057757 ] Yangze Guo commented on FLINK-16548: Thanks for the information [~fly_in_gis]. I think it is a valid

[jira] [Commented] (FLINK-15666) GPU scheduling support in Kubernetes mode

2020-03-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057733#comment-17057733 ] Yangze Guo commented on FLINK-15666: Hi, [~felixzheng]. We have opened FLIP-108 in which we address

[jira] [Created] (FLINK-16566) Change the log level of the launching command and dynamic properties from DEBUG to INFO in Mesos integration

2020-03-12 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-16566: -- Summary: Change the log level of the launching command and dynamic properties from DEBUG to INFO in Mesos integration Key: FLINK-16566 URL:

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-03-08 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054589#comment-17054589 ] Yangze Guo commented on FLINK-15959: Hi, [~liuyufei]. I'm very interested and pay close attention to

[jira] [Commented] (FLINK-16462) PrometheusReporterEndToEndITCase failed with NoClassDefFoundError RequestBody

2020-03-06 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053358#comment-17053358 ] Yangze Guo commented on FLINK-16462: Another instance 

[jira] [Closed] (FLINK-16299) Release containers recovered from previous attempt in which TaskExecutor is not started.

2020-03-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-16299. -- > Release containers recovered from previous attempt in which TaskExecutor is > not started. >

[jira] [Commented] (FLINK-15727) Let BashJavaUtils return dynamic configs and JVM parameters in one call

2020-03-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051757#comment-17051757 ] Yangze Guo commented on FLINK-15727: Hi, [~trohrmann]. I'd like to work on it. Could you assign this

[jira] [Commented] (FLINK-16416) Shutdown the task manager gracefully in standalone mode

2020-03-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051737#comment-17051737 ] Yangze Guo commented on FLINK-16416: [~azagrebin] Thanks for the explanation. I agree that there is

[jira] [Resolved] (FLINK-16416) Shutdown the task manager gracefully in standalone mode

2020-03-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo resolved FLINK-16416. Resolution: Won't Fix > Shutdown the task manager gracefully in standalone mode >

[jira] [Closed] (FLINK-16416) Shutdown the task manager gracefully in standalone mode

2020-03-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-16416. -- > Shutdown the task manager gracefully in standalone mode >

[jira] [Commented] (FLINK-16416) Shutdown the task manager gracefully in standalone mode

2020-03-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051220#comment-17051220 ] Yangze Guo commented on FLINK-16416: I agree that we should not delay the abrupt TM shutdown.

[jira] [Comment Edited] (FLINK-16416) Shutdown the task manager gracefully in standalone mode

2020-03-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051212#comment-17051212 ] Yangze Guo edited comment on FLINK-16416 at 3/4/20, 1:13 PM: - [~azagrebin]

[jira] [Commented] (FLINK-16416) Shutdown the task manager gracefully in standalone mode

2020-03-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051212#comment-17051212 ] Yangze Guo commented on FLINK-16416: AFAIK, the `TaskExecutor#onStop` is not called when I run

[jira] [Updated] (FLINK-16416) Shutdown the task manager gracefully in standalone mode

2020-03-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16416: --- Description: Recently, I try to add a new {{GPUManager}} to the {{TaskExecutorServices}}. I

[jira] [Created] (FLINK-16416) Shutdown the task manager gracefully in standalone mode

2020-03-03 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-16416: -- Summary: Shutdown the task manager gracefully in standalone mode Key: FLINK-16416 URL: https://issues.apache.org/jira/browse/FLINK-16416 Project: Flink Issue

[jira] [Resolved] (FLINK-16299) Release containers recovered from previous attempt in which TaskExecutor is not started.

2020-03-03 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo resolved FLINK-16299. Resolution: Not A Problem > Release containers recovered from previous attempt in which

[jira] [Commented] (FLINK-16215) Start redundant TaskExecutor when JM failed

2020-03-03 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050678#comment-17050678 ] Yangze Guo commented on FLINK-16215: [~liuyufei] Hi, after a deeper investigation, we believe

[jira] [Commented] (FLINK-16299) Release containers recovered from previous attempt in which TaskExecutor is not started.

2020-03-03 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050674#comment-17050674 ] Yangze Guo commented on FLINK-16299: After a deeper investigation, I believe this is actually not an

[jira] [Commented] (FLINK-16299) Release containers recovered from previous attempt in which TaskExecutor is not started.

2020-02-26 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046248#comment-17046248 ] Yangze Guo commented on FLINK-16299: I'd like work on it. > Release containers recovered from

[jira] [Comment Edited] (FLINK-16299) Release containers recovered from previous attempt in which TaskExecutor is not started.

2020-02-26 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046248#comment-17046248 ] Yangze Guo edited comment on FLINK-16299 at 2/27/20 7:17 AM: - I'd like to

[jira] [Commented] (FLINK-16215) Start redundant TaskExecutor when JM failed

2020-02-26 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046198#comment-17046198 ] Yangze Guo commented on FLINK-16215: [~liuyufei] SlotManager will decide what and how many

[jira] [Commented] (FLINK-16297) Remove the redundant intent and blank line in highlight code blocks

2020-02-26 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046192#comment-17046192 ] Yangze Guo commented on FLINK-16297: [~chesnay] I'd like to work for it. Could you assign this to

[jira] [Updated] (FLINK-16297) Remove the redundant intent and blank line in highlight code blocks

2020-02-26 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16297: --- Description: Currently, there are lots of redundant intent and blank lines in highlight code

[jira] [Created] (FLINK-16297) Remove the redundant intent and blank line in highlight code blocks

2020-02-26 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-16297: -- Summary: Remove the redundant intent and blank line in highlight code blocks Key: FLINK-16297 URL: https://issues.apache.org/jira/browse/FLINK-16297 Project: Flink

[jira] [Commented] (FLINK-16237) Wordcount on Docker test (custom fs plugin) fails.

2020-02-22 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042766#comment-17042766 ] Yangze Guo commented on FLINK-16237: It seems related to FLINK-15672. cc: [~chesnay] > Wordcount on

[jira] [Updated] (FLINK-16237) Wordcount on Docker test (custom fs plugin) fails.

2020-02-22 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16237: --- Description: Wordcount on Docker test (custom fs plugin) fails on Travis. 

[jira] [Created] (FLINK-16237) Wordcount on Docker test (custom fs plugin) fails.

2020-02-22 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-16237: -- Summary: Wordcount on Docker test (custom fs plugin) fails. Key: FLINK-16237 URL: https://issues.apache.org/jira/browse/FLINK-16237 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-16228) test_mesos_wordcount.sh fails

2020-02-22 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042591#comment-17042591 ] Yangze Guo edited comment on FLINK-16228 at 2/23/20 12:26 AM: -- Currently,

[jira] [Commented] (FLINK-16228) test_mesos_wordcount.sh fails

2020-02-22 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042591#comment-17042591 ] Yangze Guo commented on FLINK-16228: Currently, the Flink's Mesos integration is not hadoop-free,

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-20 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041609#comment-17041609 ] Yangze Guo commented on FLINK-15959: Hi, [~liuyufei]. I have basic some ideas from the perspective

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2020-02-18 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038890#comment-17038890 ] Yangze Guo commented on FLINK-12122: [~huwh], We have some discussion in FLINK-15959. > Spread out

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-16 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037840#comment-17037840 ] Yangze Guo commented on FLINK-15959: Yes, I think it is equivalent to the "maximum slots number"

[jira] [Comment Edited] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037719#comment-17037719 ] Yangze Guo edited comment on FLINK-15959 at 2/16/20 7:10 AM: - Hi,

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037719#comment-17037719 ] Yangze Guo commented on FLINK-15959: Hi, [~liuyufei]. Thanks for proposing this change. Regarding

[jira] [Comment Edited] (FLINK-16052) Homebrew test failed with 1.10.0 dist package

2020-02-14 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036950#comment-17036950 ] Yangze Guo edited comment on FLINK-16052 at 2/14/20 1:02 PM: - FYI: I just

[jira] [Comment Edited] (FLINK-16052) Homebrew test failed with 1.10.0 dist package

2020-02-14 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036950#comment-17036950 ] Yangze Guo edited comment on FLINK-16052 at 2/14/20 12:59 PM: -- FYI: I just

[jira] [Comment Edited] (FLINK-16052) Homebrew test failed with 1.10.0 dist package

2020-02-14 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036950#comment-17036950 ] Yangze Guo edited comment on FLINK-16052 at 2/14/20 12:45 PM: -- FYI: I just

[jira] [Commented] (FLINK-16052) Homebrew test failed with 1.10.0 dist package

2020-02-14 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036950#comment-17036950 ] Yangze Guo commented on FLINK-16052: FYI: I just install Flink-1.10 by 'brew install

[jira] [Updated] (FLINK-15562) Improve the maven archetype command for SNAPSHOT versions document

2020-02-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15562: --- Description: For SNAPSHOT versions, if using 3.0 or higher version maven, the "archetypeCatalog"

[jira] [Updated] (FLINK-15562) Improve the maven archetype command for SNAPSHOT versions document

2020-02-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15562: --- Description: For SNAPSHOT versions, if using 3.0 or higher version maven, the "archetypeCatalog"

[jira] [Updated] (FLINK-15562) Improve the maven archetype command for SNAPSHOT versions document

2020-02-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15562: --- Summary: Improve the maven archetype command for SNAPSHOT versions document (was: Unable to create

[jira] [Commented] (FLINK-15562) Unable to create walk through project

2020-02-11 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034958#comment-17034958 ] Yangze Guo commented on FLINK-15562: Yes, I'd like to. > Unable to create walk through project >

[jira] [Closed] (FLINK-15870) Wait the job's terminal state through REST interface

2020-02-11 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-15870. -- Fix Version/s: (was: 1.11.0) Resolution: Won't Fix > Wait the job's terminal state through

[jira] [Commented] (FLINK-15870) Wait the job's terminal state through REST interface

2020-02-11 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034956#comment-17034956 ] Yangze Guo commented on FLINK-15870: [~gjy]Thanks for your information. I'm excited to see

[jira] [Commented] (FLINK-15870) Wait the job's terminal state through REST interface

2020-02-03 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029488#comment-17029488 ] Yangze Guo commented on FLINK-15870: cc [~gjy]. I'd like to work on it, after 1.10-release. > Wait

[jira] [Updated] (FLINK-15870) Wait the job's terminal state through REST interface

2020-02-03 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15870: --- Description: As discussed in [this

[jira] [Created] (FLINK-15870) Wait the job's terminal state through REST interface

2020-02-03 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-15870: -- Summary: Wait the job's terminal state through REST interface Key: FLINK-15870 URL: https://issues.apache.org/jira/browse/FLINK-15870 Project: Flink Issue Type:

[jira] [Commented] (FLINK-15562) Unable to create walk through project

2020-02-03 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029435#comment-17029435 ] Yangze Guo commented on FLINK-15562: Thanks for the information, I think it will work. I'd like to

[jira] [Commented] (FLINK-15666) GPU scheduling support in Kubernetes mode

2020-02-03 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028875#comment-17028875 ] Yangze Guo commented on FLINK-15666: [~felixzheng] AFAIK, it is in the 1.11 planning. However, it's

[jira] [Commented] (FLINK-15774) Consider adding an explicit network memory size config option

2020-02-02 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028672#comment-17028672 ] Yangze Guo commented on FLINK-15774: Just help to fix the broken link. > Consider adding an

[jira] [Updated] (FLINK-15774) Consider adding an explicit network memory size config option

2020-02-02 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15774: --- Description: See [PR discussion|https://github.com/apache/flink/pull/10946#discussion_r371169251]

[jira] [Commented] (FLINK-15562) Unable to create walk through project

2020-02-02 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028645#comment-17028645 ] Yangze Guo commented on FLINK-15562: [~gjy] I think it would help. I'm not sure whether we should

[jira] [Commented] (FLINK-15562) Unable to create walk through project

2020-01-22 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020989#comment-17020989 ] Yangze Guo commented on FLINK-15562: Thanks for the explanation [~gjy]. Agreed with you. Regarding

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-01-20 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019461#comment-17019461 ] Yangze Guo commented on FLINK-15611: [~gjy]Thanks for clarify it. > KafkaITCase.testOneToOneSources

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-01-20 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019377#comment-17019377 ] Yangze Guo commented on FLINK-15611: FYI, the branch tree is

[jira] [Created] (FLINK-15679) Improve Flink's ID system

2020-01-19 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-15679: -- Summary: Improve Flink's ID system Key: FLINK-15679 URL: https://issues.apache.org/jira/browse/FLINK-15679 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-15666) GPU scheduling support in Kubernetes mode

2020-01-19 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019179#comment-17019179 ] Yangze Guo commented on FLINK-15666: Not yet. The community is now focused on the release-1.10 and

[jira] [Commented] (FLINK-15666) GPU scheduling support in Kubernetes mode

2020-01-19 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018853#comment-17018853 ] Yangze Guo commented on FLINK-15666: Hi~[~felixzheng]. Currently, Flink does not well support the

[jira] [Updated] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-01-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15611: --- Priority: Blocker (was: Critical) > KafkaITCase.testOneToOneSources fails on Travis >

[jira] [Comment Edited] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-01-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17017786#comment-17017786 ] Yangze Guo edited comment on FLINK-15611 at 1/17/20 8:08 AM: - Hi, [~SleePy].

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-01-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17017786#comment-17017786 ] Yangze Guo commented on FLINK-15611: Hi, [~SleePy]. I'm not familiar with kafka connector module. Do

[jira] [Created] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-01-15 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-15611: -- Summary: KafkaITCase.testOneToOneSources fails on Travis Key: FLINK-15611 URL: https://issues.apache.org/jira/browse/FLINK-15611 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-15562) Unable to create walk through project

2020-01-13 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014152#comment-17014152 ] Yangze Guo commented on FLINK-15562: Hi, [~chesnay], I think it will benefit the user experience if

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013999#comment-17013999 ] Yangze Guo commented on FLINK-15527: I'm not quite familiar with the contract of yarn session mode

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013983#comment-17013983 ] Yangze Guo commented on FLINK-15527: [~ykt836] I think this approach won't solve this problem since

[jira] [Comment Edited] (FLINK-15562) Unable to create walk through project

2020-01-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013961#comment-17013961 ] Yangze Guo edited comment on FLINK-15562 at 1/13/20 2:11 AM: - _With

[jira] [Comment Edited] (FLINK-15562) Unable to create walk through project

2020-01-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013961#comment-17013961 ] Yangze Guo edited comment on FLINK-15562 at 1/13/20 2:09 AM: - _With

[jira] [Commented] (FLINK-15562) Unable to create walk through project

2020-01-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013961#comment-17013961 ] Yangze Guo commented on FLINK-15562: _With maven-archetype-plugin 3.x it is not possible anymore to

[jira] [Commented] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

2020-01-11 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013414#comment-17013414 ] Yangze Guo commented on FLINK-15549: Hi, [~caojian0613]. Thanks for your effort:). I'll try to find

[jira] [Commented] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

2020-01-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012755#comment-17012755 ] Yangze Guo commented on FLINK-15549: Same issue is also exist in _SpillingResettableIterator_ . I'd

[jira] [Commented] (FLINK-15247) Closing (Testing)MiniCluster may cause ConcurrentModificationException

2020-01-09 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012441#comment-17012441 ] Yangze Guo commented on FLINK-15247: Another instance:

[jira] [Commented] (FLINK-15448) Log host informations for TaskManager failures.

2020-01-09 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011567#comment-17011567 ] Yangze Guo commented on FLINK-15448: Hi, [~victor-wong], I am interested in this topic and would

[jira] [Commented] (FLINK-15488) Cannot start a taskmanger if using logback

2020-01-07 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009572#comment-17009572 ] Yangze Guo commented on FLINK-15488: Disable logging makes sense to me. Actually, it's a bit odd to

[jira] [Commented] (FLINK-15150) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on Travis

2020-01-06 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008633#comment-17008633 ] Yangze Guo commented on FLINK-15150: Another instance

[jira] [Commented] (FLINK-15247) Closing (Testing)MiniCluster may cause ConcurrentModificationException

2020-01-05 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008573#comment-17008573 ] Yangze Guo commented on FLINK-15247: Another instance

[jira] [Commented] (FLINK-15471) HA e2e check for empty .out files does not print specific error

2020-01-05 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008530#comment-17008530 ] Yangze Guo commented on FLINK-15471: You are right. we'll never go into the block of this if

[jira] [Commented] (FLINK-15247) Closing (Testing)MiniCluster may cause ConcurrentModificationException

2020-01-05 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008521#comment-17008521 ] Yangze Guo commented on FLINK-15247: Another instance of the same issue I believe: 

[jira] [Commented] (FLINK-15477) Create BatchTableEnvironment failed.

2020-01-05 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008513#comment-17008513 ] Yangze Guo commented on FLINK-15477: Hi, could you find {code:java}

[jira] [Commented] (FLINK-15417) Remove the docker volume or mount when starting Mesos e2e cluster

2019-12-31 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005991#comment-17005991 ] Yangze Guo commented on FLINK-15417: Could someone assign this to me? > Remove the docker volume or

[jira] [Updated] (FLINK-15442) Harden the Avro Confluent Schema Registry nightly end-to-end test

2019-12-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15442: --- Issue Type: Bug (was: Test) > Harden the Avro Confluent Schema Registry nightly end-to-end test >

[jira] [Updated] (FLINK-15442) Harden the Avro Confluent Schema Registry nightly end-to-end test

2019-12-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15442: --- Description: We have already harden the Avro Confluent Schema Registry test in

[jira] [Commented] (FLINK-15428) Avro Confluent Schema Registry nightly end-to-end test fails on travis

2019-12-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005932#comment-17005932 ] Yangze Guo commented on FLINK-15428: For not blocking the release progress, I open

[jira] [Commented] (FLINK-15442) Harden the Avro Confluent Schema Registry nightly end-to-end test

2019-12-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005931#comment-17005931 ] Yangze Guo commented on FLINK-15442: Could someone kindly assign this to me? > Harden the Avro

[jira] [Created] (FLINK-15442) Harden the Avro Confluent Schema Registry nightly end-to-end test

2019-12-30 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-15442: -- Summary: Harden the Avro Confluent Schema Registry nightly end-to-end test Key: FLINK-15442 URL: https://issues.apache.org/jira/browse/FLINK-15442 Project: Flink

[jira] [Commented] (FLINK-15428) Avro Confluent Schema Registry nightly end-to-end test fails on travis

2019-12-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005222#comment-17005222 ] Yangze Guo commented on FLINK-15428: FYI, I found it only produced under JDK 11 profile. As

[jira] [Commented] (FLINK-15428) Avro Confluent Schema Registry nightly end-to-end test fails on travis

2019-12-30 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005189#comment-17005189 ] Yangze Guo commented on FLINK-15428: Another instance after fix the wrong command:

[jira] [Commented] (FLINK-15428) Avro Confluent Schema Registry nightly end-to-end test fails on travis

2019-12-29 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005169#comment-17005169 ] Yangze Guo commented on FLINK-15428: Since the root cause is the missing of ".sh" for

[jira] [Commented] (FLINK-15428) Avro Confluent Schema Registry nightly end-to-end test fails on travis

2019-12-29 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005112#comment-17005112 ] Yangze Guo commented on FLINK-15428: BTW, the error message shows that there is missing ".sh" for

[jira] [Commented] (FLINK-15428) Avro Confluent Schema Registry nightly end-to-end test fails on travis

2019-12-29 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005100#comment-17005100 ] Yangze Guo commented on FLINK-15428: I found that if the cleanup command return 1, the

<    3   4   5   6   7   8   9   >