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

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

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

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

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132166483 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -157,15 +157,28 @@ */ private boolean

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

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

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

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

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

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

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

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

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

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

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132175300 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/AfterMatchSkipITCase.java --- @@ -0,0 +1,431 @@ +/* + * Licensed to the

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132137487 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -157,15 +157,28 @@ */ private boolean

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132139143 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -322,6 +336,64 @@ public void resetNFAChanged() {

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

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

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

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

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

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

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

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

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

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

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

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

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132168886 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -150,6 +160,59 @@ long getWindowTime() {

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132173777 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -150,6 +160,59 @@ long getWindowTime() {

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132169303 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -150,6 +160,59 @@ long getWindowTime() {

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132136797 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java --- @@ -0,0 +1,276 @@ +/* + * Licensed to

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132139074 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -322,6 +336,64 @@ public void resetNFAChanged() {

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132173699 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -150,6 +160,59 @@ long getWindowTime() {

[GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio...

2017-08-09 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4331#discussion_r132132564 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java --- @@ -0,0 +1,276 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-7395) NumBytesOut metric in RecordWriter call synchronized method

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

[GitHub] flink pull request #4504: [FLINK-7395] [metrics] Count bytesIn/Out without s...

2017-08-09 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4504 [FLINK-7395] [metrics] Count bytesIn/Out without synchronization ## What is the purpose of the change This PR changes the numBytesIn/Out measurement to not use the synchronized

[jira] [Assigned] (FLINK-6697) Add batch multi-window support

2017-08-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6697: Assignee: Fabian Hueske > Add batch multi-window support > --

[jira] [Commented] (FLINK-6697) Add batch multi-window support

2017-08-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119822#comment-16119822 ] Fabian Hueske commented on FLINK-6697: -- We have to add support for {{'w.rowtime}} for batch to have

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132141735 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSink.java --- @@ -0,0 +1,97 @@ +/* + *

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132157359 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSinkBuilder.java --- @@ -0,0 +1,97 @@ +/* + *

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132141831 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSink.java --- @@ -0,0 +1,97 @@ +/* + *

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132168767 --- Diff: docs/dev/table/sourceSinks.md --- @@ -202,7 +202,38 @@ val csvTableSource = CsvTableSource Provided TableSinks ---

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132160714 --- Diff: docs/dev/table/sourceSinks.md --- @@ -202,7 +202,38 @@ val csvTableSource = CsvTableSource Provided TableSinks ---

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132162563 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCSinkFunction.java --- @@ -0,0 +1,62 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132146108 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSinkBuilder.java --- @@ -0,0 +1,97 @@ +/* + *

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132146531 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSinkBuilder.java --- @@ -0,0 +1,97 @@ +/* + *

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132160738 --- Diff: docs/dev/table/sourceSinks.md --- @@ -202,7 +202,38 @@ val csvTableSource = CsvTableSource Provided TableSinks ---

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132142854 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSink.java --- @@ -0,0 +1,97 @@ +/* + *

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

2017-08-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3712#discussion_r132166866 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCTypeUtil.java --- @@ -0,0 +1,87 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-7354) test instability in LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119798#comment-16119798 ] ASF GitHub Bot commented on FLINK-7354: --- Github user zentol commented on the issue:

[GitHub] flink issue #4464: [FLINK-7354][tests] ignore "initialSeedUniquifierGenerato...

2017-08-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4464 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

[jira] [Commented] (FLINK-7312) activate checkstyle for flink/core/memory/*

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119791#comment-16119791 ] ASF GitHub Bot commented on FLINK-7312: --- Github user zentol commented on the issue:

[GitHub] flink issue #4447: [FLINK-7312][checkstyle] activate checkstyle for flink/co...

2017-08-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4447 oh, you already did. Well, never mind. ;) --- 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

[jira] [Commented] (FLINK-7312) activate checkstyle for flink/core/memory/*

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119788#comment-16119788 ] ASF GitHub Bot commented on FLINK-7312: --- Github user zentol commented on the issue:

[GitHub] flink issue #4447: [FLINK-7312][checkstyle] activate checkstyle for flink/co...

2017-08-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4447 @NicoK could you revert the removal of `final` and rebase the 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

[jira] [Commented] (FLINK-6494) Migrate ResourceManager configuration options

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119786#comment-16119786 ] ASF GitHub Bot commented on FLINK-6494: --- Github user zentol commented on the issue:

[GitHub] flink issue #4075: [FLINK-6494] Migrate ResourceManager/Yarn/Mesos configura...

2017-08-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4075 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

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

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

[GitHub] flink pull request #4493: [FLINK-4565] [table] Support for SQL IN operator -...

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

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119770#comment-16119770 ] ASF GitHub Bot commented on FLINK-7337: --- Github user twalthr commented on the issue:

[GitHub] flink issue #4488: [FLINK-7337] [table] Refactor internal handling of time i...

2017-08-09 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4488 @wuchong No problem. Thursday is fine. --- 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

[GitHub] flink pull request #4477: [FLINK-7370][docs] rework the operator documentati...

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

[jira] [Commented] (FLINK-7370) rework operator documentation

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

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

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

[GitHub] flink pull request #4214: [FLINK-7021] Flink Task Manager hangs on startup i...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4214#discussion_r132162054 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java --- @@ -196,4 +198,12 @@ protected

[jira] [Commented] (FLINK-7370) rework operator documentation

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119757#comment-16119757 ] ASF GitHub Bot commented on FLINK-7370: --- Github user twalthr commented on the issue:

[GitHub] flink issue #4477: [FLINK-7370][docs] rework the operator documentation stru...

2017-08-09 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4477 Thanks @NicoK. I will relocate the files according to the new structure and merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink issue #4494: [FLINK-7026] Introduce flink-shaded-asm-5

2017-08-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4494 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

[jira] [Commented] (FLINK-7026) Add shaded asm dependency

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119747#comment-16119747 ] ASF GitHub Bot commented on FLINK-7026: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6982) Replace guava dependencies

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

[GitHub] flink pull request #4503: [FLINK-6982] [guava] Integrate flink-shaded-guava-...

2017-08-09 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4503 [FLINK-6982] [guava] Integrate flink-shaded-guava-18 ## What is the purpose of the change This PR integrates the shaded guava dependency from flink-shaded. Basically, replace all usages of

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132155748 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java --- @@ -101,127 +98,112 @@ public void update() {

[jira] [Commented] (FLINK-7062) Support the basic functionality of MATCH_RECOGNIZE

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119728#comment-16119728 ] ASF GitHub Bot commented on FLINK-7062: --- GitHub user dianfu opened a pull request:

[GitHub] flink pull request #4502: [FLINK-7062] [table, cep] Support the basic functi...

2017-08-09 Thread dianfu
GitHub user dianfu opened a pull request: https://github.com/apache/flink/pull/4502 [FLINK-7062] [table, cep] Support the basic functionality of MATCH_RECOGNIZE ## What is the purpose of the change *This pull request adds the basic support of MATCH_RECOGNIZE.*

[jira] [Commented] (FLINK-7397) Which scheduling mechanism and algorithm used for scheduling Jobs

2017-08-09 Thread saif.aljumaili (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119722#comment-16119722 ] saif.aljumaili commented on FLINK-7397: --- iam send it > Which scheduling mechanism and algorithm

[jira] [Closed] (FLINK-7397) Which scheduling mechanism and algorithm used for scheduling Jobs

2017-08-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7397. --- Resolution: Not A Problem Please ask questions on the {{u...@flink.apache.org}} or

[jira] [Created] (FLINK-7397) Which scheduling mechanism and algorithm used for scheduling Jobs

2017-08-09 Thread saif.aljumaili (JIRA)
saif.aljumaili created FLINK-7397: - Summary: Which scheduling mechanism and algorithm used for scheduling Jobs Key: FLINK-7397 URL: https://issues.apache.org/jira/browse/FLINK-7397 Project: Flink

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[GitHub] flink issue #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from ActorG...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4492 Thanks for the review @zentol. I've addressed most of your comments modulo the web frontend configuration options and rebased the PR onto the latest master. I've tested the web

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132143993 --- Diff: docs/setup/config.md --- @@ -389,6 +389,10 @@ These parameters allow for advanced tuning. The default values are sufficient wh -

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132142466 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerGateway.java --- @@ -63,4 +70,103 @@ * @return Future

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132142562 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java --- @@ -247,6 +262,8 @@ public static Path

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132142385 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java --- @@ -101,127 +98,112 @@ public void

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132141995 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java --- @@ -101,127 +98,112 @@ public void

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132141830 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/WebMonitorOptions.java --- @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132141613 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/WebMonitorOptions.java --- @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

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

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132141346 --- Diff: docs/setup/config.md --- @@ -389,6 +389,10 @@ These parameters allow for advanced tuning. The default values are sufficient wh -

[jira] [Commented] (FLINK-7375) Remove ActorGateway from JobClient

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

[GitHub] flink issue #4486: [FLINK-7375] Replace ActorGateway with JobManagerGateway ...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4486 Rebased onto the latest master. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-7372) Remove ActorGateway from JobGraph

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

<    1   2   3   >