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

2017-07-10 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081702#comment-16081702 ] mingleizhang commented on FLINK-6378: - Why are we going to remove akka dependency ? > Implement

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081665#comment-16081665 ] Steven Zhen Wu commented on FLINK-7143: --- I see. change is for support of multiple topics. hashCode()

[jira] [Comment Edited] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081420#comment-16081420 ] Steven Zhen Wu edited comment on FLINK-7143 at 7/11/17 4:51 AM: regarding

[jira] [Commented] (FLINK-7126) Support Distinct for Stream SQL and Table API

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081615#comment-16081615 ] ASF GitHub Bot commented on FLINK-7126: --- Github user wuchong commented on a diff in the pull

[GitHub] flink pull request #4279: [FLINK-7126] [table] Support Distinct for Stream S...

2017-07-10 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4279#discussion_r126589762 --- Diff: docs/dev/table/tableApi.md --- @@ -373,7 +373,7 @@ Table result = orders Distinct -Batch +

[GitHub] flink pull request #4279: [FLINK-7126] [table] Support Distinct for Stream S...

2017-07-10 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4279#discussion_r126589666 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/AggregationsTest.scala --- @@ -39,4 +40,42 @@ class

[jira] [Created] (FLINK-7144) Optimize multiple LogicalAggregate into one

2017-07-10 Thread Jark Wu (JIRA)
Jark Wu created FLINK-7144: -- Summary: Optimize multiple LogicalAggregate into one Key: FLINK-7144 URL: https://issues.apache.org/jira/browse/FLINK-7144 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

2017-07-10 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081588#comment-16081588 ] Dian Fu commented on FLINK-6429: Hi [~twalthr], could I know what's the progress of this ticket as

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081474#comment-16081474 ] Tzu-Li (Gordon) Tai commented on FLINK-7143: [~henryz] yes. One small correction, it would

[jira] [Comment Edited] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081474#comment-16081474 ] Tzu-Li (Gordon) Tai edited comment on FLINK-7143 at 7/11/17 1:28 AM: -

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081420#comment-16081420 ] Steven Zhen Wu commented on FLINK-7143: --- regarding test coverage, we need a test that verify the

[GitHub] flink pull request #4150: [FLINK-6951] Incompatible versions of httpcomponen...

2017-07-10 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4150#discussion_r126511039 --- Diff: flink-connectors/flink-connector-kinesis/pom.xml --- @@ -36,6 +36,8 @@ under the License. 1.10.71 1.6.2

[jira] [Updated] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-7143: -- Description: while deploying Flink 1.3 release to hundreds of routing jobs, we found some

[jira] [Updated] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-7143: -- Description: while deploying Flink 1.3 release to hundreds of routing jobs, we found some

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081386#comment-16081386 ] Tzu-Li (Gordon) Tai commented on FLINK-7143: IIRC, sorting the fetched partition list was

[jira] [Updated] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-7143: -- Description: while deploying Flink 1.3 release to hundreds of routing jobs, we found some

[jira] [Comment Edited] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081386#comment-16081386 ] Tzu-Li (Gordon) Tai edited comment on FLINK-7143 at 7/11/17 12:03 AM: --

[jira] [Comment Edited] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081386#comment-16081386 ] Tzu-Li (Gordon) Tai edited comment on FLINK-7143 at 7/11/17 12:03 AM: --

[jira] [Assigned] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7143: -- Assignee: Tzu-Li (Gordon) Tai > Partition assignment for Kafka consumer is not

[jira] [Updated] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7143: --- Fix Version/s: 1.3.2 > Partition assignment for Kafka consumer is not stable >

[GitHub] flink issue #4099: [FLINK-6882] [runtime] Activate checkstyle for runtime/re...

2017-07-10 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4099 @zentol not sure if this was overlooked. I have rebased to master, is there anyone you think we should check with before including this package? --- If your project is set up for it, you can

[jira] [Updated] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-7143: -- Description: while deploying Flink 1.3 release to hundreds of routing jobs, we found some

[jira] [Updated] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-7143: -- Description: while deploying Flink 1.3 release to hundreds of routing jobs, we found some

[jira] [Updated] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-7143: -- Description: while deploying Flink 1.3 release to hundreds of routing jobs, we found some

[jira] [Commented] (FLINK-6698) Activate strict checkstyle

2017-07-10 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081336#comment-16081336 ] Greg Hogan commented on FLINK-6698: --- [~Zentol] what is the best strategy for continuing the checkstyle

[jira] [Created] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-7143: - Summary: Partition assignment for Kafka consumer is not stable Key: FLINK-7143 URL: https://issues.apache.org/jira/browse/FLINK-7143 Project: Flink Issue

[jira] [Updated] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-7143: -- Description: while deploying Flink 1.3 release to hundreds of routing jobs, we found some

[jira] [Commented] (FLINK-6882) Activate checkstyle for runtime/registration

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081320#comment-16081320 ] ASF GitHub Bot commented on FLINK-6882: --- Github user greghogan commented on the issue:

[jira] [Updated] (FLINK-7143) Partition assignment for Kafka consumer is not stable

2017-07-10 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-7143: -- Description: while deploying Flink 1.3 release to hundreds of routing jobs, we found some

[jira] [Commented] (FLINK-6731) Activate strict checkstyle for flink-tests

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081302#comment-16081302 ] ASF GitHub Bot commented on FLINK-6731: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #4295: [FLINK-6731] [tests] Activate strict checkstyle fo...

2017-07-10 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/4295 [FLINK-6731] [tests] Activate strict checkstyle for flink-tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink

[GitHub] flink pull request #4279: [FLINK-7126] [table] Support Distinct for Stream S...

2017-07-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4279#discussion_r126534907 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/AggregationsTest.scala --- @@ -39,4 +40,42 @@ class

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r126541801 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[jira] [Commented] (FLINK-7126) Support Distinct for Stream SQL and Table API

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

[jira] [Commented] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations

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

[GitHub] flink pull request #4279: [FLINK-7126] [table] Support Distinct for Stream S...

2017-07-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4279#discussion_r126535807 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala --- @@ -38,6 +38,43 @@

[GitHub] flink pull request #3783: [FLINK-6388] Add support for DISTINCT into Code Ge...

2017-07-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3783#discussion_r126536553 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -296,6 +299,39 @@ class CodeGenerator(

[jira] [Commented] (FLINK-7126) Support Distinct for Stream SQL and Table API

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

[jira] [Commented] (FLINK-7126) Support Distinct for Stream SQL and Table API

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

[jira] [Commented] (FLINK-7126) Support Distinct for Stream SQL and Table API

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

[GitHub] flink pull request #4279: [FLINK-7126] [table] Support Distinct for Stream S...

2017-07-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4279#discussion_r126534385 --- Diff: docs/dev/table/tableApi.md --- @@ -373,7 +373,7 @@ Table result = orders Distinct -Batch +

[GitHub] flink pull request #4279: [FLINK-7126] [table] Support Distinct for Stream S...

2017-07-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4279#discussion_r126532548 --- Diff: docs/dev/table/sql.md --- @@ -284,7 +284,7 @@ FROM Orders Distinct -Batch +Batch

[GitHub] flink issue #4293: [FLINK-7141][build] enable travis cache again

2017-07-10 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4293 Seems like this ain't working for a Pull Request. I also checked your local builds (https://travis-ci.org/NicoK/flink/builds/251943625 & https://travis-ci.org/NicoK/flink/builds/252022358) but it'

[jira] [Commented] (FLINK-7141) enable travis cache again

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

[GitHub] flink issue #3511: [Flink-5734] code generation for normalizedkey sorter

2017-07-10 Thread heytitle
Github user heytitle commented on the issue: https://github.com/apache/flink/pull/3511 Hi @greghogan, Thank very much for the feedback. > Are you able to continue working on this feature? Yes, I would like to complete the feature and will take a look into

[jira] [Assigned] (FLINK-2170) Add OrcTableSource

2017-07-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2170: Assignee: Usman Younas (was: Owen O'Malley) > Add OrcTableSource > -- > >

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080898#comment-16080898 ] ASF GitHub Bot commented on FLINK-6951: --- Github user bowenli86 commented on a diff in the pull

[jira] [Commented] (FLINK-7127) Remove unnecessary null check or add null check

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080879#comment-16080879 ] ASF GitHub Bot commented on FLINK-7127: --- GitHub user mylog00 opened a pull request:

[GitHub] flink issue #4150: [FLINK-6951] Incompatible versions of httpcomponents jars...

2017-07-10 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4150 @tzulitai @tedyu Hi guys, I'm also wondering how much percentage of Flink users are using Flink with Kinesis? Kinesis has so many limitations that we are considering to move from Kinesis

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080911#comment-16080911 ] ASF GitHub Bot commented on FLINK-6951: --- Github user bowenli86 commented on the issue:

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080907#comment-16080907 ] ASF GitHub Bot commented on FLINK-6951: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink pull request #4150: [FLINK-6951] Incompatible versions of httpcomponen...

2017-07-10 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4150#discussion_r126509865 --- Diff: docs/setup/aws.md --- @@ -224,8 +224,6 @@ Depending on which file system you use, please add the following dependencies. Y -

[GitHub] flink pull request #4294: [FLINK-7127] [runtime] Remove unnecessary null che...

2017-07-10 Thread mylog00
GitHub user mylog00 opened a pull request: https://github.com/apache/flink/pull/4294 [FLINK-7127] [runtime] Remove unnecessary null check or add null check; Hi. To avoid NPE I decided add null check instead remove it one. You can merge this pull request into a Git repository by

[GitHub] flink pull request #4136: [FLINK-6940][docs] Clarify the effect of configuri...

2017-07-10 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4136#discussion_r126503269 --- Diff: docs/ops/state_backends.md --- @@ -123,8 +123,7 @@ RocksDBStateBackend is currently the only backend that offers incremental checkp

[jira] [Commented] (FLINK-6940) Clarify the effect of configuring per-job state backend

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080832#comment-16080832 ] ASF GitHub Bot commented on FLINK-6940: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink issue #4183: [FLINK-6969][table]Add support for deferred computation f...

2017-07-10 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4183 Yes, @fhueske you are right, we must define watermark for each table. And I was trying to consider the semantics of Flink configs, including (FLINK-6649, FLINK-6962, FLINK-6969 etc), I was

[jira] [Commented] (FLINK-6969) Add support for deferred computation for group window aggregates

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

[GitHub] flink issue #3511: [Flink-5734] code generation for normalizedkey sorter

2017-07-10 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3511 @heytitle apologies for the long delay. I've been working to improve the Gelly examples to process with each of the standard data types (from byte to string). I think we can validate both the

[jira] [Commented] (FLINK-2170) Add OrcTableSource

2017-07-10 Thread Usman Younas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080656#comment-16080656 ] Usman Younas commented on FLINK-2170: - Hi [~fhueske] I'd like to work on OrcTableSource and will

[jira] [Created] (FLINK-7142) Scala DataSet API ignores ResultTypeQueryable interface

2017-07-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7142: Summary: Scala DataSet API ignores ResultTypeQueryable interface Key: FLINK-7142 URL: https://issues.apache.org/jira/browse/FLINK-7142 Project: Flink Issue

[jira] [Assigned] (FLINK-7050) RFC Compliant CSV Parser for Table Source

2017-07-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7050: Assignee: Usman Younas > RFC Compliant CSV Parser for Table Source >

[jira] [Commented] (FLINK-6901) Flip checkstyle configuration files

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080548#comment-16080548 ] ASF GitHub Bot commented on FLINK-6901: --- Github user uce commented on a diff in the pull request:

[GitHub] flink pull request #4112: [FLINK-6901] Flip checkstyle configuration files

2017-07-10 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/4112#discussion_r126464199 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyBufferPool.java --- @@ -61,7 +60,9 @@ public NettyBufferPool(int

[jira] [Updated] (FLINK-6358) Write job details for Gelly examples

2017-07-10 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6358: -- Fix Version/s: 1.4.0 > Write job details for Gelly examples > > >

[jira] [Commented] (FLINK-5253) Remove special treatment of "dynamic properties"

2017-07-10 Thread Mariusz Wojakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080495#comment-16080495 ] Mariusz Wojakowski commented on FLINK-5253: --- Thanks for the comments! I'll take a look and

[jira] [Commented] (FLINK-6357) ParameterTool get unrequested parameters

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

[GitHub] flink pull request #4169: [FLINK-6357] [java] ParameterTool get unrequested ...

2017-07-10 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/4169#discussion_r126452583 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java --- @@ -278,6 +518,26 @@ public void testUnrequestedRequired()

[jira] [Commented] (FLINK-6901) Flip checkstyle configuration files

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080483#comment-16080483 ] ASF GitHub Bot commented on FLINK-6901: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4112: [FLINK-6901] Flip checkstyle configuration files

2017-07-10 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4112#discussion_r126451783 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyBufferPool.java --- @@ -61,7 +60,9 @@ public NettyBufferPool(int

[GitHub] flink pull request #4169: [FLINK-6357] [java] ParameterTool get unrequested ...

2017-07-10 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/4169#discussion_r126450338 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java --- @@ -174,9 +210,38 @@ public void testUnrequestedByte() {

[jira] [Commented] (FLINK-6357) ParameterTool get unrequested parameters

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

[GitHub] flink pull request #4110: [FLINK-6900] [metrics] Limit size of metric name c...

2017-07-10 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4110#discussion_r126443494 --- Diff: flink-metrics/flink-metrics-statsd/src/main/java/org/apache/flink/metrics/statsd/StatsDReporter.java --- @@ -193,7 +198,10 @@ private void

[jira] [Commented] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080447#comment-16080447 ] ASF GitHub Bot commented on FLINK-6900: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

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

[jira] [Closed] (FLINK-7063) test instability in OperatorStateBackendTest.testSnapshotAsyncCancel

2017-07-10 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-7063. - Resolution: Fixed Fixed in 74adb84742. > test instability in

[GitHub] flink pull request #4110: [FLINK-6900] [metrics] Limit size of metric name c...

2017-07-10 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/4110#discussion_r126446702 --- Diff: docs/monitoring/metrics.md --- @@ -376,6 +376,7 @@ Parameters: - `dmax` - hard limit for how long an old metric should be retained -

[jira] [Commented] (FLINK-7063) test instability in OperatorStateBackendTest.testSnapshotAsyncCancel

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080427#comment-16080427 ] ASF GitHub Bot commented on FLINK-7063: --- Github user StefanRRichter closed the pull request at:

[jira] [Commented] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080449#comment-16080449 ] ASF GitHub Bot commented on FLINK-6900: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080448#comment-16080448 ] ASF GitHub Bot commented on FLINK-6900: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4110: [FLINK-6900] [metrics] Limit size of metric name c...

2017-07-10 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4110#discussion_r126442516 --- Diff: flink-metrics/flink-metrics-dropwizard/src/main/java/org/apache/flink/dropwizard/ScheduledDropwizardReporter.java --- @@ -184,7 +188,10 @@ public

[GitHub] flink pull request #4110: [FLINK-6900] [metrics] Limit size of metric name c...

2017-07-10 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4110#discussion_r126443486 --- Diff: flink-metrics/flink-metrics-statsd/src/test/java/org/apache/flink/metrics/statsd/StatsDReporterTest.java --- @@ -60,6 +60,20 @@ public class

[GitHub] flink issue #4183: [FLINK-6969][table]Add support for deferred computation f...

2017-07-10 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4183 I think support for watermark configuration in a DDL statement is a nice feature but not a replacement for this parameter. I am thinking of a use case where streaming tables are registered

[jira] [Commented] (FLINK-7063) test instability in OperatorStateBackendTest.testSnapshotAsyncCancel

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080413#comment-16080413 ] ASF GitHub Bot commented on FLINK-7063: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-6969) Add support for deferred computation for group window aggregates

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080429#comment-16080429 ] ASF GitHub Bot commented on FLINK-6969: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4246: [FLINK-7063] [checkpoint] Call super.cancel(...) before c...

2017-07-10 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4246 Thanks for the review @NicoK ! Merged in 74adb84742. --- 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

[GitHub] flink pull request #4246: [FLINK-7063] [checkpoint] Call super.cancel(...) b...

2017-07-10 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/4246 --- 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

[jira] [Commented] (FLINK-7063) test instability in OperatorStateBackendTest.testSnapshotAsyncCancel

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080426#comment-16080426 ] ASF GitHub Bot commented on FLINK-7063: --- Github user StefanRRichter commented on the issue:

[GitHub] flink pull request #4246: [FLINK-7063] [checkpoint] Call super.cancel(...) b...

2017-07-10 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4246#discussion_r126437776 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/async/AsyncStoppableTaskWithCallback.java --- @@ -21,6 +21,7 @@ import

[jira] [Commented] (FLINK-7141) enable travis cache again

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080394#comment-16080394 ] ASF GitHub Bot commented on FLINK-7141: --- Github user NicoK commented on the issue:

[GitHub] flink issue #4293: [FLINK-7141][build] enable travis cache again

2017-07-10 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4293 that's actually hard to know in advance - I had only 3 builds that went under the limit by chance so I was able to use the cache henceforth in those three which constantly were below the 49min. This

[GitHub] flink pull request #4256: [FLINK-6747] [docs] Add documentation for QueryCon...

2017-07-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4256 --- 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 pull request #4136: [FLINK-6940][docs] Clarify the effect of configuri...

2017-07-10 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4136#discussion_r126431179 --- Diff: docs/ops/state_backends.md --- @@ -123,8 +123,7 @@ RocksDBStateBackend is currently the only backend that offers incremental checkp

[jira] [Commented] (FLINK-6747) Table API / SQL Docs: Streaming Page

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

[jira] [Commented] (FLINK-6747) Table API / SQL Docs: Streaming Page

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080355#comment-16080355 ] ASF GitHub Bot commented on FLINK-6747: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4256: [FLINK-6747] [docs] Add documentation for QueryConfig.

2017-07-10 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4256 Thanks for the review @sunjincheng121! I addressed your points and will merge the PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-6940) Clarify the effect of configuring per-job state backend

2017-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080363#comment-16080363 ] ASF GitHub Bot commented on FLINK-6940: --- Github user alpinegizmo commented on a diff in the pull

[GitHub] flink issue #4293: [FLINK-7141][build] enable travis cache again

2017-07-10 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4293 Forks also benefit from this. It would be cool if we knew how much this affects the build times given that we're also adding more work (for the scanning of the cache). Note that the

[jira] [Commented] (FLINK-7141) enable travis cache again

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

[GitHub] flink issue #4158: [FLINK-7052][blob] remove (unused) NAME_ADDRESSABLE mode

2017-07-10 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4158 +1 to merge. --- 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

  1   2   >