[jira] [Updated] (FLINK-9757) Typos found in docs after hunspell run

2018-07-05 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-9757: --- Affects Version/s: 1.6.0 1.5.0 1.4.2 > Typos

[jira] [Assigned] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

2018-07-05 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-9743: -- Assignee: Sergey Nuyanzin > PackagedProgram.extractContainedLibraries fails on

[jira] [Updated] (FLINK-9757) Typos found in docs after hunspell run

2018-07-05 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-9757: --- Description: After [hunspell|http://hunspell.github.io/] run the next typos found ||File||

[GitHub] flink pull request #6254: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-05 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/6254#discussion_r200247127 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -479,6 +508,9 @@ void

[GitHub] flink pull request #6254: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-05 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/6254#discussion_r200245464 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -594,22 +626,22 @@ public

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[GitHub] flink pull request #6257: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-05 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/6257#discussion_r200274038 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java --- @@ -251,27 +257,56 @@ private MemorySegment

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

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

[GitHub] flink issue #6092: [FLINK-9352] In Standalone checkpoint recover mode many j...

2018-07-05 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6092 @tillrohrmann has refactored, please review again. the reason of the travis error is not because of this PR. ---

[GitHub] flink pull request #6257: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-05 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/6257#discussion_r200283214 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java --- @@ -251,27 +257,56 @@ private MemorySegment

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[GitHub] flink issue #6090: [FLINK-8863] [SQL] Add user-defined function support in S...

2018-07-05 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/6090 Hi @twalthr, please give me one more day. I will commit the changes tomorrow. 😄 ---

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

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

[GitHub] flink issue #6171: [FLINK-9593] Unified After Match semantics with SQL MATCH...

2018-07-05 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/6171 Thanks @kl0u for review. I've addressed points 1 and 3. As the second one touches some critical parts, let's address it in a separate JIRA. ---

[GitHub] flink issue #6261: [FLINK-9759] [DOCS] remove irrelevant answer about the sa...

2018-07-05 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/6261 :100:, you are welcome, thank you for your explanation, I'll close this PR. ---

[jira] [Commented] (FLINK-9759) give an irrelevant answer about the savepoint restore when stateless operators be added etc

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

[jira] [Commented] (FLINK-9759) give an irrelevant answer about the savepoint restore when stateless operators be added etc

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

[GitHub] flink pull request #6261: [FLINK-9759] [DOCS] remove irrelevant answer about...

2018-07-05 Thread lamber-ken
Github user lamber-ken closed the pull request at: https://github.com/apache/flink/pull/6261 ---

[jira] [Created] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures

2018-07-05 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9761: -- Summary: Potential buffer leak in PartitionRequestClientHandler during job failures Key: FLINK-9761 URL: https://issues.apache.org/jira/browse/FLINK-9761 Project: Flink

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[GitHub] flink pull request #6261: [FLINK-9759] [DOCS] give an right answer about the...

2018-07-05 Thread lamber-ken
GitHub user lamber-ken opened a pull request: https://github.com/apache/flink/pull/6261 [FLINK-9759] [DOCS] give an right answer about the savepoint restore when stateless operators be added, deleted etc ## What is the purpose of the change - fix irrelevant answer about the

[jira] [Commented] (FLINK-9759) give an irrelevant answer about the savepoint restore when stateless operators be added etc

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

[jira] [Commented] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE

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

[jira] [Assigned] (FLINK-8858) Add support for INSERT INTO in SQL Client

2018-07-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-8858: --- Assignee: Timo Walther (was: Renjie Liu) > Add support for INSERT INTO in SQL Client >

[jira] [Updated] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

2018-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9743: -- Labels: pull-request-available (was: ) > PackagedProgram.extractContainedLibraries fails on

[jira] [Commented] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

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

[GitHub] flink pull request #6263: [FLINK-9743][Client] Use correct zip/jar path sepa...

2018-07-05 Thread snuyanzin
GitHub user snuyanzin opened a pull request: https://github.com/apache/flink/pull/6263 [FLINK-9743][Client] Use correct zip/jar path separator ## What is the purpose of the change *This PR resolves libraries extraction issue from jars* ## Brief change log

[jira] [Resolved] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

2018-07-05 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9676. Resolution: Fixed Fixed via 1.6.0: a9b5579b397b6c56e44e21ebb8b2a6a7e6d8b2d1 1.5.0:

[jira] [Commented] (FLINK-9643) Flink allowing TLS 1.1 in spite of configuring TLS 1.2

2018-07-05 Thread Viktor Vlasov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1653#comment-1653 ] Viktor Vlasov commented on FLINK-9643: -- Thank you for the comment, [~StephanEwen]. Actually, if

[jira] [Commented] (FLINK-7344) Migrate usage of joda-time to the Java 8 DateTime API

2018-07-05 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533442#comment-16533442 ] Congxian Qiu commented on FLINK-7344: - Hi, [~yew1eb], are you still working on this, If you don't

[jira] [Commented] (FLINK-8858) Add support for INSERT INTO in SQL Client

2018-07-05 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533453#comment-16533453 ] Renjie Liu commented on FLINK-8858: --- Hi [~twalthr] That's ok since currently I have no time for that.

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[GitHub] flink pull request #6257: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6257 ---

[jira] [Created] (FLINK-9762) CoreOptions.TMP_DIRS wrongly managed on Yarn

2018-07-05 Thread Oleksandr Nitavskyi (JIRA)
Oleksandr Nitavskyi created FLINK-9762: -- Summary: CoreOptions.TMP_DIRS wrongly managed on Yarn Key: FLINK-9762 URL: https://issues.apache.org/jira/browse/FLINK-9762 Project: Flink Issue

[jira] [Commented] (FLINK-9742) Widen scope of Expression.resultType to 'public'

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

[GitHub] flink issue #6252: [FLINK-9742][Table API & SQL] Widen scope of Expression.r...

2018-07-05 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/6252 Thanks for opening this PR @HeartSaVioR! (cc @twalthr) I thought about this again and I don't think we should make the method public. The problem is that `Expression` is one of the core

[GitHub] flink issue #6257: [FLINK-9676][network] clarify contracts of BufferListener...

2018-07-05 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/6257 Thanks for fixing this bug, and we also solve this problem in this way. This solution seems more lightweight than the way in [6254](https://github.com/apache/flink/pull/6254), and I also

[jira] [Created] (FLINK-9759) give an irrelevant answer about the savepoint restore when stateless operators be added etc

2018-07-05 Thread lamber-ken (JIRA)
lamber-ken created FLINK-9759: - Summary: give an irrelevant answer about the savepoint restore when stateless operators be added etc Key: FLINK-9759 URL: https://issues.apache.org/jira/browse/FLINK-9759

[jira] [Updated] (FLINK-9759) give an irrelevant answer about the savepoint restore when stateless operators be added etc

2018-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9759: -- Labels: pull-request-available (was: ) > give an irrelevant answer about the savepoint

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[GitHub] flink pull request #6257: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-05 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/6257#discussion_r200287796 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java --- @@ -251,27 +257,56 @@ private MemorySegment

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[GitHub] flink pull request #6257: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-05 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/6257#discussion_r200287730 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java --- @@ -251,27 +257,56 @@ private MemorySegment

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

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

[jira] [Assigned] (FLINK-9718) Add enviroment variable in start-scala-shell.sh & flink to enable remote debug

2018-07-05 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-9718: - Assignee: Jeff Zhang > Add enviroment variable in start-scala-shell.sh & flink to enable remote

[jira] [Updated] (FLINK-9718) Add enviroment variable in start-scala-shell.sh & flink to enable remote debug

2018-07-05 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-9718: -- Summary: Add enviroment variable in start-scala-shell.sh & flink to enable remote debug (was: Add

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

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

[GitHub] flink issue #6090: [FLINK-8863] [SQL] Add user-defined function support in S...

2018-07-05 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6090 Hi @xccui, sorry for being pushy but when do you think you can update this PR? The feature freeze is in approx. 1 week and I need to coordinate my work/reviewing efforts. Let me know if you want me

[GitHub] flink issue #6090: [FLINK-8863] [SQL] Add user-defined function support in S...

2018-07-05 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6090 @xccui perfect. thank you very much! ---

[jira] [Commented] (FLINK-8858) Add support for INSERT INTO in SQL Client

2018-07-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533444#comment-16533444 ] Timo Walther commented on FLINK-8858: - Hi [~liurenjie1024], would it be ok if I assign this issue to

[GitHub] flink pull request #6262: [hotfix][filesystem] Remove incorrect equals metho...

2018-07-05 Thread pnowojski
GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/6262 [hotfix][filesystem] Remove incorrect equals methods in StreamWriters This pull request removes incorrect equals methods in `StreamWriterBase` (and in classes that inherit from it) that were used

[jira] [Created] (FLINK-9760) Return a single element from extractPatterns

2018-07-05 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-9760: --- Summary: Return a single element from extractPatterns Key: FLINK-9760 URL: https://issues.apache.org/jira/browse/FLINK-9760 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[jira] [Updated] (FLINK-8558) Add unified format interfaces and format discovery

2018-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8558: -- Labels: pull-request-available (was: ) > Add unified format interfaces and format discovery >

[GitHub] flink pull request #6264: [FLINK-8558] [table] Add unified format interfaces...

2018-07-05 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/6264 [FLINK-8558] [table] Add unified format interfaces and separate formats from connectors ## What is the purpose of the change This PR introduces a format discovery mechanism based on Java

[jira] [Commented] (FLINK-9736) Potential null reference in KeyGroupPartitionedPriorityQueue#poll()

2018-07-05 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533506#comment-16533506 ] Sihua Zhou commented on FLINK-9736: --- Hi [~yuzhih...@gmail.com] AFAIK, {{heapOfKeyGroupHeaps}} will

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[GitHub] flink pull request #6257: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-05 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/6257#discussion_r200252253 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java --- @@ -251,27 +257,56 @@ private MemorySegment

[GitHub] flink pull request #6257: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-05 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/6257#discussion_r200251500 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java --- @@ -251,27 +257,56 @@ private MemorySegment

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[GitHub] flink pull request #6257: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-05 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/6257#discussion_r200274433 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java --- @@ -251,27 +257,56 @@ private MemorySegment

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

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

[jira] [Commented] (FLINK-9736) Potential null reference in KeyGroupPartitionedPriorityQueue#poll()

2018-07-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533515#comment-16533515 ] Stefan Richter commented on FLINK-9736: --- [~sihuazhou] Is correct, this heap is always initialized

[jira] [Closed] (FLINK-9736) Potential null reference in KeyGroupPartitionedPriorityQueue#poll()

2018-07-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9736. - Resolution: Not A Bug > Potential null reference in KeyGroupPartitionedPriorityQueue#poll() >

[GitHub] flink issue #6252: [FLINK-9742][Table API & SQL] Widen scope of Expression.r...

2018-07-05 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/flink/pull/6252 @fhueske Yeah, that would be great. I'm happy to revert the change and introduce new class. I'm just not sure where to place and how to name it, since it will be going to have

[jira] [Commented] (FLINK-9742) Widen scope of Expression.resultType to 'public'

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

[jira] [Commented] (FLINK-9742) Widen scope of Expression.resultType to 'public'

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

[jira] [Updated] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

2018-07-05 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9764: --- Labels: test-stability (was: ) > Failure in LocalRecoveryRocksDBFullITCase >

[jira] [Created] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

2018-07-05 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9764: -- Summary: Failure in LocalRecoveryRocksDBFullITCase Key: FLINK-9764 URL: https://issues.apache.org/jira/browse/FLINK-9764 Project: Flink Issue Type: Bug

[GitHub] flink issue #6252: [FLINK-9742][Table API & SQL] Widen scope of Expression.r...

2018-07-05 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/flink/pull/6252 @fhueske Ah I didn't notice the object is already existing. Thanks for letting me know! ---

[jira] [Created] (FLINK-9765) Improve CLI responsiveness when cluster is not reachable

2018-07-05 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9765: --- Summary: Improve CLI responsiveness when cluster is not reachable Key: FLINK-9765 URL: https://issues.apache.org/jira/browse/FLINK-9765 Project: Flink Issue

[jira] [Updated] (FLINK-9765) Improve CLI responsiveness when cluster is not reachable

2018-07-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9765: Affects Version/s: 1.5.0 > Improve CLI responsiveness when cluster is not reachable >

[jira] [Commented] (FLINK-9765) Improve CLI responsiveness when cluster is not reachable

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

[GitHub] flink issue #6265: [FLINK-9765] [sql-client] Improve CLI responsiveness when...

2018-07-05 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6265 +1 ---

[jira] [Closed] (FLINK-9759) give an irrelevant answer about the savepoint restore when stateless operators be added etc

2018-07-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9759. --- Resolution: Not A Problem Fix Version/s: (was: 1.5.1) (was:

[jira] [Commented] (FLINK-9742) Expose Expression.resultType to public

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

[jira] [Commented] (FLINK-9742) Expose Expression.resultType to public

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

[GitHub] flink issue #6252: [FLINK-9742][Table API & SQL] Expose Expression.resultTyp...

2018-07-05 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/6252 Looks good. Just one last comment. ---

[GitHub] flink issue #6253: [FLINK-8094][Table API & SQL] Support other types for Exi...

2018-07-05 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/flink/pull/6253 Btw, looks like it may be also possible for ExistingField to replace needs of ParsingExistingField, via adding optional dateformat parameter (not sure which is more preferred), but I feel we can

[jira] [Commented] (FLINK-8094) Support other types for ExistingField rowtime extractor

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

[GitHub] flink pull request #6247: [FLINK-9730] [code refactor] fix access static via...

2018-07-05 Thread nekrassov
Github user nekrassov commented on a diff in the pull request: https://github.com/apache/flink/pull/6247#discussion_r200369787 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java --- @@ -179,7 +179,7 @@

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

2018-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9576: -- Labels: pull-request-available (was: ) > Wrong contiguity documentation >

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

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

[GitHub] flink pull request #6268: [FLINK-9576] Fixed documentation for contiguity wi...

2018-07-05 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/6268 [FLINK-9576] Fixed documentation for contiguity within looping pattern. Fixed example in the documentation plus restructured it a bit to make it more straightforward. You can merge this pull

[jira] [Updated] (FLINK-9763) Flink SQL Client bat script

2018-07-05 Thread Pavel Shvetsov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pavel Shvetsov updated FLINK-9763: -- Component/s: (was: Client) Startup Shell Scripts > Flink SQL Client bat

[jira] [Commented] (FLINK-9742) Widen scope of Expression.resultType to 'public'

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

[jira] [Commented] (FLINK-9742) Expose Expression.resultType to public

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

[GitHub] flink issue #6252: [FLINK-9742][Table API & SQL] Expose Expression.resultTyp...

2018-07-05 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/flink/pull/6252 @fhueske Addressed. Please take a look again. ---

[jira] [Commented] (FLINK-8094) Support other types for ExistingField rowtime extractor

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

[GitHub] flink pull request #6262: [hotfix][filesystem] Remove incorrect equals metho...

2018-07-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6262 ---

[GitHub] flink issue #6253: [FLINK-8094][Table API & SQL] Support other types for Exi...

2018-07-05 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/flink/pull/6253 @fhueske Thanks for the nice feedback! Addressed your comment except regarding unit test. Let me try out adding unit test later, since it might bring too high barrier as of now. ---

[GitHub] flink issue #6262: [hotfix][filesystem] Remove incorrect equals methods in S...

2018-07-05 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/6262 Thanks, fixed travis failure and merged. ---

[jira] [Updated] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator

2018-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8479: -- Labels: pull-request-available (was: ) > Implement time-bounded inner join of streams as a

[GitHub] flink pull request #5342: [FLINK-8479] Timebounded stream join

2018-07-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5342 ---

[GitHub] flink issue #5342: [FLINK-8479] Timebounded stream join

2018-07-05 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5342 Thanks for the work @florianschmidt1994 ! Merging this. ---

[jira] [Commented] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator

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

[jira] [Resolved] (FLINK-9588) Reuse the same conditionContext with in a same computationState

2018-07-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-9588. - Resolution: Fixed Fix Version/s: 1.6.0 > Reuse the same conditionContext with in

[jira] [Updated] (FLINK-9438) Add documentation for (Registry)AvroDeserializationSchema

2018-07-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-9438: Affects Version/s: 1.6.0 > Add documentation for (Registry)AvroDeserializationSchema >

  1   2   3   >