[jira] [Commented] (FLINK-8830) YarnResourceManager throws NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-8830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385710#comment-16385710 ] ASF GitHub Bot commented on FLINK-8830: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5629: [FLINK-8830][YARN] YarnResourceManager throws Null...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5629#discussion_r172105998 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java --- @@ -496,18 +496,20 @@ static ContainerLaunchContext createTaskExecutorContext(

[jira] [Commented] (FLINK-8829) Flink in EMR(YARN) is down due to Akka communication issue

[ https://issues.apache.org/jira/browse/FLINK-8829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385655#comment-16385655 ] Bowen Li commented on FLINK-8829: - [~Filichkin] A typical problem that I ran into this before on AWS. Try

[jira] [Comment Edited] (FLINK-7588) Document RocksDB tuning for spinning disks

[ https://issues.apache.org/jira/browse/FLINK-7588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258309#comment-16258309 ] Ted Yu edited comment on FLINK-7588 at 3/5/18 2:55 AM: --- bq. Be careful about whether

[jira] [Updated] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

[ https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7897: -- Description: nio.Files#delete() provides better clue as to why the deletion may fail:

[jira] [Assigned] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-8687: --- Assignee: mingleizhang > MaterializedCollectStreamResult#retrievePage should take resultLock

[jira] [Commented] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385511#comment-16385511 ] mingleizhang commented on FLINK-8687: - Thank you very much [~yuzhih...@gmail.com]. :) >

[jira] [Commented] (FLINK-8843) Decouple bind REST address from advertised address

[ https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385510#comment-16385510 ] ASF GitHub Bot commented on FLINK-8843: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5632: [FLINK-8843][REST] Decouple bind REST address from...

GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5632 [FLINK-8843][REST] Decouple bind REST address from advertised address ## What is the purpose of the change *This pull request decouples bind REST address from advertised address*

[jira] [Commented] (FLINK-8843) Decouple bind REST address from advertised address

[ https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385509#comment-16385509 ] ASF GitHub Bot commented on FLINK-8843: --- Github user yanghua closed the pull request at:

[GitHub] flink pull request #5631: [FLINK-8843][REST] Decouple bind REST address from...

Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/5631 ---

[jira] [Commented] (FLINK-8843) Decouple bind REST address from advertised address

[ https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385504#comment-16385504 ] ASF GitHub Bot commented on FLINK-8843: --- GitHub user yanghua opened a pull request:

[jira] [Commented] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385502#comment-16385502 ] Ted Yu commented on FLINK-8687: --- I agree with what you said. > MaterializedCollectStreamResult#retrievePage

[GitHub] flink pull request #5631: [FLINK-8843][REST] Decouple bind REST address from...

GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5631 [FLINK-8843][REST] Decouple bind REST address from advertised address ## What is the purpose of the change *This pull request decouples bind REST address from advertised address*

[jira] [Commented] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385497#comment-16385497 ] mingleizhang commented on FLINK-8687: - Thanks [~yuzhih...@gmail.com] I checked what you said, I would

[jira] [Commented] (FLINK-8843) Decouple bind REST address from advertised address

[ https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385484#comment-16385484 ] vinoyang commented on FLINK-8843: - Hi [~mingleizhang] thanks. I know about 0.0.0.0 , I just make sure the

[jira] [Commented] (FLINK-8843) Decouple bind REST address from advertised address

[ https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385477#comment-16385477 ] mingleizhang commented on FLINK-8843: - Hi, [~yanghua] I think that is what Till meant. {{0.0.0.0}} can

[jira] [Commented] (FLINK-8855) SQL client result serving gets stuck in result-mode=table

[ https://issues.apache.org/jira/browse/FLINK-8855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385476#comment-16385476 ] Xingcan Cui commented on FLINK-8855: Hi [~fhueske], I'd like to look into this. Could you share more

[GitHub] flink issue #5614: [FLINK-8827] When FLINK_CONF_DIR contains spaces, execute...

Github user davidxdh commented on the issue: https://github.com/apache/flink/pull/5614 @StephanEwen, please review this pr, thanks. ---

[jira] [Commented] (FLINK-8827) When FLINK_CONF_DIR contains spaces, execute zookeeper related scripts failed

[ https://issues.apache.org/jira/browse/FLINK-8827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385464#comment-16385464 ] ASF GitHub Bot commented on FLINK-8827: --- Github user davidxdh commented on the issue:

[jira] [Updated] (FLINK-8856) Move all interrupt() calls to TaskCanceler

[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-8856: Description: We need this to work around the following JVM bug:

[jira] [Assigned] (FLINK-8856) Move all interrupt() calls to TaskCanceler

[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-8856: --- Assignee: Stephan Ewen > Move all interrupt() calls to TaskCanceler >

[jira] [Commented] (FLINK-8834) Job fails to restart due to some tasks stuck in cancelling state

[ https://issues.apache.org/jira/browse/FLINK-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385456#comment-16385456 ] Stephan Ewen commented on FLINK-8834: - I filed a follow-up under FLINK-8856 > Job fails to restart

[jira] [Updated] (FLINK-8856) Move all interrupt() calls to TaskCanceler

[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-8856: Fix Version/s: 1.6.0 > Move all interrupt() calls to TaskCanceler >

[jira] [Created] (FLINK-8856) Move all interrupt() calls to TaskCanceler

Stephan Ewen created FLINK-8856: --- Summary: Move all interrupt() calls to TaskCanceler Key: FLINK-8856 URL: https://issues.apache.org/jira/browse/FLINK-8856 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8834) Job fails to restart due to some tasks stuck in cancelling state

[ https://issues.apache.org/jira/browse/FLINK-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385453#comment-16385453 ] Stephan Ewen commented on FLINK-8834: - Thanks, that is interesting, and mighty suspicious. If I read

[jira] [Comment Edited] (FLINK-8834) Job fails to restart due to some tasks stuck in cancelling state

[ https://issues.apache.org/jira/browse/FLINK-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385453#comment-16385453 ] Stephan Ewen edited comment on FLINK-8834 at 3/5/18 12:41 AM: -- Thanks, that

[jira] [Commented] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

[ https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385448#comment-16385448 ] ASF GitHub Bot commented on FLINK-8807: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5623: [FLINK-8807] Fix ZookeeperCompleted checkpoint store can ...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5623 I would suggest to do the comparison by checking that the list have the same checkpoint IDs. ---

[jira] [Assigned] (FLINK-8851) SQL Client fails if same file is used as default and env configuration

[ https://issues.apache.org/jira/browse/FLINK-8851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-8851: --- Assignee: Timo Walther > SQL Client fails if same file is used as default and env

[jira] [Assigned] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

[ https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-8854: --- Assignee: Timo Walther > Mapping of SchemaValidator.deriveFieldMapping() is incorrect. >

[jira] [Assigned] (FLINK-8852) SQL Client does not work with new FLIP-6 mode

[ https://issues.apache.org/jira/browse/FLINK-8852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-8852: --- Assignee: Timo Walther > SQL Client does not work with new FLIP-6 mode >

[jira] [Assigned] (FLINK-8853) SQL Client cannot emit query results that contain a rowtime attribute

[ https://issues.apache.org/jira/browse/FLINK-8853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-8853: --- Assignee: Timo Walther > SQL Client cannot emit query results that contain a rowtime

[jira] [Assigned] (FLINK-8850) SQL Client does not support Event-time

[ https://issues.apache.org/jira/browse/FLINK-8850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-8850: --- Assignee: Timo Walther > SQL Client does not support Event-time >

[jira] [Updated] (FLINK-8686) Improve basic embedded SQL client

[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8686: - Description: This issue describes follow-up issues that should be fixes in order to make the SQL

[jira] [Created] (FLINK-8855) SQL client result serving gets stuck in result-mode=table

Fabian Hueske created FLINK-8855: Summary: SQL client result serving gets stuck in result-mode=table Key: FLINK-8855 URL: https://issues.apache.org/jira/browse/FLINK-8855 Project: Flink

[jira] [Created] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

Fabian Hueske created FLINK-8854: Summary: Mapping of SchemaValidator.deriveFieldMapping() is incorrect. Key: FLINK-8854 URL: https://issues.apache.org/jira/browse/FLINK-8854 Project: Flink

[jira] [Created] (FLINK-8853) SQL Client cannot emit query results that contain a rowtime attribute

Fabian Hueske created FLINK-8853: Summary: SQL Client cannot emit query results that contain a rowtime attribute Key: FLINK-8853 URL: https://issues.apache.org/jira/browse/FLINK-8853 Project: Flink

[jira] [Created] (FLINK-8852) SQL Client does not work with new FLIP-6 mode

Fabian Hueske created FLINK-8852: Summary: SQL Client does not work with new FLIP-6 mode Key: FLINK-8852 URL: https://issues.apache.org/jira/browse/FLINK-8852 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8851) SQL Client fails if same file is used as default and env configuration

Fabian Hueske created FLINK-8851: Summary: SQL Client fails if same file is used as default and env configuration Key: FLINK-8851 URL: https://issues.apache.org/jira/browse/FLINK-8851 Project: Flink

[jira] [Created] (FLINK-8850) SQL Client does not support Event-time

Fabian Hueske created FLINK-8850: Summary: SQL Client does not support Event-time Key: FLINK-8850 URL: https://issues.apache.org/jira/browse/FLINK-8850 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8849) Wrong link from concepts/runtime to doc on chaining

[ https://issues.apache.org/jira/browse/FLINK-8849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385256#comment-16385256 ] ASF GitHub Bot commented on FLINK-8849: --- GitHub user kkrugler opened a pull request:

[GitHub] flink pull request #5630: [FLINK-8849][Documentation] Fix link to chaining d...

GitHub user kkrugler opened a pull request: https://github.com/apache/flink/pull/5630 [FLINK-8849][Documentation] Fix link to chaining docs OK, after reading through the (very helpful) contributing text, it looks like you'd rather not have Jira issues for minor doc fixes, right?

[jira] [Created] (FLINK-8849) Wrong link from concepts/runtime to doc on chaining

Ken Krugler created FLINK-8849: -- Summary: Wrong link from concepts/runtime to doc on chaining Key: FLINK-8849 URL: https://issues.apache.org/jira/browse/FLINK-8849 Project: Flink Issue Type:

[jira] [Closed] (FLINK-8848) bin/start-cluster.sh won't start jobmanager on master machine.

[ https://issues.apache.org/jira/browse/FLINK-8848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yesheng Ma closed FLINK-8848. - Resolution: Not A Bug > bin/start-cluster.sh won't start jobmanager on master machine. >

[jira] [Commented] (FLINK-8848) bin/start-cluster.sh won't start jobmanager on master machine.

[ https://issues.apache.org/jira/browse/FLINK-8848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385166#comment-16385166 ] Yesheng Ma commented on FLINK-8848: --- Hi [~kkrugler], sorry about that. I will post this on the user

[jira] [Commented] (FLINK-8848) bin/start-cluster.sh won't start jobmanager on master machine.

[ https://issues.apache.org/jira/browse/FLINK-8848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385157#comment-16385157 ] Ken Krugler commented on FLINK-8848: Hi [~manifoldQAQ] - in general it's best to first post to the

[jira] [Created] (FLINK-8848) bin/start-cluster.sh won't start jobmanager on master machine.

Yesheng Ma created FLINK-8848: - Summary: bin/start-cluster.sh won't start jobmanager on master machine. Key: FLINK-8848 URL: https://issues.apache.org/jira/browse/FLINK-8848 Project: Flink

[jira] [Commented] (FLINK-8843) Decouple bind REST address from advertised address

[ https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385040#comment-16385040 ] vinoyang commented on FLINK-8843: - hi [~till.rohrmann] , you mean we should change the 

[jira] [Assigned] (FLINK-8843) Decouple bind REST address from advertised address

[ https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8843: --- Assignee: vinoyang > Decouple bind REST address from advertised address >

[jira] [Commented] (FLINK-8830) YarnResourceManager throws NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-8830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385038#comment-16385038 ] ASF GitHub Bot commented on FLINK-8830: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5629: [FLINK-8830][YARN] YarnResourceManager throws NullPointer...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5629 cc @tillrohrmann , please review Thanks! ---

[jira] [Commented] (FLINK-8830) YarnResourceManager throws NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-8830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385037#comment-16385037 ] ASF GitHub Bot commented on FLINK-8830: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5629: [FLINK-8830][YARN] YarnResourceManager throws Null...

GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5629 [FLINK-8830][YARN] YarnResourceManager throws NullPointerException ## What is the purpose of the change *This pull request fixed a NullPointException issue which `YarnResourceManager`