[jira] [Commented] (FLINK-6860) update Apache Beam in page Ecosystem

2017-06-10 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045431#comment-16045431 ] Hai Zhou commented on FLINK-6860: - [~mingmxu] , the website code is at https://github.com

[jira] [Commented] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

2017-06-10 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045459#comment-16045459 ] mingleizhang commented on FLINK-6849: - Yep. [~srichter]. We should have a concrete pla

[GitHub] flink issue #4095: [FLINK-6877] [runtime] Activate checkstyle for runtime/se...

2017-06-10 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4095 Please don't merge this or any other runtime related checkstyle PR's over the weekend. I'm gonna have a chat with @StephanEwen early next week about which packages we can cover with checkstyle without

[jira] [Commented] (FLINK-6877) Activate checkstyle for runtime/security

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

[jira] [Commented] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

2017-06-10 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045475#comment-16045475 ] mingleizhang commented on FLINK-6849: - [~tzulitai] [~srichter] I just do a little refa

[jira] [Comment Edited] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

2017-06-10 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045475#comment-16045475 ] mingleizhang edited comment on FLINK-6849 at 6/10/17 9:49 AM: --

[jira] [Comment Edited] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

2017-06-10 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045475#comment-16045475 ] mingleizhang edited comment on FLINK-6849 at 6/10/17 9:48 AM: --

[jira] [Created] (FLINK-6883) Serializer for collection of Scala case classes are generated with different anonymous class names in 1.3

2017-06-10 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6883: -- Summary: Serializer for collection of Scala case classes are generated with different anonymous class names in 1.3 Key: FLINK-6883 URL: https://issues.apache.org/jira/

[jira] [Updated] (FLINK-6883) Serializer for collection of Scala case classes are generated with different anonymous class names in 1.3

2017-06-10 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6883: --- Description: In the Scala API, serializers are generated using Scala macros (via the

[jira] [Commented] (FLINK-6488) Mark deprecated for 'start-local.sh' script

2017-06-10 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045494#comment-16045494 ] mingleizhang commented on FLINK-6488: - Hey [~Zentol]! I have updated the PR. > Mark

[jira] [Commented] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

2017-06-10 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045498#comment-16045498 ] mingleizhang commented on FLINK-6849: - Here is a basic skeleton for the abstract class

[jira] [Comment Edited] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

2017-06-10 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045498#comment-16045498 ] mingleizhang edited comment on FLINK-6849 at 6/10/17 11:55 AM: -

[jira] [Commented] (FLINK-6876) The comment of DataStream#assignTimestampsAndWatermarks is incorrect

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

[GitHub] flink issue #4092: [FLINK-6876] [streaming] Correct the comments of DataStre...

2017-06-10 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4092 Good catch! The comment same as `DataStream.java`. +1 to merged. --- 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 pro

[jira] [Created] (FLINK-6884) Incompatible TableSource#getReturnType and actual input type should fail faster

2017-06-10 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-6884: --- Summary: Incompatible TableSource#getReturnType and actual input type should fail faster Key: FLINK-6884 URL: https://issues.apache.org/jira/browse/FLINK-6884 P

[jira] [Created] (FLINK-6885) RMQSource does not support qos, leading to oom

2017-06-10 Thread Ruben van Vreeland (JIRA)
Ruben van Vreeland created FLINK-6885: - Summary: RMQSource does not support qos, leading to oom Key: FLINK-6885 URL: https://issues.apache.org/jira/browse/FLINK-6885 Project: Flink Issue

[jira] [Commented] (FLINK-6884) Incompatible TableSource#getReturnType and actual input type should fail faster

2017-06-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045587#comment-16045587 ] sunjincheng commented on FLINK-6884: Hi, [~dawidwys] Thanks for your reporting. you ar

[jira] [Assigned] (FLINK-6884) Incompatible TableSource#getReturnType and actual input type should fail faster

2017-06-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6884: -- Assignee: sunjincheng > Incompatible TableSource#getReturnType and actual input type should fai

[jira] [Comment Edited] (FLINK-6884) Incompatible TableSource#getReturnType and actual input type should fail faster

2017-06-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045587#comment-16045587 ] sunjincheng edited comment on FLINK-6884 at 6/10/17 3:55 PM: -

[jira] [Commented] (FLINK-6884) Incompatible TableSource#getReturnType and actual input type should fail faster

2017-06-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045608#comment-16045608 ] sunjincheng commented on FLINK-6884: The {{generateResultExpression}} is called by {{

[GitHub] flink pull request #4100: [FLINK-6884][table] Improve confused exception inf...

2017-06-10 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4100 [FLINK-6884][table] Improve confused exception information. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration

[jira] [Commented] (FLINK-6884) Incompatible TableSource#getReturnType and actual input type should fail faster

2017-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045612#comment-16045612 ] ASF GitHub Bot commented on FLINK-6884: --- GitHub user sunjincheng121 opened a pull re

[jira] [Comment Edited] (FLINK-6884) Incompatible TableSource#getReturnType and actual input type should fail faster

2017-06-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045587#comment-16045587 ] sunjincheng edited comment on FLINK-6884 at 6/10/17 4:58 PM: -

[GitHub] flink issue #2761: [FLINK-3551] [examples] Sync Scala Streaming Examples

2017-06-10 Thread ch33hau
Github user ch33hau commented on the issue: https://github.com/apache/flink/pull/2761 @fhueske very sorry about this decade-long delay... I was working on some relocation stuff for the past few months. I have rebased and push a commit for fixing the PR comments: - Remove

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

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

[GitHub] flink issue #4095: [FLINK-6877] [runtime] Activate checkstyle for runtime/se...

2017-06-10 Thread hsaputra
Github user hsaputra commented on the issue: https://github.com/apache/flink/pull/4095 @zentol thats just matter of rebasing to feature branches. Not sure how would you coordinate among all feature branches --- If your project is set up for it, you can reply to this email and have yo

[jira] [Commented] (FLINK-6877) Activate checkstyle for runtime/security

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

[jira] [Commented] (FLINK-5776) Improve XXMapRunner support create instance by carrying constructor parameters

2017-06-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045668#comment-16045668 ] Fabian Hueske commented on FLINK-5776: -- Thanks [~sunjincheng121]. Can you close the P

[GitHub] flink pull request #4100: [FLINK-6884][table] Improve confused exception inf...

2017-06-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4100#discussion_r121265361 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -718,16 +718,20 @@ abstract class TableEnviron

[GitHub] flink pull request #4100: [FLINK-6884][table] Improve confused exception inf...

2017-06-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4100#discussion_r121265430 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -936,32 +936,42 @@ class CodeGenerator(

[jira] [Commented] (FLINK-6884) Incompatible TableSource#getReturnType and actual input type should fail faster

2017-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045680#comment-16045680 ] ASF GitHub Bot commented on FLINK-6884: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6884) Incompatible TableSource#getReturnType and actual input type should fail faster

2017-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16045679#comment-16045679 ] ASF GitHub Bot commented on FLINK-6884: --- Github user fhueske commented on a diff in

[GitHub] flink issue #4100: [FLINK-6884][table] Improve confused exception informatio...

2017-06-10 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4100 HI @fhueske Thanks very much for your reviewing. Update the PR. according your comments. Best, SunJincheng --- If your project is set up for it, you can reply to this email and h

[jira] [Commented] (FLINK-6884) Incompatible TableSource#getReturnType and actual input type should fail faster

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

[GitHub] flink pull request #3418: [FLINK-5776][Table API & SQL]Improve XXMapRunner s...

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

[jira] [Commented] (FLINK-5776) Improve XXMapRunner support create instance by carrying constructor parameters

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