[GitHub] flink pull request #2914: [FLINK-4611] [kinesis] Make "AUTO" credential prov...

2016-12-15 Thread tony810430
Github user tony810430 commented on a diff in the pull request: https://github.com/apache/flink/pull/2914#discussion_r92583846 --- Diff: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerTest.java --- @@

[jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751341#comment-15751341 ] ASF GitHub Bot commented on FLINK-4611: --- Github user tony810430 commented on a diff in the pull

[GitHub] flink pull request #2764: [FLINK-5008] Update quickstart documentation

2016-12-15 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/2764#discussion_r92608012 --- Diff: docs/quickstart/run_example_quickstart.md --- @@ -90,23 +92,23 @@ use it in our program. Edit the `dependencies` section so that it looks like thi

[jira] [Commented] (FLINK-5008) Update quickstart documentation

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

[GitHub] flink pull request #2903: [FLINK-5074] [runtime] add a zookeeper based runni...

2016-12-15 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2903#discussion_r92608715 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/ZooKeeperRegistryTest.java --- @@ -0,0 +1,87 @@ +/* + * Licensed

[GitHub] flink pull request #2717: [FLINK-4956] Enhance StreamTaskTestHarness with ea...

2016-12-15 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/2717 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[GitHub] flink issue #3008: [FLINK-4973] Let LatencyMarksEmitter use StreamTask's Pro...

2016-12-15 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3008 True. The `ProcessingTimeService` extension seemed to me like the slightly cleaner approach (even though, the `ScheduledThreadPoolExecutor` does it in a similar fashion internally). Thanks for

[jira] [Commented] (FLINK-4956) Introduce convenient methods for testing checkpoint/restore in StreamTaskTestHarness

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751396#comment-15751396 ] ASF GitHub Bot commented on FLINK-4956: --- Github user StefanRRichter closed the pull request at:

[jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751395#comment-15751395 ] ASF GitHub Bot commented on FLINK-4973: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2958: [FLINK-4704] Move Table API to org.apache.flink.table

2016-12-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2958 Thanks for the update @ex00! I'll do a few additional minor refactorings and merge the PR later. Thanks, Fabian --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-4704) Move Table API to org.apache.flink.table

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751425#comment-15751425 ] ASF GitHub Bot commented on FLINK-4704: --- Github user ex00 commented on the issue:

[GitHub] flink issue #2958: [FLINK-4704] Move Table API to org.apache.flink.table

2016-12-15 Thread ex00
Github user ex00 commented on the issue: https://github.com/apache/flink/pull/2958 Thank you Fabian! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[GitHub] flink issue #2723: [FLINK-3617] Fixed NPE from CaseClassSerializer

2016-12-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2723 Having `null` as the full transported type es explicitly not supported right now. The handling of null member fields belongs logically to the Tuple/Pojo/CaseClass serializer, not to the

[jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751438#comment-15751438 ] ASF GitHub Bot commented on FLINK-4973: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2914: [FLINK-4611] [kinesis] Make "AUTO" credential provider as...

2016-12-15 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2914 Merging ... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector

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

[GitHub] flink issue #2723: [FLINK-3617] Fixed NPE from CaseClassSerializer

2016-12-15 Thread chermenin
Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2723 No-no, i'm forced to disagree with you... IMHO, `null` is a value of concrete type and it must be processed by individual serializer for this type. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-5008) Update quickstart documentation

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

[GitHub] flink pull request #2764: [FLINK-5008] Update quickstart documentation

2016-12-15 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/2764#discussion_r92608383 --- Diff: docs/quickstart/java_api_quickstart.md --- @@ -46,39 +46,79 @@ Use one of the following commands to __create a project__: {% highlight bash

[jira] [Commented] (FLINK-5074) Implement a RunningJobRegistry based on Zookeeper

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751383#comment-15751383 ] ASF GitHub Bot commented on FLINK-5074: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-4704) Move Table API to org.apache.flink.table

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751415#comment-15751415 ] ASF GitHub Bot commented on FLINK-4704: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751411#comment-15751411 ] ASF GitHub Bot commented on FLINK-3617: --- Github user chermenin commented on the issue:

[GitHub] flink issue #2723: [FLINK-3617] Fixed NPE from CaseClassSerializer

2016-12-15 Thread chermenin
Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2723 I think that if some type can have `null` as value then there must be possibility to serialize this value (it may be Option or any other type). And by the way `CaseClassSerializer` class have been

[jira] [Commented] (FLINK-5008) Update quickstart documentation

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

[GitHub] flink pull request #2764: [FLINK-5008] Update quickstart documentation

2016-12-15 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/2764#discussion_r92611981 --- Diff: docs/quickstart/java_api_quickstart.md --- @@ -46,39 +46,79 @@ Use one of the following commands to __create a project__: {% highlight bash

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751440#comment-15751440 ] ASF GitHub Bot commented on FLINK-3617: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3008: [FLINK-4973] Let LatencyMarksEmitter use StreamTask's Pro...

2016-12-15 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3008 +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector

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

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751461#comment-15751461 ] ASF GitHub Bot commented on FLINK-3617: --- Github user chermenin commented on the issue:

[GitHub] flink pull request #2914: [FLINK-4611] [kinesis] Make "AUTO" credential prov...

2016-12-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2914 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector

2016-12-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751466#comment-15751466 ] Tzu-Li (Gordon) Tai commented on FLINK-4611: Resolved in {{master}} via

[jira] [Updated] (FLINK-5344) docs don't build in dockerized jekyll; -p option is broken

2016-12-15 Thread David Anderson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-5344: -- Description: The recent Gemfile update doesn't work with the ruby in the provided dockerized

[jira] [Commented] (FLINK-5311) Write user documentation for BipartiteGraph

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751844#comment-15751844 ] ASF GitHub Bot commented on FLINK-5311: --- Github user vasia commented on the issue:

[GitHub] flink issue #2984: [FLINK-5311] Add user documentation for bipartite graph

2016-12-15 Thread vasia
Github user vasia commented on the issue: https://github.com/apache/flink/pull/2984 Hi @mushketyk, thank you for the update! Just a couple of small things and we can merge: - Can you add a note in the beginning of the docs that bipartite graphs are only currently supported in

[jira] [Commented] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751854#comment-15751854 ] ASF GitHub Bot commented on FLINK-5097: --- Github user vasia commented on the issue:

[jira] [Commented] (FLINK-4631) NullPointerException during stream task cleanup

2016-12-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751655#comment-15751655 ] Robert Metzger commented on FLINK-4631: --- The issue persists for Flink 1.1.4 RC3 >

[GitHub] flink pull request #2917: [FLINK-2821] use custom Akka build to listen on al...

2016-12-15 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2917#discussion_r92658254 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala --- @@ -102,21 +102,24 @@ object AkkaUtils { * specified, then the

[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition...

2016-12-15 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3001 @tony810430 (cc @StephanEwen, f.y.i.) At a second closer look, I'm afraid this PR can't be merged as is. The problem is that the state redistribution of `ListCheckpointed` doesn't work with the

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

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

[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition...

2016-12-15 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3001 I have an open PR #2948 that would introduce all the facilities for global and union state. It is just a matter of also exposing it two the user. I think at least for the union state, this

[jira] [Created] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration

2016-12-15 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5346: --- Summary: Remove all ad-hoc config loading via GlobalConfiguration Key: FLINK-5346 URL: https://issues.apache.org/jira/browse/FLINK-5346 Project: Flink Issue

[GitHub] flink pull request #2917: [FLINK-2821] use custom Akka build to listen on al...

2016-12-15 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2917#discussion_r92658704 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala --- @@ -216,12 +219,19 @@ object AkkaUtils { * identified by

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

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

[jira] [Commented] (FLINK-5104) Implement BipartiteGraph validator

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751646#comment-15751646 ] ASF GitHub Bot commented on FLINK-5104: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2985: [FLINK-5104] Bipartite graph validation

2016-12-15 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2985 @mushketyk I had meant just with a simple comment noting that with an anti-join we could also remove the FlatJoinFunction. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-5344) docs don't build in dockerized jekyll; -p option is broken

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

[jira] [Commented] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations

2016-12-15 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751890#comment-15751890 ] Vasia Kalavri commented on FLINK-5127: -- It'd be nice to have for 1.2, but I don't know when I'll have

[GitHub] flink pull request #3013: [FLINK-5344] relax spec for requested ruby version...

2016-12-15 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/3013#discussion_r92653981 --- Diff: docs/build_docs.sh --- @@ -46,8 +46,8 @@ DOCS_DST=${DOCS_SRC}/content JEKYLL_CMD="build" # if -p flag is provided, serve site on

[jira] [Commented] (FLINK-5344) docs don't build in dockerized jekyll; -p option is broken

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

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-15 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751685#comment-15751685 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~jark] Your suggestion makes sense to me. >> But

[jira] [Updated] (FLINK-5345) IOManager failed to properly clean up temp file directory

2016-12-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5345: Labels: simplex (was: ) > IOManager failed to properly clean up temp file directory >

[jira] [Commented] (FLINK-5345) IOManager failed to properly clean up temp file directory

2016-12-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751722#comment-15751722 ] Stephan Ewen commented on FLINK-5345: - I think that is a problem of

[jira] [Updated] (FLINK-5345) IOManager failed to properly clean up temp file directory

2016-12-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5345: Labels: simplex starter (was: simplex) > IOManager failed to properly clean up temp file directory

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

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

[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition...

2016-12-15 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3001 Thanks for the info Stefan! @tony810430 we'll probably need to block this PR for now, and refresh it once the unioned state interface comes around. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

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

[GitHub] flink pull request #2917: [FLINK-2821] use custom Akka build to listen on al...

2016-12-15 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2917#discussion_r92659443 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala --- @@ -216,12 +219,19 @@ object AkkaUtils { * identified by

[GitHub] flink pull request #2917: [FLINK-2821] use custom Akka build to listen on al...

2016-12-15 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2917#discussion_r92661183 --- Diff: flink-runtime/pom.xml --- @@ -193,8 +193,8 @@ under the License. - com.typesafe.akka -

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

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

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751991#comment-15751991 ] ASF GitHub Bot commented on FLINK-2821: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

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

[GitHub] flink issue #2917: [FLINK-2821] use custom Akka build to listen on all inter...

2016-12-15 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2917 Thanks you @tillrohrmann and @StephanEwen. I've addressed your comments. I'll have to redeploy Flakka because the staging repository which this PR used, has been dropped in the meantime. I will update

[GitHub] flink issue #2842: [FLINK-5097][gelly] Add missing input type information to...

2016-12-15 Thread vasia
Github user vasia commented on the issue: https://github.com/apache/flink/pull/2842 Sure, I can revert using `getMapReturnTypes` , rebase, and merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751849#comment-15751849 ] ASF GitHub Bot commented on FLINK-4821: --- Github user StefanRRichter commented on the issue:

[GitHub] flink pull request #3013: [FLINK-5344] relax spec for requested ruby version...

2016-12-15 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/3013#discussion_r92654203 --- Diff: docs/Gemfile --- @@ -17,13 +17,14 @@ source

[GitHub] flink issue #2917: [FLINK-2821] use custom Akka build to listen on all inter...

2016-12-15 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2917 I've added the new staging repository to test the PR changes. Also, the repository is currently deploying to Maven central. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752145#comment-15752145 ] ASF GitHub Bot commented on FLINK-2821: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-5344) docs don't build in dockerized jekyll; -p option is broken

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752377#comment-15752377 ] ASF GitHub Bot commented on FLINK-5344: --- Github user alpinegizmo commented on a diff in the pull

[GitHub] flink issue #2842: [FLINK-5097][gelly] Add missing input type information to...

2016-12-15 Thread vasia
Github user vasia commented on the issue: https://github.com/apache/flink/pull/2842 Done. I'll wait for travis, then merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-5344) docs don't build in dockerized jekyll; -p option is broken

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752384#comment-15752384 ] ASF GitHub Bot commented on FLINK-5344: --- Github user alpinegizmo commented on the issue:

[GitHub] flink issue #3013: [FLINK-5344] relax spec for requested ruby version so the...

2016-12-15 Thread alpinegizmo
Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/3013 Max, this latest commit allows one to take advantage of ruby 2.0 if it is available, but is backwards compatible to 1.9. Hopefully this will satisfy everyone. The only issue I can see is that if

[GitHub] flink pull request #3013: [FLINK-5344] relax spec for requested ruby version...

2016-12-15 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3013#discussion_r92689908 --- Diff: docs/build_docs.sh --- @@ -46,8 +46,8 @@ DOCS_DST=${DOCS_SRC}/content JEKYLL_CMD="build" # if -p flag is provided, serve site on

[jira] [Commented] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752120#comment-15752120 ] ASF GitHub Bot commented on FLINK-5097: --- Github user vasia commented on the issue:

[jira] [Created] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write()

2016-12-15 Thread Ted Yu (JIRA)
Ted Yu created FLINK-5347: - Summary: Unclosed stream in OperatorBackendSerializationProxy#write() Key: FLINK-5347 URL: https://issues.apache.org/jira/browse/FLINK-5347 Project: Flink Issue Type:

[GitHub] flink pull request #3014: [FLINK-4861] [build] Package optional project arti...

2016-12-15 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3014 [FLINK-4861] [build] Package optional project artifacts Package the Flink connectors, metrics, and libraries into subdirectories of a new opt directory in the release/snapshot tarballs.

[jira] [Commented] (FLINK-4861) Package optional project artifacts

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

[jira] [Commented] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write()

2016-12-15 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752765#comment-15752765 ] Stefan Richter commented on FLINK-5347: --- {{dos}} is just a wrapper around {{out}}. {{out}} does not

[GitHub] flink issue #3009: [FLINK-5255] Improve single row check in DataSetSingleRow...

2016-12-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3009 Thanks for the PR @AlexanderShoshin! It's good to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15753091#comment-15753091 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tony810430 commented on the issue:

[jira] [Commented] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15753235#comment-15753235 ] ASF GitHub Bot commented on FLINK-5324: --- GitHub user hzyuemeng1 reopened a pull request:

[GitHub] flink pull request #2994: [FLINK-5324] [yarn] JVM Opitons will work for both...

2016-12-15 Thread hzyuemeng1
GitHub user hzyuemeng1 reopened a pull request: https://github.com/apache/flink/pull/2994 [FLINK-5324] [yarn] JVM Opitons will work for both YarnApplicationMas… Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752834#comment-15752834 ] ASF GitHub Bot commented on FLINK-5255: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition...

2016-12-15 Thread tony810430
Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/3001 OK. Thanks for pointing out this problem. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Created] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-15 Thread Jark Wu (JIRA)
Jark Wu created FLINK-5348: -- Summary: Support custom field names for RowTypeInfo Key: FLINK-5348 URL: https://issues.apache.org/jira/browse/FLINK-5348 Project: Flink Issue Type: Improvement

[GitHub] flink issue #3000: [FLINK-4861] [build] Package optional project artifacts

2016-12-15 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3000 New PR to only include metrics, cep, ml, and gelly: #3014 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[jira] [Commented] (FLINK-4861) Package optional project artifacts

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752708#comment-15752708 ] ASF GitHub Bot commented on FLINK-4861: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2984: [FLINK-5311] Add user documentation for bipartite graph

2016-12-15 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2984 Hi @vasia , thank you for your review! I've added the warning to the Bipartite Graph page. I am a bit reluctant to rename "Graph transformations" though since I wanted to extend this

[jira] [Commented] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write()

2016-12-15 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752754#comment-15752754 ] Stefan Richter commented on FLINK-5347: --- The stream is not opened in the method and therefore should

[jira] [Issue Comment Deleted] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write()

2016-12-15 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-5347: -- Comment: was deleted (was: The stream is not opened in the method and therefore should also not

[jira] [Resolved] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write()

2016-12-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-5347. --- Resolution: Not A Problem > Unclosed stream in OperatorBackendSerializationProxy#write() >

[GitHub] flink issue #3011: [FLINK-5343] [table] Add support to overwrite files with ...

2016-12-15 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3011 Thanks @fhueske. Looks good to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-5311) Write user documentation for BipartiteGraph

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752618#comment-15752618 ] ASF GitHub Bot commented on FLINK-5311: --- Github user mushketyk commented on the issue:

[jira] [Commented] (FLINK-5343) Add more option to CsvTableSink

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752714#comment-15752714 ] ASF GitHub Bot commented on FLINK-5343: --- Github user twalthr commented on the issue:

[GitHub] flink issue #3013: [FLINK-5344] relax spec for requested ruby version so the...

2016-12-15 Thread alpinegizmo
Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/3013 I've concluded this was the wrong approach. I'll open another pull request to deal with these issues. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-5344) docs don't build in dockerized jekyll; -p option is broken

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15753699#comment-15753699 ] ASF GitHub Bot commented on FLINK-5344: --- Github user alpinegizmo commented on the issue:

[GitHub] flink pull request #3013: [FLINK-5344] relax spec for requested ruby version...

2016-12-15 Thread alpinegizmo
Github user alpinegizmo closed the pull request at: https://github.com/apache/flink/pull/3013 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-5344) docs don't build in dockerized jekyll; -p option is broken

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15753700#comment-15753700 ] ASF GitHub Bot commented on FLINK-5344: --- Github user alpinegizmo closed the pull request at:

[jira] [Commented] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-15 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15753260#comment-15753260 ] godfrey he commented on FLINK-5342: --- take your point,there is a lot of work to do if we want to achieve

[jira] [Assigned] (FLINK-3746) WebRuntimeMonitorITCase.testNoCopyFromJar failing intermittently

2016-12-15 Thread Boris Osipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Osipov reassigned FLINK-3746: --- Assignee: Boris Osipov > WebRuntimeMonitorITCase.testNoCopyFromJar failing intermittently >

[jira] [Assigned] (FLINK-4255) Unstable test WebRuntimeMonitorITCase.testNoEscape

2016-12-15 Thread Boris Osipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Osipov reassigned FLINK-4255: --- Assignee: Boris Osipov > Unstable test WebRuntimeMonitorITCase.testNoEscape >

  1   2   3   >