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

[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15978103#comment-15978103 ] Chesnay Schepler commented on FLINK-5095: - It's less maintainable. By introducing a set of generic

[jira] [Comment Edited] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977998#comment-15977998 ] mingleizhang edited comment on FLINK-6351 at 4/21/17 3:10 AM: --

[jira] [Commented] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977998#comment-15977998 ] mingleizhang commented on FLINK-6351: - [~till.rohrmann] Hi, Till. Please check it out and how do you

[jira] [Updated] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6351: Description: The currently YarnFlinkApplicationMasterRunner inherits from

[jira] [Updated] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6351: Priority: Major (was: Minor) > Refactoring YarnFlinkApplicationMasterRunner by combining >

[jira] [Created] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

mingleizhang created FLINK-6351: --- Summary: Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class Key: FLINK-6351 URL:

[jira] [Updated] (FLINK-6350) Flink: Windowing does not work with streams from collections and the local execution environment

[ https://issues.apache.org/jira/browse/FLINK-6350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6350: Component/s: Streaming > Flink: Windowing does not work with streams from collections and the local >

[jira] [Created] (FLINK-6350) Flink: Windowing does not work with streams from collections and the local execution environment

Bowen Li created FLINK-6350: --- Summary: Flink: Windowing does not work with streams from collections and the local execution environment Key: FLINK-6350 URL: https://issues.apache.org/jira/browse/FLINK-6350

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

[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977893#comment-15977893 ] Bowen Li edited comment on FLINK-5095 at 4/21/17 1:02 AM: -- What's the main

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

[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977893#comment-15977893 ] Bowen Li commented on FLINK-5095: - What's the main disadvantage of having counter, meters, and gauge

[jira] [Commented] (FLINK-6309) Memory consumer weights should be calculated in job vertex level

[ https://issues.apache.org/jira/browse/FLINK-6309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977892#comment-15977892 ] Xu Pingyong commented on FLINK-6309: Memory consumer weights should be considered not only in terms of

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

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

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

GitHub user PangZhi opened a pull request: https://github.com/apache/flink/pull/3748 [FLINK-6225] [Cassandra Connector] add CassandraTableSink This PR is to address https://issues.apache.org/jira/browse/FLINK-6225 - add Row type support for CassandraSink - add

[jira] [Created] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer

Tzu-Li (Gordon) Tai created FLINK-6349: -- Summary: Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer Key: FLINK-6349 URL: https://issues.apache.org/jira/browse/FLINK-6349

[jira] [Created] (FLINK-6348) Migrate from Java serialization for RollingSink's state

Tzu-Li (Gordon) Tai created FLINK-6348: -- Summary: Migrate from Java serialization for RollingSink's state Key: FLINK-6348 URL: https://issues.apache.org/jira/browse/FLINK-6348 Project: Flink

[jira] [Created] (FLINK-6347) Migrate from Java serialization for MessageAcknowledgingSourceBase's state

Tzu-Li (Gordon) Tai created FLINK-6347: -- Summary: Migrate from Java serialization for MessageAcknowledgingSourceBase's state Key: FLINK-6347 URL: https://issues.apache.org/jira/browse/FLINK-6347

[jira] [Created] (FLINK-6346) Migrate from Java serialization for GenericWriteAheadSink's state

Tzu-Li (Gordon) Tai created FLINK-6346: -- Summary: Migrate from Java serialization for GenericWriteAheadSink's state Key: FLINK-6346 URL: https://issues.apache.org/jira/browse/FLINK-6346 Project:

[jira] [Created] (FLINK-6345) Migrate from Java serialization for ContinuousFileReaderOperator's state

Tzu-Li (Gordon) Tai created FLINK-6345: -- Summary: Migrate from Java serialization for ContinuousFileReaderOperator's state Key: FLINK-6345 URL: https://issues.apache.org/jira/browse/FLINK-6345

[jira] [Updated] (FLINK-6344) Migrate from Java serialization for BucketingSink's state

[ https://issues.apache.org/jira/browse/FLINK-6344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6344: --- Summary: Migrate from Java serialization for BucketingSink's state (was: Migrate

[jira] [Created] (FLINK-6344) Migrate from Java serialization for `BucketingSink`'s state

Tzu-Li (Gordon) Tai created FLINK-6344: -- Summary: Migrate from Java serialization for `BucketingSink`'s state Key: FLINK-6344 URL: https://issues.apache.org/jira/browse/FLINK-6344 Project: Flink

[jira] [Updated] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

[ https://issues.apache.org/jira/browse/FLINK-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6343: --- Description: With FLINK-6324, the Java serialization shortcut for operator state is

[jira] [Updated] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

[ https://issues.apache.org/jira/browse/FLINK-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6343: --- Description: With FLINK-6324, the Java serialization shortcut for operator state is

[jira] [Created] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

Tzu-Li (Gordon) Tai created FLINK-6343: -- Summary: Migrate from discouraged Java serialization for all sources / sinks Key: FLINK-6343 URL: https://issues.apache.org/jira/browse/FLINK-6343

[jira] [Closed] (FLINK-6311) NPE in FlinkKinesisConsumer if source was closed before run

[ https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6311. -- Resolution: Fixed Fix Version/s: 1.2.2 1.3.0 Resolved for

[jira] [Commented] (FLINK-6311) NPE in FlinkKinesisConsumer if source was closed before run

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

[GitHub] flink pull request #3738: [FLINK-6311] [Kinesis Connector] NPE in FlinkKines...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3738 --- 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

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

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

[GitHub] flink issue #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics reporter

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/3736 Green build! @zentol --- 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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112461145 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala --- @@ -216,6 +216,26 @@ object

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112560976 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112469838 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/aggregations.scala --- @@ -35,6 +37,18 @@ abstract sealed class

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112571486 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/windows.scala --- @@ -22,6 +22,126 @@ import

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112494372 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112459590 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala --- @@ -190,8 +190,8 @@ object

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112482490 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/windows.scala --- @@ -22,6 +22,126 @@ import

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112460885 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala --- @@ -216,6 +216,26 @@ object

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112485134 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112559640 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112479103 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala --- @@ -586,6 +602,13 @@ trait

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112456485 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala --- @@ -810,6 +810,47 @@ class Table( new

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112476982 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala --- @@ -364,6 +365,21 @@ trait

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112471307 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala --- @@ -216,6 +216,26 @@ object

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112460318 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala --- @@ -216,6 +216,26 @@ object

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112494282 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112567381 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112570409 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/OverAggregate.scala --- @@ -23,7 +23,9 @@ import

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

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

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112570917 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/OverWindowITCase.scala --- @@ -0,0 +1,265 @@ +/*

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112499806 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala --- @@ -93,28 +96,43 @@

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112555311 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/windows.scala --- @@ -83,3 +83,49 @@ object Session { */

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112570230 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala --- @@ -93,28 +96,43 @@

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r11245 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala --- @@ -810,6 +810,47 @@ class Table( new

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112473915 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala --- @@ -810,6 +810,47 @@ class Table( new

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112557404 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112570095 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112495783 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala --- @@ -54,6 +54,9 @@ case class

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112457606 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala --- @@ -190,8 +190,8 @@ object

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112495160 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112501222 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/typeutils/SqlTypeUtils.scala --- @@ -0,0 +1,47 @@ +/* + * Licensed to

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112469357 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112488004 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/aggregations.scala --- @@ -35,6 +37,18 @@ abstract sealed class

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112564205 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112561580 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

[GitHub] flink pull request #3743: [FLINK-6228][table] Integrating the OVER windows i...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3743#discussion_r112567644 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala --- @@ -49,6 +57,128 @@ case class Call(functionName:

  1   2   3   >