[jira] [Updated] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8915: Labels: flip6 (was: ) > CheckpointingStatisticsHandler fails to return PendingCheckpointStats >

[jira] [Commented] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct agg on DataStream

[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394404#comment-16394404 ] Hequn Cheng commented on FLINK-8690: Looks good for the rule changes :D > Update logical rule set to

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394403#comment-16394403 ] ASF GitHub Bot commented on FLINK-8689: --- Github user hequn8128 commented on a diff in the pull

[jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView

[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394402#comment-16394402 ] ASF GitHub Bot commented on FLINK-8689: --- Github user hequn8128 commented on a diff in the pull

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r173644059 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/DistinctAccumulator.scala --- @@ -0,0 +1,102 @@

[GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct...

Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/#discussion_r173644062 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1439,7 +1467,47 @@ object

[jira] [Commented] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct agg on DataStream

[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394379#comment-16394379 ] Rong Rong commented on FLINK-8690: -- Thanks [~hequn8128] for the valuable feedback :-) I did some research

[jira] [Assigned] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface

[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-5095: --- Assignee: (was: Bowen Li) > Add explicit notifyOfAddedX methods to MetricReporter interface >

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

[ https://issues.apache.org/jira/browse/FLINK-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394377#comment-16394377 ] Rong Rong commented on FLINK-7144: -- Hi [~jark], I am working on FLINK-8688 and I think I can use the fix

[jira] [Created] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

Gary Yao created FLINK-8915: --- Summary: CheckpointingStatisticsHandler fails to return PendingCheckpointStats Key: FLINK-8915 URL: https://issues.apache.org/jira/browse/FLINK-8915 Project: Flink

[jira] [Commented] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

[ https://issues.apache.org/jira/browse/FLINK-8904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394268#comment-16394268 ] ASF GitHub Bot commented on FLINK-8904: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5670: [FLINK-8904][cli][tests] always restore the previo...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5670#discussion_r173627882 --- Diff: flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendTestUtils.java --- @@ -65,9 +67,14 @@ public static String

[jira] [Updated] (FLINK-8771) Upgrade scalastyle to 1.0.0

[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8771: -- Description: scalastyle 1.0.0 fixes issue with import order, explicit type for public methods, line length

[jira] [Commented] (FLINK-8914) CEP's greedy() modifier doesn't work

[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394222#comment-16394222 ] David Anderson commented on FLINK-8914: --- This bug was also reported on Stackoverflow:

[jira] [Created] (FLINK-8914) CEP's greedy() modifier doesn't work

David Anderson created FLINK-8914: - Summary: CEP's greedy() modifier doesn't work Key: FLINK-8914 URL: https://issues.apache.org/jira/browse/FLINK-8914 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8800) Set Logging to TRACE for org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler

[ https://issues.apache.org/jira/browse/FLINK-8800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394145#comment-16394145 ] ASF GitHub Bot commented on FLINK-8800: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-8847) Modules containing package-info.java are always recompiled

[ https://issues.apache.org/jira/browse/FLINK-8847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8847. --- Resolution: Fixed master: 870ff31a944da5eba2c228f4529a26b6ff1d6846 1.5:

[jira] [Commented] (FLINK-8847) Modules containing package-info.java are always recompiled

[ https://issues.apache.org/jira/browse/FLINK-8847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394146#comment-16394146 ] ASF GitHub Bot commented on FLINK-8847: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5594: [FLINK-8800][REST] Reduce logging of all requests ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5594 ---

[GitHub] flink pull request #5644: [FLINK-8847][build] Prevent unnecessary recompilat...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5644 ---

[jira] [Closed] (FLINK-8800) Set Logging to TRACE for org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler

[ https://issues.apache.org/jira/browse/FLINK-8800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8800. --- Resolution: Fixed Fix Version/s: (was: 1.6.0) master:

[GitHub] flink issue #5613: [FLINK-8274] [table] Split generated methods for preventi...

Github user Xpray commented on the issue: https://github.com/apache/flink/pull/5613 @twalthr I'm fine with this PR. Best ---

[jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

[ https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394133#comment-16394133 ] ASF GitHub Bot commented on FLINK-8274: --- Github user Xpray commented on the issue:

[GitHub] flink issue #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAPI

Github user suez1224 commented on the issue: https://github.com/apache/flink/pull/5638 The PR looks good. Could you please add documentation in docs/dev/table/tableApi.md for both java and scala? Thanks. ---

[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394110#comment-16394110 ] ASF GitHub Bot commented on FLINK-6924: --- Github user suez1224 commented on the issue: