[jira] [Updated] (FLINK-3475) DISTINCT aggregate function support for SQL queries

[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-3475: - Assignee: Zhenghua Gao > DISTINCT aggregate function support for SQL queries >

[jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables

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

[jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables

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

[jira] [Assigned] (FLINK-5444) Flink UI uses absolute URLs.

[ https://issues.apache.org/jira/browse/FLINK-5444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joerg Schad reassigned FLINK-5444: -- Assignee: Joerg Schad > Flink UI uses absolute URLs. > > >

[GitHub] flink pull request #2938: [FLINK-4692] [tableApi] Add tumbling group-windows...

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2938#discussion_r95728469 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -591,5 +729,27 @@ object

[jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables

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

[GitHub] flink pull request #3098: [FLINK-5438] Typo in JobGraph generator Exception

GitHub user mtunique opened a pull request: https://github.com/apache/flink/pull/3098 [FLINK-5438] Typo in JobGraph generator Exception Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your

[jira] [Commented] (FLINK-5438) Typo in JobGraph generator Exception

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

[GitHub] flink pull request #2938: [FLINK-4692] [tableApi] Add tumbling group-windows...

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2938#discussion_r95726648 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetWindowAggregate.scala --- @@ -0,0 +1,244 @@ +/*

[GitHub] flink pull request #3097: [FLINK-5448] Fix typo in StateAssignmentOperation ...

GitHub user mtunique opened a pull request: https://github.com/apache/flink/pull/3097 [FLINK-5448] Fix typo in StateAssignmentOperation Exception Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-5448) Fix typo in StateAssignmentOperation Exception

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

[GitHub] flink issue #2938: [FLINK-4692] [tableApi] Add tumbling group-windows for ba...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2938 Hi @twalthr , thanks for your reviewing. I have addressed your comments. --- 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] [Created] (FLINK-5446) System metrics reference incomplete

Chesnay Schepler created FLINK-5446: --- Summary: System metrics reference incomplete Key: FLINK-5446 URL: https://issues.apache.org/jira/browse/FLINK-5446 Project: Flink Issue Type:

[GitHub] flink pull request #3074: [FLINK-5421] Explicit restore method in Snapshotab...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3074#discussion_r95589363 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/InterruptSensitiveRestoreTest.java --- @@ -280,4 +368,50 @@

[jira] [Commented] (FLINK-5421) Explicit restore method in Snapshotable

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

[GitHub] flink issue #3093: [FLINK-5444] Made Flink UI links relative.

Github user joerg84 commented on the issue: https://github.com/apache/flink/pull/3093 @zentol Thx! Could you check again? --- 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

[jira] [Commented] (FLINK-5444) Flink UI uses absolute URLs.

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

[jira] [Updated] (FLINK-5449) Time drift in MetricRegistry

[ https://issues.apache.org/jira/browse/FLINK-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5449: Fix Version/s: (was: 2.0.0) > Time drift in MetricRegistry >

[jira] [Updated] (FLINK-5449) Time drift in MetricRegistry

[ https://issues.apache.org/jira/browse/FLINK-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5449: Affects Version/s: (was: 1.1.3) (was: 2.0.0)

[jira] [Commented] (FLINK-5449) Time drift in MetricRegistry

[ https://issues.apache.org/jira/browse/FLINK-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15818606#comment-15818606 ] Chesnay Schepler commented on FLINK-5449: - I'm not so sure about this. scheduledWithFixedDelay

[jira] [Created] (FLINK-5451) Extend JMX metrics documentation section

Chesnay Schepler created FLINK-5451: --- Summary: Extend JMX metrics documentation section Key: FLINK-5451 URL: https://issues.apache.org/jira/browse/FLINK-5451 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4920) Add a Scala Function Gauge

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

[jira] [Resolved] (FLINK-5418) Estimated row size does not support nested types

[ https://issues.apache.org/jira/browse/FLINK-5418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-5418. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 1.3:

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15818486#comment-15818486 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- One suggestion is that, though we are going

[jira] [Created] (FLINK-5448) Fix typo in StateAssignmentOperation Exception

Ufuk Celebi created FLINK-5448: -- Summary: Fix typo in StateAssignmentOperation Exception Key: FLINK-5448 URL: https://issues.apache.org/jira/browse/FLINK-5448 Project: Flink Issue Type:

[GitHub] flink pull request #2767: [FLINK-4988] Elasticsearch 5.x support

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2767#discussion_r95601743 --- Diff: flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java --- @@

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[jira] [Commented] (FLINK-5449) Time drift in MetricRegistry

[ https://issues.apache.org/jira/browse/FLINK-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15818608#comment-15818608 ] Chesnay Schepler commented on FLINK-5449: - Admittedly, the current documentation isn't quite

[GitHub] flink pull request #3080: [FLINK-4920] Add a Scala Function Gauge

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3080#discussion_r95583671 --- Diff: flink-scala/src/test/scala/org/apache/flink/api/scala/metrics/ScalaGaugeTest.scala --- @@ -0,0 +1,48 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4920) Add a Scala Function Gauge

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

[GitHub] flink pull request #3080: [FLINK-4920] Add a Scala Function Gauge

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3080#discussion_r95583820 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala --- @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #3093: [FLINK-5444] Made Flink UI links relative.

GitHub user joerg84 opened a pull request: https://github.com/apache/flink/pull/3093 [FLINK-5444] Made Flink UI links relative. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes

[GitHub] flink issue #3093: [FLINK-5444] Made Flink UI links relative.

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3093 These changes will be overridden the next time someone builds the web-dashboard. You have to modify the .jade files. --- If your project is set up for it, you can reply to this email and have your

[jira] [Created] (FLINK-5450) WindowOperator logs about "re-registering state from an older Flink version" even though its not a restored window

Robert Metzger created FLINK-5450: - Summary: WindowOperator logs about "re-registering state from an older Flink version" even though its not a restored window Key: FLINK-5450 URL:

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95593492 --- Diff: flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowTranslationTest.scala --- @@ -48,6 +49,45 @@ import org.junit.Test

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95593424 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TimeWindowTranslationTest.java --- @@ -51,12 +53,48 @@

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[jira] [Commented] (FLINK-5421) Explicit restore method in Snapshotable

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

[jira] [Commented] (FLINK-5444) Flink UI uses absolute URLs.

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

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95594190 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TimeWindowTranslationTest.java --- @@ -51,12 +53,48 @@

[jira] [Commented] (FLINK-4988) Elasticsearch 5.x support

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

[jira] [Created] (FLINK-5447) Sync documentation of built-in functions for Table API with SQL

Timo Walther created FLINK-5447: --- Summary: Sync documentation of built-in functions for Table API with SQL Key: FLINK-5447 URL: https://issues.apache.org/jira/browse/FLINK-5447 Project: Flink

[GitHub] flink pull request #3074: [FLINK-5421] Explicit restore method in Snapshotab...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3074#discussion_r95588497 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/InterruptSensitiveRestoreTest.java --- @@ -280,4 +368,50 @@ public

[jira] [Commented] (FLINK-5418) Estimated row size does not support nested types

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

[GitHub] flink issue #3075: [FLINK-5296] Expose the old AlignedWindowOperators throug...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3075 @aljoscha I integrated your comments. --- 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

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[jira] [Commented] (FLINK-5030) Support hostname verification

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

[GitHub] flink issue #3061: [FLINK-5030] Support hostname verification

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3061 This looks critical, thanks for addressing this! Will try to get to this very soon. It may be that we do not get this into 1.2.0, but should have it in 1.2.1 definitely. We should add a

[GitHub] flink issue #3061: [FLINK-5030] Support hostname verification

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3061 What we need to double check is that it interplays properly with the hostname/address resolution and normalization that we do for akka. Because akka does exact matches in the actor URLs, all

[GitHub] flink issue #3087: [FLINK-4917] Deprecate "CheckpointedAsynchronously" inter...

Github user mtunique commented on the issue: https://github.com/apache/flink/pull/3087 @greghogan I have add the javadoc about replacement. Maybe `Checkpointed` has the same problem about javadoc. Fix it in this PR or create a new issue on jira? --- If your project is set up for

[jira] [Commented] (FLINK-5030) Support hostname verification

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

[jira] [Commented] (FLINK-4917) Deprecate "CheckpointedAsynchronously" interface

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

[jira] [Assigned] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

[ https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4396: --- Assignee: Chesnay Schepler > GraphiteReporter class not found at startup of

[GitHub] flink pull request #3073: [FLINK-5418] [table] Estimated row size does not s...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3073 --- 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-5418) Estimated row size does not support nested types

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

[jira] [Commented] (FLINK-5461) Remove Superflous TypeInformation Declaration

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

[GitHub] flink pull request #3096: [FLINK-5461] [gelly] Remove Superflous TypeInforma...

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3096 [FLINK-5461] [gelly] Remove Superflous TypeInformation Declaration FLINK-4624 updated Gelly's Summarization algorithm to use Either in order to support types for which the

[jira] [Assigned] (FLINK-5281) Extend KafkaJsonTableSources to support nested data

[ https://issues.apache.org/jira/browse/FLINK-5281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-5281: - Assignee: Ivan Mushketyk > Extend KafkaJsonTableSources to support nested data >

[jira] [Commented] (FLINK-4920) Add a Scala Function Gauge

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

[GitHub] flink pull request #3080: [FLINK-4920] Add a Scala Function Gauge

Github user heytitle commented on a diff in the pull request: https://github.com/apache/flink/pull/3080#discussion_r95671339 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala --- @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

Robert Metzger created FLINK-5465: - Summary: RocksDB fails with segfault while calling AbstractRocksDBState.clear() Key: FLINK-5465 URL: https://issues.apache.org/jira/browse/FLINK-5465 Project:

[jira] [Updated] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

[ https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5465: -- Attachment: hs-err-pid26662.log I've attached the error report file, containing the stack trace

[jira] [Comment Edited] (FLINK-5449) Time drift in MetricRegistry

[ https://issues.apache.org/jira/browse/FLINK-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15818608#comment-15818608 ] Chesnay Schepler edited comment on FLINK-5449 at 1/11/17 4:53 PM: --

[jira] [Closed] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5320. --- Fixed in ebc138841f8f890d47a590496459a0f6f7609d4b for Flink 1.2 > Fix result TypeInformation in

[jira] [Commented] (FLINK-5444) Flink UI uses absolute URLs.

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

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95592206 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TimeWindowTranslationTest.java --- @@ -51,12 +53,48 @@

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[jira] [Created] (FLINK-5449) Time drift in MetricRegistry

Andrey created FLINK-5449: - Summary: Time drift in MetricRegistry Key: FLINK-5449 URL: https://issues.apache.org/jira/browse/FLINK-5449 Project: Flink Issue Type: Bug Components: Metrics

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95592514 --- Diff: flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowTranslationTest.scala --- @@ -48,6 +49,45 @@ import

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[jira] [Commented] (FLINK-5450) WindowOperator logs about "re-registering state from an older Flink version" even though its not a restored window

[ https://issues.apache.org/jira/browse/FLINK-5450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15818629#comment-15818629 ] Chesnay Schepler commented on FLINK-5450: - It is also malformatted; the log message has 2

[jira] [Created] (FLINK-5453) REST API request reference incomplete

Chesnay Schepler created FLINK-5453: --- Summary: REST API request reference incomplete Key: FLINK-5453 URL: https://issues.apache.org/jira/browse/FLINK-5453 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5449) Time drift in MetricRegistry

[ https://issues.apache.org/jira/browse/FLINK-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15818822#comment-15818822 ] Chesnay Schepler commented on FLINK-5449: - With "reporting actions" i referred to the execution of

[jira] [Commented] (FLINK-5449) Time drift in MetricRegistry

[ https://issues.apache.org/jira/browse/FLINK-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15818929#comment-15818929 ] Andrey commented on FLINK-5449: --- Sorry, but I still don't understand how deploy/cleanup relates to the task

[jira] [Created] (FLINK-5452) Make table unit tests pass under cluster mode

Kurt Young created FLINK-5452: - Summary: Make table unit tests pass under cluster mode Key: FLINK-5452 URL: https://issues.apache.org/jira/browse/FLINK-5452 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5452) Make table unit tests pass under cluster mode

[ https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-5452: Component/s: Table API & SQL > Make table unit tests pass under cluster mode >

[GitHub] flink issue #2929: [FLINK-5247] Fix incorrect check in allowedLateness() met...

Github user xhumanoid commented on the issue: https://github.com/apache/flink/pull/2929 I think @mindprince mean: at now logger not defined in class file this classes without private static final Logger LOG --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[GitHub] flink issue #3075: [FLINK-5296] Expose the old AlignedWindowOperators throug...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3075 @aljoscha thanks for the review. I changed the names of the tests and also put them in the right classes. Let me know what you think. --- If your project is set up for it, you can reply to

[GitHub] flink pull request #3095: [FLINK-5452] [table] Fix SortITCase which will fai...

GitHub user KurtYoung opened a pull request: https://github.com/apache/flink/pull/3095 [FLINK-5452] [table] Fix SortITCase which will fail under cluster mode I tried this combination from `TableProgramsTestBase`: Array(TestExecutionMode.CLUSTER, DEFAULT)

[jira] [Commented] (FLINK-5452) Make table unit tests pass under cluster mode

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

[GitHub] flink issue #3093: [FLINK-5444] Made Flink UI links relative.

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3093 That looks better. I tried out these changes locally and they don't seem to break anything. Have you verifies yourself that this fixes the issue mentioned in the JIRA? Still, I'd like other

[jira] [Updated] (FLINK-5384) clean up jira issues

[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: h4. must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere;

[GitHub] flink issue #3049: [FLINK-5395] [Build System] support locally build distrib...

Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/3049 > Before merging this, we would definitely have to run the script as well. I did not do this and hence I would wait with merging this. @uce @rmetzger I use this script build local distribution

[jira] [Commented] (FLINK-5395) support locally build distribution by script create_release_files.sh

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

[jira] [Assigned] (FLINK-5003) Provide Access to State Stores in Operator Snapshot Context

[ https://issues.apache.org/jira/browse/FLINK-5003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-5003: --- Assignee: Aljoscha Krettek > Provide Access to State Stores in Operator Snapshot

[GitHub] flink issue #2938: [FLINK-4692] [tableApi] Add tumbling group-windows for ba...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2938 Thanks for fixing the bug. The collection execution mode is on purpose because we have too many IT cases at the moment. We should only test the subclasses of `FlinkRel` like `DataSetUnion`,

[jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables

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

[jira] [Commented] (FLINK-4920) Add a Scala Function Gauge

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

[jira] [Commented] (FLINK-4920) Add a Scala Function Gauge

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

[GitHub] flink pull request #3080: [FLINK-4920] Add a Scala Function Gauge

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3080#discussion_r95547836 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala --- @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #3080: [FLINK-4920] Add a Scala Function Gauge

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3080#discussion_r95547940 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala --- @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15817890#comment-15817890 ] Stephan Ewen commented on FLINK-4973: - I thought we made use of the Timer Service that is quiesced

[GitHub] flink issue #3091: [FLINK-5442] Ensure order of enum elements in StateDescri...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3091 cc @StephanEwen --- 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-5442) Add test to fix ordinals of serialized enum StateDescriptor.Type

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

[jira] [Commented] (FLINK-5442) Add test to fix ordinals of serialized enum StateDescriptor.Type

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

[GitHub] flink pull request #3091: [FLINK-5442] Ensure order of enum elements in Stat...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/3091 [FLINK-5442] Ensure order of enum elements in StateDescriptor.Type This PR adds a test to ensure the order of elements in enum ``StateDescriptor.Type`` which is important for the

[jira] [Created] (FLINK-5444) Flink UI uses absolute URLs.

Joerg Schad created FLINK-5444: -- Summary: Flink UI uses absolute URLs. Key: FLINK-5444 URL: https://issues.apache.org/jira/browse/FLINK-5444 Project: Flink Issue Type: Bug Reporter:

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15817935#comment-15817935 ] Fabian Hueske commented on FLINK-5256: -- Hi [~anmu], I had a brief look over your branch and it looks

  1   2   3   >