[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871827#comment-15871827 ] ASF GitHub Bot commented on FLINK-5747: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101753433 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FutureUtilsTest.java --- @@ -0,0 +1,190 @@ +/* + * Licensed to the Apa

[jira] [Closed] (FLINK-5099) Test testCancelPartitionRequest is instable

2017-02-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-5099. -- Resolution: Cannot Reproduce the stack trace seems incomplete and the actual OutOfMemory error may even

[jira] [Updated] (FLINK-5831) Sort metrics in metric selector and add search box

2017-02-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5831: -- Attachment: dropDown.png I've attached the drop down I'm talking about as a screenshot. > Sort

[jira] [Created] (FLINK-5831) Sort metrics in metric selector and add search box

2017-02-17 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5831: - Summary: Sort metrics in metric selector and add search box Key: FLINK-5831 URL: https://issues.apache.org/jira/browse/FLINK-5831 Project: Flink Issue Type

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871813#comment-15871813 ] ASF GitHub Bot commented on FLINK-5414: --- Github user wuchong commented on a diff in

[GitHub] flink pull request #3338: [FLINK-5414] [table] Bump up Calcite version to 1....

2017-02-17 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3338#discussion_r101750708 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/ExpressionReducer.scala --- @@ -106,8 +106,16 @@ class ExpressionReducer

[jira] [Comment Edited] (FLINK-5782) Support GPU calculations

2017-02-17 Thread Kate Eri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871803#comment-15871803 ] Kate Eri edited comment on FLINK-5782 at 2/17/17 12:55 PM: --- I ha

[jira] [Resolved] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

2017-02-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5616. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed via cc9334a4694b06abde2723548f9576256ae063db

[jira] [Updated] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

2017-02-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5616: - Affects Version/s: (was: 1.2.0) > YarnPreConfiguredMasterHaServicesTest fails sometimes >

[jira] [Updated] (FLINK-5782) Support GPU calculations

2017-02-17 Thread Kate Eri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kate Eri updated FLINK-5782: Description: This ticket was initiated as continuation of the dev discussion thread: [New Flink team member

[jira] [Commented] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871810#comment-15871810 ] ASF GitHub Bot commented on FLINK-5616: --- Github user asfgit closed the pull request

[GitHub] flink pull request #3327: [FLINK-5616] [tests] Harden YarnIntraNonHaMasterSe...

2017-02-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3327 --- 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 enab

[GitHub] flink issue #3327: [FLINK-5616] [tests] Harden YarnIntraNonHaMasterServicesT...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3327 Travis now passed :-) Merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871805#comment-15871805 ] ASF GitHub Bot commented on FLINK-5616: --- Github user tillrohrmann commented on the i

[jira] [Comment Edited] (FLINK-5782) Support GPU calculations

2017-02-17 Thread Kate Eri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871803#comment-15871803 ] Kate Eri edited comment on FLINK-5782 at 2/17/17 12:50 PM: --- I ha

[jira] [Comment Edited] (FLINK-5782) Support GPU calculations

2017-02-17 Thread Kate Eri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871803#comment-15871803 ] Kate Eri edited comment on FLINK-5782 at 2/17/17 12:50 PM: --- I ha

[jira] [Commented] (FLINK-5782) Support GPU calculations

2017-02-17 Thread Kate Eri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871803#comment-15871803 ] Kate Eri commented on FLINK-5782: - I have checked out ND4J and Apache Mahout for their GPU

[GitHub] flink pull request #3332: [FLINK-5751] [docs] Add link check script

2017-02-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3332 --- 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 enab

[jira] [Commented] (FLINK-5751) 404 in documentation

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871802#comment-15871802 ] ASF GitHub Bot commented on FLINK-5751: --- Github user asfgit closed the pull request

[GitHub] flink issue #3332: [FLINK-5751] [docs] Add link check script

2017-02-17 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3332 Thanks @patricklucas, I've addressed your comments and re-added the red formatting, which is nice indeed. ;-) I'm going to merge this with you as the author. Hope that's fine. --- If your project is s

[jira] [Commented] (FLINK-5751) 404 in documentation

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871798#comment-15871798 ] ASF GitHub Bot commented on FLINK-5751: --- Github user uce commented on the issue:

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871788#comment-15871788 ] ASF GitHub Bot commented on FLINK-5747: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871790#comment-15871790 ] ASF GitHub Bot commented on FLINK-5747: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871795#comment-15871795 ] ASF GitHub Bot commented on FLINK-5747: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871792#comment-15871792 ] ASF GitHub Bot commented on FLINK-5747: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101747520 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FutureUtilsTest.java --- @@ -0,0 +1,190 @@ +/* + * Licensed to the Ap

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871791#comment-15871791 ] ASF GitHub Bot commented on FLINK-5747: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871789#comment-15871789 ] ASF GitHub Bot commented on FLINK-5747: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101737967 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -292,7 +305,8 @@ public ExecutionGraph(

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101746831 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphUtils.java --- @@ -0,0 +1,108 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871793#comment-15871793 ] ASF GitHub Bot commented on FLINK-5747: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101747876 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/Flip6LocalStreamEnvironment.java --- @@ -41,7 +41,7 @@ *

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101737070 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -88,4 +100,104 @@ public RetryException(Throwable cau

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871794#comment-15871794 ] ASF GitHub Bot commented on FLINK-5747: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-5747) Eager Scheduling should deploy all Tasks together

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871787#comment-15871787 ] ASF GitHub Bot commented on FLINK-5747: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101739062 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -754,6 +759,139 @@ public void scheduleForExec

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101746547 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -754,6 +759,139 @@ public void scheduleForExec

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101739380 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -754,6 +759,139 @@ public void scheduleForExec

[GitHub] flink pull request #3295: [FLINK-5747] [distributed coordination] Eager sche...

2017-02-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3295#discussion_r101731399 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -88,4 +100,104 @@ public RetryException(Throwable cau

[GitHub] flink pull request #3344: FLINK-5731 Spilt up tests into three disjoint grou...

2017-02-17 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/3344 FLINK-5731 Spilt up tests into three disjoint groups We were running into build timeouts again recently on travis. That's why I've split the tests into three groups (instead of two). Th

[jira] [Commented] (FLINK-5731) Split up CI builds

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871774#comment-15871774 ] ASF GitHub Bot commented on FLINK-5731: --- GitHub user rmetzger opened a pull request:

[jira] [Commented] (FLINK-4422) Convert all time interval measurements to System.nanoTime()

2017-02-17 Thread Jin Mingjian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871757#comment-15871757 ] Jin Mingjian commented on FLINK-4422: - This issue could be seen as a low hanging fruit

[jira] [Assigned] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2017-02-17 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5402: Assignee: Dawid Wysakowicz > Fails AkkaRpcServiceTest#testTerminationFuture > -

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871737#comment-15871737 ] Dawid Wysakowicz commented on FLINK-5824: - [~StephanEwen] Sure, will do it. We don

[jira] [Commented] (FLINK-5828) BlobServer create cache dir has concurrency safety problem

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871724#comment-15871724 ] ASF GitHub Bot commented on FLINK-5828: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3342: TO FLINK-5828

2017-02-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3342 Good fix, thank you! +1 to merge this --- 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 f

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871722#comment-15871722 ] Stephan Ewen commented on FLINK-5824: - I think some names in checkpoints are serialize

[jira] [Commented] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871715#comment-15871715 ] ASF GitHub Bot commented on FLINK-5402: --- GitHub user dawidwys opened a pull request:

[GitHub] flink pull request #3343: [FLINK-5402] Fails AkkaRpcServiceTest#testTerminat...

2017-02-17 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3343 [FLINK-5402] Fails AkkaRpcServiceTest#testTerminationFuture On macOS this test fails consistently as the actorSystem creation already causes timeout. Unfortunately the actorSystem and rpcServic

[jira] [Commented] (FLINK-5441) Directly allow SQL queries on a Table

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871705#comment-15871705 ] ASF GitHub Bot commented on FLINK-5441: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3107: [FLINK-5441] [table] Directly allow SQL queries on a Tabl...

2017-02-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3107 Hi, I like @twalthr's suggestion to use `env.sql("SELECT * FROM _ JOIN _", table, otherTable)`. I'd also be fine with slf4j syntax as @wuchong proposed. What do you think @KurtYoung? -

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r101733413 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/AggregationsITCase.scala --- @@ -213,34 +213,45 @@ class Agg

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

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871698#comment-15871698 ] ASF GitHub Bot commented on FLINK-3475: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r101732097 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetAggregateRule.scala --- @@ -45,7 +45,7 @@ class DataSe

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r101735785 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/FlinkAggregateExpandDistinctAggregatesRule.java --- @@ -0,0 +

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

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871696#comment-15871696 ] ASF GitHub Bot commented on FLINK-3475: --- Github user fhueske commented on a diff in

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

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871699#comment-15871699 ] ASF GitHub Bot commented on FLINK-3475: --- Github user fhueske commented on a diff in

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

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871697#comment-15871697 ] ASF GitHub Bot commented on FLINK-3475: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r101732154 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetAggregateWithNullValuesRule.scala --- @@ -51,7 +51,7 @

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

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871700#comment-15871700 ] ASF GitHub Bot commented on FLINK-3475: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r101733431 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/AggregationsITCase.scala --- @@ -213,34 +213,45 @@ class Agg

[jira] [Updated] (FLINK-5545) remove FlinkAggregateExpandDistinctAggregatesRule when we upgrade calcite

2017-02-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5545: - Issue Type: Sub-task (was: Bug) Parent: FLINK-5829 > remove FlinkAggregateExpandDistinctA

[jira] [Created] (FLINK-5830) OutOfMemoryError during notify final state in TaskExecutor may cause job stuck

2017-02-17 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5830: Summary: OutOfMemoryError during notify final state in TaskExecutor may cause job stuck Key: FLINK-5830 URL: https://issues.apache.org/jira/browse/FLINK-5830 Project:

[jira] [Created] (FLINK-5829) Bump Calcite version to 1.12 once available

2017-02-17 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-5829: Summary: Bump Calcite version to 1.12 once available Key: FLINK-5829 URL: https://issues.apache.org/jira/browse/FLINK-5829 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

2017-02-17 Thread Zhuoluo Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871634#comment-15871634 ] Zhuoluo Yang commented on FLINK-5826: - Thanks [~jiangxw]. After some investigation on

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871623#comment-15871623 ] ASF GitHub Bot commented on FLINK-5414: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3338: [FLINK-5414] [table] Bump up Calcite version to 1.11

2017-02-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3338 @twalthr, you might want to have a look at the `FlinkTypeFactory` changes --- 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 proje

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871622#comment-15871622 ] ASF GitHub Bot commented on FLINK-5414: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #3338: [FLINK-5414] [table] Bump up Calcite version to 1....

2017-02-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3338#discussion_r101728056 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/ExpressionReducer.scala --- @@ -106,8 +106,16 @@ class ExpressionReducer

[GitHub] flink pull request #3330: [FLINK-5795][TableAPI&SQL] Improve UDTF to support...

2017-02-17 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3330#discussion_r101726090 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetUserDefinedFunctionITCase.scala --- @@ -0,0 +1,75

[jira] [Commented] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871600#comment-15871600 ] ASF GitHub Bot commented on FLINK-5795: --- Github user sunjincheng121 commented on a d

[jira] [Commented] (FLINK-5792) Improve “UDF/UDTF" to support constructor with parameter.

2017-02-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871584#comment-15871584 ] sunjincheng commented on FLINK-5792: HI,[~clarkyzl] Thanks for your attention to this

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

2017-02-17 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871572#comment-15871572 ] Stefan Richter commented on FLINK-1725: --- I agree with you [~aljoscha]. While this wo

[jira] [Updated] (FLINK-5827) Exception when do filter after join a udtf which returns a POJO type

2017-02-17 Thread kaibo.zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaibo.zhou updated FLINK-5827: -- Summary: Exception when do filter after join a udtf which returns a POJO type (was: Compile error when

[jira] [Commented] (FLINK-5828) BlobServer create cache dir has concurrency safety problem

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871553#comment-15871553 ] ASF GitHub Bot commented on FLINK-5828: --- GitHub user bwzheng2010 opened a pull reque

[GitHub] flink pull request #3342: TO FLINK-5828

2017-02-17 Thread bwzheng2010
GitHub user bwzheng2010 opened a pull request: https://github.com/apache/flink/pull/3342 TO FLINK-5828 flip the logic to resolve currency safety problem [flink-runtime] https://issues.apache.org/jira/browse/FLINK-5828 fix currency safety problem for this issue

[jira] [Updated] (FLINK-4856) Add MapState for keyed streams

2017-02-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4856: Component/s: DataStream API > Add MapState for keyed streams > -

[GitHub] flink issue #3340: [FLINK-5703][runtime]Job manager failure recovery via rec...

2017-02-17 Thread wangzhijiang999
Github user wangzhijiang999 commented on the issue: https://github.com/apache/flink/pull/3340 @StephanEwen , wish your reviews. Thank you for any 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 d

[jira] [Commented] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871544#comment-15871544 ] ASF GitHub Bot commented on FLINK-5703: --- Github user wangzhijiang999 commented on th

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

2017-02-17 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871538#comment-15871538 ] Stefan Richter commented on FLINK-2491: --- This seems still valid, but I assume it is

[jira] [Commented] (FLINK-5827) Compile error when do filter after join a udtf which returns a POJO type

2017-02-17 Thread kaibo.zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871530#comment-15871530 ] kaibo.zhou commented on FLINK-5827: --- Patch is ready but i have no permission assign to m

[jira] [Updated] (FLINK-5827) Compile error when do filter after join a udtf which returns a POJO type

2017-02-17 Thread kaibo.zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaibo.zhou updated FLINK-5827: -- Description: The test case: {code:title=testFilterUdtfOutputPojo} @Test def testFilterUdtfOutputPojo(

[jira] [Updated] (FLINK-5827) Compile error when do filter after join a udtf which returns a POJO type

2017-02-17 Thread kaibo.zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaibo.zhou updated FLINK-5827: -- Description: The test case: {code:title=testFilterUdtfOutputPojo} @Test def testFilterUdtfOutputPojo(

[jira] [Closed] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators

2017-02-17 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-3841. - Resolution: Not A Problem Fix Version/s: 1.2.0 Not a problem any more. Will close this beca

[jira] [Created] (FLINK-5828) BlobServer create cache dir has concurrency safety problem

2017-02-17 Thread ZhengBowen (JIRA)
ZhengBowen created FLINK-5828: - Summary: BlobServer create cache dir has concurrency safety problem Key: FLINK-5828 URL: https://issues.apache.org/jira/browse/FLINK-5828 Project: Flink Issue Type

[jira] [Created] (FLINK-5827) Compile error when do filter after join a udtf which returns a POJO type

2017-02-17 Thread kaibo.zhou (JIRA)
kaibo.zhou created FLINK-5827: - Summary: Compile error when do filter after join a udtf which returns a POJO type Key: FLINK-5827 URL: https://issues.apache.org/jira/browse/FLINK-5827 Project: Flink

[jira] [Commented] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts.

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871505#comment-15871505 ] ASF GitHub Bot commented on FLINK-5817: --- GitHub user wenlong88 opened a pull request

[GitHub] flink pull request #3341: [FLINK-5817]Fix test concurrent execution failure ...

2017-02-17 Thread wenlong88
GitHub user wenlong88 opened a pull request: https://github.com/apache/flink/pull/3341 [FLINK-5817]Fix test concurrent execution failure by test dir conflicts. use TemporaryFold to create temp files and folds for UT You can merge this pull request into a Git repository by running:

[GitHub] flink pull request #3340: [FLINK-5703][runtime]Job manager failure recovery ...

2017-02-17 Thread wangzhijiang999
GitHub user wangzhijiang999 opened a pull request: https://github.com/apache/flink/pull/3340 [FLINK-5703][runtime]Job manager failure recovery via reconciliation with TaskManager reports This is part of [Non-disruptive JobManager Failures via Reconciliation ](https://issues.apache.

[jira] [Commented] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871499#comment-15871499 ] ASF GitHub Bot commented on FLINK-5703: --- GitHub user wangzhijiang999 opened a pull r

[jira] [Commented] (FLINK-5586) Extend TableProgramsTestBase for object reuse modes

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871480#comment-15871480 ] ASF GitHub Bot commented on FLINK-5586: --- GitHub user KurtYoung opened a pull request

[GitHub] flink pull request #3339: [FLINK-5586] [table] Extend TableProgramsClusterTe...

2017-02-17 Thread KurtYoung
GitHub user KurtYoung opened a pull request: https://github.com/apache/flink/pull/3339 [FLINK-5586] [table] Extend TableProgramsClusterTestBase for object reuse mode Make all cluster-based ITCases verified in object reuse mode. This only includes batch table tests now. You can mer

[GitHub] flink issue #3337: [FLINK-5825][UI]make the cite path relative to show it co...

2017-02-17 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3337 Thanks for the pull request. Let me try this out and merge it if everything works as expected. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[jira] [Commented] (FLINK-5825) In yarn mode, a small pic can not be loaded

2017-02-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871474#comment-15871474 ] ASF GitHub Bot commented on FLINK-5825: --- Github user uce commented on the issue:

[jira] [Commented] (FLINK-5586) Extend TableProgramsTestBase for object reuse modes

2017-02-17 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871463#comment-15871463 ] Kurt Young commented on FLINK-5586: --- It looks like {{TableProgramsTestBase}} is only use

[jira] [Commented] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts.

2017-02-17 Thread Wenlong Lyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871461#comment-15871461 ] Wenlong Lyu commented on FLINK-5817: [~shijinkui] I think the reason why you want to c

[jira] [Assigned] (FLINK-5586) Extend TableProgramsTestBase for object reuse modes

2017-02-17 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-5586: - Assignee: Kurt Young > Extend TableProgramsTestBase for object reuse modes >

[jira] [Commented] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871455#comment-15871455 ] Ufuk Celebi commented on FLINK-5824: [~dawidwys] I've just assigned it to you. [~Step

[jira] [Assigned] (FLINK-5824) Fix String/byte conversions without explicit encoding

2017-02-17 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5824: -- Assignee: Dawid Wysakowicz > Fix String/byte conversions without explicit encoding > --

<    1   2   3   4   >