[jira] [Commented] (FLINK-7801) Integrate list command into REST client

2017-10-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199979#comment-16199979 ] Chesnay Schepler commented on FLINK-7801: - [~till.rohrmann] This is a duplicate of FLINK-7791 that

[jira] [Updated] (FLINK-7802) Error occur when empty field collection was pushed into TableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Summary: Error occur when empty field collection was pushed into TableSource (was: Bug in

[jira] [Updated] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

2017-10-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7657: - Affects Version/s: 1.4.0 > SQL Timestamps Converted To Wrong Type By Optimizer Causing

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Description: Consider such SQL: select count(1) from csv_table. When above SQL was executed, an

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Description: Consider such SQL: select count(1) from csv_table. When above SQL was executed, an

[jira] [Commented] (FLINK-6584) Support multiple consecutive windows in SQL

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

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Summary: Exception occur when empty field collection was pushed into CSVTableSource (was: Exception

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into TableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Summary: Exception occur when empty field collection was pushed into TableSource (was: Error occur

[GitHub] flink issue #4199: [FLINK-6584] [table] Support multiple consecutive windows...

2017-10-11 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4199 Hi @twalthr, I looked into this PR again. We should add this to the next release to also support window joins on a window aggregated table. I tried to rebase it on the current master.

[GitHub] flink issue #4789: [FLINK-7780] [REST][Client] Define protocol for triggerin...

2017-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4789 merging. ---

[jira] [Created] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview

2017-10-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7806: Summary: Move CurrentJobsOverviewHandler to jobs/overview Key: FLINK-7806 URL: https://issues.apache.org/jira/browse/FLINK-7806 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

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

[GitHub] flink issue #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to new RES...

2017-10-11 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4734 @tillrohrmann @zentol alright, thanks for the review and inputs. I'll address comments and change the `CurrentJobIdsHandler` to return all available Job IDs as a simple list as Till suggested.

[jira] [Updated] (FLINK-7468) Implement sender backlog logic for credit-based

2017-10-11 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-7468: Summary: Implement sender backlog logic for credit-based (was: Implement Netty sender backlog logic for

[jira] [Created] (FLINK-7805) Add HA capabilities to YarnResourceManager

2017-10-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7805: Summary: Add HA capabilities to YarnResourceManager Key: FLINK-7805 URL: https://issues.apache.org/jira/browse/FLINK-7805 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7465) Add build-in BloomFilterCount on TableAPI

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

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r143959669 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -227,13 +241,19 @@ public void startNewWorker(ResourceProfile

[GitHub] flink issue #4790: [FLINK-7764] [kafka] Enable the operator settings for Fli...

2017-10-11 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4790 We actually still need to do this because we cannot remove the `writeToKafkaWithTimestamps()` methods without breaking compatibility. (They are marked as deprecated, though). @xccui For

[jira] [Assigned] (FLINK-7803) Update savepoint Documentation

2017-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7803: --- Assignee: Razvan > Update savepoint Documentation > -- >

[jira] [Commented] (FLINK-7750) Strange behaviour in savepoints

2017-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200038#comment-16200038 ] Aljoscha Krettek commented on FLINK-7750: - Yes, that would be great! You can create a Jira issue

[jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

2017-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199891#comment-16199891 ] Aljoscha Krettek commented on FLINK-7669: - Could you maybe send me your code so that I can build

[GitHub] flink pull request #4652: [FLINK-7465][table]Add cardinality count for table...

2017-10-11 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4652#discussion_r143956930 --- Diff: docs/dev/table/sql.md --- @@ -2020,7 +2020,16 @@ COUNT(*) Returns the number of input rows. - + +

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

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

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

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

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r143958924 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -227,13 +241,19 @@ public void startNewWorker(ResourceProfile

[jira] [Commented] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200028#comment-16200028 ] ASF GitHub Bot commented on FLINK-7764: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-4808) Allow skipping failed checkpoints

2017-10-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200032#comment-16200032 ] Stephan Ewen commented on FLINK-4808: - I think the contributor that wanted to look into this did not

[jira] [Commented] (FLINK-7792) CliFrontend tests suppress logging

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

[GitHub] flink pull request #4792: [FLINK-7792] [tests][client] Only suppress stdout ...

2017-10-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4792 ---

[GitHub] flink pull request #4797: [hotfix][doc] Remove outdated best-practice sugges...

2017-10-11 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/4797 [hotfix][doc] Remove outdated best-practice suggestion to use .withParameters() This way of passing parameters does not work with the streaming API and is actually confusing for users.

[jira] [Closed] (FLINK-7741) Fix NPE when throw new SlotNotFoundException

2017-10-11 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-7741. - Resolution: Won't Fix > Fix NPE when throw new SlotNotFoundException >

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-10-11 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r143934625 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,439 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

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

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

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

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-11 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199946#comment-16199946 ] Shashank Agarwal commented on FLINK-6321: - It's coming in 1.3.2 also. I have used Keyedcep with 2

[jira] [Comment Edited] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-11 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199946#comment-16199946 ] Shashank Agarwal edited comment on FLINK-6321 at 10/11/17 8:14 AM: --- It's

[jira] [Commented] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

2017-10-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199948#comment-16199948 ] Stephan Ewen commented on FLINK-7737: - I am still a bit confused - if {{hsync()}} is really only about

[jira] [Created] (FLINK-7803) Update savepoint Documentation

2017-10-11 Thread Razvan (JIRA)
Razvan created FLINK-7803: - Summary: Update savepoint Documentation Key: FLINK-7803 URL: https://issues.apache.org/jira/browse/FLINK-7803 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-7791) Integrate LIST command into REST client

2017-10-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7791: Issue Type: Sub-task (was: Improvement) Parent: FLINK-7040 > Integrate LIST

[jira] [Commented] (FLINK-7801) Integrate list command into REST client

2017-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200026#comment-16200026 ] Till Rohrmann commented on FLINK-7801: -- True, didn't see this one. Will close this issue in favour of

[jira] [Closed] (FLINK-7801) Integrate list command into REST client

2017-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7801. Resolution: Duplicate > Integrate list command into REST client >

[jira] [Commented] (FLINK-7780) Integrate savepoint command into REST client

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

[jira] [Created] (FLINK-7804) YarnResourceManager does not execute AMRMClientAsync callbacks in main thread

2017-10-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7804: Summary: YarnResourceManager does not execute AMRMClientAsync callbacks in main thread Key: FLINK-7804 URL: https://issues.apache.org/jira/browse/FLINK-7804 Project:

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into TableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Summary: Exception occur when empty field collection was pushed into TableSource (was: Exception occur

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

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

[GitHub] flink issue #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to new RES...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4734 I just talked to @zentol and we both agreed that we should register the `CurrentJobsOverviewHandler` under `jobs/overview`. Moreover, we should change the `CurrentJobIdsHandler` such that it

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

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

[GitHub] flink pull request #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to ...

2017-10-11 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4734#discussion_r143983019 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobStatusesWithIdsOverview.java --- @@ -0,0 +1,368 @@ +/* + *

[jira] [Created] (FLINK-7808) JobDetails constructor should check length of tasksPerState array

2017-10-11 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7808: --- Summary: JobDetails constructor should check length of tasksPerState array Key: FLINK-7808 URL: https://issues.apache.org/jira/browse/FLINK-7808 Project: Flink

[jira] [Commented] (FLINK-7785) DispatcherTest failure

2017-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200181#comment-16200181 ] Till Rohrmann commented on FLINK-7785: -- Link to the failed travis build:

[jira] [Commented] (FLINK-7731) Trigger on GlobalWindow does not clean state completely

2017-10-11 Thread Gerard Garcia (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200208#comment-16200208 ] Gerard Garcia commented on FLINK-7731: -- I tried that but it still doesn't work. I have been doing

[jira] [Commented] (FLINK-7812) Log system resources as metrics

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200225#comment-16200225 ] ASF GitHub Bot commented on FLINK-7812: --- GitHub user pnowojski opened a pull request:

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

2017-10-11 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200247#comment-16200247 ] Xingcan Cui commented on FLINK-7798: Hi [~fhueske], I tried to add the check logic, but encountered

[GitHub] flink issue #4791: [hotfix] [Javadoc] Fix typos

2017-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4791 merging. ---

[jira] [Commented] (FLINK-7813) Replace MetricRegistryThreadFactory

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

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-10-11 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r143934519 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -227,13 +241,19 @@ public void startNewWorker(ResourceProfile

[jira] [Closed] (FLINK-7792) CliFrontend tests suppress logging

2017-10-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7792. --- Resolution: Fixed 1.4: 367e430e5d4afd6bd7f78ff68dd31254fb2179bd > CliFrontend tests suppress

[GitHub] flink pull request #4799: [FLINK-7807] [REST] Log exceptions in HandlerUtils...

2017-10-11 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4799 [FLINK-7807] [REST] Log exceptions in HandlerUtils methods ## What is the purpose of the change This PR introduces a logger into the `HandlerUtils` class to log exceptions that otherwise

[jira] [Commented] (FLINK-7807) HandlerUtils methods should log errors

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

[jira] [Updated] (FLINK-7785) DispatcherTest failure

2017-10-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7785: Description: https://travis-ci.org/zentol/flink/builds/285598037 {code} Tests run: 2,

[jira] [Updated] (FLINK-7785) DispatcherTest failure

2017-10-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7785: Description: https://travis-ci.org/zentol/flink/builds/285598037

[jira] [Created] (FLINK-7809) Drop support for Scala 2.10

2017-10-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7809: --- Summary: Drop support for Scala 2.10 Key: FLINK-7809 URL: https://issues.apache.org/jira/browse/FLINK-7809 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7810: --- Summary: Switch from custom Flakka to Akka 2.4.x Key: FLINK-7810 URL: https://issues.apache.org/jira/browse/FLINK-7810 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

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

[jira] [Resolved] (FLINK-7707) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint

2017-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7707. -- Resolution: Done Added via bc4638a3c96049de3ef615159cf83bbd88019575 > Port

[GitHub] flink pull request #4772: [FLINK-7707] [flip6] Add TaskCheckpointStatisticDe...

2017-10-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4772 ---

[GitHub] flink issue #4800: [FLINK-7808] [REST] JobDetails constructor checks size of...

2017-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4800 merging. ---

[jira] [Commented] (FLINK-7808) JobDetails constructor should check length of tasksPerState array

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

[GitHub] flink issue #4797: [hotfix][doc] Remove outdated best-practice suggestion to...

2017-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4797 merging. ---

[GitHub] flink pull request #4803: [FLINK-7813] [metrics] Replace MetricRegistryThrea...

2017-10-11 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4803 [FLINK-7813] [metrics] Replace MetricRegistryThreadFactory ## What is the purpose of the change This PR modifies the MetricRegistry to use the ExecutorThreadFactory instead of its own

[GitHub] flink pull request #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to ...

2017-10-11 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4734#discussion_r143973267 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -242,6 +248,86 @@ public void start() throws Exception {

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200092#comment-16200092 ] ASF GitHub Bot commented on FLINK-6505: --- GitHub user bowenli86 opened a pull request:

[jira] [Created] (FLINK-7807) HandlerUtils methods should log errors

2017-10-11 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7807: --- Summary: HandlerUtils methods should log errors Key: FLINK-7807 URL: https://issues.apache.org/jira/browse/FLINK-7807 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7808) JobDetails constructor should check length of tasksPerState array

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

[GitHub] flink pull request #4800: [FLINK-7808] [REST] JobDetails constructor checks ...

2017-10-11 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4800 [FLINK-7808] [REST] JobDetails constructor checks size of tasksPerSta… …te argument ## What is the purpose of the change This PR modifies the JobDetails constructor to verify that

[GitHub] flink issue #4791: [hotfix] [Javadoc] Fix typos

2017-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4791 +1 ---

[jira] [Created] (FLINK-7812) Log system resources as metrics

2017-10-11 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-7812: - Summary: Log system resources as metrics Key: FLINK-7812 URL: https://issues.apache.org/jira/browse/FLINK-7812 Project: Flink Issue Type: New Feature

[GitHub] flink pull request #4802: [FLINK-7791] [REST][client] Integrate LIST command...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4802#discussion_r144007707 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java --- @@ -684,6 +688,29 @@ public void stop(final JobID jobId)

[GitHub] flink pull request #4802: [FLINK-7791] [REST][client] Integrate LIST command...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4802#discussion_r144004816 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -420,89 +420,72 @@ protected int list(String[] args) {

[GitHub] flink pull request #4798: [FLINK-6505] Proactively cleanup local FS for Rock...

2017-10-11 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4798 [FLINK-6505] Proactively cleanup local FS for RocksDBKeyedStateBackend on startup ## What is the purpose of the change In `RocksDBKeyedStateBackend`, the `instanceBasePath` is cleared on

[jira] [Closed] (FLINK-7780) Integrate savepoint command into REST client

2017-10-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7780. --- Resolution: Fixed 1.4: e8e1e330a62bcdad939c896ab807362cc346278b &

[GitHub] flink pull request #4789: [FLINK-7780] [REST][Client] Define protocol for tr...

2017-10-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4789 ---

[jira] [Created] (FLINK-7811) Add support for Scala 2.12

2017-10-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7811: --- Summary: Add support for Scala 2.12 Key: FLINK-7811 URL: https://issues.apache.org/jira/browse/FLINK-7811 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to ...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4734#discussion_r143996677 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobStatusesWithIdsOverview.java --- @@ -0,0 +1,368 @@ +/* +

[GitHub] flink pull request #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to ...

2017-10-11 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4734#discussion_r143998745 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobStatusesWithIdsOverview.java --- @@ -0,0 +1,368 @@ +/* + *

[jira] [Commented] (FLINK-7707) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint

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

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

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

[jira] [Commented] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200221#comment-16200221 ] ASF GitHub Bot commented on FLINK-7764: --- Github user aljoscha commented on the issue:

[GitHub] flink pull request #4802: [FLINK-7791] [REST][client] Integrate LIST command...

2017-10-11 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4802 [FLINK-7791] [REST][client] Integrate LIST command into RestClusterClient ## What is the purpose of the change This PR integrates the LIST command into the RestClusterClient. This is a

[GitHub] flink issue #4799: [FLINK-7807] [REST] Log exceptions in HandlerUtils method...

2017-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4799 merging. ---

[jira] [Commented] (FLINK-7807) HandlerUtils methods should log errors

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

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

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

[GitHub] flink pull request #4802: [FLINK-7791] [REST][client] Integrate LIST command...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4802#discussion_r144006709 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClusterClientTest.java --- @@ -134,6 +140,25 @@ public void

[GitHub] flink pull request #4802: [FLINK-7791] [REST][client] Integrate LIST command...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4802#discussion_r144005365 --- Diff: flink-clients/src/test/java/org/apache/flink/client/CliFrontendListTest.java --- @@ -0,0 +1,72 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

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

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

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

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

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

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

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

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

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

[GitHub] flink pull request #4802: [FLINK-7791] [REST][client] Integrate LIST command...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4802#discussion_r144005254 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -192,6 +196,18 @@ public String

  1   2   3   >