[jira] [Commented] (FLINK-9173) RestClient - Received response is abnormal

2018-04-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440482#comment-16440482 ] Chesnay Schepler commented on FLINK-9173: - is the response received by the client no longer

[jira] [Commented] (FLINK-9173) RestClient - Received response is abnormal

2018-04-17 Thread Bob Lau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440450#comment-16440450 ] Bob Lau commented on FLINK-9173: The last question has been solved. Because I adjusted the

[jira] [Updated] (FLINK-9173) RestClient - Received response is abnormal

2018-04-17 Thread Bob Lau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Lau updated FLINK-9173: --- Attachment: image-2018-04-17-14-09-33-991.png > RestClient - Received response is abnormal >

[jira] [Reopened] (FLINK-9145) Website build is broken

2018-04-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9145: - > Website build is broken > --- > > Key: FLINK-9145 >

[GitHub] flink issue #5244: [FLINK-8366] [table] Use Row instead of String as key whe...

2018-04-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5244 Thanks for the fix @hequn8128! +1 to merge ---

[jira] [Commented] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions

2018-04-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440751#comment-16440751 ] Chesnay Schepler commented on FLINK-8785: - The {{ErrorResponseBody}} can accept a list of errors.

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

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

[GitHub] flink issue #4674: [FLINK-7627] [table] SingleElementIterable should impleme...

2018-04-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4674 Hi @hequn8128, @wuchong. What are your plans for this PR. Should we get it in or are you OK to close it? Thanks, Fabian ---

[jira] [Commented] (FLINK-8955) Port ClassLoaderITCase to flip6

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

[jira] [Commented] (FLINK-8366) Use Row instead of String as key when process upsert results

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440795#comment-16440795 ] ASF GitHub Bot commented on FLINK-8366: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-7627) SingleElementIterable should implement with Serializable

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440799#comment-16440799 ] ASF GitHub Bot commented on FLINK-7627: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-8955) Port ClassLoaderITCase to flip6

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440691#comment-16440691 ] ASF GitHub Bot commented on FLINK-8955: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #5780: [FLINK-8955][tests] Port ClassLoaderITCase to flip6

2018-04-17 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5780 Failing reproducibly, and only on this branch? ---

[GitHub] flink issue #5780: [FLINK-8955][tests] Port ClassLoaderITCase to flip6

2018-04-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5780 I may have found the case, we have to set `MANAGED_MEMORY_SIZE` for this test. ---

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

2018-04-17 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r182048477 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java --- @@ -107,4 +131,12 @@ public int getAttemptNumber() { public

[jira] [Commented] (FLINK-9145) Website build is broken

2018-04-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440749#comment-16440749 ] Chesnay Schepler commented on FLINK-9145: - The issue is still present unfortunately; for some

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[GitHub] flink issue #5665: [FLINK-8703][tests] Port WebFrontendITCase to MiniCluster...

2018-04-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5665 @aljoscha I've addressed your comments and rebased the branch. ---

[jira] [Assigned] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

2018-04-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-8867: --- Assignee: Stephan Ewen (was: Stefan Richter) > Rocksdb checkpointing failing with

[jira] [Created] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-04-17 Thread Gary Yao (JIRA)
Gary Yao created FLINK-9190: --- Summary: YarnResourceManager sometimes does not request new Containers Key: FLINK-9190 URL: https://issues.apache.org/jira/browse/FLINK-9190 Project: Flink Issue

[jira] [Created] (FLINK-9189) Add a SBT and Gradle Quickstarts

2018-04-17 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-9189: --- Summary: Add a SBT and Gradle Quickstarts Key: FLINK-9189 URL: https://issues.apache.org/jira/browse/FLINK-9189 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9192) Undo parameterization of StateMachine Example

2018-04-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440933#comment-16440933 ] Kostas Kloudas commented on FLINK-9192: --- These changes were made in the context of the end-to-end

[jira] [Commented] (FLINK-8990) End-to-end test: Dynamic Kafka partition discovery

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440959#comment-16440959 ] ASF GitHub Bot commented on FLINK-8990: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI

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

[GitHub] flink pull request #4674: [FLINK-7627] [table] SingleElementIterable should ...

2018-04-17 Thread hequn8128
Github user hequn8128 closed the pull request at: https://github.com/apache/flink/pull/4674 ---

[jira] [Commented] (FLINK-7627) SingleElementIterable should implement with Serializable

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

[jira] [Commented] (FLINK-9195) Delete non-well-defined output methods on DataStream

2018-04-17 Thread Michael Latta (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440984#comment-16440984 ] Michael Latta commented on FLINK-9195: -- Those sinks are for debugging of simple jobs.  They are

[jira] [Commented] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440840#comment-16440840 ] ASF GitHub Bot commented on FLINK-9113: --- GitHub user twalthr opened a pull request:

[jira] [Created] (FLINK-9191) Misleading URLs for website source

2018-04-17 Thread Sebb (JIRA)
Sebb created FLINK-9191: --- Summary: Misleading URLs for website source Key: FLINK-9191 URL: https://issues.apache.org/jira/browse/FLINK-9191 Project: Flink Issue Type: Bug Components: Project

[jira] [Created] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

2018-04-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-9193: --- Summary: Deprecate non-well-defined output methods on DataStream Key: FLINK-9193 URL: https://issues.apache.org/jira/browse/FLINK-9193 Project: Flink

[jira] [Commented] (FLINK-9192) Undo parameterization of StateMachine Example

2018-04-17 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440934#comment-16440934 ] Stefan Richter commented on FLINK-9192: --- +1, I think that the test could build upon the universal

[GitHub] flink pull request #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAP...

2018-04-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5638#discussion_r182104673 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala --- @@ -1130,4 +1130,13 @@ object concat_ws {

[jira] [Created] (FLINK-9192) Undo parameterization of StateMachine Example

2018-04-17 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-9192: --- Summary: Undo parameterization of StateMachine Example Key: FLINK-9192 URL: https://issues.apache.org/jira/browse/FLINK-9192 Project: Flink Issue Type:

[jira] [Created] (FLINK-9195) Delete non-well-defined output methods on DataStream

2018-04-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-9195: --- Summary: Delete non-well-defined output methods on DataStream Key: FLINK-9195 URL: https://issues.apache.org/jira/browse/FLINK-9195 Project: Flink

[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440975#comment-16440975 ] ASF GitHub Bot commented on FLINK-6924: --- Github user fhueske commented on the issue:

[jira] [Updated] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-04-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9190: Description: *Description* The {{YarnResourceManager}} does not request new containers if {{TaskManagers}}

[GitHub] flink pull request #5861: [FLINK-9113] [connectors] Use raw local file syste...

2018-04-17 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5861 [FLINK-9113] [connectors] Use raw local file system for bucketing sink to prevent data loss ## What is the purpose of the change This change replaces Hadoop's LocalFileSystem (which is a

[jira] [Comment Edited] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-04-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440927#comment-16440927 ] Gary Yao edited comment on FLINK-8900 at 4/17/18 2:37 PM: -- When submitting in

[jira] [Reopened] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-04-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reopened FLINK-8900: - When submitting in non-detached mode, the problem still surfaces. It detached mode the status is set

[GitHub] flink issue #5779: [FLINK-8990] [test] Extend Kafka end-to-end test to verif...

2018-04-17 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5779 The changes look good to merge! 👍 ---

[GitHub] flink issue #4674: [FLINK-7627] [table] SingleElementIterable should impleme...

2018-04-17 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/4674 @fhueske Hi, I will close it. Thanks for the checking. ---

[jira] [Commented] (FLINK-8366) Use Row instead of String as key when process upsert results

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440978#comment-16440978 ] ASF GitHub Bot commented on FLINK-8366: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-7627) SingleElementIterable should implement with Serializable

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440979#comment-16440979 ] ASF GitHub Bot commented on FLINK-7627: --- Github user hequn8128 commented on the issue:

[jira] [Created] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-17 Thread Gary Yao (JIRA)
Gary Yao created FLINK-9194: --- Summary: Finished jobs are not archived to HistoryServer Key: FLINK-9194 URL: https://issues.apache.org/jira/browse/FLINK-9194 Project: Flink Issue Type: Bug

[GitHub] flink issue #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAPI

2018-04-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5638 Thanks for the PR @buptljy! As mentioned in the comment, the function should be exposed similar to `ln()` and `log10()` as `expr.log(base)`. For that the expression parser would need to be

[jira] [Closed] (FLINK-7627) SingleElementIterable should implement with Serializable

2018-04-17 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-7627. -- Resolution: Not A Problem > SingleElementIterable should implement with Serializable >

[jira] [Created] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown

2018-04-17 Thread Gary Yao (JIRA)
Gary Yao created FLINK-9196: --- Summary: YARN: Flink binaries are not deleted from HDFS after cluster shutdown Key: FLINK-9196 URL: https://issues.apache.org/jira/browse/FLINK-9196 Project: Flink

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441020#comment-16441020 ] ASF GitHub Bot commented on FLINK-8703: --- Github user aljoscha commented on the issue:

[jira] [Assigned] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions

2018-04-17 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] buptljy reassigned FLINK-8785: -- Assignee: buptljy > JobSubmitHandler does not handle JobSubmissionExceptions >

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441175#comment-16441175 ] ASF GitHub Bot commented on FLINK-2435: --- GitHub user DmitryKober opened a pull request:

[GitHub] flink pull request #5862: [FLINK-2435] User-defined types in CsvReader

2018-04-17 Thread DmitryKober
GitHub user DmitryKober opened a pull request: https://github.com/apache/flink/pull/5862 [FLINK-2435] User-defined types in CsvReader [FLINK-2435] Provides the capability of specifying user-defined types in Tuple and Row 'containers' while reading from a csv file You can merge

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

2018-04-17 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r182116588 --- Diff: flink-end-to-end-tests/test-scripts/common.sh --- @@ -176,10 +176,40 @@ function s3_delete {

[jira] [Commented] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

2018-04-17 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441023#comment-16441023 ] Timo Walther commented on FLINK-9193: - Do we really want to deprecate these useful methods? I think

[GitHub] flink pull request #5835: [FLINK-2435] Extending CsvReader capabilities: it ...

2018-04-17 Thread DmitryKober
Github user DmitryKober closed the pull request at: https://github.com/apache/flink/pull/5835 ---

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

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

[GitHub] flink issue #5665: [FLINK-8703][tests] Port WebFrontendITCase to MiniCluster...

2018-04-17 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5665 I think this looks good to go then. 👍 ---

[jira] [Commented] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions

2018-04-17 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441047#comment-16441047 ] buptljy commented on FLINK-8785: [~Zentol]  Okay, I've already known how to do this. I will assign this

[jira] [Commented] (FLINK-8955) Port ClassLoaderITCase to flip6

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441019#comment-16441019 ] ASF GitHub Bot commented on FLINK-8955: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #5780: [FLINK-8955][tests] Port ClassLoaderITCase to flip6

2018-04-17 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5780 still failures because of this? ---

[jira] [Assigned] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-17 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9194: --- Assignee: yuqi > Finished jobs are not archived to HistoryServer >

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

2018-04-17 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r182116943 --- Diff: flink-end-to-end-tests/test-scripts/common.sh --- @@ -176,10 +176,40 @@ function s3_delete {

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

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

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

2018-04-17 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r182117045 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

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

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

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

[jira] [Comment Edited] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

2018-04-17 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441023#comment-16441023 ] Timo Walther edited comment on FLINK-9193 at 4/17/18 3:30 PM: -- Do we really

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

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

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

2018-04-17 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r182126796 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[GitHub] flink pull request #4883: [FLINK-4809] Operators should tolerate checkpoint ...

2018-04-17 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/4883#discussion_r182155763 --- Diff: docs/dev/stream/state/checkpointing.md --- @@ -118,6 +120,9 @@ env.getCheckpointConfig.setMinPauseBetweenCheckpoints(500) // checkpoints

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441927#comment-16441927 ] Gary Yao commented on FLINK-9194: - [~yuqi] I configured {{jobmanager.archive.fs.dir}}, and started the

[jira] [Created] (FLINK-9199) SubtaskExecutionAttemptAccumulatorsHeaders & SubtaskExecutionAttemptDetailsHeaders has malfunctioning URL

2018-04-17 Thread Rong Rong (JIRA)
Rong Rong created FLINK-9199: Summary: SubtaskExecutionAttemptAccumulatorsHeaders & SubtaskExecutionAttemptDetailsHeaders has malfunctioning URL Key: FLINK-9199 URL: https://issues.apache.org/jira/browse/FLINK-9199

[jira] [Assigned] (FLINK-9199) SubtaskExecutionAttemptAccumulatorsHeaders & SubtaskExecutionAttemptDetailsHeaders has malfunctioning URL

2018-04-17 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-9199: Assignee: Rong Rong > SubtaskExecutionAttemptAccumulatorsHeaders & >

[jira] [Updated] (FLINK-9199) Malfunctioning URL target in some messageheaders

2018-04-17 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9199: - Summary: Malfunctioning URL target in some messageheaders (was:

[jira] [Commented] (FLINK-8978) End-to-end test: Job upgrade

2018-04-17 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440834#comment-16440834 ] mingleizhang commented on FLINK-8978: - Sounds like a HotSwap functionality. Interesting. > End-to-end

[GitHub] flink issue #5244: [FLINK-8366] [table] Use Row instead of String as key whe...

2018-04-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5244 merging ---

[GitHub] flink issue #5839: [FLINK-9158][Distributed Coordination] Set default FixedR...

2018-04-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5839 Looks good, thanks! Merging... ---

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441438#comment-16441438 ] ASF GitHub Bot commented on FLINK-8335: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5488: [FLINK-8335] [hbase] Upgrade hbase connector dependency t...

2018-04-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5488 All right, trying to merge this for 1.6 ---

[jira] [Commented] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

2018-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441391#comment-16441391 ] ASF GitHub Bot commented on FLINK-9158: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

2018-04-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441397#comment-16441397 ] Stephan Ewen commented on FLINK-9158: - I think there is no reason for a default delay. It just makes

[GitHub] flink pull request #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAP...

2018-04-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5638 ---

[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI

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

[GitHub] flink pull request #5244: [FLINK-8366] [table] Use Row instead of String as ...

2018-04-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5244 ---

[jira] [Commented] (FLINK-8366) Use Row instead of String as key when process upsert results

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

[jira] [Closed] (FLINK-8366) Use Row instead of String as key when process upsert results

2018-04-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8366. Resolution: Fixed Fix Version/s: 1.5.0 Fixed on master with

[jira] [Closed] (FLINK-6924) ADD LOG(X) supported in TableAPI

2018-04-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6924. Resolution: Fixed Fix Version/s: 1.6.0 Implemented for 1.6.0 with

[GitHub] flink issue #5861: [FLINK-9113] [connectors] Use raw local file system for b...

2018-04-17 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5861 It seems that for Hadoop 2.8.3 truncating is supported for the raw local filesystems. I will need to adapt the test for that. ---

[jira] [Commented] (FLINK-4809) Operators should tolerate checkpoint failures

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

[jira] [Commented] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem

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

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

2018-04-17 Thread Dmitrii Kober (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441211#comment-16441211 ] Dmitrii Kober commented on FLINK-2435: -- Hello [~fhueske]. Thank you for the review! I have updated

[jira] [Assigned] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9194: --- Assignee: Chesnay Schepler (was: yuqi) > Finished jobs are not archived to

[jira] [Created] (FLINK-9198) Improve error messages in AbstractDeserializationSchema for type extraction

2018-04-17 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-9198: --- Summary: Improve error messages in AbstractDeserializationSchema for type extraction Key: FLINK-9198 URL: https://issues.apache.org/jira/browse/FLINK-9198 Project:

[jira] [Commented] (FLINK-8955) Port ClassLoaderITCase to flip6

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

[GitHub] flink issue #5780: [FLINK-8955][tests] Port ClassLoaderITCase to flip6

2018-04-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5780 checkstyle 😡 ---

[jira] [Commented] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown

2018-04-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441248#comment-16441248 ] Stephan Ewen commented on FLINK-9196: - I think this may explain parts of the error described here:

[jira] [Created] (FLINK-9197) Improve error message for TypyInformation and TypeHint with generics

2018-04-17 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-9197: --- Summary: Improve error message for TypyInformation and TypeHint with generics Key: FLINK-9197 URL: https://issues.apache.org/jira/browse/FLINK-9197 Project: Flink

[jira] [Commented] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap()

2018-04-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441581#comment-16441581 ] Ted Yu commented on FLINK-8661: --- Should this issue be resolved ? > Replace Collections.EMPTY_MAP with

[jira] [Commented] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap()

2018-04-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441586#comment-16441586 ] Chesnay Schepler commented on FLINK-8661: - I don't see a commit for it, so I'd keep it open. >

[jira] [Comment Edited] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex

2018-04-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432712#comment-16432712 ] Ted Yu edited comment on FLINK-7917 at 4/17/18 10:15 PM: - +1 was (Author:

[jira] [Commented] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

2018-04-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441585#comment-16441585 ] Ted Yu commented on FLINK-7897: --- lgtm > Consider using nio.Files for file deletion in

  1   2   >