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

2017-02-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881829#comment-15881829 ] ASF GitHub Bot commented on FLINK-5586: --- Github user KurtYoung commented on the issue:

[GitHub] flink issue #3339: [FLINK-5586] [table] Extend TableProgramsClusterTestBase ...

2017-02-23 Thread KurtYoung
Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3339 rebased to the latest master. --- 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

[GitHub] flink pull request #3354: [FLINK-5767] [Table] New aggregate function interf...

2017-02-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3354#discussion_r102835712 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/MaxAggFunction.scala --- @@ -31,7 +31,8 @@ abstract

[GitHub] flink pull request #3354: [FLINK-5767] [Table] New aggregate function interf...

2017-02-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3354#discussion_r102828658 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SumAggFunction.scala --- @@ -67,10 +68,13 @@ abstract

[jira] [Commented] (FLINK-5767) New aggregate function interface and built-in aggregate functions

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

[jira] [Commented] (FLINK-5767) New aggregate function interface and built-in aggregate functions

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

[jira] [Commented] (FLINK-5767) New aggregate function interface and built-in aggregate functions

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

[jira] [Commented] (FLINK-5767) New aggregate function interface and built-in aggregate functions

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

[jira] [Commented] (FLINK-5767) New aggregate function interface and built-in aggregate functions

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

[jira] [Commented] (FLINK-5767) New aggregate function interface and built-in aggregate functions

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

[jira] [Commented] (FLINK-5767) New aggregate function interface and built-in aggregate functions

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

[jira] [Commented] (FLINK-5767) New aggregate function interface and built-in aggregate functions

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

[jira] [Commented] (FLINK-5767) New aggregate function interface and built-in aggregate functions

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

[GitHub] flink pull request #3354: [FLINK-5767] [Table] New aggregate function interf...

2017-02-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3354#discussion_r102835585 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SumAggFunction.scala --- @@ -32,7 +31,8 @@ abstract

[GitHub] flink pull request #3354: [FLINK-5767] [Table] New aggregate function interf...

2017-02-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3354#discussion_r102828705 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SumAggFunction.scala --- @@ -127,30 +132,31 @@ class

[jira] [Commented] (FLINK-5767) New aggregate function interface and built-in aggregate functions

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

[GitHub] flink pull request #3354: [FLINK-5767] [Table] New aggregate function interf...

2017-02-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3354#discussion_r102828543 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SumAggFunction.scala --- @@ -44,21 +44,22 @@ abstract

[GitHub] flink pull request #3354: [FLINK-5767] [Table] New aggregate function interf...

2017-02-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3354#discussion_r102826611 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/MaxAggFunction.scala --- @@ -109,8 +119,11 @@ class

[GitHub] flink pull request #3354: [FLINK-5767] [Table] New aggregate function interf...

2017-02-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3354#discussion_r102835657 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/MinAggFunction.scala --- @@ -31,7 +31,8 @@ abstract

[GitHub] flink pull request #3336: [FLINK-4856][state] Add MapState in KeyedState

2017-02-23 Thread shixiaogang
Github user shixiaogang closed the pull request at: https://github.com/apache/flink/pull/3336 --- 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

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

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

[jira] [Created] (FLINK-5900) Add non-partial merge Aggregates and unit tests

2017-02-23 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5900: Summary: Add non-partial merge Aggregates and unit tests Key: FLINK-5900 URL: https://issues.apache.org/jira/browse/FLINK-5900 Project: Flink Issue Type:

[GitHub] flink pull request #3354: [FLINK-5767] [Table] New aggregate function interf...

2017-02-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3354#discussion_r102835493 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SumAggFunction.scala --- @@ -32,7 +31,8 @@ abstract

[GitHub] flink pull request #3354: [FLINK-5767] [Table] New aggregate function interf...

2017-02-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3354#discussion_r102826382 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/MaxAggFunction.scala --- @@ -41,24 +42,33 @@ abstract

[GitHub] flink pull request #3354: [FLINK-5767] [Table] New aggregate function interf...

2017-02-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3354#discussion_r102826652 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/MinAggFunction.scala --- @@ -41,24 +42,33 @@ abstract

[jira] [Closed] (FLINK-5863) Unify the serialization of queryable list states in different backends

2017-02-23 Thread Xiaogang Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaogang Shi closed FLINK-5863. --- Resolution: Fixed Now that we are refactoring the queryable states, we can make the changes then. >

[jira] [Closed] (FLINK-5790) Use list types when ListStateDescriptor extends StateDescriptor

2017-02-23 Thread Xiaogang Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaogang Shi closed FLINK-5790. --- Resolution: Fixed Fixed via d47446cafffe0d34d89488f6eb860aa139ceb3f1 > Use list types when

[jira] [Created] (FLINK-5899) Fix the bug in initializing the DataSetTumbleTimeWindowAggReduceGroupFunction

2017-02-23 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5899: Summary: Fix the bug in initializing the DataSetTumbleTimeWindowAggReduceGroupFunction Key: FLINK-5899 URL: https://issues.apache.org/jira/browse/FLINK-5899 Project:

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-23 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881737#comment-15881737 ] Kurt Young commented on FLINK-5859: --- Hi [~fhueske], How about this approach: We both provide

[jira] [Commented] (FLINK-5881) ScalarFunction(UDF) should support variable types and variable arguments

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

[jira] [Commented] (FLINK-5881) ScalarFunction(UDF) should support variable types and variable arguments

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

[GitHub] flink pull request #3389: [FLINK-5881] [table] ScalarFunction(UDF) should su...

2017-02-23 Thread clarkyzl
Github user clarkyzl commented on a diff in the pull request: https://github.com/apache/flink/pull/3389#discussion_r102865002 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -78,20 +78,7 @@ object

[GitHub] flink pull request #3389: [FLINK-5881] [table] ScalarFunction(UDF) should su...

2017-02-23 Thread clarkyzl
Github user clarkyzl commented on a diff in the pull request: https://github.com/apache/flink/pull/3389#discussion_r102864763 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -140,6 +138,24 @@ object

[jira] [Commented] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

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

[jira] [Updated] (FLINK-5242) Implement Scala API for BipartiteGraph

2017-02-23 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-5242: -- Issue Type: Sub-task (was: New Feature) Parent: FLINK-2254 > Implement Scala API for

[GitHub] flink pull request #3404: [FLINK-5597] [docs] Improve the LocalClusteringCoe...

2017-02-23 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3404 [FLINK-5597] [docs] Improve the LocalClusteringCoefficient documentation Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Updated] (FLINK-5597) Improve the LocalClusteringCoefficient documentation

2017-02-23 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-5597: -- Fix Version/s: 1.3.0 > Improve the LocalClusteringCoefficient documentation >

[GitHub] flink pull request #3314: [FLINK-3679] DeserializationSchema should handle z...

2017-02-23 Thread haohui
Github user haohui commented on a diff in the pull request: https://github.com/apache/flink/pull/3314#discussion_r102830609 --- Diff: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SimpleConsumerThread.java --- @@

[GitHub] flink pull request #3370: [FLINK-5710] Add ProcTime() function to indicate S...

2017-02-23 Thread haohui
Github user haohui closed the pull request at: https://github.com/apache/flink/pull/3370 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

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

[jira] [Commented] (FLINK-5597) Improve the LocalClusteringCoefficient documentation

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

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881999#comment-15881999 ] godfrey he commented on FLINK-5859: --- Hi, [~fhueske], Thanks for your advice. yes, partition pruning is a

[jira] [Updated] (FLINK-5901) DAG can not show properly in IE

2017-02-23 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5901: Description: The DAG of running jobs can not show properly in IE11(I am using 11.0.9600.18059, but

[jira] [Created] (FLINK-5902) Some images can not show in IE

2017-02-23 Thread Tao Wang (JIRA)
Tao Wang created FLINK-5902: --- Summary: Some images can not show in IE Key: FLINK-5902 URL: https://issues.apache.org/jira/browse/FLINK-5902 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-5901) DAG can not show properly in IE

2017-02-23 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5901: Attachment: IE11 with problem.png > DAG can not show properly in IE > --- > >

[jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

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

[jira] [Comment Edited] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881999#comment-15881999 ] godfrey he edited comment on FLINK-5859 at 2/24/17 5:59 AM: Hi, [~fhueske],

[jira] [Updated] (FLINK-5902) Some images can not show in IE

2017-02-23 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5902: Attachment: chrome is ok.png > Some images can not show in IE > -- > >

[jira] [Updated] (FLINK-5902) Some images can not show in IE

2017-02-23 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5902: Attachment: IE 11 with problem.png > Some images can not show in IE > -- > >

[jira] [Updated] (FLINK-5901) DAG can not show properly in IE

2017-02-23 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5901: Attachment: (was: IE11 with problem.png) > DAG can not show properly in IE >

[jira] [Updated] (FLINK-5570) Support register external catalog to table environment

2017-02-23 Thread jingzhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jingzhang updated FLINK-5570: - Description: This issue aims to support register one or more {{ExternalCatalog}} (which is referred in

[GitHub] flink pull request #3405: [FLINK-5899] [table] Fix the bug in EventTimeTumbl...

2017-02-23 Thread shaoxuan-wang
GitHub user shaoxuan-wang opened a pull request: https://github.com/apache/flink/pull/3405 [FLINK-5899] [table] Fix the bug in EventTimeTumblingWindow for non-partialMerge aggregate I have changed the supportPartial to false for all built-in Aggregates, and run all the UTs.

[jira] [Commented] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-02-23 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881967#comment-15881967 ] Scott Kidder commented on FLINK-5898: - Hi [~tzulitai], I'll look into fixing this in the KPL. I

[jira] [Commented] (FLINK-5903) taskmanager.numberOfTaskSlots and yarn.containers.vcores did not work well in YARN mode

2017-02-23 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15882126#comment-15882126 ] Tao Wang commented on FLINK-5903: - I've located the reason and fix it ASAP. >

[jira] [Created] (FLINK-5903) taskmanager.numberOfTaskSlots and yarn.containers.vcores did not work well in YARN mode

2017-02-23 Thread Tao Wang (JIRA)
Tao Wang created FLINK-5903: --- Summary: taskmanager.numberOfTaskSlots and yarn.containers.vcores did not work well in YARN mode Key: FLINK-5903 URL: https://issues.apache.org/jira/browse/FLINK-5903 Project:

[GitHub] flink issue #3190: [FLINK-5546][build] java.io.tmpdir setted as project buil...

2017-02-23 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/3190 > Can we just use the ${project.build.directory} as java.io.tmpdir ? @wenlong88 Sorry for late reply. It's good question. If use `${project.build.directory}` without sub directory `tmp`,

[jira] [Commented] (FLINK-5546) java.io.tmpdir setted as project build directory in surefire plugin

2017-02-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881895#comment-15881895 ] ASF GitHub Bot commented on FLINK-5546: --- Github user shijinkui commented on the issue:

[jira] [Comment Edited] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-02-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881949#comment-15881949 ] Tzu-Li (Gordon) Tai edited comment on FLINK-5898 at 2/24/17 5:12 AM: -

[GitHub] flink pull request #3314: [FLINK-3679] DeserializationSchema should handle z...

2017-02-23 Thread haohui
Github user haohui commented on a diff in the pull request: https://github.com/apache/flink/pull/3314#discussion_r102881264 --- Diff: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SimpleConsumerThread.java --- @@

[jira] [Commented] (FLINK-5692) Add an Option to Deactivate Kryo Fallback for Serializers

2017-02-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15882007#comment-15882007 ] ASF GitHub Bot commented on FLINK-5692: --- Github user jinmingjian commented on the issue:

[GitHub] flink issue #3373: [FLINK-5692] [config] Add an Option to Deactivate Kryo Fa...

2017-02-23 Thread jinmingjian
Github user jinmingjian commented on the issue: https://github.com/apache/flink/pull/3373 @StephanEwen Just my coding habit. Correction done. And very appreciated for your review. I am open for more contribution! :tada: --- If your project is set up for it, you can reply

[jira] [Updated] (FLINK-5903) taskmanager.numberOfTaskSlots and yarn.containers.vcores did not work well in YARN mode

2017-02-23 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5903: Attachment: set yarn.container.vcores to 5_RM.JPG set yarn.container.vcores to 5_JM.JPG

[jira] [Commented] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-02-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881949#comment-15881949 ] Tzu-Li (Gordon) Tai commented on FLINK-5898: Thanks for looking into the issue [~skidder].

[jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

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

[GitHub] flink pull request #3314: [FLINK-3679] DeserializationSchema should handle z...

2017-02-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3314#discussion_r102881632 --- Diff: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SimpleConsumerThread.java --- @@

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

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

[GitHub] flink pull request #3166: [FLINK-3849] Add FilterableTableSource interface a...

2017-02-23 Thread godfreyhe
Github user godfreyhe commented on a diff in the pull request: https://github.com/apache/flink/pull/3166#discussion_r102886003 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/PushFilterIntoStreamTableSourceScanRule.scala --- @@

[jira] [Updated] (FLINK-5901) DAG can not show properly in IE

2017-02-23 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5901: Attachment: using IE.png > DAG can not show properly in IE > --- > >

[jira] [Updated] (FLINK-5901) DAG can not show properly in IE

2017-02-23 Thread Tao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tao Wang updated FLINK-5901: Attachment: using chrom(same job).png > DAG can not show properly in IE > --- >

[jira] [Updated] (FLINK-5899) Fix the bug in EventTimeTumblingWindow for non-partialMerge aggregate

2017-02-23 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5899: - Summary: Fix the bug in EventTimeTumblingWindow for non-partialMerge aggregate (was: Fix the bug

[jira] [Commented] (FLINK-5899) Fix the bug in EventTimeTumblingWindow for non-partialMerge aggregate

2017-02-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881900#comment-15881900 ] ASF GitHub Bot commented on FLINK-5899: --- GitHub user shaoxuan-wang opened a pull request:

[jira] [Comment Edited] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-02-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881949#comment-15881949 ] Tzu-Li (Gordon) Tai edited comment on FLINK-5898 at 2/24/17 4:53 AM: -

[jira] [Commented] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-02-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881976#comment-15881976 ] Tzu-Li (Gordon) Tai commented on FLINK-5898: That's great! Thanks a lot for the efforts and

[GitHub] flink pull request #3314: [FLINK-3679] DeserializationSchema should handle z...

2017-02-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3314#discussion_r102881092 --- Diff: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SimpleConsumerThread.java --- @@

[jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

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

[jira] [Commented] (FLINK-5891) ConnectedComponents is broken when object reuse enabled

2017-02-23 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15882017#comment-15882017 ] Xingcan Cui commented on FLINK-5891: Thanks for your explanation, [~greghogan]. I'm afraid my PR on

[jira] [Created] (FLINK-5901) DAG can not show properly in IE

2017-02-23 Thread Tao Wang (JIRA)
Tao Wang created FLINK-5901: --- Summary: DAG can not show properly in IE Key: FLINK-5901 URL: https://issues.apache.org/jira/browse/FLINK-5901 Project: Flink Issue Type: Bug Components:

[GitHub] flink pull request #3406: [flink-5568] [Table API & SQL]Introduce interface ...

2017-02-23 Thread beyond1920
GitHub user beyond1920 opened a pull request: https://github.com/apache/flink/pull/3406 [flink-5568] [Table API & SQL]Introduce interface for catalog, and provide an in-memory implementation. Integrate external catalog with calcite catalog This pr aims to introduce interface for

[GitHub] flink pull request #3370: [FLINK-5710] Add ProcTime() function to indicate S...

2017-02-23 Thread haohui
GitHub user haohui reopened a pull request: https://github.com/apache/flink/pull/3370 [FLINK-5710] Add ProcTime() function to indicate StreamSQL. This is the commit we used internally -- There is no unit tests associated with this PR. It simply serves as a reference point for

[jira] [Commented] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

2017-02-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881507#comment-15881507 ] ASF GitHub Bot commented on FLINK-5710: --- GitHub user haohui reopened a pull request:

[jira] [Created] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-02-23 Thread Scott Kidder (JIRA)
Scott Kidder created FLINK-5898: --- Summary: Race-Condition with Amazon Kinesis KPL Key: FLINK-5898 URL: https://issues.apache.org/jira/browse/FLINK-5898 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-5743) Mark WindowedStream.aggregate* methods as PublicEvolving

2017-02-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5743: Fix Version/s: 1.3.0 > Mark WindowedStream.aggregate* methods as PublicEvolving >

[jira] [Created] (FLINK-5894) HA docs are misleading re: state backends

2017-02-23 Thread David Anderson (JIRA)
David Anderson created FLINK-5894: - Summary: HA docs are misleading re: state backends Key: FLINK-5894 URL: https://issues.apache.org/jira/browse/FLINK-5894 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5891) ConnectedComponents is broken when object reuse enabled

2017-02-23 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15880459#comment-15880459 ] Greg Hogan commented on FLINK-5891: --- [~xccui] even when wrapping in another object both references will

[GitHub] flink issue #2982: [FLINK-4460] Side Outputs in Flink

2017-02-23 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2982 Thanks for looking at that! I'll open a new discussion thread on the Mailing lists to discuss Side Outputs and split/select and how we're going to proceed with that. Regarding your other

[GitHub] flink pull request #3393: [FLINK-3903][docs] adding alternative installation...

2017-02-23 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3393#discussion_r102723574 --- Diff: docs/quickstart/setup_quickstart.md --- @@ -72,6 +72,15 @@ $ cd build-target # this is where Flink is installed to ~~~

[jira] [Commented] (FLINK-3903) Homebrew Installation

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

[GitHub] flink pull request #3366: [FLINK-3427] [webui] watermarks tab and low waterm...

2017-02-23 Thread nellboy
Github user nellboy commented on a diff in the pull request: https://github.com/apache/flink/pull/3366#discussion_r102726419 --- Diff: flink-runtime-web/web-dashboard/app/scripts/index.coffee --- @@ -30,7 +30,7 @@ angular.module('flinkApp', ['ui.router', 'angularMoment',

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

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

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

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

[GitHub] flink pull request #3366: [FLINK-3427] [webui] watermarks tab and low waterm...

2017-02-23 Thread nellboy
Github user nellboy commented on a diff in the pull request: https://github.com/apache/flink/pull/3366#discussion_r102726454 --- Diff: flink-runtime-web/web-dashboard/app/scripts/modules/jobs/jobs.ctrl.coffee --- @@ -81,6 +78,51 @@ angular.module('flinkApp')

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

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

[GitHub] flink pull request #3366: [FLINK-3427] [webui] watermarks tab and low waterm...

2017-02-23 Thread nellboy
Github user nellboy commented on a diff in the pull request: https://github.com/apache/flink/pull/3366#discussion_r102726198 --- Diff: flink-runtime-web/web-dashboard/app/scripts/common/filters.coffee --- @@ -87,3 +87,27 @@ angular.module('flinkApp') .filter

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15880416#comment-15880416 ] Fabian Hueske commented on FLINK-5859: -- For such cases, we could either 1. implement

[jira] [Commented] (FLINK-4460) Side Outputs in Flink

2017-02-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15880467#comment-15880467 ] ASF GitHub Bot commented on FLINK-4460: --- Github user aljoscha commented on the issue:

[GitHub] flink pull request #3366: [FLINK-3427] [webui] watermarks tab and low waterm...

2017-02-23 Thread nellboy
Github user nellboy commented on a diff in the pull request: https://github.com/apache/flink/pull/3366#discussion_r102725706 --- Diff: flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node.watermarks.jade --- @@ -0,0 +1,27 @@ +// + Licensed to the Apache

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

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

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

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

[GitHub] flink pull request #3366: [FLINK-3427] [webui] watermarks tab and low waterm...

2017-02-23 Thread nellboy
Github user nellboy commented on a diff in the pull request: https://github.com/apache/flink/pull/3366#discussion_r102725620 --- Diff: flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node.watermarks.jade --- @@ -0,0 +1,27 @@ +// + Licensed to the Apache

[GitHub] flink pull request #3366: [FLINK-3427] [webui] watermarks tab and low waterm...

2017-02-23 Thread nellboy
Github user nellboy commented on a diff in the pull request: https://github.com/apache/flink/pull/3366#discussion_r102725785 --- Diff: flink-runtime-web/web-dashboard/app/scripts/common/filters.coffee --- @@ -87,3 +87,27 @@ angular.module('flinkApp') .filter

  1   2   3   >