[jira] [Commented] (FLINK-7554) Add a testing RuntimeContext to test utilities

2018-06-11 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16509099#comment-16509099 ] buptljy commented on FLINK-7554: [~twalthr] Can you help review my PR ? > Add a testing RuntimeContext

[jira] [Assigned] (FLINK-9236) Use Apache Parent POM 19

2018-06-11 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-9236: --- Assignee: Stephen Jason (was: mingleizhang) > Use Apache Parent POM 19 >

[jira] [Assigned] (FLINK-9568) Wrong error handling for batch input formats with invalid paths

2018-06-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9568: --- Assignee: vinoyang > Wrong error handling for batch input formats with invalid paths >

[jira] [Assigned] (FLINK-8920) Split code generated input unboxing code

2018-06-11 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-8920: -- Assignee: Ruidong Li (was: Hequn Cheng) > Split code generated input unboxing code >

[jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2018-06-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281 ] Ted Yu edited comment on FLINK-6105 at 6/12/18 12:32 AM: - In

[jira] [Updated] (FLINK-9236) Use Apache Parent POM 19

2018-06-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9236: -- Description: Flink is still using Apache Parent POM 18. Apache Parent POM 19 is out. This will also fix

[jira] [Commented] (FLINK-9530) Task numRecords metrics broken for chains

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508750#comment-16508750 ] ASF GitHub Bot commented on FLINK-9530: --- Github user zentol commented on the issue:

[GitHub] flink issue #6126: [FLINK-9530][metrics] Fix numRecords task metric for chai...

2018-06-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6126 This gives you a consistent view about operators regardless of whether they are chained or not. I don't quite understand how you could consider this metric not being useful. ---

[jira] [Commented] (FLINK-9562) Wrong wording in flink-optimizer module

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508647#comment-16508647 ] ASF GitHub Bot commented on FLINK-9562: --- GitHub user alex-arkhipov opened a pull request:

[GitHub] flink pull request #6150: [FLINK-9562] [flink-optimizer] Wrong wording in fl...

2018-06-11 Thread alex-arkhipov
GitHub user alex-arkhipov opened a pull request: https://github.com/apache/flink/pull/6150 [FLINK-9562] [flink-optimizer] Wrong wording in flink-optimizer module ## What is the purpose of the change This pull request corrects some typos and copy paste errors in

[jira] [Commented] (FLINK-9530) Task numRecords metrics broken for chains

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508609#comment-16508609 ] ASF GitHub Bot commented on FLINK-9530: --- Github user kl0u commented on the issue:

[GitHub] flink issue #6126: [FLINK-9530][metrics] Fix numRecords task metric for chai...

2018-06-11 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/6126 I got this, it is just that I am wondering how useful this is, given that the operators/functions are chained. ---

[jira] [Commented] (FLINK-9530) Task numRecords metrics broken for chains

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508603#comment-16508603 ] ASF GitHub Bot commented on FLINK-9530: --- Github user zentol commented on the issue:

[GitHub] flink issue #6126: [FLINK-9530][metrics] Fix numRecords task metric for chai...

2018-06-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6126 This is the very counter that, for a chain A -> B, counts the outgoing records of A and incoming records of B. ---

[jira] [Comment Edited] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-06-11 Thread Nikolas Davis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501068#comment-16501068 ] Nikolas Davis edited comment on FLINK-8946 at 6/11/18 5:41 PM: --- I think we

[jira] [Commented] (FLINK-9530) Task numRecords metrics broken for chains

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508418#comment-16508418 ] ASF GitHub Bot commented on FLINK-9530: --- Github user zentol commented on the issue:

[GitHub] flink issue #6126: [FLINK-9530][metrics] Fix numRecords task metric for chai...

2018-06-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6126 No we can't remove it as it is still used for the operator. ---

[GitHub] flink pull request #6059: [Flink-9418] Migrate SharedBuffer to use MapState

2018-06-11 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6059#discussion_r194482707 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -296,42 +292,31 @@ public void resetNFAChanged() {

[GitHub] flink pull request #6059: [Flink-9418] Migrate SharedBuffer to use MapState

2018-06-11 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6059#discussion_r194473454 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -296,42 +292,31 @@ public void resetNFAChanged() {

[GitHub] flink pull request #6059: [Flink-9418] Migrate SharedBuffer to use MapState

2018-06-11 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6059#discussion_r194470370 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -296,42 +292,31 @@ public void resetNFAChanged() {

[GitHub] flink pull request #6059: [Flink-9418] Migrate SharedBuffer to use MapState

2018-06-11 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6059#discussion_r194469640 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -296,42 +292,31 @@ public void resetNFAChanged() {

[GitHub] flink pull request #6059: [Flink-9418] Migrate SharedBuffer to use MapState

2018-06-11 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6059#discussion_r194468194 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java --- @@ -296,42 +292,31 @@ public void resetNFAChanged() {

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508302#comment-16508302 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194459557 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/HierarchyDescriptor.scala --- @@ -0,0 +1,29 @@ +/* + *

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508306#comment-16508306 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508304#comment-16508304 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508296#comment-16508296 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194442694 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/UDFDescriptor.java --- @@ -0,0 +1,153 @@ +/* + *

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508297#comment-16508297 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508300#comment-16508300 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194458815 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/FunctionDescriptor.scala --- @@ -0,0 +1,48 @@ +/* + *

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508295#comment-16508295 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508299#comment-16508299 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508301#comment-16508301 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194462064 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/PrimitiveTypeValidator.scala --- @@ -0,0 +1,72 @@ +/* + *

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508303#comment-16508303 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194451906 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java --- @@ -187,6 +206,7 @@ private

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194456301 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/ClassTypeDescriptor.scala --- @@ -0,0 +1,71 @@ +/* + *

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194463649 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/PrimitiveTypeValidator.scala --- @@ -0,0 +1,72 @@ +/* + *

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194426814 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/UDFDescriptor.java --- @@ -0,0 +1,153 @@ +/* + *

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508298#comment-16508298 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508305#comment-16508305 ] ASF GitHub Bot commented on FLINK-8863: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194452740 --- Diff: flink-libraries/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/LocalExecutorITCase.java --- @@ -145,6 +146,68 @@

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194461789 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/PrimitiveTypeDescriptor.scala --- @@ -0,0 +1,56 @@ +/* + *

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194451816 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java --- @@ -101,6 +110,16 @@ public

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-06-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6090#discussion_r194453136 --- Diff: flink-libraries/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/utils/UserDefinedFunctions.java --- @@ -0,0 +1,105 @@

[jira] [Commented] (FLINK-9530) Task numRecords metrics broken for chains

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508248#comment-16508248 ] ASF GitHub Bot commented on FLINK-9530: --- Github user kl0u commented on the issue:

[GitHub] flink issue #6126: [FLINK-9530][metrics] Fix numRecords task metric for chai...

2018-06-11 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/6126 If this is correct, then I suppose we can remove it altogether so that the code is also cleaner, right? ---

[jira] [Commented] (FLINK-9530) Task numRecords metrics broken for chains

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508244#comment-16508244 ] ASF GitHub Bot commented on FLINK-9530: --- Github user zentol commented on the issue:

[GitHub] flink issue #6126: [FLINK-9530][metrics] Fix numRecords task metric for chai...

2018-06-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6126 yes, the `numRecordsIn` metric for a `ChainingOutput` is irrelevant for the task metrics and thus can be removed without affecting the test. ---

[jira] [Commented] (FLINK-6670) remove CommonTestUtils.createTempDirectory()

2018-06-11 Thread Mahesh Senniappan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508191#comment-16508191 ] Mahesh Senniappan commented on FLINK-6670: -- Hello [~Zentol], I saw your comment in a starter

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

2018-06-11 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508175#comment-16508175 ] Hequn Cheng commented on FLINK-9528: Hi, [~fhueske] If we agree to add a state we can simply add the

[jira] [Commented] (FLINK-9560) RateLimiting for FileSystem

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508151#comment-16508151 ] ASF GitHub Bot commented on FLINK-9560: --- GitHub user etiennecarriere opened a pull request:

[GitHub] flink pull request #6149: [FLINK-9560] Add RateLimiting for FileSystem

2018-06-11 Thread etiennecarriere
GitHub user etiennecarriere opened a pull request: https://github.com/apache/flink/pull/6149 [FLINK-9560] Add RateLimiting for FileSystem ## Contribution Checklist - Make sure that the change passes the automated tests, i.e., `mvn clean verify` passes. You can set up

[jira] [Commented] (FLINK-7554) Add a testing RuntimeContext to test utilities

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508141#comment-16508141 ] ASF GitHub Bot commented on FLINK-7554: --- GitHub user buptljy opened a pull request:

[GitHub] flink pull request #6148: [FLINK-7554][Tests] Add a testing RuntimeContext t...

2018-06-11 Thread buptljy
GitHub user buptljy opened a pull request: https://github.com/apache/flink/pull/6148 [FLINK-7554][Tests] Add a testing RuntimeContext to test utilities ## What is the purpose of the change This pull request adds a TestingRuntimeContext to help developers test their own

[jira] [Commented] (FLINK-9564) Expose end-to-end module directory to test scripts

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508121#comment-16508121 ] ASF GitHub Bot commented on FLINK-9564: --- Github user medcv commented on the issue:

[jira] [Commented] (FLINK-9564) Expose end-to-end module directory to test scripts

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508124#comment-16508124 ] ASF GitHub Bot commented on FLINK-9564: --- Github user medcv commented on the issue:

[GitHub] flink issue #6146: [FLINK-9564][tests] Expose flink-end-to-end module direct...

2018-06-11 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6146 +1 ---

[GitHub] flink issue #6145: [FLINK-9564][tests] Expose flink-end-to-end module direct...

2018-06-11 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6145 +1 ---

[jira] [Updated] (FLINK-9568) Wrong error handling for batch input formats with invalid paths

2018-06-11 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9568: Component/s: Distributed Coordination Batch Connectors and Input/Output Formats >

[jira] [Updated] (FLINK-9568) Wrong error handling for batch input formats with invalid paths

2018-06-11 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9568: Affects Version/s: 1.5.0 > Wrong error handling for batch input formats with invalid paths >

[jira] [Created] (FLINK-9568) Wrong error handling for batch input formats with invalid paths

2018-06-11 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9568: --- Summary: Wrong error handling for batch input formats with invalid paths Key: FLINK-9568 URL: https://issues.apache.org/jira/browse/FLINK-9568 Project: Flink

[jira] [Commented] (FLINK-8654) Extend quickstart docs on how to submit jobs

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508094#comment-16508094 ] ASF GitHub Bot commented on FLINK-8654: --- Github user medcv commented on the issue:

[GitHub] flink issue #6084: [FLINK-8654][Docs] Extend quickstart docs on how to submi...

2018-06-11 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6084 @zentol sure, will update the PR shortly! ---

[jira] [Commented] (FLINK-8861) Add support for batch queries in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508083#comment-16508083 ] ASF GitHub Bot commented on FLINK-8861: --- Github user xccui commented on the issue:

[GitHub] flink issue #5660: [FLINK-8861] [table] Add support for batch queries in SQL...

2018-06-11 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/5660 Thanks for the improvements, @twalthr. ---

[GitHub] flink pull request #5660: [FLINK-8861] [table] Add support for batch queries...

2018-06-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5660 ---

[jira] [Resolved] (FLINK-8861) Add support for batch queries in SQL Client

2018-06-11 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8861. - Resolution: Fixed Fix Version/s: 1.6.0 Fixed in 1.6.0:

[jira] [Commented] (FLINK-8861) Add support for batch queries in SQL Client

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

[jira] [Updated] (FLINK-9560) RateLimiting for FileSystem

2018-06-11 Thread Etienne CARRIERE (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne CARRIERE updated FLINK-9560: Description: *Pain*: On our system, we see that during checkpoint , all the bandwidth is

[jira] [Updated] (FLINK-9560) RateLimiting for FileSystem

2018-06-11 Thread Etienne CARRIERE (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne CARRIERE updated FLINK-9560: Description: *Pain*: On our system, we see that during checkpoint , all the bandwidth is

[jira] [Commented] (FLINK-8861) Add support for batch queries in SQL Client

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508064#comment-16508064 ] ASF GitHub Bot commented on FLINK-8861: --- Github user twalthr commented on the issue:

[GitHub] flink issue #5660: [FLINK-8861] [table] Add support for batch queries in SQL...

2018-06-11 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5660 Thank you @xccui. I will test your code and merge this... ---

[jira] [Commented] (FLINK-8067) User code ClassLoader not set before calling ProcessingTimeCallback

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508057#comment-16508057 ] ASF GitHub Bot commented on FLINK-8067: --- Github user pnowojski commented on the issue:

[GitHub] flink issue #6081: [FLINK-8067] User code ClassLoader not set before calling...

2018-06-11 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/6081 @yanghua why is it difficult? Can not you create more or less similar test to @GJL's `testSetsUserCodeClassLoader` from here: https://github.com/apache/flink/pull/4980/files. With couple side

[jira] [Closed] (FLINK-9508) General Spell Check on Flink Docs

2018-06-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9508. --- Resolution: Fixed Fix Version/s: 1.5.1 1.4.3

[GitHub] flink pull request #6112: [FLINK-9508][Docs]General Spell Check on Flink Doc...

2018-06-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6112 ---

[jira] [Commented] (FLINK-9508) General Spell Check on Flink Docs

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

[jira] [Updated] (FLINK-9508) General Spell Check on Flink Docs

2018-06-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9508: Affects Version/s: (was: 1.4.1) 1.6.0 > General Spell Check on

[jira] [Commented] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests"

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507988#comment-16507988 ] ASF GitHub Bot commented on FLINK-9498: --- Github user zentol commented on the issue:

[GitHub] flink issue #6116: [FLINK-9498][build] Disable dependency convergence for fl...

2018-06-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6116 I'm not aware of a mechanism that allows defining an adhoc dependency convergence. Users will have to modify the pom of `flink-shaded-hadoop` and add a convergence profile for the given version,

[GitHub] flink pull request #6076: [hotfix][docs] Specify operators behaviour on proc...

2018-06-11 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6076#discussion_r194393116 --- Diff: docs/dev/event_time.md --- @@ -213,10 +213,33 @@ arrive after the system's event time clock (as signaled by the watermarks) has a

[jira] [Commented] (FLINK-9539) Integrate flink-shaded 4.0

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

[GitHub] flink pull request #6128: [FLINK-9539][build] Integrate flink-shaded 4.0

2018-06-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6128 ---

[jira] [Closed] (FLINK-9539) Integrate flink-shaded 4.0

2018-06-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9539. --- Resolution: Fixed master: ed3890af0bc4332d2eabd56be55d0ebd21ab43c7 > Integrate flink-shaded

[jira] [Commented] (FLINK-9539) Integrate flink-shaded 4.0

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507974#comment-16507974 ] ASF GitHub Bot commented on FLINK-9539: --- Github user zentol commented on the issue:

[GitHub] flink issue #6128: [FLINK-9539][build] Integrate flink-shaded 4.0

2018-06-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6128 merging. ---

[GitHub] flink pull request #6143: [hotfix] [docs] Fixed scala variable declaration w...

2018-06-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6143 ---

[GitHub] flink pull request #6076: [hotfix][docs] Specify operators behaviour on proc...

2018-06-11 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6076#discussion_r194390932 --- Diff: docs/dev/event_time.md --- @@ -213,10 +213,33 @@ arrive after the system's event time clock (as signaled by the watermarks) has a

[jira] [Commented] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes

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

[jira] [Closed] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes

2018-06-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9549. --- Resolution: Fixed Fix Version/s: 1.5.1 1.6.0 master:

[GitHub] flink pull request #6137: [FLINK-9549][DOC]Fix FlickCEP Docs broken link and...

2018-06-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6137 ---

[jira] [Updated] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes

2018-06-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9549: Affects Version/s: 1.6.0 1.5.0 > Fix FlickCEP Docs broken link and

[GitHub] flink pull request #6144: [hotfix][javadoc]Fix the incorrect java doc for Op...

2018-06-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6144 ---

[jira] [Updated] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes

2018-06-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9549: Component/s: Documentation CEP > Fix FlickCEP Docs broken link and minor

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

2018-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507960#comment-16507960 ] ASF GitHub Bot commented on FLINK-9168: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

2018-06-11 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5845 Sorry for delays on my reply here. I'll take a look at this week, over the next days. If there is going to be a new PR, please also let me know. Thanks! ---

[jira] [Updated] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-06-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8946: Fix Version/s: 1.4.3 1.6.0 > TaskManager stop sending metrics after

[jira] [Updated] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-06-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8946: Affects Version/s: 1.6.0 1.5.0 > TaskManager stop sending metrics

  1   2   >