[jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

2017-09-26 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181315#comment-16181315 ] Bowen Li commented on FLINK-7648: - [~till.rohrmann] Hi Till, I built Flink from source, copied

[GitHub] flink pull request #4722: [FLINK-7683] Iterate over keys in KeyedStateBacken...

2017-09-26 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4722#discussion_r141136758 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1946,4

[GitHub] flink issue #4706: [FLINK-7670][doc] fix typo in docs runtime section

2017-09-26 Thread keweishang
Github user keweishang commented on the issue: https://github.com/apache/flink/pull/4706 @tzulitai thanks for merging the fix! ---

[GitHub] flink pull request #4706: [FLINK-7670][doc] fix typo in docs runtime section

2017-09-26 Thread keweishang
Github user keweishang closed the pull request at: https://github.com/apache/flink/pull/4706 ---

[jira] [Commented] (FLINK-7670) typo in docs runtime section

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181263#comment-16181263 ] ASF GitHub Bot commented on FLINK-7670: --- Github user keweishang commented on the issue:

[jira] [Commented] (FLINK-7670) typo in docs runtime section

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181264#comment-16181264 ] ASF GitHub Bot commented on FLINK-7670: --- Github user keweishang closed the pull request at:

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181246#comment-16181246 ] ASF GitHub Bot commented on FLINK-7683: --- Github user bowenli86 commented on the issue:

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-09-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181234#comment-16181234 ] Fabian Hueske commented on FLINK-7548: -- I think there might be a misunderstanding of the

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181245#comment-16181245 ] ASF GitHub Bot commented on FLINK-7683: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink issue #4722: [FLINK-7683] Iterate over keys in KeyedStateBackend

2017-09-26 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4722 LGTM ---

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-26 Thread Paolo Rendano (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181713#comment-16181713 ] Paolo Rendano commented on FLINK-7606: -- Hi [~kkl0u], 1) sure I have to set and I was not setting it

[jira] [Commented] (FLINK-7549) CEP - Pattern not discovered if source streaming is very fast

2017-09-26 Thread Paolo Rendano (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181718#comment-16181718 ] Paolo Rendano commented on FLINK-7549: -- mentioned in > CEP - Pattern not discovered if source

[jira] [Comment Edited] (FLINK-7606) CEP operator leaks state

2017-09-26 Thread Paolo Rendano (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181713#comment-16181713 ] Paolo Rendano edited comment on FLINK-7606 at 9/26/17 10:59 PM: Hi

[jira] [Comment Edited] (FLINK-7606) CEP operator leaks state

2017-09-26 Thread Paolo Rendano (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16176654#comment-16176654 ] Paolo Rendano edited comment on FLINK-7606 at 9/26/17 10:59 PM: Hi

[jira] [Updated] (FLINK-7606) CEP operator leaks state

2017-09-26 Thread Paolo Rendano (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Rendano updated FLINK-7606: - Attachment: Schermata 2017-09-27 alle 00.35.53.png > CEP operator leaks state >

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-09-26 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181847#comment-16181847 ] Xingcan Cui commented on FLINK-7548: Thanks for the explanation, [~fhueske]. I was too paranoid about

[jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

2017-09-26 Thread Raymond Tay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181812#comment-16181812 ] Raymond Tay commented on FLINK-7669: Checked but its still occurring, i'll investigate this a little

[GitHub] flink issue #4704: [hotfix] [docs] Update function name in DataStream API

2017-09-26 Thread phiradet
Github user phiradet commented on the issue: https://github.com/apache/flink/pull/4704 Thanks ---

[GitHub] flink pull request #4694: [FLINK-7654][RabbitMQ Connector] Update RabbitMQ J...

2017-09-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4694 ---

[GitHub] flink pull request #4679: [hotfix] [doc] Fix typo for s3a config in AWS depl...

2017-09-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4679 ---

[GitHub] flink pull request #4708: [FLINK-7393][kinesis connector] Move unit tests th...

2017-09-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4708 ---

[GitHub] flink pull request #4659: [FLINK-4047] Fix documentation about determinism o...

2017-09-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4659 ---

[GitHub] flink pull request #4691: [FLINK-7647] [flip6] Port JobManagerConfigHandler ...

2017-09-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4691 ---

[GitHub] flink pull request #4704: [hotfix] [docs] Update function name in DataStream...

2017-09-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4704 ---

[GitHub] flink pull request #4720: Release 1.3.2 rc3

2017-09-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4720 ---

[GitHub] flink pull request #4687: [hotfix][docs][CEP] wrong method name for PatternF...

2017-09-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4687 ---

[jira] [Commented] (FLINK-7654) Update RabbitMQ Java client to 4.x

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

[jira] [Resolved] (FLINK-7670) typo in docs runtime section

2017-09-26 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7670. Resolution: Fixed Thanks for the fix Kewei. Fixed in {{release-1.3}} via

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141100624 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r14367 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1414,8 +1414,29 @@ object

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141093589 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141105482 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141096297 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141097263 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141097303 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141097202 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141112340 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1414,8 +1414,29 @@ object

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141102418 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141099803 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141093104 --- Diff: docs/dev/table/sql.md --- @@ -746,6 +746,7 @@ The SQL runtime is built on top of Flink's DataSet and DataStream APIs. Internal |

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r14022 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1414,8 +1414,29 @@ object

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141096269 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141106084 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141103652 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141095159 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141096324 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141104254 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141113194 --- Diff: docs/dev/table/sql.md --- @@ -2107,6 +2108,17 @@ VAR_SAMP(value) Returns the sample variance (square of the sample standard

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[GitHub] flink issue #4706: [FLINK-7670][doc] fix typo in docs runtime section

2017-09-26 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4706 I merged. @keweishang could you please close this PR, thanks! ---

[jira] [Created] (FLINK-7695) Port JobConfigHandler to new REST endpoint

2017-09-26 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7695: Summary: Port JobConfigHandler to new REST endpoint Key: FLINK-7695 URL: https://issues.apache.org/jira/browse/FLINK-7695 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181151#comment-16181151 ] ASF GitHub Bot commented on FLINK-7650: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4697: [FLINK-7650] [flip6] Port JobCancellationHandler t...

2017-09-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4697#discussion_r141120508 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobCancellationHeaders.java --- @@ -0,0 +1,68 @@ +/* + * Licensed to

[GitHub] flink issue #4710: [FLINK-7446] [table] Change DefinedRowtimeAttribute to wo...

2017-09-26 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4710 Thanks for the review @twalthr. I've updated the PR. @haohui: This PR preserves the current logic that time attributes are exposed as `TIMESTAMP`. I agree that support for time

[GitHub] flink issue #4570: [FLINK-7438][build]Remove useless import, avoid warnings

2017-09-26 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4570 can someone review this please? :) ---

[jira] [Commented] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180971#comment-16180971 ] ASF GitHub Bot commented on FLINK-7438: --- GitHub user yew1eb reopened a pull request:

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180993#comment-16180993 ] ASF GitHub Bot commented on FLINK-7683: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180992#comment-16180992 ] ASF GitHub Bot commented on FLINK-7683: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180994#comment-16180994 ] ASF GitHub Bot commented on FLINK-7683: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #4722: [FLINK-7683] Iterate over keys in KeyedStateBacken...

2017-09-26 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4722#discussion_r141100065 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTable.java --- @@ -287,6 +289,14 @@ public S get(K key, N

[GitHub] flink pull request #4722: [FLINK-7683] Iterate over keys in KeyedStateBacken...

2017-09-26 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4722#discussion_r141090682 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -252,6

[GitHub] flink pull request #4722: [FLINK-7683] Iterate over keys in KeyedStateBacken...

2017-09-26 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4722#discussion_r141083304 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -252,6

[jira] [Commented] (FLINK-7670) typo in docs runtime section

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181023#comment-16181023 ] ASF GitHub Bot commented on FLINK-7670: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4609: [FLINK-7541] Refactor StateAssignmentOperation

2017-09-26 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4609 Surprisingly even kafka tests have passed this time oO ---

[jira] [Resolved] (FLINK-7647) Port JobManagerConfigHandler to new REST endpoint

2017-09-26 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7647. Resolution: Fixed Merged to {{master}} via

[jira] [Resolved] (FLINK-7393) Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest

2017-09-26 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7393. Resolution: Fixed Thanks for the work! Merged to {{master}} via

[jira] [Closed] (FLINK-7393) Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest

2017-09-26 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7393. -- > Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to >

[GitHub] flink pull request #4700: [FLINK-7649] [flip6] Extend JobTerminationHandler ...

2017-09-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4700#discussion_r141121095 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobTerminationMessageParameters.java --- @@ -26,9 +26,10 @@ * * A

[jira] [Commented] (FLINK-7649) Port JobStoppingHandler to new REST endpoint

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181158#comment-16181158 ] ASF GitHub Bot commented on FLINK-7649: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181224#comment-16181224 ] ASF GitHub Bot commented on FLINK-7446: --- Github user fhueske commented on the issue:

[GitHub] flink pull request #4570: [FLINK-7438][build]Remove useless import, avoid wa...

2017-09-26 Thread yew1eb
GitHub user yew1eb reopened a pull request: https://github.com/apache/flink/pull/4570 [FLINK-7438][build]Remove useless import, avoid warnings ## What is the purpose of the change Avoid warnings,details: [ISSUE #FLINK-7438](https://issues.apache.org/jira/browse/FLINK-7438).

[jira] [Resolved] (FLINK-4047) Fix documentation about determinism of KeySelectors

2017-09-26 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-4047. Resolution: Fixed Assignee: mingleizhang Thanks for the fix [~mingleizhang].

[GitHub] flink pull request #4699: [FLINK-7663] [flip6] Return BAD_REQUEST if Handler...

2017-09-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4699#discussion_r141119740 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestEndpointITCase.java --- @@ -162,8 +225,8 @@ public void testEndpoints() throws

[jira] [Commented] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180963#comment-16180963 ] ASF GitHub Bot commented on FLINK-7438: --- Github user yew1eb closed the pull request at:

[GitHub] flink pull request #4570: [FLINK-7438][build]Remove useless import, avoid wa...

2017-09-26 Thread yew1eb
Github user yew1eb closed the pull request at: https://github.com/apache/flink/pull/4570 ---

[jira] [Commented] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180974#comment-16180974 ] ASF GitHub Bot commented on FLINK-7547: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #4614: [FLINK-7547][build] AsyncFunction.scala extends Function,...

2017-09-26 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4614 can someone review this please? :) ---

[jira] [Commented] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180972#comment-16180972 ] ASF GitHub Bot commented on FLINK-7438: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #4706: [FLINK-7670][doc] fix typo in docs runtime section

2017-09-26 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4706 LGTM, thanks for the fix @keweishang. Merging this to `release-1.3` .. ---

[jira] [Commented] (FLINK-7670) typo in docs runtime section

2017-09-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181029#comment-16181029 ] ASF GitHub Bot commented on FLINK-7670: --- Github user tzulitai commented on the issue:

[GitHub] flink pull request #4727: [FLINK-7667] [flip6] Use ArchivedExecutionGraph as...

2017-09-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4727#discussion_r141110165 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/JobCheckpointingConfiguration.java --- @@ -0,0 +1,128 @@ +/* + *

  1   2   3   >