[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=16045679#comment-16045679 ] ASF GitHub Bot commented on FLINK-6884: --- Github user fhueske commented on a diff in the pull

[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=16045680#comment-16045680 ] ASF GitHub Bot commented on FLINK-6884: --- Github user fhueske commented on a diff in the pull

[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

[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-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=16045668#comment-16045668 ] Fabian Hueske commented on FLINK-5776: -- Thanks [~sunjincheng121]. Can you close the PR #3418 as well?

[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=16045652#comment-16045652 ] ASF GitHub Bot commented on FLINK-6877: --- Github user hsaputra 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

[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=16045626#comment-16045626 ] ASF GitHub Bot commented on FLINK-3551: --- Github user ch33hau commented on the issue:

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

[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=16045587#comment-16045587 ] sunjincheng edited comment on FLINK-6884 at 6/10/17 4:58 PM: - Hi, [~dawidwys]

[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=16045612#comment-16045612 ] ASF GitHub Bot commented on FLINK-6884: --- GitHub user sunjincheng121 opened a pull request:

[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

[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=16045608#comment-16045608 ] sunjincheng commented on FLINK-6884: The {{generateResultExpression}} is called by

[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=16045587#comment-16045587 ] sunjincheng edited comment on FLINK-6884 at 6/10/17 3:55 PM: - Hi, [~dawidwys]

[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

[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=16045587#comment-16045587 ] sunjincheng commented on FLINK-6884: Hi, [~dawidwys] Thanks for your reporting. you are right, we can

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

[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

[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=16045521#comment-16045521 ] ASF GitHub Bot commented on FLINK-6876: --- Github user sunjincheng121 commented on the issue:

[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=16045498#comment-16045498 ] mingleizhang edited comment on FLINK-6849 at 6/10/17 11:55 AM: --- Here is a

[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=16045498#comment-16045498 ] mingleizhang commented on FLINK-6849: - Here is a basic skeleton for the abstract class

[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=16045494#comment-16045494 ] mingleizhang commented on FLINK-6488: - Hey [~Zentol]! I have updated the PR. > Mark deprecated for

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

[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=16045475#comment-16045475 ] mingleizhang edited comment on FLINK-6849 at 6/10/17 9:49 AM: -- [~tzulitai]

[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=16045475#comment-16045475 ] mingleizhang edited comment on FLINK-6849 at 6/10/17 9:48 AM: -- [~tzulitai]

[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=16045475#comment-16045475 ] mingleizhang commented on FLINK-6849: - [~tzulitai] [~srichter] I just do a little refactor for the

[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=16045462#comment-16045462 ] ASF GitHub Bot commented on FLINK-6877: --- Github user zentol commented on the issue:

[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

[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=16045459#comment-16045459 ] mingleizhang commented on FLINK-6849: - Yep. [~srichter]. We should have a concrete plan refactor

[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=16045431#comment-16045431 ] Hai Zhou commented on FLINK-6860: - [~mingmxu] , the website code is at