[GitHub] flink pull request #6297: [FLINK-9777] YARN: JM and TM Memory must be specif...

2018-07-17 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6297#discussion_r203000672 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/FlinkYarnSessionCliTest.java --- @@ -352,6 +352,76 @@ public void

[GitHub] flink pull request #6297: [FLINK-9777] YARN: JM and TM Memory must be specif...

2018-07-17 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6297#discussion_r203000806 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/FlinkYarnSessionCliTest.java --- @@ -352,6 +352,76 @@ public void

[GitHub] flink pull request #6297: [FLINK-9777] YARN: JM and TM Memory must be specif...

2018-07-17 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6297#discussion_r203000441 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/FlinkYarnSessionCliTest.java --- @@ -352,6 +352,76 @@ public void

[GitHub] flink pull request #6297: [FLINK-9777] YARN: JM and TM Memory must be specif...

2018-07-17 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6297#discussion_r203000456 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/FlinkYarnSessionCliTest.java --- @@ -352,6 +352,76 @@ public void

[jira] [Commented] (FLINK-9857) Processing-time timers fire too early

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546548#comment-16546548 ] ASF GitHub Bot commented on FLINK-9857: --- Github user aljoscha closed the pull request at:

[jira] [Closed] (FLINK-9857) Processing-time timers fire too early

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9857. --- Resolution: Fixed Fixed on master in 690bc370e19d8003add4e41c05acfb4dccc662b4 Fixed on

[jira] [Commented] (FLINK-9860) Netty resource leak on receiver side

2018-07-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546579#comment-16546579 ] Nico Kruber commented on FLINK-9860: FYI: with leak detection (as well as error logging!) enabled,

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

2018-07-17 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203040441 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/util/JarFileCreatorTest.java --- @@ -102,15 +104,62 @@ public void

[jira] [Updated] (FLINK-9876) ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout

2018-07-17 Thread Deepak Sharma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Sharma updated FLINK-9876: - Component/s: Tests > ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes

[jira] [Commented] (FLINK-9868) Expose channel id to ProcessFunction

2018-07-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546694#comment-16546694 ] Kostas Kloudas commented on FLINK-9868: --- Thanks a lot [~hequn8128]! > Expose channel id to

[jira] [Updated] (FLINK-9870) Support field mapping and time attributes for table sinks

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9870: - Fix Version/s: 1.7.0 > Support field mapping and time attributes for table sinks >

[GitHub] flink issue #6297: [FLINK-9777] YARN: JM and TM Memory must be specified wit...

2018-07-17 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/6297 LGTM for me, Thanks for your contribution @yanghua. @GJL would you like to have last look, or can I merge it? ---

[jira] [Created] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

2018-07-17 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9878: -- Summary: IO worker threads BLOCKED on SSL Session Cache while CMS full gc Key: FLINK-9878 URL: https://issues.apache.org/jira/browse/FLINK-9878 Project: Flink

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546800#comment-16546800 ] ASF GitHub Bot commented on FLINK-9777: --- Github user GJL commented on the issue:

[GitHub] flink issue #6297: [FLINK-9777] YARN: JM and TM Memory must be specified wit...

2018-07-17 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/6297 @dawidwys Please merge. ---

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546531#comment-16546531 ] ASF GitHub Bot commented on FLINK-7251: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546533#comment-16546533 ] ASF GitHub Bot commented on FLINK-7251: --- Github user aljoscha commented on a diff in the pull

[jira] [Updated] (FLINK-9875) Add concurrent creation of execution job vertex

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9875: -- Labels: pull-request-available (was: ) > Add concurrent creation of execution job vertex >

[GitHub] flink pull request #6353: [FLINK-9875] Add concurrent creation of execution ...

2018-07-17 Thread tison1
GitHub user tison1 opened a pull request: https://github.com/apache/flink/pull/6353 [FLINK-9875] Add concurrent creation of execution job vertex ## Add concurrent creation of execution job vertex in some case like inputformat vertex, creation of execution job vertex is

[jira] [Commented] (FLINK-9875) Add concurrent creation of execution job vertex

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546612#comment-16546612 ] ASF GitHub Bot commented on FLINK-9875: --- GitHub user tison1 opened a pull request:

[jira] [Commented] (FLINK-9855) Check all calls to the TypeExtractor.getBinaryOperatorReturnType()

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546610#comment-16546610 ] Till Rohrmann commented on FLINK-9855: -- Could we maybe add some easier to use convenience methods

[jira] [Created] (FLINK-9876) ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout

2018-07-17 Thread Florian Schmidt (JIRA)
Florian Schmidt created FLINK-9876: -- Summary: ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout Key: FLINK-9876 URL: https://issues.apache.org/jira/browse/FLINK-9876

[jira] [Commented] (FLINK-8418) Kafka08ITCase.testStartFromLatestOffsets() times out on Travis

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546677#comment-16546677 ] Till Rohrmann commented on FLINK-8418: -- Any new insights [~tzulitai]? >

[jira] [Updated] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9874: - Fix Version/s: 1.6.0 > set_conf_ssl in E2E tests fails on macOS >

[jira] [Closed] (FLINK-9868) Expose channel id to ProcessFunction

2018-07-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9868. - Resolution: Won't Fix > Expose channel id to ProcessFunction >

[jira] [Closed] (FLINK-9856) ExecutionGraphCoLocationRestartTest#testConstraintsAfterRestart failed on travis

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9856. Resolution: Duplicate > ExecutionGraphCoLocationRestartTest#testConstraintsAfterRestart failed on

[jira] [Closed] (FLINK-9876) ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9876. Resolution: Duplicate > ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes

[jira] [Updated] (FLINK-9851) Add documentation for unified table sources/sinks

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9851: - Fix Version/s: 1.6.0 > Add documentation for unified table sources/sinks >

[jira] [Updated] (FLINK-9851) Add documentation for unified table sources/sinks

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9851: - Affects Version/s: 1.6.0 > Add documentation for unified table sources/sinks >

[jira] [Updated] (FLINK-9851) Add documentation for unified table sources/sinks

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9851: - Priority: Critical (was: Major) > Add documentation for unified table sources/sinks >

[jira] [Updated] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9852: - Affects Version/s: 1.6.0 > Expose descriptor-based sink creation in table environments >

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546758#comment-16546758 ] ASF GitHub Bot commented on FLINK-7251: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

2018-07-17 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r203070220 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlFormatter.java --- @@ -0,0 +1,67 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

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

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546532#comment-16546532 ] ASF GitHub Bot commented on FLINK-7251: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546530#comment-16546530 ] ASF GitHub Bot commented on FLINK-7251: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

2018-07-17 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203002928 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/util/JarFileCreatorTest.java --- @@ -102,15 +104,62 @@ public void

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

2018-07-17 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203001399 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java --- @@ -271,19 +214,20 @@ public void

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

2018-07-17 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203003680 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -237,19 +248,81 @@ private boolean

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

2018-07-17 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203001023 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java --- @@ -50,12 +41,12 @@ import static

[GitHub] flink pull request #6348: [FLINK-9857] Delay firing of processing-time timer...

2018-07-17 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/6348 ---

[jira] [Created] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

2018-07-17 Thread Florian Schmidt (JIRA)
Florian Schmidt created FLINK-9874: -- Summary: set_conf_ssl in E2E tests fails on macOS Key: FLINK-9874 URL: https://issues.apache.org/jira/browse/FLINK-9874 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8871: - Fix Version/s: (was: 1.6.0) 1.7.0 > Checkpoint cancellation is not

[jira] [Updated] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8871: - Affects Version/s: 1.6.0 > Checkpoint cancellation is not propagated to stop checkpointing

[jira] [Updated] (FLINK-8971) Create general purpose testing job

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8971: - Fix Version/s: (was: 1.6.0) 1.7.0 > Create general purpose testing job >

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546681#comment-16546681 ] ASF GitHub Bot commented on FLINK-7251: --- Github user twalthr commented on a diff in the pull

[jira] [Resolved] (FLINK-9865) flink-hadoop-compatibility should assume Hadoop as provided

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9865. -- Resolution: Fixed Fixed via 975fdbe5a762bd80bee843927e67e8eba417af8d >

[jira] [Updated] (FLINK-9812) SpanningRecordSerializationTest fails on travis

2018-07-17 Thread Deepak Sharma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Sharma updated FLINK-9812: - Component/s: Tests > SpanningRecordSerializationTest fails on travis >

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546755#comment-16546755 ] ASF GitHub Bot commented on FLINK-9777: --- Github user dawidwys commented on the issue:

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-07-17 Thread Deepak Sharma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546775#comment-16546775 ] Deepak Sharma commented on FLINK-9635: -- [~till.rohrmann], does this issue still need to be resolved,

[jira] [Updated] (FLINK-9860) Netty resource leak on receiver side

2018-07-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9860: --- Affects Version/s: 1.5.1 > Netty resource leak on receiver side >

[jira] [Commented] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546628#comment-16546628 ] ASF GitHub Bot commented on FLINK-9869: --- Github user tison1 commented on the issue:

[jira] [Updated] (FLINK-9574) Add a dedicated documentation page for state evolution

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9574: - Fix Version/s: (was: 1.6.0) 1.7.0 > Add a dedicated documentation page

[jira] [Updated] (FLINK-9376) Allow upgrading to incompatible state serializers (state schema evolution)

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9376: - Fix Version/s: (was: 1.6.0) 1.7.0 > Allow upgrading to incompatible state

[jira] [Commented] (FLINK-9868) Expose channel id to ProcessFunction

2018-07-17 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546692#comment-16546692 ] Hequn Cheng commented on FLINK-9868: Hi [~kkl0u] [~yanghua] Thanks for your replies. I have a sense

[jira] [Updated] (FLINK-5601) Window operator does not checkpoint watermarks

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5601: - Fix Version/s: (was: 1.6.0) 1.7.0 > Window operator does not checkpoint

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546794#comment-16546794 ] ASF GitHub Bot commented on FLINK-9792: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-5735) Non-overlapping sliding window is not deterministic

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546574#comment-16546574 ] Aljoscha Krettek commented on FLINK-5735: - I think the problem here is that the watermark

[jira] [Assigned] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

2018-07-17 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9874: -- Assignee: Florian Schmidt > set_conf_ssl in E2E tests fails on macOS >

[jira] [Updated] (FLINK-9000) Add automated cluster framework tests

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9000: - Fix Version/s: (was: 1.6.0) 1.7.0 > Add automated cluster framework tests

[jira] [Created] (FLINK-9877) Add separate docs page for different join types in DataStream API

2018-07-17 Thread Florian Schmidt (JIRA)
Florian Schmidt created FLINK-9877: -- Summary: Add separate docs page for different join types in DataStream API Key: FLINK-9877 URL: https://issues.apache.org/jira/browse/FLINK-9877 Project: Flink

[jira] [Updated] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7386: - Fix Version/s: (was: 1.6.0) 1.7.0 > Flink Elasticsearch 5 connector is

[jira] [Commented] (FLINK-9872) SavepointITCase#testSavepointForJobWithIteration does not properly cancel jobs

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546703#comment-16546703 ] Till Rohrmann commented on FLINK-9872: -- Is this a test instability [~Zentol]? >

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

2018-07-17 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r203069199 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlFormatter.java --- @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

2018-07-17 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r203069177 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlFormatter.java --- @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

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

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

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

[GitHub] flink issue #6348: [FLINK-9857] Delay firing of processing-time timers by 1 ...

2018-07-17 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/6348 I quickly talked to @StephanEwen directly and he agreed the fix is good so I'm merging. ---

[jira] [Updated] (FLINK-9876) ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout

2018-07-17 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9876: --- Description:  See [https://travis-ci.org/florianschmidt1994/flink/jobs/404871788]

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

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6306. -- Resolution: Duplicate This issue should be covered by FLINK-9752 (once it is completed). >

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

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6306: - Fix Version/s: (was: 1.6.0) > Sink for eventually consistent file systems >

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

2018-07-17 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r203074481 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlFormatter.java --- @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-9857) Processing-time timers fire too early

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546541#comment-16546541 ] ASF GitHub Bot commented on FLINK-9857: --- Github user aljoscha commented on the issue:

[jira] [Reopened] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on Travis

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-9646: -- The problem is still not fully fixed: https://api.travis-ci.org/v3/job/404321779/log.txt >

[jira] [Updated] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on Travis

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9646: - Fix Version/s: (was: 1.5.1) 1.5.2 >

[jira] [Commented] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

2018-07-17 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546587#comment-16546587 ] Florian Schmidt commented on FLINK-9874: I think we should be able to work around this issue by

[jira] [Created] (FLINK-9875) Add concurrent creation of execution job vertex

2018-07-17 Thread JIRA
陈梓立 created FLINK-9875: -- Summary: Add concurrent creation of execution job vertex Key: FLINK-9875 URL: https://issues.apache.org/jira/browse/FLINK-9875 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546614#comment-16546614 ] ASF GitHub Bot commented on FLINK-7251: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

2018-07-17 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203021961 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java --- @@ -50,12 +41,12 @@ import static

[jira] [Commented] (FLINK-8981) End-to-end test: Kerberos security

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546639#comment-16546639 ] Aljoscha Krettek commented on FLINK-8981: - I'm actually working on a Kerberos test that uses

[jira] [Assigned] (FLINK-8981) End-to-end test: Kerberos security

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-8981: --- Assignee: Aljoscha Krettek (was: Shuyi Chen) > End-to-end test: Kerberos security

[jira] [Commented] (FLINK-8981) End-to-end test: Kerberos security

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546640#comment-16546640 ] Aljoscha Krettek commented on FLINK-8981: - [~suez1224] I hope it's alright if I assign this to

[jira] [Updated] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6856: - Fix Version/s: (was: 1.6.0) 1.7.0 > Eagerly check if serializer config

[jira] [Updated] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6856: - Affects Version/s: 1.6.0 1.4.2 1.5.1 > Eagerly

[jira] [Updated] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6944: - Fix Version/s: (was: 1.6.0) 1.7.0 > Introduce

[jira] [Assigned] (FLINK-9576) Wrong contiguity documentation

2018-07-17 Thread Deepak Sharma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Sharma reassigned FLINK-9576: Assignee: Dawid Wysakowicz > Wrong contiguity documentation >

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546520#comment-16546520 ] ASF GitHub Bot commented on FLINK-9777: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546519#comment-16546519 ] ASF GitHub Bot commented on FLINK-9777: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546518#comment-16546518 ] ASF GitHub Bot commented on FLINK-9777: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-9777) YARN: JM and TM Memory must be specified with Units

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546517#comment-16546517 ] ASF GitHub Bot commented on FLINK-9777: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-5735) Non-overlapping sliding window is not deterministic

2018-07-17 Thread Valerii Florov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546585#comment-16546585 ] Valerii Florov commented on FLINK-5735: --- It is not reproducible if all rows are in ascending time

[GitHub] flink issue #6345: [FLINK-9869] Send PartitionInfo in batch to Improve perfo...

2018-07-17 Thread tison1
Github user tison1 commented on the issue: https://github.com/apache/flink/pull/6345 cc @sihuazhou ---

[jira] [Assigned] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

2018-07-17 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9874: -- Assignee: (was: Florian Schmidt) > set_conf_ssl in E2E tests fails on macOS >

[jira] [Updated] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9874: - Labels: test-stability (was: ) > set_conf_ssl in E2E tests fails on macOS >

[jira] [Updated] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

2018-07-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9874: - Priority: Critical (was: Blocker) > set_conf_ssl in E2E tests fails on macOS >

[jira] [Commented] (FLINK-9658) Test data output directories are no longer cleaned up

2018-07-17 Thread Deepak Sharma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546699#comment-16546699 ] Deepak Sharma commented on FLINK-9658: -- This may have been taken care of by 

[jira] [Commented] (FLINK-5735) Non-overlapping sliding window is not deterministic

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546846#comment-16546846 ] Aljoscha Krettek commented on FLINK-5735: - That's what I though. So there is no bug, it's just a

[jira] [Created] (FLINK-9880) Incorrect argument order calling BucketerContext#update

2018-07-17 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9880: - Summary: Incorrect argument order calling BucketerContext#update Key: FLINK-9880 URL: https://issues.apache.org/jira/browse/FLINK-9880 Project: Flink Issue Type: Bug

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

2018-07-17 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6120#discussion_r203083498 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java --- @@ -271,19 +214,20 @@ public void

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546826#comment-16546826 ] ASF GitHub Bot commented on FLINK-7251: --- Github user twalthr commented on a diff in the pull

  1   2   3   4   >