[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-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&focusedCommentId=15882126#comment-15882126 ] Tao Wang commented on FLINK-5903: - I've located the reason and fix it ASAP. > taskmanager

[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 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 cat

[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 ht

[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-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-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] [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: Webf

[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] [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 assuming

[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&focusedCommentId=15882058#comment-15882058 ] ASF GitHub Bot commented on FLINK-3849: --- Github user godfreyhe commented on a diff i

[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 --- @@ -0,

[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-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] [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: Web

[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&focusedCommentId=15881999#comment-15881999 ] godfrey he edited comment on FLINK-5859 at 2/24/17 5:59 AM: Hi

[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&focusedCommentId=15882017#comment-15882017 ] Xingcan Cui commented on FLINK-5891: Thanks for your explanation, [~greghogan]. I'm af

[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&focusedCommentId=15882007#comment-15882007 ] ASF GitHub Bot commented on FLINK-5692: --- Github user jinmingjian commented on the is

[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 t

[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&focusedCommentId=15881999#comment-15881999 ] godfrey he commented on FLINK-5859: --- Hi, [~fhueske], Thanks for your advice. yes, partit

[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&focusedCommentId=15881992#comment-15881992 ] ASF GitHub Bot commented on FLINK-3679: --- Github user tzulitai commented on a diff in

[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-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&focusedCommentId=15881989#comment-15881989 ] ASF GitHub Bot commented on FLINK-3679: --- Github user haohui commented on a diff in t

[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 --- @@ -37

[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&focusedCommentId=15881986#comment-15881986 ] ASF GitHub Bot commented on FLINK-3679: --- Github user tzulitai commented on a diff in

[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] [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&focusedCommentId=15881949#comment-15881949 ] Tzu-Li (Gordon) Tai edited comment on FLINK-5898 at 2/24/17 5:12 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&focusedCommentId=15881976#comment-15881976 ] Tzu-Li (Gordon) Tai commented on FLINK-5898: That's great! Thanks a lot for th

[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&focusedCommentId=15881967#comment-15881967 ] Scott Kidder commented on FLINK-5898: - Hi [~tzulitai], I'll look into fixing this in

[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&focusedCommentId=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&focusedCommentId=15881949#comment-15881949 ] Tzu-Li (Gordon) Tai commented on FLINK-5898: Thanks for looking into the issue

[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&focusedCommentId=15881900#comment-15881900 ] ASF GitHub Bot commented on FLINK-5899: --- GitHub user shaoxuan-wang opened a pull req

[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. Luckily

[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&focusedCommentId=15881895#comment-15881895 ] ASF GitHub Bot commented on FLINK-5546: --- Github user shijinkui commented on the issu

[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`, th

[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] [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: Imp

[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-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&focusedCommentId=15881829#comment-15881829 ] ASF GitHub Bot commented on FLINK-5586: --- Github user KurtYoung commented on the issu

[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

[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 ListStateD

[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&focusedCommentId=15881789#comment-15881789 ] ASF GitHub Bot commented on FLINK-5881: --- Github user clarkyzl commented on a diff in

[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&focusedCommentId=15881790#comment-15881790 ] ASF GitHub Bot commented on FLINK-5881: --- Github user clarkyzl commented on a diff in

[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

[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 Us

[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. > U

[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&focusedCommentId=15881755#comment-15881755 ] ASF GitHub Bot commented on FLINK-4856: --- Github user shixiaogang closed the pull req

[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 is

[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&focusedCommentId=15881737#comment-15881737 ] Kurt Young commented on FLINK-5859: --- Hi [~fhueske], How about this approach: We both pr

[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

[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 #3302.

[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&focusedCommentId=15881507#comment-15881507 ] ASF GitHub Bot commented on FLINK-5710: --- GitHub user haohui reopened a pull request:

[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 Decim

[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&focusedCommentId=15881427#comment-15881427 ] ASF GitHub Bot commented on FLINK-5767: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15881424#comment-15881424 ] ASF GitHub Bot commented on FLINK-5767: --- Github user fhueske commented on a diff in

[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 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_r102828705 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SumAggFunction.scala --- @@ -127,30 +132,31 @@ class Deci

[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&focusedCommentId=15881428#comment-15881428 ] ASF GitHub Bot commented on FLINK-5767: --- Github user fhueske commented on a diff in

[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 cla

[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&focusedCommentId=15881431#comment-15881431 ] ASF GitHub Bot commented on FLINK-5767: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15881432#comment-15881432 ] ASF GitHub Bot commented on FLINK-5767: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15881425#comment-15881425 ] ASF GitHub Bot commented on FLINK-5767: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15881426#comment-15881426 ] ASF GitHub Bot commented on FLINK-5767: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15881430#comment-15881430 ] ASF GitHub Bot commented on FLINK-5767: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15881423#comment-15881423 ] ASF GitHub Bot commented on FLINK-5767: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15881429#comment-15881429 ] ASF GitHub Bot commented on FLINK-5767: --- Github user fhueske commented on a diff in

[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 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_r102835712 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/MaxAggFunction.scala --- @@ -31,7 +31,8 @@ abstract 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_r102828658 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SumAggFunction.scala --- @@ -67,10 +68,13 @@ abstract cla

[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 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_r102826382 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/MaxAggFunction.scala --- @@ -41,24 +42,33 @@ abstract cla

[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 cla

[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&focusedCommentId=15881376#comment-15881376 ] ASF GitHub Bot commented on FLINK-3679: --- Github user haohui commented on a diff in t

[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 --- @@ -37

[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&focusedCommentId=15881329#comment-15881329 ] ASF GitHub Bot commented on FLINK-5710: --- Github user haohui closed the pull request

[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 enab

[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 #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 consi

[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&focusedCommentId=15881320#comment-15881320 ] ASF GitHub Bot commented on FLINK-5597: --- GitHub user greghogan opened a pull request

[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 BipartiteG

[jira] [Updated] (FLINK-5243) Implement an example for BipartiteGraph

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

[jira] [Updated] (FLINK-5245) Add support for BipartiteGraph mutations

2017-02-23 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-5245: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-2254 > Add support for BipartiteGraph mut

[jira] [Updated] (FLINK-5244) Implement methods for BipartiteGraph transformations

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

[jira] [Updated] (FLINK-5362) Implement methods to access BipartiteGraph properties

2017-02-23 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-5362: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-2254 > Implement methods to access Bipart

[jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

2017-02-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582930#comment-15582930 ] Ted Yu edited comment on FLINK-4848 at 2/23/17 7:26 PM: There is s

[jira] [Resolved] (FLINK-3801) Upgrade Joda-Time library to 2.9.3

2017-02-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-3801. --- Resolution: Later > Upgrade Joda-Time library to 2.9.3 > -- > >

[jira] [Commented] (FLINK-5763) Make savepoints self-contained and relocatable

2017-02-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15881045#comment-15881045 ] Stephan Ewen commented on FLINK-5763: - Second part implemented in 6e7a91741708a2b167a2

[jira] [Closed] (FLINK-5887) Make CheckpointBarrier type immutable

2017-02-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5887. --- > Make CheckpointBarrier type immutable > - > > Key: F

[jira] [Resolved] (FLINK-5887) Make CheckpointBarrier type immutable

2017-02-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5887. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed via 8ffe75a54f24cbd8e69c455b42a4e969b943a279

[jira] [Updated] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology()

2017-02-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5541: -- Description: {code} if (localJar == null) { try { for (final URL url : ((ContextEnvironm

[jira] [Updated] (FLINK-5629) Unclosed RandomAccessFile in StaticFileServerHandler#respondAsLeader()

2017-02-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5629: -- Description: {code} final RandomAccessFile raf; try { raf = new RandomAccessFile(file, "r"); ...

[jira] [Created] (FLINK-5897) Untie Checkpoint Externalization from FileSystems

2017-02-23 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5897: --- Summary: Untie Checkpoint Externalization from FileSystems Key: FLINK-5897 URL: https://issues.apache.org/jira/browse/FLINK-5897 Project: Flink Issue Type: Sub

[jira] [Closed] (FLINK-5877) Fix Scala snippet in Async I/O API doc

2017-02-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5877. --- > Fix Scala snippet in Async I/O API doc > -- > > Key:

[jira] [Resolved] (FLINK-5877) Fix Scala snippet in Async I/O API doc

2017-02-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5877. - Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in - 1.2.1 via b5ec

[GitHub] flink pull request #:

2017-02-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/30c9e2b683bf7f4776ffc23b6a860946a4429ae5#commitcomment-21018833 Great to have this in! I would suggest to mention in the JavaDocs of `MapState.size()` that this can be a potentially expen

[jira] [Closed] (FLINK-5763) Make savepoints self-contained and relocatable

2017-02-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5763. --- > Make savepoints self-contained and relocatable > -- > >

[jira] [Resolved] (FLINK-5763) Make savepoints self-contained and relocatable

2017-02-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5763. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in fcc1efcb05bce13e435946107a842727b1e3ee20 an

[jira] [Commented] (FLINK-5157) Extending AllWindow Function Metadata

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

[GitHub] flink issue #2946: [FLINK-5157] Extend AllWindow function metadata

2017-02-23 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2946 Thanks I'll have a look! --- 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

  1   2   3   >