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

2018-04-15 Thread godfrey johnson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey johnson updated FLINK-9175: --- Environment: * Checkpoint Interval: 1min * Checkpoint Timeout: 2min * Checkpoint Pause: 5s

[jira] [Commented] (FLINK-9163) Harden e2e tests' signal traps and config restoration during abort

2018-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438999#comment-16438999 ] ASF GitHub Bot commented on FLINK-9163: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5841: [FLINK-9163[e2e-tests] harden signal traps and config res...

2018-04-15 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5841 Thanks for the contribution @NicoK! These are nice fixes for the end-to-end tests. +1, merging this ... ---

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

2018-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438994#comment-16438994 ] ASF GitHub Bot commented on FLINK-9168: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-04-15 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5845 Thanks for this contribution @XiaoZYang! Pulsar seems like an interesting project. I think before we proceed with this, we need to make it clear (community-wise) that if we do accept this

[jira] [Commented] (FLINK-9176) Category annotations are unused

2018-04-15 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438920#comment-16438920 ] mingleizhang commented on FLINK-9176: - I would re-introduce them into the surefire configuration. >

[jira] [Assigned] (FLINK-9176) Category annotations are unused

2018-04-15 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-9176: --- Assignee: mingleizhang > Category annotations are unused > --- >

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

2018-04-15 Thread Bob Lau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438918#comment-16438918 ] Bob Lau commented on FLINK-9173: [~Zentol]  Hello, forgot to paste the JsonResponse JSON string.

[jira] [Commented] (FLINK-8986) End-to-end test: REST

2018-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438729#comment-16438729 ] ASF GitHub Bot commented on FLINK-8986: --- Github user walterddr commented on the issue:

[GitHub] flink issue #5849: [FLINK-8986][e2e-test] Flink end to end test REST API

2018-04-15 Thread walterddr
Github user walterddr commented on the issue: https://github.com/apache/flink/pull/5849 At this moment it skips 8 of the 39 tests (PATCH & POST methods). And there's 2 test failures and I think should be fix in another JIRA. Namely,

[jira] [Commented] (FLINK-8986) End-to-end test: REST

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

[GitHub] flink pull request #5849: [FLINK-8986][e2e-test] Flink end to end test REST ...

2018-04-15 Thread walterddr
GitHub user walterddr opened a pull request: https://github.com/apache/flink/pull/5849 [FLINK-8986][e2e-test] Flink end to end test REST API ## What is the purpose of the change Adding end to end test for REST APIs for FLIP-6 generated endpoints ## Brief change

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

2018-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438711#comment-16438711 ] ASF GitHub Bot commented on FLINK-9056: --- Github user yuqi1129 commented on the issue:

[GitHub] flink issue #5829: [FLINK-9056] [jobmanager] Job submission fails with AskTi...

2018-04-15 Thread yuqi1129
Github user yuqi1129 commented on the issue: https://github.com/apache/flink/pull/5829 @tillrohrmann Could you help to check if this change is acceptable ? ---

[GitHub] flink issue #5846: [FLINK-9143] [client] Restart strategy defined in flink-c...

2018-04-15 Thread yuqi1129
Github user yuqi1129 commented on the issue: https://github.com/apache/flink/pull/5846 @tillrohrmann Can you help to look if this change is OK ? thanks ---

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438710#comment-16438710 ] ASF GitHub Bot commented on FLINK-9143: --- Github user yuqi1129 commented on the issue:

[jira] [Commented] (FLINK-8370) Port AbstractAggregatingMetricsHandler to RestServerEndpoint

2018-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438708#comment-16438708 ] ASF GitHub Bot commented on FLINK-8370: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5805: [FLINK-8370][REST] Port AggregatingMetricsHandler ...

2018-04-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5805#discussion_r181583359 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/DoubleAccumulator.java --- @@ -0,0 +1,257 @@ +/* + *

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

2018-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438702#comment-16438702 ] 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-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5780 I've cut down the PR to only not make any changes outside the tests, fixed the checkstyle violations and the failing test. ---

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

2018-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438700#comment-16438700 ] ASF GitHub Bot commented on FLINK-8955: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5780: [FLINK-8955][tests] Port ClassLoaderITCase to flip...

2018-04-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5780#discussion_r181582943 --- Diff: flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java --- @@ -196,21 +188,23 @@ public void

[jira] [Created] (FLINK-9176) Category annotations are unused

2018-04-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9176: --- Summary: Category annotations are unused Key: FLINK-9176 URL: https://issues.apache.org/jira/browse/FLINK-9176 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-04-15 Thread Alex Smirnov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Smirnov updated FLINK-9143: Description: Restart strategy defined in flink-conf.yaml is disregarded, when user enables

[jira] [Assigned] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom)

2018-04-15 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-8993: --- Assignee: mingleizhang > Add a test operator with keyed state that uses Kryo serializer >