[jira] [Comment Edited] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

2017-07-27 Thread Egor Litvinenko (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102771#comment-16102771 ] Egor Litvinenko edited comment on FLINK-7274 at 7/27/17 6:21 AM: - Simple

[GitHub] flink pull request #4408: Release 1.3

2017-07-27 Thread Ashwin4590
GitHub user Ashwin4590 opened a pull request: https://github.com/apache/flink/pull/4408 Release 1.3 *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the community review your contribution in the best possible way,

[jira] [Commented] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

2017-07-27 Thread Egor Litvinenko (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102771#comment-16102771 ] Egor Litvinenko commented on FLINK-7274: Simple example created with Libre Offices - [^Untitled

[jira] [Updated] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

2017-07-27 Thread Egor Litvinenko (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Egor Litvinenko updated FLINK-7274: --- Attachment: Untitled 1.csv > ParserError NUMERIC_VALUE_FORMAT_ERROR >

[jira] [Comment Edited] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

2017-07-27 Thread Egor Litvinenko (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102771#comment-16102771 ] Egor Litvinenko edited comment on FLINK-7274 at 7/27/17 6:20 AM: - Simple

[jira] [Commented] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

2017-07-27 Thread Egor Litvinenko (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102932#comment-16102932 ] Egor Litvinenko commented on FLINK-7274: I see. Excellent, I think, we can close this issue. Thank

[jira] [Commented] (FLINK-7098) Start standalone cluster entry point via start-up script

2017-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102931#comment-16102931 ] ASF GitHub Bot commented on FLINK-7098: --- Github user tillrohrmann commented on the issue:

[GitHub] flink pull request #4406: [FLINK-7280] Wrong clearing SharedBuffer of Equal ...

2017-07-27 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/4406 [FLINK-7280] Wrong clearing SharedBuffer of Equal elements with same … ## What is the purpose of the change Fixes a bug that resulted in not clearing the NFA when the matched

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[GitHub] flink issue #3829: [FLINK-6442] [table] Extend TableAPI Support Sink Table R...

2017-07-27 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3829 That looks very good to me! :-) Thanks for starting the discussion on the ml. --- 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

[jira] [Commented] (FLINK-7280) Wrong clearing SharedBuffer of Equal elements with same Timestamp

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

[GitHub] flink pull request #4407: [FLINK-7281] Fix various issues in (Maven) release...

2017-07-27 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/4407 [FLINK-7281] Fix various issues in (Maven) release infrastructure ## What is the purpose of the change Fix various issues in the release infrastructure and Maven. ## Brief

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129777841 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -722,12 +697,30 @@ public ApplicationReport

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[jira] [Commented] (FLINK-7249) Bump Java version in build plugin

2017-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102970#comment-16102970 ] ASF GitHub Bot commented on FLINK-7249: --- Github user greghogan commented on the issue:

[GitHub] flink issue #4262: [FLINK-7098] Adapt startup scripts to start Flip-6 standa...

2017-07-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4262 Thanks for the review @zentol. Will rebase this PR and if Travis gives green light, then I'll merge it. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Created] (FLINK-7279) MiniCluster can deadlock at shut down

2017-07-27 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7279: Summary: MiniCluster can deadlock at shut down Key: FLINK-7279 URL: https://issues.apache.org/jira/browse/FLINK-7279 Project: Flink Issue Type: Bug

[GitHub] flink issue #4408: Release 1.3

2017-07-27 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4408 Hi @Ashwin4590, this seems to be opened by accident? Could you close the PR? Thanks. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129771505 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -478,12 +485,15 @@ public static void

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129769550 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java --- @@ -58,7 +58,7 @@ public void addGeneralOptions(Options baseOptions)

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129769520 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java --- @@ -77,10 +77,10 @@ public StandaloneClusterClient

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129770778 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnCLI.java --- @@ -214,22 +218,21 @@ public void addGeneralOptions(Options

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129774438 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java --- @@ -210,6 +207,7 @@ public void

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129774051 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -163,23 +161,17 @@ public

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129768986 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CustomCommandLine.java --- @@ -62,25 +62,27 @@ * Retrieves a client for a

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129772021 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -549,7 +559,12 @@ protected void runWithArgs(String[] args, String

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129770769 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnCLI.java --- @@ -214,22 +218,21 @@ public void addGeneralOptions(Options

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[jira] [Created] (FLINK-7281) Fix various issues in (Maven) release infrastructure

2017-07-27 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7281: --- Summary: Fix various issues in (Maven) release infrastructure Key: FLINK-7281 URL: https://issues.apache.org/jira/browse/FLINK-7281 Project: Flink

[GitHub] flink issue #4398: [FLINK-7249] [build] Bump java.version property to 1.8

2017-07-27 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4398 Also need to update the documentation. $ grep -lir "java 7" docs/ docs//quickstart/java_api_quickstart.md docs//quickstart/scala_api_quickstart.md

[jira] [Commented] (FLINK-1234) Make Hadoop2 profile default

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

[GitHub] flink issue #4401: [hotfix][tests] minor test improvements in TaskManagerCon...

2017-07-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4401 +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 feature

[jira] [Created] (FLINK-7280) Wrong clearing SharedBuffer of Equal elements with same Timestamp

2017-07-27 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7280: --- Summary: Wrong clearing SharedBuffer of Equal elements with same Timestamp Key: FLINK-7280 URL: https://issues.apache.org/jira/browse/FLINK-7280 Project: Flink

[jira] [Updated] (FLINK-7281) Fix various issues in (Maven) release infrastructure

2017-07-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7281: Priority: Blocker (was: Major) > Fix various issues in (Maven) release infrastructure >

[jira] [Commented] (FLINK-7281) Fix various issues in (Maven) release infrastructure

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

[jira] [Assigned] (FLINK-7092) Shutdown ResourceManager components properly

2017-07-27 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-7092: --- Assignee: mingleizhang > Shutdown ResourceManager components properly >

[jira] [Commented] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

2017-07-27 Thread Egor Litvinenko (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102768#comment-16102768 ] Egor Litvinenko commented on FLINK-7274: Hi, Fabian Thank you for the answer. In my opinion, it

[jira] [Comment Edited] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

2017-07-27 Thread Egor Litvinenko (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102768#comment-16102768 ] Egor Litvinenko edited comment on FLINK-7274 at 7/27/17 6:17 AM: - Hi,

[jira] [Comment Edited] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

2017-07-27 Thread Egor Litvinenko (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102768#comment-16102768 ] Egor Litvinenko edited comment on FLINK-7274 at 7/27/17 6:17 AM: - Hi,

[jira] [Commented] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

2017-07-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16102902#comment-16102902 ] Fabian Hueske commented on FLINK-7274: -- [RFC 4180|https://tools.ietf.org/html/rfc4180] says > Each

[jira] [Closed] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR

2017-07-27 Thread Egor Litvinenko (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Egor Litvinenko closed FLINK-7274. -- Resolution: Workaround > ParserError NUMERIC_VALUE_FORMAT_ERROR >

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

2017-07-27 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r129832284 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java --- @@ -0,0 +1,290 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7281) Fix various issues in (Maven) release infrastructure

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

[jira] [Commented] (FLINK-7281) Fix various issues in (Maven) release infrastructure

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

[GitHub] flink pull request #4407: [FLINK-7281] Fix various issues in (Maven) release...

2017-07-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4407#discussion_r129808825 --- Diff: pom.xml --- @@ -1246,14 +1247,32 @@ under the License.

[GitHub] flink pull request #4407: [FLINK-7281] Fix various issues in (Maven) release...

2017-07-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4407#discussion_r129808895 --- Diff: tools/force-shading/pom.xml --- @@ -93,11 +93,13 @@ under the License.

[jira] [Created] (FLINK-7282) Credit-based Network Flow Control

2017-07-27 Thread zhijiang (JIRA)
zhijiang created FLINK-7282: --- Summary: Credit-based Network Flow Control Key: FLINK-7282 URL: https://issues.apache.org/jira/browse/FLINK-7282 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-7281) Fix various issues in (Maven) release infrastructure

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

[GitHub] flink pull request #4407: [FLINK-7281] Fix various issues in (Maven) release...

2017-07-27 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4407#discussion_r129824759 --- Diff: tools/force-shading/pom.xml --- @@ -93,11 +93,13 @@ under the License.

[jira] [Commented] (FLINK-7281) Fix various issues in (Maven) release infrastructure

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

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

2017-07-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103143#comment-16103143 ] Stephan Ewen commented on FLINK-6909: - I think Greg has a point here, but I also see that Lombok is

[jira] [Updated] (FLINK-7282) Credit-based Network Flow Control

2017-07-27 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-7282: Description: This is a part of work for network stack improvements proposed in [~StephanEwen] 's

[jira] [Updated] (FLINK-7282) Credit-based Network Flow Control

2017-07-27 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-7282: Description: This is a part of work for network stack improvements proposed in [~StephanEwen] 's

[jira] [Commented] (FLINK-7281) Fix various issues in (Maven) release infrastructure

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

[GitHub] flink pull request #4407: [FLINK-7281] Fix various issues in (Maven) release...

2017-07-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4407#discussion_r129808661 --- Diff: pom.xml --- @@ -802,20 +802,6 @@ under the License.

[jira] [Commented] (FLINK-7281) Fix various issues in (Maven) release infrastructure

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

[jira] [Commented] (FLINK-7281) Fix various issues in (Maven) release infrastructure

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

[GitHub] flink pull request #4407: [FLINK-7281] Fix various issues in (Maven) release...

2017-07-27 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4407#discussion_r129824394 --- Diff: pom.xml --- @@ -802,20 +802,6 @@ under the License.

[GitHub] flink pull request #4407: [FLINK-7281] Fix various issues in (Maven) release...

2017-07-27 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4407#discussion_r129824175 --- Diff: pom.xml --- @@ -1257,6 +1243,17 @@ under the License. + +

[jira] [Commented] (FLINK-7281) Fix various issues in (Maven) release infrastructure

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

[GitHub] flink pull request #4407: [FLINK-7281] Fix various issues in (Maven) release...

2017-07-27 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4407#discussion_r129824585 --- Diff: pom.xml --- @@ -1246,14 +1247,32 @@ under the License.

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

2017-07-27 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r129830367 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java --- @@ -492,4 +506,10 @@ private void checkIfQuantifierApplied()

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

2017-07-27 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r129830324 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java --- @@ -105,6 +107,14 @@ public void optional() {

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[GitHub] flink issue #4296: [FLINK-7147] [cep] Support greedy quantifier in CEP

2017-07-27 Thread dianfu
Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4296 @dawidwys Thanks a lot for the review. I have updated the patch. Currently, there is something wrong when the greedy state is followed by an optional state. This can be covered by test case

[jira] [Updated] (FLINK-7282) Credit-based Network Flow Control

2017-07-27 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-7282: Description: This is a part of work for network stack improvements proposed in [~StephanEwen] 's

[GitHub] flink issue #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP function in CE...

2017-07-27 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4331 Hi @yestinchen , Thanks for the update. After second round of review. I found many problems with current approach. It returns only the first match in a stream in most cases. 1.

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

2017-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103166#comment-16103166 ] ASF GitHub Bot commented on FLINK-7169: --- Github user dawidwys commented on the issue:

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[GitHub] flink pull request #4380: Time sort with offset/fetch without retraction

2017-07-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4380#discussion_r129827640 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -75,12 +77,105 @@ object SortUtil {

[GitHub] flink pull request #4380: Time sort with offset/fetch without retraction

2017-07-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4380#discussion_r129835046 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala --- @@

[GitHub] flink pull request #4380: Time sort with offset/fetch without retraction

2017-07-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4380#discussion_r129832039 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala --- @@

[GitHub] flink pull request #4380: Time sort with offset/fetch without retraction

2017-07-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4380#discussion_r129838980 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala --- @@ -108,28 +108,25 @@ class

[GitHub] flink pull request #4380: Time sort with offset/fetch without retraction

2017-07-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4380#discussion_r129833609 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala --- @@

[GitHub] flink pull request #4380: Time sort with offset/fetch without retraction

2017-07-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4380#discussion_r129833309 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala --- @@

[jira] [Updated] (FLINK-7282) Credit-based Network Flow Control

2017-07-27 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-7282: Description: This is a part of work for network stack improvements proposed in [~StephanEwen] 's

[GitHub] flink pull request #4407: [FLINK-7281] Fix various issues in (Maven) release...

2017-07-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4407#discussion_r129807756 --- Diff: pom.xml --- @@ -1257,6 +1243,17 @@ under the License. + +

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

2017-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103180#comment-16103180 ] ASF GitHub Bot commented on FLINK-7147: --- Github user dianfu commented on the issue:

[GitHub] flink pull request #4380: Time sort with offset/fetch without retraction

2017-07-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4380#discussion_r129821546 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala --- @@ -108,28 +108,25 @@ class

[GitHub] flink pull request #4380: Time sort with offset/fetch without retraction

2017-07-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4380#discussion_r129837121 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala --- @@

[GitHub] flink pull request #4380: Time sort with offset/fetch without retraction

2017-07-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4380#discussion_r129833188 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeIdentitySortProcessFunctionOffsetFetch.scala --- @@

[jira] [Commented] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor

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

[GitHub] flink pull request #4410: [FLINK-7268] [checkpoints] Scope SharedStateRegist...

2017-07-27 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/4410 [FLINK-7268] [checkpoints] Scope SharedStateRegistry objects per (re)start ## What is the purpose of the change This PR fixes FLINK-7268. The problem was that

[jira] [Commented] (FLINK-7268) Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles

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

[GitHub] flink pull request #4280: [FLINK-7125] [yarn] Remove Configuration loading f...

2017-07-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4280#discussion_r129878926 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -722,12 +697,30 @@ public ApplicationReport

[GitHub] flink issue #4410: [FLINK-7268] [checkpoints] Scope SharedStateRegistry obje...

2017-07-27 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4410 CC @aljoscha --- 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,

[GitHub] flink issue #4413: [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope SharedStat...

2017-07-27 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4413 CC @aljoscha --- 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,

[GitHub] flink pull request #4413: [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope Sha...

2017-07-27 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/4413 [BACKPORT-1.3][FLINK-7268] [checkpoints] Scope SharedStateRegistry objects See #4410 . This is a bugfix backport from 1.4 to 1.3.x . You can merge this pull request into a Git repository by

[jira] [Created] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

2017-07-27 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7286: - Summary: Flink Dashboard fails to display bytes/records received by sources Key: FLINK-7286 URL: https://issues.apache.org/jira/browse/FLINK-7286 Project: Flink

[jira] [Commented] (FLINK-7086) Create entry point for standalone session mode

2017-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103316#comment-16103316 ] ASF GitHub Bot commented on FLINK-7086: --- Github user tillrohrmann commented on the issue:

[jira] [Comment Edited] (FLINK-7245) Enhance the operators to support holding back watermarks

2017-07-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103282#comment-16103282 ] Xingcan Cui edited comment on FLINK-7245 at 7/27/17 3:18 PM: - Hi [~fhueske],

  1   2   >