[jira] [Created] (FLINK-9175) Flink CEP with Checkpointing alway failed

2018-04-14 Thread godfrey johnson (JIRA)
godfrey johnson created FLINK-9175: -- Summary: Flink CEP with Checkpointing alway failed Key: FLINK-9175 URL: https://issues.apache.org/jira/browse/FLINK-9175 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-9173) RestClient - Received response is abnormal

2018-04-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16438527#comment-16438527 ] Chesnay Schepler commented on FLINK-9173: - So one thing we need to do is add a {{t

[jira] [Updated] (FLINK-9173) RestClient - Received response is abnormal

2018-04-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9173: Component/s: (was: flink-shaded.git) > RestClient - Received response is abnormal >

[jira] [Commented] (FLINK-8955) Port ClassLoaderITCase to flip6

2018-04-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16438492#comment-16438492 ] ASF GitHub Bot commented on FLINK-8955: --- Github user zentol commented on the issue:

[GitHub] flink issue #5780: [FLINK-8955][tests] Port ClassLoaderITCase to flip6

2018-04-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5780 I would be fine with changing the PR to work against a `MiniCluster` (to drop the JobExecutor changes) and a `TemporaryFolder` that we manage ourselves, i,e. not as a `@Rule` (to drop the icky configu

[GitHub] flink pull request #5848: Minor cleanup of Java example code for AsyncFuncti...

2018-04-14 Thread kkrugler
GitHub user kkrugler opened a pull request: https://github.com/apache/flink/pull/5848 Minor cleanup of Java example code for AsyncFunctions Use `CompletableFuture` correctly, via `.supplyAsync()` wrapping `Future.get()` You can merge this pull request into a Git repository by runni

[jira] [Commented] (FLINK-9174) The type of state created in ProccessWindowFunction.proccess() is inconsistency

2018-04-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16438307#comment-16438307 ] ASF GitHub Bot commented on FLINK-9174: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5847: [FLINK-9174][datastream]Fix the type of state created in ...

2018-04-14 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5847 Hi, @StephanEwen could you please have a look at this? If you think this is a a non-issue, I'd like to close this. (sorry for pinging you here, it because I saw your some comments about ```UserFaci

[jira] [Commented] (FLINK-9174) The type of state created in ProccessWindowFunction.proccess() is inconsistency

2018-04-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16438306#comment-16438306 ] ASF GitHub Bot commented on FLINK-9174: --- GitHub user sihuazhou opened a pull request

[GitHub] flink pull request #5847: [FLINK-9174][datastream]Fix the type of state crea...

2018-04-14 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5847 [FLINK-9174][datastream]Fix the type of state created in ProccessWindowFunction.proccess() is inconsistency ## What is the purpose of the change This PR fixes the type of state created in

[jira] [Created] (FLINK-9174) The type of state created in ProccessWindowFunction.proccess() is inconsistency

2018-04-14 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9174: - Summary: The type of state created in ProccessWindowFunction.proccess() is inconsistency Key: FLINK-9174 URL: https://issues.apache.org/jira/browse/FLINK-9174 Project: Flin