[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16076051#comment-16076051 ] ASF GitHub Bot commented on FLINK-6996: --- Github user pnowojski commented on the issu

[GitHub] flink issue #4206: [FLINK-6996] FlinkKafkaProducer010 doesn't guarantee at-l...

2017-07-05 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4206 thanks! --- 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 f

[GitHub] flink pull request #4267: [FLINK-7018][streaming] Refactor streamGraph to ma...

2017-07-05 Thread XuPingyong
GitHub user XuPingyong opened a pull request: https://github.com/apache/flink/pull/4267 [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear You can merge this pull request into a Git repository by running: $ git pull https://github.com/PingyongXu/flink FLINK-

[jira] [Commented] (FLINK-7018) Refactor streamGraph to make interfaces clear

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16076036#comment-16076036 ] ASF GitHub Bot commented on FLINK-7018: --- GitHub user XuPingyong opened a pull reques

[jira] [Updated] (FLINK-7018) Refactor streamGraph to make interfaces clear

2017-07-05 Thread Xu Pingyong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Pingyong updated FLINK-7018: --- Summary: Refactor streamGraph to make interfaces clear (was: Refactor streamGraph to make interface c

[jira] [Updated] (FLINK-7018) Refactor streamGraph to make interface clear

2017-07-05 Thread Xu Pingyong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Pingyong updated FLINK-7018: --- Summary: Refactor streamGraph to make interface clear (was: Refactor streamGraph to clean interface)

[jira] [Updated] (FLINK-7018) Refactor streamGraph to clean interface

2017-07-05 Thread Xu Pingyong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Pingyong updated FLINK-7018: --- Summary: Refactor streamGraph to clean interface (was: Refactor streamGraph to clear interface) > Re

[jira] [Updated] (FLINK-7018) Refactor streamGraph to clear interface

2017-07-05 Thread Xu Pingyong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Pingyong updated FLINK-7018: --- Summary: Refactor streamGraph to clear interface (was: Refactor streamGraph to clear interfac) > Ref

[jira] [Updated] (FLINK-7018) Refactor streamGraph to clear interfac

2017-07-05 Thread Xu Pingyong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Pingyong updated FLINK-7018: --- Summary: Refactor streamGraph to clear interfac (was: Refactor streamgraph to clear interface) > Ref

[GitHub] flink pull request #4257: [pre-merge Travis run] Merge for 1.4

2017-07-05 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/4257 --- 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 en

[jira] [Resolved] (FLINK-6422) Unreachable code in FileInputFormat#createInputSplits

2017-07-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6422. Resolution: Fixed Fixed for master via df859fb284f0cefd8ff31bd511d2719469de9fdc. Fix

[jira] [Updated] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6996: --- Fix Version/s: 1.4.0 > FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

[jira] [Resolved] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6996. Resolution: Fixed Fixed for master via 0e7a53189991f7615891e9a168c747f43d1b13c3. Fix

[jira] [Resolved] (FLINK-7041) Deserialize StateBackend from JobCheckpointingSettings with user classloader

2017-07-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7041. Resolution: Fixed Fix Version/s: 1.4.0 Fixed for master via 64c6fa70f53425d09

[jira] [Resolved] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-07-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7038. Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed for mas

[GitHub] flink pull request #4258: [pre-merge Travis run] Merge for 1.3

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

[jira] [Commented] (FLINK-6499) Migrate state configuration options

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

[jira] [Commented] (FLINK-7041) Deserialize StateBackend from JobCheckpointingSettings with user classloader

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

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

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

[GitHub] flink pull request #4173: [FLINK-6499] Migrate state configuration options

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

[jira] [Commented] (FLINK-6422) Unreachable code in FileInputFormat#createInputSplits

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

[GitHub] flink pull request #4206: [FLINK-6996] FlinkKafkaProducer010 doesn't guarant...

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

[GitHub] flink pull request #4232: [FLINK-7041] Deserialize StateBackend from JobChec...

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

[GitHub] flink pull request #4229: [FLINK-7038] [docs] Correct misused term to KeyedS...

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

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

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

[GitHub] flink pull request #4202: [FLINK-6422] [core] Unreachable code in FileInputF...

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

[GitHub] flink pull request #4244: [docs]Added missing "more" word to programming-mod...

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-07-05 Thread hongyuhong
Github user hongyuhong commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r125807639 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamWindowJoinRule.scala --- @@ -20,28 +20,60 @@

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075893#comment-16075893 ] ASF GitHub Bot commented on FLINK-6232: --- Github user hongyuhong commented on the iss

[GitHub] flink issue #3715: [FLINK-6232][Table&SQL]Support proctime inner equi-join b...

2017-07-05 Thread hongyuhong
Github user hongyuhong commented on the issue: https://github.com/apache/flink/pull/3715 Hi @fhueske, thanks for the reviewing, i have update the pr here for reviewing, and also create a new pr https://github.com/apache/flink/issues/4266 to merge the commit, once you finish reviewing,

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075878#comment-16075878 ] ASF GitHub Bot commented on FLINK-6232: --- Github user hongyuhong commented on the iss

[GitHub] flink issue #4266: [FLINK-6232][Table&Sql] support proctime inner windowed s...

2017-07-05 Thread hongyuhong
Github user hongyuhong commented on the issue: https://github.com/apache/flink/pull/4266 Hi @wuchong, thanks for the reminding. There still have some modify in the new commit, so i want to reserve the older commit for easy reviewing, after the reviewing finish, i will close the pr htt

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[GitHub] flink issue #4266: [FLINK-6232][Table&Sql] support proctime inner windowed s...

2017-07-05 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4266 Hi @hongyuhong , is this the same PR with #3715 ? In order to rebase/remove merge commit, please do not create a new PR, otherwise committers may review an out-date PR or lose the review context.

[GitHub] flink pull request #4266: [FLINK-6232][Table&Sql] support proctime inner win...

2017-07-05 Thread hongyuhong
GitHub user hongyuhong opened a pull request: https://github.com/apache/flink/pull/4266 [FLINK-6232][Table&Sql] support proctime inner windowed stream join Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considera

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075864#comment-16075864 ] ASF GitHub Bot commented on FLINK-6232: --- GitHub user hongyuhong opened a pull reques

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink issue #4263: [FLINK-6075] - Support Limit/Top(Sort) for Stream SQL

2017-07-05 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4263 Thank your for the work , I will also look into this in the next days. BTW, can you please close #3714 @rtudoran ? --- If your project is set up for it, you can reply to this email and have your rep

[jira] [Assigned] (FLINK-7021) Flink Task Manager hangs on startup if one Zookeeper node is unresolvable

2017-07-05 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Kidder reassigned FLINK-7021: --- Assignee: Scott Kidder > Flink Task Manager hangs on startup if one Zookeeper node is unresol

[jira] [Commented] (FLINK-6842) Uncomment or remove code in HadoopFileSystem

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

[GitHub] flink issue #4219: [FLINK-6842] [runtime] Uncomment and activate code in Had...

2017-07-05 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4219 Thanks @greghogan, and PR have been updated, please check again. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project d

[GitHub] flink issue #3943: [FLINK-6617][table] Improve JAVA and SCALA logical plans ...

2017-07-05 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3943 Rebase code according 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

[jira] [Commented] (FLINK-6617) Improve JAVA and SCALA logical plans consistent test

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075741#comment-16075741 ] ASF GitHub Bot commented on FLINK-6617: --- Github user sunjincheng121 commented on the

[jira] [Assigned] (FLINK-6810) Add Some built-in Scalar Function supported

2017-07-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6810: -- Assignee: sunjincheng > Add Some built-in Scalar Function supported > -

[jira] [Commented] (FLINK-7109) HadoopUtils#getHadoopConfiguration should not load global configuration

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075594#comment-16075594 ] ASF GitHub Bot commented on FLINK-7109: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #4265: [FLINK-7109] [hadoop] Remove GlobalConfiguration.l...

2017-07-05 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4265 [FLINK-7109] [hadoop] Remove GlobalConfiguration.loadConfiguration from HadoopUtils#getHadoopConfiguration The HadoopUtils#getHadoopConfiguration should not load the global configuration. Inst

[jira] [Updated] (FLINK-7109) HadoopUtils#getHadoopConfiguration should not load global configuration

2017-07-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7109: - Description: The {{HadoopUtils#getHadoopConfiguration}} should not load the global configuration

[jira] [Created] (FLINK-7109) HadoopUtils#getHadoopConfiguration should not load global configuration

2017-07-05 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7109: Summary: HadoopUtils#getHadoopConfiguration should not load global configuration Key: FLINK-7109 URL: https://issues.apache.org/jira/browse/FLINK-7109 Project: Flink

[jira] [Created] (FLINK-7108) Implement Session cluster entry point

2017-07-05 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7108: Summary: Implement Session cluster entry point Key: FLINK-7108 URL: https://issues.apache.org/jira/browse/FLINK-7108 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7107) Start Yarn session via start-up script

2017-07-05 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7107: Summary: Start Yarn session via start-up script Key: FLINK-7107 URL: https://issues.apache.org/jira/browse/FLINK-7107 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

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

[GitHub] flink issue #4110: [FLINK-6900] [metrics] Limit size of metric name componen...

2017-07-05 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4110 yes it is still required, but this PR does address a similar issue. #4109 limits the size of the operator name in the metric identifier. This was a problem for all reporters, because a 200+ ch

[jira] [Closed] (FLINK-7045) Reduce element count of UdfStreamOperatorCheckpointingITCase

2017-07-05 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-7045. - Resolution: Implemented Implemented in master: 2a3ab2bcb68fcb630181186bcce7532dd3bd87b8 > Reduce element

[jira] [Commented] (FLINK-6879) Activate checkstyle for runtime/memory

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

[jira] [Commented] (FLINK-7045) Reduce element count of UdfStreamOperatorCheckpointingITCase

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

[jira] [Commented] (FLINK-7023) Remaining types for Gelly ValueArrays

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

[GitHub] flink pull request #4097: [FLINK-6879] [runtime] Activate checkstyle for run...

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

[GitHub] flink pull request #4203: [FLINK-7023] [gelly] Remaining types for Gelly Val...

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

[GitHub] flink pull request #4230: [FLINK-7045] [checkpoints] Reduce element count of...

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

[GitHub] flink pull request #4201: [FLINK-7006] [gelly] Base class using POJOs for Ge...

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

[jira] [Commented] (FLINK-7045) Reduce element count of UdfStreamOperatorCheckpointingITCase

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075412#comment-16075412 ] ASF GitHub Bot commented on FLINK-7045: --- Github user greghogan commented on the issu

[GitHub] flink issue #4230: [FLINK-7045] [checkpoints] Reduce element count of UdfStr...

2017-07-05 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4230 @zhangminglei thanks for the contributions. Merging ... --- 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

[jira] [Updated] (FLINK-7106) Make SubmittedJobGraphStore implementation configurable

2017-07-05 Thread Chen Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-7106: Summary: Make SubmittedJobGraphStore implementation configurable (was: Make SubmittedJobGraphStore configur

[jira] [Created] (FLINK-7106) Make SubmittedJobGraphStore configurable

2017-07-05 Thread Chen Qin (JIRA)
Chen Qin created FLINK-7106: --- Summary: Make SubmittedJobGraphStore configurable Key: FLINK-7106 URL: https://issues.apache.org/jira/browse/FLINK-7106 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6822) Activate checkstyle for runtime/plugable

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075254#comment-16075254 ] ASF GitHub Bot commented on FLINK-6822: --- Github user greghogan commented on the issu

[GitHub] flink issue #4064: [FLINK-6822] Activate checkstyle for runtime/plugable

2017-07-05 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4064 +1 --- 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 featur

[jira] [Commented] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075252#comment-16075252 ] ASF GitHub Bot commented on FLINK-6900: --- Github user greghogan commented on the issu

[GitHub] flink issue #4110: [FLINK-6900] [metrics] Limit size of metric name componen...

2017-07-05 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4110 @zentol since this has not yet been reviewed I'll chance a question: is this needed in addition to #4109? --- If your project is set up for it, you can reply to this email and have your reply appe

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[GitHub] flink issue #4187: [FLINK-6998][Kafka Connector] Add kafka offset commit met...

2017-07-05 Thread zhenzhongxu
Github user zhenzhongxu commented on the issue: https://github.com/apache/flink/pull/4187 @tzulitai rebase done. --- 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 wishe

[jira] [Commented] (FLINK-6903) Activate checkstyle for runtime/akka

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075229#comment-16075229 ] ASF GitHub Bot commented on FLINK-6903: --- Github user greghogan commented on the issu

[GitHub] flink issue #4114: [FLINK-6903] [runtime] Activate checkstyle for runtime/ak...

2017-07-05 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4114 @zentol is this worthwhile to review and commit? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this f

[jira] [Commented] (FLINK-7006) Base class using POJOs for Gelly algorithms

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075218#comment-16075218 ] ASF GitHub Bot commented on FLINK-7006: --- Github user greghogan commented on the issu

[GitHub] flink issue #4201: [FLINK-7006] [gelly] Base class using POJOs for Gelly alg...

2017-07-05 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4201 Thanks for the review @vasia, I somehow missed the notification. --- 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

[jira] [Commented] (FLINK-6842) Uncomment or remove code in HadoopFileSystem

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075204#comment-16075204 ] ASF GitHub Bot commented on FLINK-6842: --- Github user greghogan commented on the issu

[GitHub] flink issue #4219: [FLINK-6842] [runtime] Uncomment and activate code in Had...

2017-07-05 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4219 The call to `hadoopConf.getClass` is no longer needed and the early `return null` could be removed. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-7042) Fix jar file discovery in YARN tests

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

[GitHub] flink pull request #4264: [FLINK-7042] [yarn] Fix jar file discovery flink-y...

2017-07-05 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/4264 [FLINK-7042] [yarn] Fix jar file discovery flink-yarn-tests Add dependencies for batch and streaming WordCount programs and copies the jar files into a new target/programs directory. The integrati

[jira] [Commented] (FLINK-4371) Add ability to take savepoints from job manager RESTful API

2017-07-05 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075151#comment-16075151 ] Zhenzhong Xu commented on FLINK-4371: - [~uce] Sure, go for it! Thanks for driving! >

[jira] [Resolved] (FLINK-3130) Visualize throughput of tasks

2017-07-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3130. --- Resolution: Fixed This has been resolved for a while now. > Visualize throughput of tasks > -

[jira] [Commented] (FLINK-5253) Remove special treatment of "dynamic properties"

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075050#comment-16075050 ] ASF GitHub Bot commented on FLINK-5253: --- Github user EronWright commented on the iss

[GitHub] flink issue #3356: [FLINK-5253] Remove special treatment of "dynamic propert...

2017-07-05 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3356 @tillrohrmann the `dynamicProperties` static field is unfortunate, yes. To eliminate it, we must evaluate the use of the zero-arg `GlobalConfiguration.loadConfiguration()` that is used in many p

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink issue #4263: [FLINK-6075] - Support Limit/Top(Sort) for Stream SQL

2017-07-05 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/4263 @fhueske I have implemented the support for offset and fetch for both rowtime and proctime. This PR will close the JIRA issue. Please have a look --- If your project is set up for it, you

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-07-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075001#comment-16075001 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran closed the pull reques

[GitHub] flink pull request #4003: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-07-05 Thread rtudoran
Github user rtudoran closed the pull request at: https://github.com/apache/flink/pull/4003 --- 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 en

[GitHub] flink issue #4003: [FLINK-6075] - Support Limit/Top(Sort) for Stream SQL

2017-07-05 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/4003 I have updated these contributions against the master branch and based on the latest modifications after the merge of the basis for orderby. I opened a new PR for this #4263. I will close this o

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #4263: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-07-05 Thread rtudoran
GitHub user rtudoran opened a pull request: https://github.com/apache/flink/pull/4263 [FLINK-6075] - Support Limit/Top(Sort) for Stream SQL Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If you

[jira] [Commented] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations

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

[GitHub] flink pull request #3783: [FLINK-6388] Add support for DISTINCT into Code Ge...

2017-07-05 Thread stefanobortoli
Github user stefanobortoli commented on a diff in the pull request: https://github.com/apache/flink/pull/3783#discussion_r125677038 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -296,6 +299,39 @@ class CodeGenerator(

[jira] [Closed] (FLINK-6925) Add CONCAT/CONCAT_WS supported in SQL

2017-07-05 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-6925. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed in 57c675ea58ab2a0003da89385a9f092f943da3ae > Add CONCAT/CO

[jira] [Commented] (FLINK-6925) Add CONCAT/CONCAT_WS supported in SQL

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

[GitHub] flink pull request #4138: [FLINK-6925][table]Add CONCAT/CONCAT_WS supported ...

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

[jira] [Commented] (FLINK-5253) Remove special treatment of "dynamic properties"

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

[GitHub] flink pull request #3356: [FLINK-5253] Remove special treatment of "dynamic ...

2017-07-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3356#discussion_r125669802 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -319,13 +306,7 @@ public AbstractYarnClusterDescriptor cre

[jira] [Commented] (FLINK-5253) Remove special treatment of "dynamic properties"

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

[jira] [Commented] (FLINK-5253) Remove special treatment of "dynamic properties"

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

  1   2   >