[jira] [Assigned] (FLINK-9300) Improve error message when in-memory state is too large

2018-05-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9300: --- Assignee: vinoyang > Improve error message when in-memory state is too large >

[jira] [Assigned] (FLINK-9299) ProcessWindowFunction documentation Java examples have errors

2018-05-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9299: --- Assignee: vinoyang > ProcessWindowFunction documentation Java examples have errors >

[jira] [Commented] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization

2018-05-04 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464544#comment-16464544 ] Shuyi Chen commented on FLINK-7001: --- Hi [~pgrulich], the paper is a nice read. And the technique applies

[jira] [Commented] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464530#comment-16464530 ] ASF GitHub Bot commented on FLINK-8533: --- Github user EronWright commented on the issue:

[GitHub] flink issue #5427: [FLINK-8533] [checkpointing] Support MasterTriggerRestore...

2018-05-04 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/5427 @StephanEwen thanks again for the feedback, which I took to heart and simplified the hook. It now has a `reset ` method that is called only in the special case. I will refactor the

[jira] [Created] (FLINK-9300) Improve error message when in-memory state is too large

2018-05-04 Thread Ken Krugler (JIRA)
Ken Krugler created FLINK-9300: -- Summary: Improve error message when in-memory state is too large Key: FLINK-9300 URL: https://issues.apache.org/jira/browse/FLINK-9300 Project: Flink Issue

[jira] [Created] (FLINK-9299) ProcessWindowFunction documentation Java examples have errors

2018-05-04 Thread Ken Krugler (JIRA)
Ken Krugler created FLINK-9299: -- Summary: ProcessWindowFunction documentation Java examples have errors Key: FLINK-9299 URL: https://issues.apache.org/jira/browse/FLINK-9299 Project: Flink

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464434#comment-16464434 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on the issue:

[GitHub] flink issue #5860: [FLINK-9138][filesystem-connectors] Implement time based ...

2018-05-04 Thread glaksh100
Github user glaksh100 commented on the issue: https://github.com/apache/flink/pull/5860 Thanks for reviewing @fhueske @aljoscha and @kl0u ! I have addressed the latest review comments. Can you PTAL (again) ? ---

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464404#comment-16464404 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on a diff in the pull

[GitHub] flink pull request #5860: [FLINK-9138][filesystem-connectors] Implement time...

2018-05-04 Thread glaksh100
Github user glaksh100 commented on a diff in the pull request: https://github.com/apache/flink/pull/5860#discussion_r186223237 --- Diff: flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -473,6

[GitHub] flink pull request #5860: [FLINK-9138][filesystem-connectors] Implement time...

2018-05-04 Thread glaksh100
Github user glaksh100 commented on a diff in the pull request: https://github.com/apache/flink/pull/5860#discussion_r186223099 --- Diff: flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -908,6

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464403#comment-16464403 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on a diff in the pull

[jira] [Created] (FLINK-9298) setup_quickstart hanging

2018-05-04 Thread Alex Chen (JIRA)
Alex Chen created FLINK-9298: Summary: setup_quickstart hanging Key: FLINK-9298 URL: https://issues.apache.org/jira/browse/FLINK-9298 Project: Flink Issue Type: Bug Reporter: Alex

[jira] [Commented] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization

2018-05-04 Thread Philipp Grulich (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464248#comment-16464248 ] Philipp Grulich commented on FLINK-7001: Hi [~walterddr] , we published recently this paper about

[jira] [Commented] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization

2018-05-04 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464239#comment-16464239 ] Rong Rong commented on FLINK-7001: -- Hi [~jark], Is there a FLIP being proposed based on the pain points

[GitHub] flink pull request #:

2018-05-04 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/commit/c8fa8d025684c2225824c54a7285bbfdec7cfddc#commitcomment-28859963 In flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeInfoParser.java: In

[jira] [Commented] (FLINK-9292) Remove TypeInfoParser

2018-05-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464135#comment-16464135 ] Stephan Ewen commented on FLINK-9292: - Feel free to take over the second half of this issue, if you

[jira] [Commented] (FLINK-9292) Remove TypeInfoParser

2018-05-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464134#comment-16464134 ] Stephan Ewen commented on FLINK-9292: - I have merged the first part of removing the the

[GitHub] flink issue #5940: [FLINK-8690][table]Support group window distinct aggregat...

2018-05-04 Thread walterddr
Github user walterddr commented on the issue: https://github.com/apache/flink/pull/5940 LOL. I think I found a way: 1. Rebase #3764 over to current master; 2. Rebase this branch to the rebased #3764; 3. Make changes on top :-) ---

[jira] [Commented] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464071#comment-16464071 ] ASF GitHub Bot commented on FLINK-8690: --- Github user walterddr commented on the issue:

[jira] [Commented] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464063#comment-16464063 ] ASF GitHub Bot commented on FLINK-8690: --- Github user fhueske commented on the issue:

[GitHub] flink issue #5940: [FLINK-8690][table]Support group window distinct aggregat...

2018-05-04 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5940 Hmmm, good point. The discussion would be lost. How about I put your changes on top of Haohui's changes before merging? ---

[jira] [Commented] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464039#comment-16464039 ] ASF GitHub Bot commented on FLINK-8690: --- Github user walterddr commented on the issue:

[GitHub] flink issue #5940: [FLINK-8690][table]Support group window distinct aggregat...

2018-05-04 Thread walterddr
Github user walterddr commented on the issue: https://github.com/apache/flink/pull/5940 Thanks @suez1224 @fhueske for the comments. I will change them accordingly. Yes I copied a lot of test cases from @haohui's PR for my own testing. I can definitely put it on top given the

[jira] [Created] (FLINK-9297) Make size of JobManager's ioExecutor configurable

2018-05-04 Thread Jelmer Kuperus (JIRA)
Jelmer Kuperus created FLINK-9297: - Summary: Make size of JobManager's ioExecutor configurable Key: FLINK-9297 URL: https://issues.apache.org/jira/browse/FLINK-9297 Project: Flink Issue

[jira] [Updated] (FLINK-9297) Make size of JobManager's ioExecutor configurable

2018-05-04 Thread Jelmer Kuperus (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jelmer Kuperus updated FLINK-9297: -- Description: With flink 1.4.0 cleaning of checkpoints is handled on the job manager, the

[jira] [Commented] (FLINK-8497) KafkaConsumer throws NPE if topic doesn't exist

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463984#comment-16463984 ] ASF GitHub Bot commented on FLINK-8497: --- Github user alexpf commented on a diff in the pull request:

[GitHub] flink pull request #5929: [FLINK-8497] [connectors] KafkaConsumer throws NPE...

2018-05-04 Thread alexpf
Github user alexpf commented on a diff in the pull request: https://github.com/apache/flink/pull/5929#discussion_r186110995 --- Diff: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09PartitionDiscoverer.java ---

[jira] [Updated] (FLINK-8978) End-to-end test: Job upgrade

2018-05-04 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8978: -- Fix Version/s: (was: 1.5.1) 1.5.0 > End-to-end test: Job upgrade >

[jira] [Closed] (FLINK-8978) End-to-end test: Job upgrade

2018-05-04 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8978. - Resolution: Fixed > End-to-end test: Job upgrade > > >

[jira] [Reopened] (FLINK-8978) End-to-end test: Job upgrade

2018-05-04 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reopened FLINK-8978: --- Change fix version > End-to-end test: Job upgrade > > >

[jira] [Closed] (FLINK-8978) End-to-end test: Job upgrade

2018-05-04 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8978. - Resolution: Fixed Merged in: master: 5ac4d29609 release-1.5: 54befe5a31 > End-to-end test: Job

[jira] [Commented] (FLINK-8978) End-to-end test: Job upgrade

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

[GitHub] flink pull request #5947: [FLINK-8978] Stateful generic stream job upgrade e...

2018-05-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5947 ---

[jira] [Commented] (FLINK-8978) End-to-end test: Job upgrade

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463907#comment-16463907 ] ASF GitHub Bot commented on FLINK-8978: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #5947: [FLINK-8978] Stateful generic stream job upgrade e2e test

2018-05-04 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5947 LGTM 👍 Will merge this. ---

[jira] [Closed] (FLINK-9254) Move NotSoMiniClusterIterations to be an end-to-end test

2018-05-04 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9254. - Resolution: Fixed Merged in: master: b50cebb656 release-1.5: ed3447e343 > Move

[jira] [Commented] (FLINK-9254) Move NotSoMiniClusterIterations to be an end-to-end test

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

[GitHub] flink pull request #5921: [FLINK-9254] Move NotSoMiniClusterIterations to be...

2018-05-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5921 ---

[jira] [Commented] (FLINK-9254) Move NotSoMiniClusterIterations to be an end-to-end test

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463876#comment-16463876 ] ASF GitHub Bot commented on FLINK-9254: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #5921: [FLINK-9254] Move NotSoMiniClusterIterations to be an end...

2018-05-04 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5921 In that case, LGTM 👍 Will merge this. ---

[jira] [Commented] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463873#comment-16463873 ] ASF GitHub Bot commented on FLINK-9169: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #5950: [FLINK-9169] [state-backend] Allow absence of old seriali...

2018-05-04 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5950 Overall, I think this looks good for me now 👍 ---

[jira] [Commented] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463869#comment-16463869 ] ASF GitHub Bot commented on FLINK-9169: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #5950: [FLINK-9169] [state-backend] Allow absence of old ...

2018-05-04 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5950#discussion_r186082804 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSerializationUtil.java --- @@ -102,17 +99,24 @@ *

[jira] [Commented] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463867#comment-16463867 ] ASF GitHub Bot commented on FLINK-9169: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #5950: [FLINK-9169] [state-backend] Allow absence of old seriali...

2018-05-04 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5950 Yes, I think we can only remove the flag further when splitting up `readSerializersAndConfigsWithResilience`, but I guess it is ok to leave it if we change this soon anyways. ---

[jira] [Commented] (FLINK-9292) Remove TypeInfoParser

2018-05-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463784#comment-16463784 ] Stephan Ewen commented on FLINK-9292: - This issue needs a lot of care to not break functionality. I

[jira] [Commented] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

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

[jira] [Commented] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

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

[jira] [Commented] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

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

[jira] [Commented] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

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

[jira] [Commented] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

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

[jira] [Commented] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

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

[GitHub] flink pull request #5940: [FLINK-8690][table]Support group window distinct a...

2018-05-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5940#discussion_r186033706 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCase.scala --- @@ -52,6 +52,76 @@ class SqlITCase

[GitHub] flink pull request #5940: [FLINK-8690][table]Support group window distinct a...

2018-05-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5940#discussion_r186022377 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -641,7 +641,8 @@ class

[GitHub] flink pull request #5940: [FLINK-8690][table]Support group window distinct a...

2018-05-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5940#discussion_r186029985 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/sql/DistinctAggregateTest.scala --- @@ -0,0 +1,173 @@ +/* +

[GitHub] flink pull request #5940: [FLINK-8690][table]Support group window distinct a...

2018-05-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5940#discussion_r185955967 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -641,7 +641,8 @@ class

[GitHub] flink pull request #5940: [FLINK-8690][table]Support group window distinct a...

2018-05-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5940#discussion_r186036107 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCase.scala --- @@ -52,6 +52,76 @@ class SqlITCase

[GitHub] flink pull request #5940: [FLINK-8690][table]Support group window distinct a...

2018-05-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5940#discussion_r186033401 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCase.scala --- @@ -52,6 +52,76 @@ class SqlITCase

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463715#comment-16463715 ] ASF GitHub Bot commented on FLINK-8946: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5869: [FLINK-8946] TaskManager stop sending metrics after JobMa...

2018-05-04 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5869 cc @zentol @GJL ---

[jira] [Created] (FLINK-9296) Support distinct aggregation on non-windowed grouped streaming tables

2018-05-04 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-9296: Summary: Support distinct aggregation on non-windowed grouped streaming tables Key: FLINK-9296 URL: https://issues.apache.org/jira/browse/FLINK-9296 Project: Flink

[jira] [Updated] (FLINK-9232) Add harness test for AggregationCodeGenerator

2018-05-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9232: - Component/s: Table API & SQL > Add harness test for AggregationCodeGenerator >

[jira] [Updated] (FLINK-8691) Update table API to support distinct operator on data stream

2018-05-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8691: - Component/s: Table API & SQL > Update table API to support distinct operator on data stream >

[jira] [Updated] (FLINK-8739) Optimize runtime support for distinct filter

2018-05-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8739: - Component/s: Table API & SQL > Optimize runtime support for distinct filter >

[jira] [Closed] (FLINK-6335) Parse DISTINCT over grouped window in stream SQL

2018-05-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6335. Resolution: Duplicate Duplicate of FLINK-8690 > Parse DISTINCT over grouped window in stream SQL >

[jira] [Updated] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

2018-05-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8690: - Summary: Support distinct aggregation on group windowed streaming tables. (was: Update logical

[jira] [Updated] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

2018-05-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8690: - Component/s: Table API & SQL > Support distinct aggregation on group windowed streaming tables. >

[jira] [Closed] (FLINK-6373) Add runtime support for distinct aggregation over grouped windows

2018-05-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6373. Resolution: Duplicate Was implemented as FLINK-8689. > Add runtime support for distinct

[jira] [Commented] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463642#comment-16463642 ] ASF GitHub Bot commented on FLINK-7775: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5799: [FLINK-7775] Remove unreferenced method PermanentBlobCach...

2018-05-04 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5799 cc @zentol @GJL this PR takes a long time and the travis build error seems uncorrelated. can you review it? thanks. ---

[GitHub] flink issue #5495: [FLINK-8659] Add migration itcases for broadcast state.

2018-05-04 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5495 I close this and I will open an updated one. ---

[GitHub] flink pull request #5495: [FLINK-8659] Add migration itcases for broadcast s...

2018-05-04 Thread kl0u
Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/5495 ---

[jira] [Commented] (FLINK-8659) Add migration tests for Broadcast state.

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463628#comment-16463628 ] ASF GitHub Bot commented on FLINK-8659: --- Github user kl0u closed the pull request at:

[GitHub] flink pull request #5955: [FLINK-8659] Add migration itcases for broadcast s...

2018-05-04 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/5955 [FLINK-8659] Add migration itcases for broadcast state. As the name implies, this PR add migration tests for the newly introduced broadcast state. For the `scala` case, more refactoring is

[jira] [Commented] (FLINK-8659) Add migration tests for Broadcast state.

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463634#comment-16463634 ] ASF GitHub Bot commented on FLINK-8659: --- GitHub user kl0u opened a pull request:

[jira] [Commented] (FLINK-8659) Add migration tests for Broadcast state.

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463630#comment-16463630 ] ASF GitHub Bot commented on FLINK-8659: --- Github user kl0u commented on the issue:

[jira] [Reopened] (FLINK-9245) Can't create a BucketingSink with a provided Configuration if no hadoop defaults

2018-05-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-9245: - reopen to remove fixVersion > Can't create a BucketingSink with a provided Configuration if

[jira] [Closed] (FLINK-9245) Can't create a BucketingSink with a provided Configuration if no hadoop defaults

2018-05-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9245. --- Resolution: Not A Problem > Can't create a BucketingSink with a provided Configuration if no

[jira] [Updated] (FLINK-9245) Can't create a BucketingSink with a provided Configuration if no hadoop defaults

2018-05-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9245: Fix Version/s: (was: 1.6.0) > Can't create a BucketingSink with a provided

[jira] [Closed] (FLINK-9245) Can't create a BucketingSink with a provided Configuration if no hadoop defaults

2018-05-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9245. --- Resolution: Not A Problem Closing now but please reopen if specifying an authority (host)

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463605#comment-16463605 ] ASF GitHub Bot commented on FLINK-8500: --- Github user FredTing commented on the issue:

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463606#comment-16463606 ] ASF GitHub Bot commented on FLINK-8500: --- Github user FredTing closed the pull request at:

[GitHub] flink pull request #5939: [FLINK-8500] [Kafka Connector] Get the timestamp o...

2018-05-04 Thread FredTing
Github user FredTing closed the pull request at: https://github.com/apache/flink/pull/5939 ---

[GitHub] flink issue #5939: [FLINK-8500] [Kafka Connector] Get the timestamp of the K...

2018-05-04 Thread FredTing
Github user FredTing commented on the issue: https://github.com/apache/flink/pull/5939 I'm closing this Pull Request and will make a new one with the newer approach as discussed in the jira issue ---

[jira] [Commented] (FLINK-6206) Log task state transitions as warn/error for FAILURE scenarios

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463583#comment-16463583 ] ASF GitHub Bot commented on FLINK-6206: --- Github user zentol commented on the issue:

[GitHub] flink issue #5399: [FLINK-6206] [runtime] Use LOG.error() when logging failu...

2018-05-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5399 @casidiablo yes that is correct. ---

[jira] [Commented] (FLINK-9276) Improve error message when TaskManager fails

2018-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463579#comment-16463579 ] ASF GitHub Bot commented on FLINK-9276: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5954: [FLINK-9276] Improve error message when TaskManage...

2018-05-04 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5954 [FLINK-9276] Improve error message when TaskManager fails ## What is the purpose of the change *This pull request improves error message when TaskManager fails* ## Brief

[jira] [Closed] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-05-04 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-8620. --- Resolution: Fixed Fix Version/s: 1.6.0 > Enable shipping custom artifacts to BlobStore

[jira] [Assigned] (FLINK-7151) FLINK SQL support create temporary function and table

2018-05-04 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-7151: - Assignee: Shuyi Chen (was: yuemeng) > FLINK SQL support create temporary function and table >

[jira] [Updated] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized

2018-05-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9169: --- Priority: Blocker (was: Major) > NPE when restoring from old savepoint and state

[jira] [Commented] (FLINK-9292) Remove TypeInfoParser

2018-05-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463542#comment-16463542 ] vinoyang commented on FLINK-9292: - [~aljoscha] and [~StephanEwen] can we remove the specific method's

[jira] [Commented] (FLINK-9292) Remove TypeInfoParser

2018-05-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463534#comment-16463534 ] vinoyang commented on FLINK-9292: - [~aljoscha] based on [~StephanEwen]'s description. the TypeInfoParser

[jira] [Closed] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

2018-05-04 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9269. - Resolution: Fixed Merged in: master: 14e7d35f26 release-1.5: 3ba21adc0e > Concurrency problem

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

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

[jira] [Commented] (FLINK-9292) Remove TypeInfoParser

2018-05-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463521#comment-16463521 ] Aljoscha Krettek commented on FLINK-9292: - [~yanghua] Keep in mind, that we can't remove this now

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-05-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5580 ---

  1   2   >