[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

2016-09-06 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2425 > T2-3 is not about the web interface netty, its about the data transfer netty In Flink, we are using netty for (at least) three things: - Akka is using Netty. This is addressed in

[jira] [Commented] (FLINK-3930) Implement Service-Level Authorization

2016-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15466600#comment-15466600 ] ASF GitHub Bot commented on FLINK-3930: --- Github user vijikarthi commented on the issue:

[jira] [Closed] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project

2016-09-06 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian closed FLINK-4278. -- Resolution: Not A Problem > Unclosed FSDataOutputStream in multiple files in

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15466699#comment-15466699 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the issue:

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-09-06 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 rebased again with the latest master --- 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-4510) Always create CheckpointCoordinator

2016-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15466673#comment-15466673 ] ASF GitHub Bot commented on FLINK-4510: --- Github user wuchong commented on the issue:

[GitHub] flink issue #2453: [FLINK-4510] [checkpoint] Always create CheckpointCoordin...

2016-09-06 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2453 Hi @StephanEwen , I have updated this PR according to your suggestion. In addition, I use an interval of `Long.MAX_VALUE` for disabled periodic checkpoint. In this way, we will not break interval

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

2016-09-06 Thread liuyuzhong
Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2452 Jenkins run error: ``` Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 30.585 sec - in org.apache.flink.test.recovery.TaskManagerProcessFailureStreamingRecoveryITCase

[jira] [Commented] (FLINK-4505) Implement TaskManagerFactory to bring up TaskManager for different modes

2016-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15466924#comment-15466924 ] ASF GitHub Bot commented on FLINK-4505: --- Github user wangzhijiang999 commented on the issue:

[GitHub] flink issue #2461: [FLINK-4505][Cluster Management] Implement TaskManagerFac...

2016-09-06 Thread wangzhijiang999
Github user wangzhijiang999 commented on the issue: https://github.com/apache/flink/pull/2461 @tillrohrmann , I created the `TaskExecutorRunner` for constructing the related components for starting `TaskExecutor`, and removed the factory class. Currently only the `ResourceID` and

[jira] [Commented] (FLINK-3930) Implement Service-Level Authorization

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

[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

2016-09-06 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2425 Thank you for addressing my comments. I've looked into the design document [1] again and some details are missing there. In particular its not clearly specified how and where the shared

[GitHub] flink pull request #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to ...

2016-09-06 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2337#discussion_r77714875 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInformation.java --- @@ -122,14 +123,25 @@ public abstract Class

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468531#comment-15468531 ] Robert Metzger commented on FLINK-3427: --- [~ivan.mushketyk] did you already start working on this

[jira] [Commented] (FLINK-3930) Implement Service-Level Authorization

2016-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468585#comment-15468585 ] ASF GitHub Bot commented on FLINK-3930: --- Github user vijikarthi commented on the issue:

[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

2016-09-06 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2425 > How is the secret transferred to the TaskManagers on YARN? Cookie is transferred to TM container through container environment variable and further gets populated to in-memory Flink

[jira] [Created] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-06 Thread Johannes (JIRA)
Johannes created FLINK-4586: --- Summary: NumberSequenceIterator and Accumulator threading issue Key: FLINK-4586 URL: https://issues.apache.org/jira/browse/FLINK-4586 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4410) Split checkpoint times into synchronous and asynchronous part

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468721#comment-15468721 ] Ivan Mushketyk commented on FLINK-4410: --- Hi [~uce]. Just to make sure that I understand correctly

[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-06 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-4586: Description: There is a strange problem when using the NumberSequenceIterator in combination with an

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

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

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468506#comment-15468506 ] Ivan Mushketyk commented on FLINK-2254: --- Hi Greg. Thank you for your comment. Could you please

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468538#comment-15468538 ] Ivan Mushketyk commented on FLINK-3427: --- [~rmetzger], I not half-way through the task yet, so it's

[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-06 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-4586: Attachment: FLINK4586Test.scala Complete Scala Testcase > NumberSequenceIterator and Accumulator threading

[GitHub] flink issue #2397: [FLINK-4439] Validate 'bootstrap.servers' config in flink...

2016-09-06 Thread gheo21
Github user gheo21 commented on the issue: https://github.com/apache/flink/pull/2397 Hi @rmetzger , The build got green. Everything should be ok, right? Thanks! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15466863#comment-15466863 ] Robert Metzger commented on FLINK-3427: --- Hey [~ivan.mushketyk], how do you plan to visualize the

[jira] [Commented] (FLINK-616) Change of java version without effect.

2016-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15466815#comment-15466815 ] ASF GitHub Bot commented on FLINK-616: -- GitHub user aljoscha opened a pull request:

[jira] [Commented] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid

2016-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15466816#comment-15466816 ] ASF GitHub Bot commented on FLINK-4439: --- Github user gheo21 commented on the issue:

[GitHub] flink pull request #2455: [FLINK-4547] [cluster management] Return same obje...

2016-09-06 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2455#discussion_r77753174 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java --- @@ -189,7 +191,49 @@ public void stop() {

[jira] [Commented] (FLINK-4547) Return same object when call connect method in AkkaRpcService using same address and same rpc gateway class

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

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77628600 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -52,15 +58,28 @@ * */ public class

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[jira] [Commented] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"

2016-09-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467287#comment-15467287 ] Tzu-Li (Gordon) Tai commented on FLINK-4559: Resolved for master in

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

2016-09-06 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2452 It looks like this is basically a copy of the old code adapted to the Storm 1.0.0 dependency. This would duplicate a lot of code. I've started a thread on the mailing list, whether we want to add a new

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77630918 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotProtocolTest.java --- @@ -0,0 +1,228 @@ +/* + * Licensed

[jira] [Commented] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"

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

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77629858 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotStatus.java --- @@ -46,13 +47,21 @@ /** if the slot is allocated, jobId

[jira] [Created] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams

2016-09-06 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-4582: -- Summary: Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams Key: FLINK-4582 URL: https://issues.apache.org/jira/browse/FLINK-4582 Project:

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r7763 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGateway.java --- @@ -32,4 +33,11 @@ //

[jira] [Assigned] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

2016-09-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-4576: -- Assignee: Tzu-Li (Gordon) Tai > Low Watermark Service in JobManager for

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-06 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467383#comment-15467383 ] Timo Walther commented on FLINK-4565: - tableEnv.sql(...) returns a Table containing a LogicalRelNode

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77628362 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/LeaderIdRegistry.java --- @@ -15,11 +15,27 @@ * See the License for the

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[jira] [Updated] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"

2016-09-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4559: --- Fix Version/s: (was: 1.1.3) 1.2.0 > Kinesis Producer not

[jira] [Resolved] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"

2016-09-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-4559. Resolution: Resolved > Kinesis Producer not setting credentials provider properly

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-06 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467236#comment-15467236 ] Simone Robutti commented on FLINK-4565: --- Ok, the testing part seems easy and straightforward. I'm

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

2016-09-06 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2452 I think you ran out of memory. Travis CI build passed, so the PR's testing state seems to be fine. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77629249 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -131,9 +149,16 @@ public RegistrationResponse

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77630351 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotProtocolTest.java --- @@ -0,0 +1,228 @@ +/* + * Licensed

[jira] [Updated] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams

2016-09-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4582: --- Description: AWS DynamoDB is a NoSQL database service that has a CDC-like (change

[jira] [Updated] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"

2016-09-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4559: --- Affects Version/s: (was: 1.1.2) (was: 1.1.1)

[GitHub] flink issue #2470: [FLINK-4559][kinesis-connector] Fix AWSUtil.getCredential...

2016-09-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2470 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-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"

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

[GitHub] flink pull request #2470: [FLINK-4559][kinesis-connector] Fix AWSUtil.getCre...

2016-09-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2470 --- 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] [Created] (FLINK-4581) Table API throws "No suitable driver found for jdbc:calcite"

2016-09-06 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4581: --- Summary: Table API throws "No suitable driver found for jdbc:calcite" Key: FLINK-4581 URL: https://issues.apache.org/jira/browse/FLINK-4581 Project: Flink

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77650313 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/LeaderIdRegistry.java --- @@ -15,11 +15,27 @@ * See the License

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77650617 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotProtocolTest.java --- @@ -0,0 +1,228 @@ +/* + *

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77650487 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotProtocolTest.java --- @@ -0,0 +1,228 @@ +/* + *

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[GitHub] flink pull request #2294: [FLINK-4265] [dataset api] Add a NoOpOperator

2016-09-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2294 --- 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-4265) Add a NoOpOperator

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

[jira] [Closed] (FLINK-4265) Add a NoOpOperator

2016-09-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4265. - Resolution: Implemented Implemented in 66d4b8724b9e9b09225d2bbd3132dc2efdcf843a > Add a NoOpOperator >

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77651399 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -52,15 +58,28 @@ * */

[jira] [Created] (FLINK-4583) NullPointerException in CliFrontend

2016-09-06 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4583: - Summary: NullPointerException in CliFrontend Key: FLINK-4583 URL: https://issues.apache.org/jira/browse/FLINK-4583 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77651201 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotProtocolTest.java --- @@ -0,0 +1,228 @@ +/* + *

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467660#comment-15467660 ] Ivan Mushketyk commented on FLINK-3427: --- Hey [~rmetzger], my idea was to record a timestamp of the

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

2016-09-06 Thread Konstantin Boudnik (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467921#comment-15467921 ] Konstantin Boudnik commented on FLINK-4315: --- I have a hunch, once the dependency is severed, it

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-09-06 Thread delding
Github user delding commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r77676350 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseMapper.java --- @@ -0,0 +1,46 @@

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-06 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467945#comment-15467945 ] Simone Robutti commented on FLINK-4565: --- I haven't assigned the issue to myself because I'm still

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-09-06 Thread delding
Github user delding commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r77676668 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseMapper.java --- @@ -0,0 +1,46 @@

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467767#comment-15467767 ] Ivan Mushketyk commented on FLINK-3427: --- [~rmetzger] If this will help in the discussing was

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-06 Thread Konstantin Boudnik (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467913#comment-15467913 ] Konstantin Boudnik commented on FLINK-4565: --- If someone starts working on an issue, shouldn't it

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[jira] [Updated] (FLINK-4257) Handle delegating algorithm change of class

2016-09-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4257: -- Description: A class created by {{ProxyFactory}} can intercept and reinterpret method calls using its

[jira] [Commented] (FLINK-4554) Add support for array types

2016-09-06 Thread Konstantin Boudnik (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15467918#comment-15467918 ] Konstantin Boudnik commented on FLINK-4554: --- Do you think adding a support for ranges a-la

[jira] [Commented] (FLINK-4554) Add support for array types

2016-09-06 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468154#comment-15468154 ] Timo Walther commented on FLINK-4554: - Apache Calcite does the parsing for us and they strictly follow

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[jira] [Created] (FLINK-4585) Fix broken links on flink.apache.org

2016-09-06 Thread Alexander Pivovarov (JIRA)
Alexander Pivovarov created FLINK-4585: -- Summary: Fix broken links on flink.apache.org Key: FLINK-4585 URL: https://issues.apache.org/jira/browse/FLINK-4585 Project: Flink Issue Type:

[GitHub] flink pull request #2471: Broken links on website

2016-09-06 Thread apivovarov
Github user apivovarov closed the pull request at: https://github.com/apache/flink/pull/2471 --- 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

[GitHub] flink issue #2471: Broken links on website

2016-09-06 Thread apivovarov
Github user apivovarov commented on the issue: https://github.com/apache/flink/pull/2471 https://issues.apache.org/jira/browse/FLINK-4585 I'll submit a PR to flink-web --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-09-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468368#comment-15468368 ] Greg Hogan commented on FLINK-2254: --- Hi Ivan, I haven't read the document, and still look for

[jira] [Updated] (FLINK-4585) Fix broken links on flink.apache.org

2016-09-06 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4585: --- Description: The following links are broken DataSet API link:

[jira] [Commented] (FLINK-4257) Handle delegating algorithm change of class

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

[jira] [Updated] (FLINK-4585) Fix broken links on flink.apache.org

2016-09-06 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4585: --- Description: The following links are broken DataSet API link:

[jira] [Commented] (FLINK-4585) Fix broken links on flink.apache.org

2016-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468416#comment-15468416 ] ASF GitHub Bot commented on FLINK-4585: --- Github user apivovarov commented on the issue:

[jira] [Updated] (FLINK-4585) Fix broken links on flink.apache.org

2016-09-06 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4585: --- Description: The following links are broken DataSet API link:

[jira] [Commented] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-06 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468729#comment-15468729 ] Johannes commented on FLINK-4586: - The testcase also fails, when just using a plain collection and a

[jira] [Updated] (FLINK-4585) Fix broken links in index.md

2016-09-06 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4585: --- Summary: Fix broken links in index.md (was: Fix broken links on flink.apache.org) >

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468520#comment-15468520 ] Robert Metzger commented on FLINK-3427: --- Afaik there is already a gauge for getting the low

[jira] [Updated] (FLINK-4585) Fix broken links in index.md

2016-09-06 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4585: --- Description: The following links are broken DataSet API link:

[jira] [Commented] (FLINK-3709) [streaming] Graph event rates over time

2016-09-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468557#comment-15468557 ] Ivan Mushketyk commented on FLINK-3709: --- [~rmetzger] I could work on it, but I wonder where would be

[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-06 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-4586: Description: There is a strange problem when using the NumberSequenceIterator in combination with an

  1   2   >