[jira] [Commented] (FLINK-6244) Emit timeouted Patterns as Side Output

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

[GitHub] flink pull request #4320: [FLINK-6244] Emit timeouted Patterns as Side Outpu...

2017-08-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4320 --- 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

[GitHub] flink issue #4320: [FLINK-6244] Emit timeouted Patterns as Side Output

2017-08-22 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4320 I will merge it then. --- 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

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137878#comment-16137878 ] ASF GitHub Bot commented on FLINK-7206: --- Github user kaibozhou commented on the issu

[GitHub] flink issue #4355: [FLINK-7206] [table] Implementation of DataView to suppor...

2017-08-22 Thread kaibozhou
Github user kaibozhou commented on the issue: https://github.com/apache/flink/pull/4355 @fhueske @wuchong Thank you for your suggestion, I have update the PR and add test case, thanks. Do you have time to look at this? Thanks, Kaibo --- If your project is set u

[jira] [Commented] (FLINK-7129) Dynamically changing patterns

2017-08-22 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137864#comment-16137864 ] Dian Fu commented on FLINK-7129: Hi [~dawidwys], I thought about the issue you mentioned f

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137860#comment-16137860 ] ASF GitHub Bot commented on FLINK-7206: --- Github user kaibozhou commented on a diff i

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-08-22 Thread kaibozhou
Github user kaibozhou commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r134653998 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1646,4 +1649,86 @@ abstract class CodeGene

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-08-22 Thread kaibozhou
Github user kaibozhou commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r134653928 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1646,4 +1649,86 @@ abstract class CodeGene

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137857#comment-16137857 ] ASF GitHub Bot commented on FLINK-7206: --- Github user kaibozhou commented on a diff i

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137854#comment-16137854 ] ASF GitHub Bot commented on FLINK-7206: --- Github user kaibozhou commented on a diff i

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-08-22 Thread kaibozhou
Github user kaibozhou commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r134653871 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1646,4 +1649,86 @@ abstract class CodeGene

[jira] [Assigned] (FLINK-6864) Remove confusing "invalid POJO type" messages from TypeExtractor

2017-08-22 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6864: Assignee: Fang Yong > Remove confusing "invalid POJO type" messages from TypeExtractor > --

[GitHub] flink issue #4574: [FLINK-6864] Fix confusing "invalid POJO type" messages f...

2017-08-22 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4574 @tzulitai I create this PR to fix [https://issues.apache.org/jira/browse/FLINK-6864](https://issues.apache.org/jira/browse/FLINK-6864), I think add logs instead of removing them will be better, what

[jira] [Commented] (FLINK-6864) Remove confusing "invalid POJO type" messages from TypeExtractor

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137830#comment-16137830 ] ASF GitHub Bot commented on FLINK-6864: --- Github user zjureel commented on the issue:

[jira] [Commented] (FLINK-6864) Remove confusing "invalid POJO type" messages from TypeExtractor

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137827#comment-16137827 ] ASF GitHub Bot commented on FLINK-6864: --- GitHub user zjureel opened a pull request:

[GitHub] flink pull request #4574: [FLINK-6864] Fix confusing "invalid POJO type" mes...

2017-08-22 Thread zjureel
GitHub user zjureel opened a pull request: https://github.com/apache/flink/pull/4574 [FLINK-6864] Fix confusing "invalid POJO type" messages from TypeExtractor ## What is the purpose of the change Fix confusing "invalid POJO type" messages from TypeExtractor ## Brie

[jira] [Commented] (FLINK-7268) Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137806#comment-16137806 ] ASF GitHub Bot commented on FLINK-7268: --- Github user tedyu commented on a diff in th

[GitHub] flink pull request #4410: [FLINK-7268] [checkpoints] Scope SharedStateRegist...

2017-08-22 Thread tedyu
Github user tedyu commented on a diff in the pull request: https://github.com/apache/flink/pull/4410#discussion_r134647310 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -1044,10 +1049,23 @@ public boolean restoreLatestC

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

2017-08-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137794#comment-16137794 ] Jark Wu commented on FLINK-7446: In the long run, we can provide a new interface called {{

[jira] [Commented] (FLINK-7402) Ineffective null check in NettyMessage#write()

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137761#comment-16137761 ] ASF GitHub Bot commented on FLINK-7402: --- Github user zjureel commented on the issue:

[GitHub] flink issue #4562: [FLINK-7402] Fix ineffective null check in NettyMessage#w...

2017-08-22 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4562 @tedyu @NicoK Than you for your suggestions, it sounds good to me, thanks --- 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 proje

[jira] [Updated] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

2017-08-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-7491: --- Component/s: Table API & SQL > Support COLLECT Aggregate function in Flink SQL > -

[jira] [Assigned] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

2017-08-22 Thread ChungChe Lai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChungChe Lai reassigned FLINK-6004: --- Assignee: ChungChe Lai > Allow FlinkKinesisConsumer to skip corrupted messages >

issues@flink.apache.org

2017-08-22 Thread Jacob Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137601#comment-16137601 ] Jacob Park commented on FLINK-7465: --- [~sunjincheng121] [~fhueske] May I recommend referr

[jira] [Assigned] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings

2017-08-22 Thread Luffy Tsai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luffy Tsai reassigned FLINK-4004: - Assignee: Luffy Tsai > Do not pass custom flink kafka connector properties to Kafka to avoid warn

issues@flink.apache.org

2017-08-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137425#comment-16137425 ] Fabian Hueske commented on FLINK-7465: -- I'm sorry, I confused count-min sketches (for

[jira] [Commented] (FLINK-6465) support FIRST_VALUE on Table API & SQL

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137422#comment-16137422 ] ASF GitHub Bot commented on FLINK-6465: --- Github user sunjincheng121 commented on the

[GitHub] flink issue #4556: [FLINK-6465][table]support FIRST_VALUE on Table API & SQL

2017-08-22 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4556 Hi @fhueske @twalthr @wuchong @shaoxuan-wang , I am appreciated if you can review the PR. Thanks, jincheng --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

2017-08-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137358#comment-16137358 ] Fabian Hueske commented on FLINK-7446: -- I agree that the watermark generation for Tab

[jira] [Commented] (FLINK-7471) Improve bounded OVER support non-retract method AGG

2017-08-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137343#comment-16137343 ] Fabian Hueske commented on FLINK-7471: -- I understand the motivation for this issue an

[jira] [Commented] (FLINK-7398) Table API operators/UDFs must not store Logger

2017-08-22 Thread Jacob Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137250#comment-16137250 ] Jacob Park commented on FLINK-7398: --- +1 for the checkstyle rule. > Table API operators/

[jira] [Commented] (FLINK-4947) Make all configuration possible via flink-conf.yaml and CLI.

2017-08-22 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137249#comment-16137249 ] Jamie Grier commented on FLINK-4947: [~gaborhermann] It's more than just that but yes

[jira] [Closed] (FLINK-7123) Support timesOrMore in CEP

2017-08-22 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7123. - Resolution: Fixed Merged with 9995588c83536e04aef3425757a008ba4c78dbde > Support timesOrMore in C

[jira] [Commented] (FLINK-7123) Support timesOrMore in CEP

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

[GitHub] flink pull request #4523: [FLINK-7123] [cep] Support timesOrMore in CEP

2017-08-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4523 --- 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] [Created] (FLINK-7493) Create Pinot Connector

2017-08-22 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-7493: Summary: Create Pinot Connector Key: FLINK-7493 URL: https://issues.apache.org/jira/browse/FLINK-7493 Project: Flink Issue Type: New Feature Repo

[jira] [Created] (FLINK-7492) Memsql Connector

2017-08-22 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-7492: Summary: Memsql Connector Key: FLINK-7492 URL: https://issues.apache.org/jira/browse/FLINK-7492 Project: Flink Issue Type: New Feature Reporter:

[jira] [Created] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

2017-08-22 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-7491: - Summary: Support COLLECT Aggregate function in Flink SQL Key: FLINK-7491 URL: https://issues.apache.org/jira/browse/FLINK-7491 Project: Flink Issue Type: New Featu

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

2017-08-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137075#comment-16137075 ] Till Rohrmann commented on FLINK-4319: -- Hi Bowen, development of Flip-6 is already u

[jira] [Assigned] (FLINK-4319) Rework Cluster Management (FLIP-6)

2017-08-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4319: Assignee: Till Rohrmann > Rework Cluster Management (FLIP-6) >

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

2017-08-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137064#comment-16137064 ] Bowen Li commented on FLINK-4319: - Hi guys, what's the schedule for this task? When are we

[jira] [Created] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader

2017-08-22 Thread Miguel Rui Pereira Marques (JIRA)
Miguel Rui Pereira Marques created FLINK-7490: - Summary: UDF Agg throws Exception when flink-table is loaded with AppClassLoader Key: FLINK-7490 URL: https://issues.apache.org/jira/browse/FLINK-7490

[jira] [Commented] (FLINK-7123) Support timesOrMore in CEP

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137030#comment-16137030 ] ASF GitHub Bot commented on FLINK-7123: --- Github user kl0u commented on the issue:

[GitHub] flink issue #4523: [FLINK-7123] [cep] Support timesOrMore in CEP

2017-08-22 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4523 LGTM, merging this --- 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 i

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134529419 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageHeaders.java --- @@ -0,0 +1,91 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134528391 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ParameterMapper.java --- @@ -0,0 +1,83 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136978#comment-16136978 ] ASF GitHub Bot commented on FLINK-7040: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134523787 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ParameterMapper.java --- @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache

[jira] [Assigned] (FLINK-6378) Implement FLIP-6 Flink-on-Mesos

2017-08-22 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright reassigned FLINK-6378: --- Assignee: Eron Wright > Implement FLIP-6 Flink-on-Mesos > --- >

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134517671 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerResponse.java --- @@ -0,0 +1,121 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134517389 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClientEndpoint.java --- @@ -0,0 +1,263 @@ +/* + * Licensed to the Apach

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136925#comment-16136925 ] ASF GitHub Bot commented on FLINK-7040: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134512942 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageHeaders.java --- @@ -0,0 +1,91 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136922#comment-16136922 ] ASF GitHub Bot commented on FLINK-7040: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134512163 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClientEndpoint.java --- @@ -0,0 +1,263 @@ +/* + * Licensed to the Apache Soft

[jira] [Updated] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment

2017-08-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4048: Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-3957) > Remove Hadoop depen

[jira] [Assigned] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment

2017-08-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-4048: --- Assignee: Aljoscha Krettek > Remove Hadoop dependencies from ExecutionEnvironment > -

[jira] [Commented] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment

2017-08-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136915#comment-16136915 ] Aljoscha Krettek commented on FLINK-4048: - I was experimenting with this as part o

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136912#comment-16136912 ] ASF GitHub Bot commented on FLINK-7040: --- Github user zentol commented on a diff in t

[jira] [Assigned] (FLINK-2268) Provide Flink binary release without Hadoop

2017-08-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2268: --- Assignee: Aljoscha Krettek > Provide Flink binary release without Hadoop > --

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134510178 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerResponse.java --- @@ -0,0 +1,121 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134507274 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClientEndpoint.java --- @@ -155,38 +129,66 @@ public void shutdown() {

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134507146 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerResponse.java --- @@ -0,0 +1,121 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134506551 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClientEndpoint.java --- @@ -0,0 +1,263 @@ +/* + * Licensed to the Apach

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136890#comment-16136890 ] ASF GitHub Bot commented on FLINK-7040: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134505729 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClientEndpoint.java --- @@ -155,38 +129,66 @@ public void shutdown() {

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136888#comment-16136888 ] ASF GitHub Bot commented on FLINK-7040: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134505357 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClientEndpoint.java --- @@ -0,0 +1,263 @@ +/* + * Licensed to the Apache Soft

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136873#comment-16136873 ] ASF GitHub Bot commented on FLINK-7040: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134502397 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerResponse.java --- @@ -0,0 +1,121 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7489) Remove job lifecycle methods from public JobMasterGateway interface

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136872#comment-16136872 ] ASF GitHub Bot commented on FLINK-7489: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #4573: [FLINK-7489] Remove startJobExecution and suspendE...

2017-08-22 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4573 [FLINK-7489] Remove startJobExecution and suspendExecution from JobMasterGateway ## What is the purpose of the change The job lifecycle methods `startJobExecution` and `suspendExecutio

[jira] [Created] (FLINK-7489) Remove job lifecycle methods from public JobMasterGateway interface

2017-08-22 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7489: Summary: Remove job lifecycle methods from public JobMasterGateway interface Key: FLINK-7489 URL: https://issues.apache.org/jira/browse/FLINK-7489 Project: Flink

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134499984 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ErrorResponseBody.java --- @@ -0,0 +1,47 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136865#comment-16136865 ] ASF GitHub Bot commented on FLINK-7040: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134499043 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ErrorResponseBody.java --- @@ -0,0 +1,47 @@ +/* + * Licensed to the Apac

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134494673 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ErrorResponseBody.java --- @@ -0,0 +1,47 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

2017-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136817#comment-16136817 ] ASF GitHub Bot commented on FLINK-7040: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134485505 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ErrorResponseBody.java --- @@ -0,0 +1,47 @@ +/* + * Licensed to the Apac

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134474815 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpointConfiguration.java --- @@ -0,0 +1,103 @@ +/* + * Licensed

[GitHub] flink pull request #4569: [FLINK-7040] [REST] Add basics for REST communicat...

2017-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4569#discussion_r134474895 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java --- @@ -0,0 +1,201 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[jira] [Closed] (FLINK-5851) Renaming AsyncCollector into ResultPromise/ResultFuture

2017-08-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5851. Resolution: Fixed Fixed via 40cec17f4303b43bbf65d8be542f0646eada57e8 > Renaming AsyncCollector into

[jira] [Updated] (FLINK-5851) Renaming AsyncCollector into ResultPromise/ResultFuture

2017-08-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5851: - Labels: api-breaking (was: ) > Renaming AsyncCollector into ResultPromise/ResultFuture >

[jira] [Reopened] (FLINK-5851) Renaming AsyncCollector into ResultPromise/ResultFuture

2017-08-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-5851: -- > Renaming AsyncCollector into ResultPromise/ResultFuture >

[jira] [Closed] (FLINK-5851) Renaming AsyncCollector into ResultPromise/ResultFuture

2017-08-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5851. Resolution: Fixed Release Note: This change is breaking the API of the AsyncFunction which is

[jira] [Commented] (FLINK-5851) Renaming AsyncCollector into ResultPromise/ResultFuture

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

[GitHub] flink pull request #4243: [FLINK-5851] [streaming API] Rename AsyncCollector...

2017-08-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4243 --- 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] [Assigned] (FLINK-5851) Renaming AsyncCollector into ResultPromise/ResultFuture

2017-08-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-5851: Assignee: mingleizhang > Renaming AsyncCollector into ResultPromise/ResultFuture >

  1   2   3   >