[jira] [Commented] (FLINK-8322) support getting number of existing timers in TimerService

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324977#comment-16324977 ] ASF GitHub Bot commented on FLINK-8322: --- Github user bowenli86 closed the pull reque

[GitHub] flink pull request #5236: [FLINK-8322] support getting number of existing ti...

2018-01-12 Thread bowenli86
Github user bowenli86 closed the pull request at: https://github.com/apache/flink/pull/5236 ---

[jira] [Resolved] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish

2018-01-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-7049. --- Resolution: Cannot Reproduce > TestingApplicationMaster keeps running after integration tests finish > ---

[jira] [Created] (FLINK-8430) Implement stream-stream non-window full outer join

2018-01-12 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-8430: -- Summary: Implement stream-stream non-window full outer join Key: FLINK-8430 URL: https://issues.apache.org/jira/browse/FLINK-8430 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-8429) Implement stream-stream non-window right outer join

2018-01-12 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-8429: -- Summary: Implement stream-stream non-window right outer join Key: FLINK-8429 URL: https://issues.apache.org/jira/browse/FLINK-8429 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-8428) Implement stream-stream non-window left outer join

2018-01-12 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-8428: -- Summary: Implement stream-stream non-window left outer join Key: FLINK-8428 URL: https://issues.apache.org/jira/browse/FLINK-8428 Project: Flink Issue Type: Sub-

[jira] [Updated] (FLINK-5878) Add stream-stream non-window inner/outer join

2018-01-12 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-5878: --- Summary: Add stream-stream non-window inner/outer join (was: Add stream-stream inner/outer join) > A

[jira] [Updated] (FLINK-6094) Implement stream-stream non-window inner join

2018-01-12 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-6094: --- Description: This includes: 1.Implement stream-stream non-window inner join was: This includes: 1.

[jira] [Updated] (FLINK-5878) Add stream-stream inner/outer join

2018-01-12 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-5878: --- Description: This task is intended to support stream-stream inner/outer join on tableAPI/SQL. A brief

[jira] [Updated] (FLINK-6094) Implement stream-stream non-window inner join

2018-01-12 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-6094: --- Summary: Implement stream-stream non-window inner join (was: Implement stream-stream proctime non-wi

[jira] [Updated] (FLINK-5878) Add stream-stream inner/outer join

2018-01-12 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-5878: --- Summary: Add stream-stream inner/outer join (was: Add stream-stream inner/left-out join) > Add strea

[jira] [Updated] (FLINK-6094) Implement stream-stream proctime non-window inner join

2018-01-12 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-6094: --- Issue Type: Sub-task (was: New Feature) Parent: FLINK-5878 > Implement stream-stream proctime

[jira] [Updated] (FLINK-8421) HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore

2018-01-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8421: --- Description: The {{HeapInternalTimerService}} still uses simple {{equals}} checks on

[jira] [Closed] (FLINK-8340) Do not pass Configuration and configuration directory to CustomCommandLine methods

2018-01-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8340. Resolution: Fixed Fixed via 30011b9b110aad0e1c28e7e0a025b73986781a72 > Do not pass Configuration an

[jira] [Closed] (FLINK-8341) Remove unneeded CommandLineOptions

2018-01-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8341. Resolution: Fixed Fixed via d7e9dc1931f1f1cedbfee12aebe34dd76e9bac10 > Remove unneeded CommandLineO

[jira] [Closed] (FLINK-8349) Remove Yarn specific commands from YarnClusterClient

2018-01-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8349. Resolution: Fixed Fixed via 402499f06a4b590ac47df64ecc01055c06b0399b > Remove Yarn specific command

[jira] [Closed] (FLINK-8342) Remove ClusterClient generic type parameter from ClusterDescriptor

2018-01-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8342. Resolution: Fixed Fixed via 10e900b25ac03876d3f9e78f260d48efe6b9d853 > Remove ClusterClient generic

[jira] [Closed] (FLINK-8347) Make Cluster id typesafe

2018-01-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8347. Resolution: Fixed Fixed via 38d3720863c6187153174d0df57fc414b0cf8e96 > Make Cluster id typesafe > -

[jira] [Commented] (FLINK-8420) Timeout exceptions are not properly recognized by RetryingRegistration

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324647#comment-16324647 ] ASF GitHub Bot commented on FLINK-8420: --- Github user asfgit closed the pull request

[jira] [Resolved] (FLINK-8119) Cannot submit jobs to YARN Session in FLIP-6 mode

2018-01-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8119. -- Resolution: Fixed Fixed via dbe0e8286d76a5facdb49589b638b87dbde80178 > Cannot submit jobs to YA

[jira] [Commented] (FLINK-8347) Make Cluster id typesafe

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324650#comment-16324650 ] ASF GitHub Bot commented on FLINK-8347: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8119) Cannot submit jobs to YARN Session in FLIP-6 mode

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324653#comment-16324653 ] ASF GitHub Bot commented on FLINK-8119: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8348) Print help for DefaultCLI

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324652#comment-16324652 ] ASF GitHub Bot commented on FLINK-8348: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8341) Remove unneeded CommandLineOptions

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324648#comment-16324648 ] ASF GitHub Bot commented on FLINK-8341: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8349) Remove Yarn specific commands from YarnClusterClient

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324656#comment-16324656 ] ASF GitHub Bot commented on FLINK-8349: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8342) Remove ClusterClient generic type parameter from ClusterDescriptor

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324649#comment-16324649 ] ASF GitHub Bot commented on FLINK-8342: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8201) YarnResourceManagerTest causes license checking failure

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324654#comment-16324654 ] ASF GitHub Bot commented on FLINK-8201: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-8348) Print help for DefaultCLI

2018-01-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8348. Resolution: Feedback Received Fixed via 7d986ce0482562efd90fec416c4b2f4638a4058a > Print help for D

[jira] [Commented] (FLINK-8340) Do not pass Configuration and configuration directory to CustomCommandLine methods

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324655#comment-16324655 ] ASF GitHub Bot commented on FLINK-8340: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8288) Register the web interface url to yarn for yarn job mode

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324651#comment-16324651 ] ASF GitHub Bot commented on FLINK-8288: --- Github user asfgit closed the pull request

[GitHub] flink pull request #5227: [FLINK-8341] [flip6] Remove not needed options fro...

2018-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5227 ---

[GitHub] flink pull request #5229: [FLINK-8349] [flip6] Remove Yarn specific commands...

2018-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5229 ---

[GitHub] flink pull request #5233: [FLINK-8348] [flip6] Print help for DefaultCLI

2018-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5233 ---

[GitHub] flink pull request #5228: [FLINK-8342] [flip6] Remove generic type parameter...

2018-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5228 ---

[GitHub] flink pull request #5226: [FLINK-8340] [flip6] Remove passing of Configurati...

2018-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5226 ---

[jira] [Closed] (FLINK-8420) Timeout exceptions are not properly recognized by RetryingRegistration

2018-01-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8420. Resolution: Fixed Fixed via 3c99ae8959f69325bb9b7d810b41c60e42e602c5 > Timeout exceptions are not p

[jira] [Resolved] (FLINK-8288) Register the web interface url to yarn for yarn job mode

2018-01-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8288. -- Resolution: Fixed Fix Version/s: 1.5.0 Fixed via 3b01686851e8281642924c4a620fb43b008de174

[GitHub] flink pull request #5234: [FLINK-8119] [flip6] Wire correct Flip6 components...

2018-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5234 ---

[GitHub] flink pull request #5286: [FLINK-8420] [flip6] Recognize TimeoutException in...

2018-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5286 ---

[jira] [Resolved] (FLINK-8201) YarnResourceManagerTest causes license checking failure

2018-01-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8201. -- Resolution: Fixed Fix Version/s: 1.5.0 Fixed via d0bc300087b037b156425ccd509147177dd9529e

[GitHub] flink pull request #5186: [FLINK-8288] [runtime] register job master rest en...

2018-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5186 ---

[GitHub] flink pull request #5232: [FLINK-8347] [flip6] Make cluster id used by Clust...

2018-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5232 ---

[GitHub] flink pull request #5123: [FLINK-8201] YarnResourceManagerTest causes licens...

2018-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5123 ---

[jira] [Created] (FLINK-8427) Checkstyle for org.apache.flink.optimizer.costs

2018-01-12 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-8427: - Summary: Checkstyle for org.apache.flink.optimizer.costs Key: FLINK-8427 URL: https://issues.apache.org/jira/browse/FLINK-8427 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-8414) Gelly performance seriously decreases when using the suggested parallelism configuration

2018-01-12 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324542#comment-16324542 ] Greg Hogan commented on FLINK-8414: --- It is incumbent on the user to configure an appropr

[jira] [Updated] (FLINK-8426) Error in Generating Timestamp/Watermakr doc

2018-01-12 Thread Christophe Jolif (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christophe Jolif updated FLINK-8426: Description: In https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/event_times

[jira] [Created] (FLINK-8426) Error in Generating Timestamp/Watermakr doc

2018-01-12 Thread Christophe Jolif (JIRA)
Christophe Jolif created FLINK-8426: --- Summary: Error in Generating Timestamp/Watermakr doc Key: FLINK-8426 URL: https://issues.apache.org/jira/browse/FLINK-8426 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-8422) Checkstyle for org.apache.flink.api.java.tuple

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

[GitHub] flink pull request #5292: [FLINK-8422] [core] Checkstyle for org.apache.flin...

2018-01-12 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/5292 [FLINK-8422] [core] Checkstyle for org.apache.flink.api.java.tuple ## What is the purpose of the change Update TupleGenerator for Flink's checkstyle and rebuild Tuple and TupleBuilder cla

[jira] [Commented] (FLINK-8361) Remove create_release_files.sh

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

[GitHub] flink pull request #5291: [FLINK-8361] [build] Remove create_release_files.s...

2018-01-12 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/5291 [FLINK-8361] [build] Remove create_release_files.sh ## What is the purpose of the change The monolithic create_release_files.sh does not support building without Hadoop and has been super

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324469#comment-16324469 ] ASF GitHub Bot commented on FLINK-7456: --- Github user NicoK commented on a diff in th

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324471#comment-16324471 ] ASF GitHub Bot commented on FLINK-7456: --- Github user NicoK commented on a diff in th

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324467#comment-16324467 ] ASF GitHub Bot commented on FLINK-7456: --- Github user NicoK commented on a diff in th

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324472#comment-16324472 ] ASF GitHub Bot commented on FLINK-7456: --- Github user NicoK commented on a diff in th

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324466#comment-16324466 ] ASF GitHub Bot commented on FLINK-7456: --- Github user NicoK commented on a diff in th

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324465#comment-16324465 ] ASF GitHub Bot commented on FLINK-7456: --- Github user NicoK commented on a diff in th

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324473#comment-16324473 ] ASF GitHub Bot commented on FLINK-7456: --- Github user NicoK commented on a diff in th

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324470#comment-16324470 ] ASF GitHub Bot commented on FLINK-7456: --- Github user NicoK commented on a diff in th

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324464#comment-16324464 ] ASF GitHub Bot commented on FLINK-7456: --- Github user NicoK commented on a diff in th

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324468#comment-16324468 ] ASF GitHub Bot commented on FLINK-7456: --- Github user NicoK commented on a diff in th

[GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom...

2018-01-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161248402 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java --- @@ -52,4 +52,9 @@ boolean isReleas

[GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom...

2018-01-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161247589 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/SequenceNumberingViewReader.java --- @@ -77,6 +92,46 @@ void requestSubpartiti

[GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom...

2018-01-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161241148 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/SequenceNumberingViewReader.java --- @@ -49,10 +50,24 @@ private

[GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom...

2018-01-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161296711 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java --- @@ -73,6 +73,9 @@ /** Flag indica

[GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom...

2018-01-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161282684 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/SequenceNumberingViewReader.java --- @@ -77,6 +92,46 @@ void requestSubpartiti

[GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom...

2018-01-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161249082 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java --- @@ -199,6 +199,19 @@ public boolean isR

[GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom...

2018-01-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161295428 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java --- @@ -163,6 +190,15 @@ public boolean isRel

[GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom...

2018-01-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161242036 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/SequenceNumberingViewReader.java --- @@ -49,10 +50,24 @@ private

[GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom...

2018-01-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161295951 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java --- @@ -199,6 +199,19 @@ public boolean isR

[GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom...

2018-01-12 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161287607 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/SequenceNumberingViewReader.java --- @@ -77,6 +92,46 @@ void requestSubpartiti

[jira] [Commented] (FLINK-7738) Create WebSocket handler (server)

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324419#comment-16324419 ] ASF GitHub Bot commented on FLINK-7738: --- Github user EronWright commented on the iss

[GitHub] flink issue #4767: [FLINK-7738] [flip-6] Create WebSocket handler (server, c...

2018-01-12 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/4767 @tillrohrmann are you still interested in this websocket code for the REST server? Aside from rebasing, any 'must fix' issues here? ---

[jira] [Created] (FLINK-8425) SpilledSubpartitionView not protected against concurrent release calls

2018-01-12 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8425: -- Summary: SpilledSubpartitionView not protected against concurrent release calls Key: FLINK-8425 URL: https://issues.apache.org/jira/browse/FLINK-8425 Project: Flink

[GitHub] flink issue #5112: [FLINK-8175] [DataStream API java/scala] remove flink-str...

2018-01-12 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5112 @StephanEwen let me know if this is good to go ---

[jira] [Commented] (FLINK-8175) remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala

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

[jira] [Updated] (FLINK-8424) [Cassandra Connector] Update Cassandra version to last one

2018-01-12 Thread Joao Boto (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joao Boto updated FLINK-8424: - Component/s: Cassandra Connector > [Cassandra Connector] Update Cassandra version to last one > --

[jira] [Updated] (FLINK-8424) [Cassandra Connector] Update Cassandra version to last one

2018-01-12 Thread Joao Boto (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joao Boto updated FLINK-8424: - Description: Cassandra connector are using a version outdated This is to upgrade the cassandra version to

[GitHub] flink issue #5290: [Flink-8424][Cassandra Connector] upgrade of cassandra ve...

2018-01-12 Thread eskabetxe
Github user eskabetxe commented on the issue: https://github.com/apache/flink/pull/5290 @twalthr @fhueske ---

[GitHub] flink pull request #5290: [Flink-8424][Cassandra Connector] upgrade of cassa...

2018-01-12 Thread eskabetxe
GitHub user eskabetxe opened a pull request: https://github.com/apache/flink/pull/5290 [Flink-8424][Cassandra Connector] upgrade of cassandra version and driver to latest ## What is the purpose of the change Update Cassandra version and driver to something new, the driv

[jira] [Updated] (FLINK-8424) [Cassandra Connector] Update Cassandra version to last one

2018-01-12 Thread Joao Boto (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joao Boto updated FLINK-8424: - Priority: Major (was: Critical) > [Cassandra Connector] Update Cassandra version to last one > --

[jira] [Created] (FLINK-8424) [Cassandra Connector] Update Cassandra version to last one

2018-01-12 Thread Joao Boto (JIRA)
Joao Boto created FLINK-8424: Summary: [Cassandra Connector] Update Cassandra version to last one Key: FLINK-8424 URL: https://issues.apache.org/jira/browse/FLINK-8424 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8414) Gelly performance seriously decreases when using the suggested parallelism configuration

2018-01-12 Thread flora karniav (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324228#comment-16324228 ] flora karniav commented on FLINK-8414: -- Thank you for your reply, I am running the

[jira] [Created] (FLINK-8423) OperatorChain#pushToOperator catch block may fail with NPE

2018-01-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8423: --- Summary: OperatorChain#pushToOperator catch block may fail with NPE Key: FLINK-8423 URL: https://issues.apache.org/jira/browse/FLINK-8423 Project: Flink

[jira] [Comment Edited] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer

2018-01-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324202#comment-16324202 ] Tzu-Li (Gordon) Tai edited comment on FLINK-8417 at 1/12/18 4:36 PM: ---

[jira] [Commented] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer

2018-01-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324204#comment-16324204 ] Tzu-Li (Gordon) Tai commented on FLINK-8417: The Role ARN for the Temporary Cr

[jira] [Commented] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer

2018-01-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324202#comment-16324202 ] Tzu-Li (Gordon) Tai commented on FLINK-8417: Fro the Javadocs, it mentions tha

[jira] [Created] (FLINK-8422) Checkstyle for org.apache.flink.api.java.tuple

2018-01-12 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-8422: - Summary: Checkstyle for org.apache.flink.api.java.tuple Key: FLINK-8422 URL: https://issues.apache.org/jira/browse/FLINK-8422 Project: Flink Issue Type: Improvemen

[jira] [Comment Edited] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer

2018-01-12 Thread Sreenath Kodedala (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324096#comment-16324096 ] Sreenath Kodedala edited comment on FLINK-8417 at 1/12/18 4:33 PM: -

[jira] [Created] (FLINK-8421) HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore

2018-01-12 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8421: -- Summary: HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore Key: FLINK-8421 URL: https://issues.apache.org/jira/browse/FLINK

[GitHub] flink pull request #5289: [hotfix] [docs] Fix typos

2018-01-12 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/5289 [hotfix] [docs] Fix typos From the IntelliJ `Typos` inspection. You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink 20180112a_fix_t

[jira] [Commented] (FLINK-8414) Gelly performance seriously decreases when using the suggested parallelism configuration

2018-01-12 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324133#comment-16324133 ] Greg Hogan commented on FLINK-8414: --- This is more of a question than a reported bug and

[jira] [Commented] (FLINK-8399) Use independent configurations for the different timeouts in slot manager

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324117#comment-16324117 ] ASF GitHub Bot commented on FLINK-8399: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8399) Use independent configurations for the different timeouts in slot manager

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324113#comment-16324113 ] ASF GitHub Bot commented on FLINK-8399: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8399) Use independent configurations for the different timeouts in slot manager

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324118#comment-16324118 ] ASF GitHub Bot commented on FLINK-8399: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8399) Use independent configurations for the different timeouts in slot manager

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324119#comment-16324119 ] ASF GitHub Bot commented on FLINK-8399: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8399) Use independent configurations for the different timeouts in slot manager

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324115#comment-16324115 ] ASF GitHub Bot commented on FLINK-8399: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8399) Use independent configurations for the different timeouts in slot manager

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324114#comment-16324114 ] ASF GitHub Bot commented on FLINK-8399: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8399) Use independent configurations for the different timeouts in slot manager

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324116#comment-16324116 ] ASF GitHub Bot commented on FLINK-8399: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8399) Use independent configurations for the different timeouts in slot manager

2018-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324120#comment-16324120 ] ASF GitHub Bot commented on FLINK-8399: --- Github user tillrohrmann commented on a dif

  1   2   3   >