[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

2017-06-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062594#comment-16062594 ] Timo Walther commented on FLINK-6995: - Thanks for offering your help [~mingleizhang].

[jira] [Commented] (FLINK-6992) add support for IN, NOT IN in tableAPI

2017-06-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062605#comment-16062605 ] Timo Walther commented on FLINK-6992: - Yes, the IN for a list of literals is contained

[jira] [Assigned] (FLINK-6942) Add E() supported in TableAPI

2017-06-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-6942: --- Assignee: Timo Walther > Add E() supported in TableAPI > - > >

[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

2017-06-26 Thread David Anderson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062612#comment-16062612 ] David Anderson commented on FLINK-6995: --- [~mingleizhang] [~twalthr] Adding the warni

[GitHub] flink pull request #4181: Add E() support in Table API

2017-06-26 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/4181 Add E() support in Table API Adds E() to Table API. You can merge this pull request into a Git repository by running: $ git pull https://github.com/twalthr/flink FLINK-6942 Alternatively you

[GitHub] flink issue #4181: [FLINK-6942] [table] Add E() support in Table API

2017-06-26 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4181 Hi @twalthr Thanks a lot for open this PR. It looks great to me. Here only one suggestion is add documentation for tableAPI. Best, SunJincheng --- If your project is set up for i

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

2017-06-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4138#discussion_r123946739 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -0,0 +1,79 @@ +/* + * Lic

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

2017-06-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4138#discussion_r123945022 --- Diff: docs/dev/table/sql.md --- @@ -1573,6 +1573,29 @@ INITCAP(string) + + +{% highlight text %}

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

2017-06-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4138#discussion_r123946426 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -0,0 +1,79 @@ +/* + * Lic

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

2017-06-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4138#discussion_r123944651 --- Diff: docs/dev/table/sql.md --- @@ -1573,6 +1573,29 @@ INITCAP(string) + + +{% highlight text %}

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

2017-06-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4138#discussion_r123946049 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1560,6 +1561,13 @@ class CodeGenerator(

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

2017-06-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4138#discussion_r123947651 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -0,0 +1,79 @@ +/* + * Lic

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

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

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

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-6942) Add E() supported in TableAPI

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

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

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

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

2017-06-26 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3943 @sunjincheng121 the structure looks very good. I would volunteer to go over the changes as a whole and merge this. If @fhueske @wuchong are fine with this? Can you rebase the PR a last time? --- If

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

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

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

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

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

2017-06-26 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/3943 Thanks @twalthr , I'm fine with this ,a great +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 fe

[GitHub] flink issue #3977: [FLINK-5490] Not allowing sinks to be cleared when gettin...

2017-06-26 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3977 @deepakmarathe Thanks for working on this. Before merging, could you please add a test that verifies that we can in fact get the execution plan and still execute the program afterwards. Otherwise, t

[jira] [Commented] (FLINK-5490) ContextEnvironment.getExecutionPlan() clears Sinks

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

[GitHub] flink issue #4181: [FLINK-6942] [table] Add E() support in Table API

2017-06-26 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4181 Thanks for the notice. Actually I updated the docs, but might forgot to add it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If you

[jira] [Commented] (FLINK-6942) Add E() supported in TableAPI

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

[jira] [Commented] (FLINK-6952) Add link to Javadocs

2017-06-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062774#comment-16062774 ] Aljoscha Krettek commented on FLINK-6952: - [~uce] About scaladocs, I think they ar

[GitHub] flink issue #4181: [FLINK-6942] [table] Add E() support in Table API

2017-06-26 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4181 I will merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so,

[jira] [Commented] (FLINK-6942) Add E() supported in TableAPI

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

[GitHub] flink issue #4181: [FLINK-6942] [table] Add E() support in Table API

2017-06-26 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4181 Thanks @twalthr . +1 to merged. --- 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 e

[jira] [Commented] (FLINK-6942) Add E() supported in TableAPI

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

[GitHub] flink pull request #4181: [FLINK-6942] [table] Add E() support in Table API

2017-06-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4181 --- 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-6942) Add E() supported in TableAPI

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

[jira] [Resolved] (FLINK-6942) Add E() supported in TableAPI

2017-06-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6942. - Resolution: Fixed Fix Version/s: 1.4.0 Fixed in 1.4.0: 2d82030277da58040b24a14ff665a9356a4e

[GitHub] flink pull request #4181: [FLINK-6942] [table] Add E() support in Table API

2017-06-26 Thread ch33hau
Github user ch33hau commented on a diff in the pull request: https://github.com/apache/flink/pull/4181#discussion_r123957141 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala --- @@ -924,6 +924,19 @@ object pi { }

[jira] [Commented] (FLINK-6942) Add E() supported in TableAPI

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

[jira] [Commented] (FLINK-6939) Not store IterativeCondition with NFA state

2017-06-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062812#comment-16062812 ] Kostas Kloudas commented on FLINK-6939: --- Hi [~jark], thanks for the quick response!

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

2017-06-26 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3943 @twalthr, sure! Thanks for taking care of this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this f

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

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

[jira] [Resolved] (FLINK-4565) Support for SQL IN operator

2017-06-26 Thread Dmytro Shkvyra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmytro Shkvyra resolved FLINK-4565. --- Resolution: Resolved > Support for SQL IN operator > --- > >

[GitHub] flink issue #3502: [FLINK-4565] Support for SQL IN operator

2017-06-26 Thread DmytroShkvyra
Github user DmytroShkvyra commented on the issue: https://github.com/apache/flink/pull/3502 @Xpray I also wondered when will this PR be merged? --- 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] [Commented] (FLINK-4565) Support for SQL IN operator

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062828#comment-16062828 ] ASF GitHub Bot commented on FLINK-4565: --- Github user DmytroShkvyra commented on the

[jira] [Commented] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization

2017-06-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062827#comment-16062827 ] Stephan Ewen commented on FLINK-7001: - Jark, this is a good idea - there have been dis

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

2017-06-26 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3943 @twalthr Extremely grateful If you can review and merge this PR after I rebase the PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

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

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

[jira] [Created] (FLINK-7004) Switch to Travis Trusty image

2017-06-26 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7004: --- Summary: Switch to Travis Trusty image Key: FLINK-7004 URL: https://issues.apache.org/jira/browse/FLINK-7004 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6991) Inaccessible link under Gelly document

2017-06-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062843#comment-16062843 ] Chesnay Schepler commented on FLINK-6991: - [~njzhuyuqi] You now have contributor p

[jira] [Assigned] (FLINK-6991) Inaccessible link under Gelly document

2017-06-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6991: --- Assignee: njzhuyuqi > Inaccessible link under Gelly document > --

[jira] [Commented] (FLINK-6991) Inaccessible link under Gelly document

2017-06-26 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062848#comment-16062848 ] mingleizhang commented on FLINK-6991: - Thanks to [~Zentol]. :) > Inaccessible link un

[jira] [Commented] (FLINK-6991) Inaccessible link under Gelly document

2017-06-26 Thread njzhuyuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062856#comment-16062856 ] njzhuyuqi commented on FLINK-6991: -- [~Zentol] thanks a lot > Inaccessible link under Gel

[GitHub] flink pull request #4182: [FLINK-7004] Switch to Travis Trusty image

2017-06-26 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4182 [FLINK-7004] Switch to Travis Trusty image Cleaned up version of #4167. With this PR we switch to the trusty image on Travis as it appears to have more stable build times. Other changes incl

[jira] [Commented] (FLINK-7004) Switch to Travis Trusty image

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

[jira] [Commented] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices

2017-06-26 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062864#comment-16062864 ] Fang Yong commented on FLINK-6522: -- Hi [~till.rohrmann], I want to pick this issue. If I

[jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition

2017-06-26 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062863#comment-16062863 ] Dawid Wysakowicz commented on FLINK-3414: - Hi [~kkl0u], [~dian.fu] As there is on

[GitHub] flink pull request #4160: {FLINK-6965] Include snappy-java in flink-dist

2017-06-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4160#discussion_r123971846 --- Diff: tools/travis_mvn_watchdog.sh --- @@ -182,6 +182,13 @@ check_shaded_artifacts() { exit 1 fi + SNAPPY=`cat allClass

[jira] [Commented] (FLINK-6965) Avro is missing snappy dependency

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062865#comment-16062865 ] ASF GitHub Bot commented on FLINK-6965: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4083: [FLINK-6742] Improve savepoint migration failure e...

2017-06-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4083#discussion_r123972388 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2.java --- @@ -168,10 +168,27 @@ public static Savepoint conve

[jira] [Commented] (FLINK-6742) Improve error message when savepoint migration fails due to task removal

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062868#comment-16062868 ] ASF GitHub Bot commented on FLINK-6742: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2017-06-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062869#comment-16062869 ] Timo Walther commented on FLINK-4565: - [~dshkvyra] this issue has been reopened by [~f

[jira] [Reopened] (FLINK-4565) Support for SQL IN operator

2017-06-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-4565: - Assignee: (was: Dmytro Shkvyra) > Support for SQL IN operator > ---

[GitHub] flink pull request #4183: [FLINK-6969][table]Add support for deferred comput...

2017-06-26 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4183 [FLINK-6969][table]Add support for deferred computation for group win… In this PR. I have add support for deferred computation for group window aggregates. - [x] General - Th

[jira] [Commented] (FLINK-6969) Add support for deferred computation for group window aggregates

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062870#comment-16062870 ] ASF GitHub Bot commented on FLINK-6969: --- GitHub user sunjincheng121 opened a pull re

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

2017-06-26 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4138#discussion_r123974055 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -0,0 +1,79 @@ +/*

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

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

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

2017-06-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062877#comment-16062877 ] Fabian Hueske commented on FLINK-6429: -- The vote for Calcite 1.13.0 has passed today

[jira] [Assigned] (FLINK-6310) LocalExecutor#endSession() uses wrong lock for synchronization

2017-06-26 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6310: Assignee: Fang Yong > LocalExecutor#endSession() uses wrong lock for synchronization >

[GitHub] flink pull request #4184: [FLINK-6310] Use lock object for synchronization

2017-06-26 Thread zjureel
GitHub user zjureel opened a pull request: https://github.com/apache/flink/pull/4184 [FLINK-6310] Use lock object for synchronization Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your chan

[jira] [Commented] (FLINK-6310) LocalExecutor#endSession() uses wrong lock for synchronization

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

[jira] [Commented] (FLINK-6909) Flink should support Lombok POJO

2017-06-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062883#comment-16062883 ] Stephan Ewen commented on FLINK-6909: - Can you provide some more information? Why is t

[jira] [Commented] (FLINK-6908) start-cluster.sh accepts batch/streaming mode argument

2017-06-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062885#comment-16062885 ] Stephan Ewen commented on FLINK-6908: - They are no longer used. +1 for removing them.

[GitHub] flink issue #4035: [FLINK-6785] [metrics] Fix ineffective asserts in MetricR...

2017-06-26 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4035 I've resolved the checkstyle issues and will start 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 hav

[jira] [Commented] (FLINK-6890) flink-dist Jar contains non-shaded Guava dependencies (built with Maven 3.0.5)

2017-06-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062889#comment-16062889 ] Stephan Ewen commented on FLINK-6890: - Has this been confirmed? If yes, this should be

[jira] [Commented] (FLINK-6785) Ineffective checks in MetricRegistryTest

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

[jira] [Commented] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062891#comment-16062891 ] Stephan Ewen commented on FLINK-6868: - Is this issue resolved? > Using `scala.binary.

[GitHub] flink issue #4109: [FLINK-6898] [metrics] Limit size of operator component i...

2017-06-26 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4109 a constant is a good idea, will add it and start 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] [Commented] (FLINK-6898) Limit size of operator component in metric name

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

[jira] [Commented] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

2017-06-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062894#comment-16062894 ] Stephan Ewen commented on FLINK-6866: - Not sure how easily this is solvable. After all

[jira] [Created] (FLINK-7005) Optimization steps are missing for nested registered tables

2017-06-26 Thread Timo Walther (JIRA)
Timo Walther created FLINK-7005: --- Summary: Optimization steps are missing for nested registered tables Key: FLINK-7005 URL: https://issues.apache.org/jira/browse/FLINK-7005 Project: Flink Issu

[GitHub] flink issue #3951: [FLINK-6461] Replace usages of deprecated web port key

2017-06-26 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3951 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 this feature enabled and wishes so, or if the fea

[jira] [Commented] (FLINK-6461) Deprecate web-related configuration defaults in ConfigConstants

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

[jira] [Updated] (FLINK-7005) Optimization steps are missing for nested registered tables

2017-06-26 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7005: Affects Version/s: 1.3.0 1.3.1 > Optimization steps are missing for nested re

[GitHub] flink pull request #4178: [FLINK-7000] Add custom configuration local enviro...

2017-06-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4178#discussion_r123979379 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala --- @@ -768,6 +768,18 @@ object StreamEx

[jira] [Commented] (FLINK-7000) Add custom configuration for StreamExecutionEnvironment#createLocalEnvironment

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062907#comment-16062907 ] ASF GitHub Bot commented on FLINK-7000: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4168: [FLINK-6987] Fix erroneous when path containing sp...

2017-06-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4168#discussion_r123980520 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java --- @@ -461,8 +463,9 @@ public LocatableInputSplitAssigner getInputSpl

[jira] [Commented] (FLINK-6987) TextInputFormatTest fails when run in path containing spaces

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062913#comment-16062913 ] ASF GitHub Bot commented on FLINK-6987: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4156: [FLINK-6655] Add validateAndNormalizeUri method to...

2017-06-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4156#discussion_r123980821 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala --- @@ -255,4 +255,75 @@ class MemoryArchivist( g

[GitHub] flink pull request #4156: [FLINK-6655] Add validateAndNormalizeUri method to...

2017-06-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4156#discussion_r123980977 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala --- @@ -255,4 +255,75 @@ class MemoryArchivist( g

[GitHub] flink pull request #4156: [FLINK-6655] Add validateAndNormalizeUri method to...

2017-06-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4156#discussion_r123980868 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala --- @@ -255,4 +255,75 @@ class MemoryArchivist( g

[GitHub] flink pull request #4156: [FLINK-6655] Add validateAndNormalizeUri method to...

2017-06-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4156#discussion_r123980694 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala --- @@ -255,4 +255,75 @@ class MemoryArchivist( g

[GitHub] flink pull request #4156: [FLINK-6655] Add validateAndNormalizeUri method to...

2017-06-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4156#discussion_r123980754 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala --- @@ -255,4 +255,75 @@ class MemoryArchivist( g

[jira] [Commented] (FLINK-6655) Misleading error message when HistoryServer path is empty

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062918#comment-16062918 ] ASF GitHub Bot commented on FLINK-6655: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6655) Misleading error message when HistoryServer path is empty

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062917#comment-16062917 ] ASF GitHub Bot commented on FLINK-6655: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6655) Misleading error message when HistoryServer path is empty

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062919#comment-16062919 ] ASF GitHub Bot commented on FLINK-6655: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6655) Misleading error message when HistoryServer path is empty

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062920#comment-16062920 ] ASF GitHub Bot commented on FLINK-6655: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6655) Misleading error message when HistoryServer path is empty

2017-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16062921#comment-16062921 ] ASF GitHub Bot commented on FLINK-6655: --- Github user zentol commented on a diff in t

[jira] [Closed] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6868. --- Resolution: Fixed [~StephanEwen] yes, thanks for noticing. 1.4: b2062eeeaf68b37aa91e71b65b520

[GitHub] flink issue #4022: [FLINK-5488] stop YarnClient before exception is thrown

2017-06-26 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4022 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 this feature enabled and wishes so, or if the fea

[jira] [Commented] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

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

[GitHub] flink issue #4123: [FLINK-6498] Migrate Zookeeper configuration options

2017-06-26 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4123 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 this feature enabled and wishes so, or if the fea

  1   2   3   >