[jira] [Updated] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

2018-05-01 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9269: -- Priority: Critical (was: Major) > Concurrency problem in HeapKeyedStateBackend when performing

[jira] [Commented] (FLINK-9273) Class cast exception

2018-05-01 Thread Bob Lau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460407#comment-16460407 ] Bob Lau commented on FLINK-9273: [~StephanEwen] Good morning! Thanks for your response!  I want to know

[jira] [Comment Edited] (FLINK-9273) Class cast exception

2018-05-01 Thread Bob Lau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460389#comment-16460389 ] Bob Lau edited comment on FLINK-9273 at 5/2/18 1:49 AM: [~StephanEwen]  I want to

[jira] [Comment Edited] (FLINK-9273) Class cast exception

2018-05-01 Thread Bob Lau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460389#comment-16460389 ] Bob Lau edited comment on FLINK-9273 at 5/2/18 1:47 AM: [~StephanEwen]  I want to

[jira] [Commented] (FLINK-9273) Class cast exception

2018-05-01 Thread Bob Lau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460389#comment-16460389 ] Bob Lau commented on FLINK-9273: [~StephanEwen]  I want to transform DataStream into table environment,

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

2018-05-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460360#comment-16460360 ] ASF GitHub Bot commented on FLINK-6306: --- Github user stevenzwu commented on the issue:

[GitHub] flink issue #4607: [FLINK-6306][connectors] Sink for eventually consistent f...

2018-05-01 Thread stevenzwu
Github user stevenzwu commented on the issue: https://github.com/apache/flink/pull/4607 @aljoscha is there any doc/write-up about the reworking of BucketingSink? ---

[jira] [Updated] (FLINK-8933) Avoid calling Class#newInstance

2018-05-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8933: -- Description: Class#newInstance is deprecated starting in Java 9 -

[jira] [Updated] (FLINK-9048) LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails

2018-05-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9048: -- Description: As of commit e0bc37bef69f5376d03214578e9b95816add661b, I got the following : {code}

[jira] [Updated] (FLINK-9150) Prepare for Java 10

2018-05-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9150: -- Description: Java 9 is not a LTS release. When compiling with Java 10, I see the following compilation error:

[jira] [Created] (FLINK-9281) LogBack not working

2018-05-01 Thread Tim (JIRA)
Tim created FLINK-9281: -- Summary: LogBack not working Key: FLINK-9281 URL: https://issues.apache.org/jira/browse/FLINK-9281 Project: Flink Issue Type: Bug Components: Logging Affects

[jira] [Commented] (FLINK-9267) Classloading issues when using RemoteEnvironment ...

2018-05-01 Thread Kedar Mhaswade (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460061#comment-16460061 ] Kedar Mhaswade commented on FLINK-9267: --- Wow! Thank you for the tip above. I have been able to talk

[jira] [Commented] (FLINK-9267) Classloading issues when using RemoteEnvironment ...

2018-05-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460019#comment-16460019 ] Chesnay Schepler commented on FLINK-9267: - Please add the following to your {{maven-shade-plugin}}

[jira] [Commented] (FLINK-9267) Classloading issues when using RemoteEnvironment ...

2018-05-01 Thread Kedar Mhaswade (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460002#comment-16460002 ] Kedar Mhaswade commented on FLINK-9267: --- I also built Flink 1.3.1 from

[jira] [Commented] (FLINK-9267) Classloading issues when using RemoteEnvironment ...

2018-05-01 Thread Kedar Mhaswade (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459924#comment-16459924 ] Kedar Mhaswade commented on FLINK-9267: --- This is very strange! Thanks [~Zentol] for trying this out,

[jira] [Commented] (FLINK-7789) Add handler for Async IO operator timeouts

2018-05-01 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459804#comment-16459804 ] tarun razdan commented on FLINK-7789: - Hi Team, Can anyone suggest some alternate method to handle

[jira] [Commented] (FLINK-9267) Classloading issues when using RemoteEnvironment ...

2018-05-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459784#comment-16459784 ] Chesnay Schepler commented on FLINK-9267: - I setup a local 1.3.1 cluster, freshly built from

[GitHub] flink issue #5928: [hotfix][doc] fix doc of externalized checkpoint

2018-05-01 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5928 @StephanEwen @alpinegizmo Thanks for your comments, I will revert the changes of `config.md` and address the comments concerning to the ``` `file://` only for local setups```. ---

[jira] [Commented] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

2018-05-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459686#comment-16459686 ] Chesnay Schepler commented on FLINK-9261: - Given that the UI and client in part go through the

[jira] [Commented] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown

2018-05-01 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459665#comment-16459665 ] yuqi commented on FLINK-9196: - [~gjy] I see, thanks for your suggestion. > YARN: Flink binaries are not

[jira] [Commented] (FLINK-6420) Cleaner CEP API to specify conditions between events

2018-05-01 Thread Tarush Grover (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459591#comment-16459591 ] Tarush Grover commented on FLINK-6420: -- Can I take this up? > Cleaner CEP API to specify conditions

[jira] [Created] (FLINK-9280) Extend JobSubmitHandler to accept jar files

2018-05-01 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9280: --- Summary: Extend JobSubmitHandler to accept jar files Key: FLINK-9280 URL: https://issues.apache.org/jira/browse/FLINK-9280 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

2018-05-01 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459483#comment-16459483 ] Sihua Zhou commented on FLINK-9269: --- [~aljoscha] I have updated the JIRA description with the code to

[jira] [Updated] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

2018-05-01 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9269: -- Description: {code:java} @Test public void testConccurrencyProblem() throws Exception {