[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&focusedCommentId=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 san

[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 enab

[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&focusedCommentId=15466699#comment-15466699 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the iss

[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 a

[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&focusedCommentId=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&focusedCommentId=15466816#comment-15466816 ] ASF GitHub Bot commented on FLINK-4439: --- Github user gheo21 commented on the issue:

[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&focusedCommentId=15466863#comment-15466863 ] Robert Metzger commented on FLINK-3427: --- Hey [~ivan.mushketyk], how do you plan to v

[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&focusedCommentId=15466924#comment-15466924 ] ASF GitHub Bot commented on FLINK-4505: --- Github user wangzhijiang999 commented on th

[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 'Con

[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&focusedCommentId=15467016#comment-15467016 ] Simone Robutti commented on FLINK-4565: --- I would like to take care of this issue to

[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&focusedCommentId=15467059#comment-15467059 ] Timo Walther commented on FLINK-4565: - Hi [~chobeat], yes I think this issue is good f

[jira] [Comment Edited] (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&focusedCommentId=15467059#comment-15467059 ] Timo Walther edited comment on FLINK-4565 at 9/6/16 10:22 AM: --

[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&focusedCommentId=15467236#comment-15467236 ] Simone Robutti commented on FLINK-4565: --- Ok, the testing part seems easy and straigh

[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 th

[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&focusedCommentId=15467271#comment-15467271 ] ASF GitHub Bot commented on FLINK-4559: --- Github user tzulitai commented on the issue

[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)

[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 settin

[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 enab

[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&focusedCommentId=15467281#comment-15467281 ] ASF GitHub Bot commented on FLINK-4559: --- Github user asfgit closed 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&focusedCommentId=15467287#comment-15467287 ] Tzu-Li (Gordon) Tai commented on FLINK-4559: Resolved for master in http://gi

[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 wh

[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 Streami

[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 Iss

[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 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 m

[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 R

[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&focusedCommentId=15467353#comment-15467353 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on a diff in the

[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 apply(fi

[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&focusedCommentId=15467350#comment-15467350 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on a diff in 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&focusedCommentId=15467361#comment-15467361 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on a diff in the

[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 spe

[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 i

[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: 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&focusedCommentId=15467376#comment-15467376 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on a diff in the

[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] [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&focusedCommentId=15467379#comment-15467379 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on a diff in the

[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 t

[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&focusedCommentId=15467382#comment-15467382 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on a diff in the

[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&focusedCommentId=15467383#comment-15467383 ] Timo Walther commented on FLINK-4565: - tableEnv.sql(...) returns a Table containing a

[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 t

[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&focusedCommentId=15467390#comment-15467390 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on a diff in the

[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 data

[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 enab

[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&focusedCommentId=15467510#comment-15467510 ] ASF GitHub Bot commented on FLINK-4265: --- Github user asfgit closed the pull request

[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_r77650313 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/LeaderIdRegistry.java --- @@ -15,11 +15,27 @@ * See the License fo

[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&focusedCommentId=15467596#comment-15467596 ] ASF GitHub Bot commented on FLINK-4538: --- Github user tillrohrmann commented on a dif

[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&focusedCommentId=15467599#comment-15467599 ] ASF GitHub Bot commented on FLINK-4538: --- Github user tillrohrmann commented on a dif

[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 @@ +/* + * L

[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 @@ +/* + * L

[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&focusedCommentId=15467609#comment-15467609 ] ASF GitHub Bot commented on FLINK-4538: --- Github user tillrohrmann commented on a dif

[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 @@ +/* + * L

[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 @@ * */ publi

[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&focusedCommentId=15467612#comment-15467612 ] ASF GitHub Bot commented on FLINK-4538: --- Github user tillrohrmann commented on a dif

[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 Compone

[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&focusedCommentId=15467602#comment-15467602 ] ASF GitHub Bot commented on FLINK-4538: --- Github user tillrohrmann commented on a dif

[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&focusedCommentId=15467660#comment-15467660 ] Ivan Mushketyk commented on FLINK-3427: --- Hey [~rmetzger], my idea was to record a ti

[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&focusedCommentId=15467767#comment-15467767 ] Ivan Mushketyk commented on FLINK-3427: --- [~rmetzger] If this will help in the discus

[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-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&focusedCommentId=15467913#comment-15467913 ] Konstantin Boudnik commented on FLINK-4565: --- If someone starts working on an iss

[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&focusedCommentId=15467918#comment-15467918 ] Konstantin Boudnik commented on FLINK-4554: --- Do you think adding a support for r

[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&focusedCommentId=15467921#comment-15467921 ] Konstantin Boudnik commented on FLINK-4315: --- I have a hunch, once the dependency

[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-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&focusedCommentId=15467928#comment-15467928 ] ASF GitHub Bot commented on FLINK-2055: --- Github user delding commented on a diff in

[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&focusedCommentId=15467934#comment-15467934 ] ASF GitHub Bot commented on FLINK-2055: --- Github user delding commented on a diff in

[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-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&focusedCommentId=15467945#comment-15467945 ] Simone Robutti commented on FLINK-4565: --- I haven't assigned the issue to myself beca

[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&focusedCommentId=15468154#comment-15468154 ] Timo Walther commented on FLINK-4554: - Apache Calcite does the parsing for us and they

[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&focusedCommentId=15468368#comment-15468368 ] Greg Hogan commented on FLINK-2254: --- Hi Ivan, I haven't read the document, and still loo

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

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

[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: Bu

[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&focusedCommentId=15468397#comment-15468397 ] ASF GitHub Bot commented on FLINK-4257: --- GitHub user greghogan opened a pull request

[GitHub] flink pull request #2474: [FLINK-4257] [gelly] Handle delegating algorithm c...

2016-09-06 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2474 [FLINK-4257] [gelly] Handle delegating algorithm change of class Replaces Delegate with NoOpOperator. You can merge this pull request into a Git repository by running: $ git pull https://gith

[GitHub] flink pull request #2475: [FLINK-4571] [gelly] Configurable little paralleli...

2016-09-06 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2475 [FLINK-4571] [gelly] Configurable little parallelism in Gelly drivers You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink 4571_c

[jira] [Commented] (FLINK-4571) Configurable little parallelism in Gelly drivers

2016-09-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15468406#comment-15468406 ] ASF GitHub Bot commented on FLINK-4571: --- 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: http://ci.apache.org/p

[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: http://ci.apache.org/p

[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. I

[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&focusedCommentId=15468416#comment-15468416 ] ASF GitHub Bot commented on FLINK-4585: --- Github user apivovarov commented on the iss

[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: http://ci.apache.org/p

[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) >

[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 secr

[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&focusedCommentId=15468482#comment-15468482 ] ASF GitHub Bot commented on FLINK-3930: --- Github user rmetzger commented on the issue

[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 getTyp

[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&focusedCommentId=15468507#comment-15468507 ] ASF GitHub Bot commented on FLINK-3042: --- Github user greghogan commented on a diff i

[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&focusedCommentId=15468506#comment-15468506 ] Ivan Mushketyk commented on FLINK-2254: --- Hi Greg. Thank you for your comment. Could

[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&focusedCommentId=15468520#comment-15468520 ] Robert Metzger commented on FLINK-3427: --- Afaik there is already a gauge for getting

[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: http://ci.apache.org/p

[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&focusedCommentId=15468531#comment-15468531 ] Robert Metzger commented on FLINK-3427: --- [~ivan.mushketyk] did you already start wor

[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&focusedCommentId=15468538#comment-15468538 ] Ivan Mushketyk commented on FLINK-3427: --- [~rmetzger], I not half-way through the tas

[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&focusedCommentId=15468557#comment-15468557 ] Ivan Mushketyk commented on FLINK-3709: --- [~rmetzger] I could work on it, but I wonde

[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&focusedCommentId=15468585#comment-15468585 ] ASF GitHub Bot commented on FLINK-3930: --- Github user vijikarthi commented on the iss

[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] [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

[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 Averag

[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&focusedCommentId=15468721#comment-15468721 ] Ivan Mushketyk commented on FLINK-4410: --- Hi [~uce]. Just to make sure that I unders

  1   2   >