[GitHub] flink pull request:

Github user zentol commented on the pull request: https://github.com/apache/flink/commit/707606ac40dbbbd497fcbbb5442870fec5468bf3#commitcomment-17574494 In flink-core/src/main/java/org/apache/flink/metrics/groups/JobMetricGroup.java: In flink-core/src/main/java/org/apache/flink/m

[jira] [Commented] (FLINK-3939) Prevent distinct aggregates and grouping sets from being translated

[ https://issues.apache.org/jira/browse/FLINK-3939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295814#comment-15295814 ] ASF GitHub Bot commented on FLINK-3939: --- Github user yjshen commented on a diff in t

[GitHub] flink pull request: [FLINK-3939] [tableAPI] Prevent translation of...

Github user yjshen commented on a diff in the pull request: https://github.com/apache/flink/pull/2014#discussion_r64160758 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetAggregateRule.scala --- @@ -33,20 +33,32 @@ class Da

[jira] [Commented] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value

[ https://issues.apache.org/jira/browse/FLINK-3586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295804#comment-15295804 ] Chengxiang Li commented on FLINK-3586: -- Not at all, feel free to take over it, Fabian

[jira] [Created] (FLINK-3952) Bump Netty to 4.1

rektide de la fey created FLINK-3952: Summary: Bump Netty to 4.1 Key: FLINK-3952 URL: https://issues.apache.org/jira/browse/FLINK-3952 Project: Flink Issue Type: Improvement Com

[jira] [Updated] (FLINK-3952) Bump Netty to 4.1

[ https://issues.apache.org/jira/browse/FLINK-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rektide de la fey updated FLINK-3952: - Description: Netty 4.1 is about to release final. This release has [a number of significan

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295698#comment-15295698 ] Gabor Gevay commented on FLINK-3702: This turned out to be more complicated than I tho

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

[ https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295688#comment-15295688 ] Stephan Ewen commented on FLINK-3660: - I would break this into two tasks: - measure

[jira] [Created] (FLINK-3951) Add Histogram Metric Type

Stephan Ewen created FLINK-3951: --- Summary: Add Histogram Metric Type Key: FLINK-3951 URL: https://issues.apache.org/jira/browse/FLINK-3951 Project: Flink Issue Type: Sub-task Componen

[jira] [Created] (FLINK-3950) Add Meter Metric Type

Stephan Ewen created FLINK-3950: --- Summary: Add Meter Metric Type Key: FLINK-3950 URL: https://issues.apache.org/jira/browse/FLINK-3950 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-3949) Collect Metrics in Runtime Operators

Stephan Ewen created FLINK-3949: --- Summary: Collect Metrics in Runtime Operators Key: FLINK-3949 URL: https://issues.apache.org/jira/browse/FLINK-3949 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1502. --- > Expose metrics to graphite, ganglia and JMX. > > >

[jira] [Resolved] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1502. - Resolution: Fixed Fix Version/s: (was: pre-apache) 1.1.0 Fixed via 0

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295685#comment-15295685 ] ASF GitHub Bot commented on FLINK-1502: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1502] [WIP] Basic Metric System

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1947#issuecomment-220850557 I did a pass over the code and committed the result: Manually merged in 003ce18efc0249fae874e56c3df6acf19f5f2429 and 707606ac40dbbbd497fcbbb5442870fec5468bf3

[jira] [Assigned] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-3702: -- Assignee: Gabor Gevay > DataStream API PojoFieldAccessor doesn't support nested POJOs > ---

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295621#comment-15295621 ] Gabor Gevay commented on FLINK-3702: I'll try to quickly do it now. > DataStream API

[GitHub] flink pull request: [FLINK-3728] [tableAPI] Improve error message ...

GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/2018 [FLINK-3728] [tableAPI] Improve error message and documentation for unsupported SQL features. This PR 1. extends the Table API / SQL documentation and lists known limitations. 2. impro

[jira] [Commented] (FLINK-3728) Throw meaningful exceptions for unsupported SQL features

[ https://issues.apache.org/jira/browse/FLINK-3728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295608#comment-15295608 ] ASF GitHub Bot commented on FLINK-3728: --- GitHub user fhueske opened a pull request:

[jira] [Assigned] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value

[ https://issues.apache.org/jira/browse/FLINK-3586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-3586: Assignee: Fabian Hueske (was: Chengxiang Li) > Risk of data overflow while use sum/count t

[jira] [Commented] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value

[ https://issues.apache.org/jira/browse/FLINK-3586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295591#comment-15295591 ] Fabian Hueske commented on FLINK-3586: -- I have a fix for this issue and would like to

[jira] [Commented] (FLINK-2673) Scala API does not support Option type as key

[ https://issues.apache.org/jira/browse/FLINK-2673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295571#comment-15295571 ] ASF GitHub Bot commented on FLINK-2673: --- Github user chiwanpark commented on the pul

[GitHub] flink pull request: [FLINK-2673] [type system] Add a comparator fo...

Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/2017#issuecomment-220833561 Failing Travis is not related to this PR. --- 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 proj

[jira] [Assigned] (FLINK-3936) Add MIN / MAX aggregations function for BOOLEAN types

[ https://issues.apache.org/jira/browse/FLINK-3936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-3936: Assignee: Fabian Hueske > Add MIN / MAX aggregations function for BOOLEAN types > -

[jira] [Assigned] (FLINK-3728) Throw meaningful exceptions for unsupported SQL features

[ https://issues.apache.org/jira/browse/FLINK-3728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-3728: Assignee: Fabian Hueske > Throw meaningful exceptions for unsupported SQL features > --

[GitHub] flink pull request: [FLINK-3632][TableAPI]Clean up Table API excep...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/2015#issuecomment-220829100 Thanks for the PR @yjshen. The changes look good. +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-3632) Clean up Table API exceptions

[ https://issues.apache.org/jira/browse/FLINK-3632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295539#comment-15295539 ] ASF GitHub Bot commented on FLINK-3632: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-2673) Scala API does not support Option type as key

[ https://issues.apache.org/jira/browse/FLINK-2673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295526#comment-15295526 ] ASF GitHub Bot commented on FLINK-2673: --- GitHub user chiwanpark opened a pull reques

[GitHub] flink pull request: [FLINK-2673] [type system] Add a comparator fo...

GitHub user chiwanpark opened a pull request: https://github.com/apache/flink/pull/2017 [FLINK-2673] [type system] Add a comparator for Scala Option type Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considerati

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15295502#comment-15295502 ] Rami commented on FLINK-3702: - This feature would really make a difference in our code. most o