[jira] [Resolved] (FLINK-14465) Let StandaloneJobClusterEntrypoint use user code class loader

2019-11-09 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14465. --- Fix Version/s: 1.10.0 Resolution: Done Done via

[jira] [Commented] (FLINK-14572) BlobsCleanupITCase failed on Travis

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970354#comment-16970354 ] Till Rohrmann commented on FLINK-14572: --- Another instance:

[jira] [Closed] (FLINK-8035) Unable to submit job when HA is enabled

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8035. Resolution: Abandoned The issue has been abandoned. > Unable to submit job when HA is enabled >

[jira] [Closed] (FLINK-7970) SlotPool support batch allocating slots

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7970. Resolution: Later This is still a valid problem but we will most likely address this problem as

[jira] [Closed] (FLINK-7969) Resource manager support batch request slots

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7969. Resolution: Later This is still a valid problem but we will most likely tackle this problem as

[jira] [Closed] (FLINK-7965) Docker-Flink: TaskManagers can't find JobManager when in different nodes in Docker Swarm

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7965. Resolution: Abandoned The issue has been abandoned. > Docker-Flink: TaskManagers can't find

[jira] [Closed] (FLINK-7961) Docker-Flink with Docker Swarm doesn't work when machines are in different clouds

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7961. Resolution: Abandoned The issue has been abandoned. > Docker-Flink with Docker Swarm doesn't work

[jira] [Closed] (FLINK-7945) Per partition-lag metric lost in kafka connector

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7945. Resolution: Abandoned This issue has been abandoned. > Per partition-lag metric lost in kafka

[jira] [Updated] (FLINK-7937) Add pagination to Flink History view

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7937: - Priority: Minor (was: Major) > Add pagination to Flink History view >

[jira] [Updated] (FLINK-7937) Add pagination to Flink History view

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7937: - Component/s: (was: Runtime / Coordination) Runtime / REST > Add pagination

[jira] [Updated] (FLINK-7926) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7926: - Component/s: (was: Runtime / Coordination) API / DataSet > Bug in Hybrid

[jira] [Updated] (FLINK-7786) JarActionHandler.tokenizeArguments removes all quotes from program arguments

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7786: - Component/s: (was: Runtime / Coordination) Runtime / REST >

[jira] [Closed] (FLINK-7795) Utilize error-prone to discover common coding mistakes

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7795. Resolution: Abandoned > Utilize error-prone to discover common coding mistakes >

[jira] [Closed] (FLINK-7825) Change the `QueryableStateClient` to use a builder pattern.

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7825. Resolution: Abandoned > Change the `QueryableStateClient` to use a builder pattern. >

[jira] [Closed] (FLINK-7758) Fix bug Kafka09Fetcher add offset metrics

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7758. Resolution: Abandoned > Fix bug Kafka09Fetcher add offset metrics >

[jira] [Closed] (FLINK-7743) Remove the restriction of minimum memory of JM

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7743. Resolution: Not A Problem Not a problem anymore. > Remove the restriction of minimum memory of JM

[jira] [Updated] (FLINK-7727) Extend logging in file server handlers

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7727: - Priority: Minor (was: Major) > Extend logging in file server handlers >

[jira] [Closed] (FLINK-7642) Upgrade maven surefire plugin to 2.21.0

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7642. Resolution: Duplicate > Upgrade maven surefire plugin to 2.21.0 >

[jira] [Closed] (FLINK-7688) ContaineredTaskManagerParameters sets off heap memory size incorrectly unlimited

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7688. Resolution: Abandoned Closing because the issue has been abandoned. >

[jira] [Updated] (FLINK-7634) Add option to create a savepoint while canceling a job in the dashboard

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7634: - Component/s: (was: Runtime / Coordination) Runtime / Web Frontend > Add

[jira] [Updated] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7624: - Component/s: Connectors / Kafka > Add kafka-topic for "KafkaProducer" metrics >

[jira] [Updated] (FLINK-7582) Rest client may buffer responses indefinitely under heavy laod

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7582: - Priority: Minor (was: Major) > Rest client may buffer responses indefinitely under heavy laod >

[jira] [Updated] (FLINK-7550) Give names to REST client/server for clearer logging.

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7550: - Priority: Minor (was: Major) > Give names to REST client/server for clearer logging. >

[jira] [Resolved] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14646. --- Resolution: Fixed Fixed via 1.10.0: 3a096659297b4b61260d1799b5fe3f7151089e19 1.9.2:

[jira] [Updated] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14646: -- Issue Type: Bug (was: Improvement) > Check non-null for key in KeyGroupStreamPartitioner >

[jira] [Updated] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

2019-11-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14646: -- Priority: Minor (was: Major) > Check non-null for key in KeyGroupStreamPartitioner >

[jira] [Closed] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-12122. - Release Note: In order to use a scheduling strategy which is more similar to the pre FLIP-6

[jira] [Reopened] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-12122: --- > Spread out tasks evenly across all available registered TaskManagers >

[jira] [Closed] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-13969. - Resolution: Fixed Fixed via 1.10.0: 7e8218515baf630e668348a68ff051dfa49c90c3 1.9.2:

[jira] [Closed] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-12122. - Fix Version/s: 1.9.2 1.10.0 Resolution: Done Done via 1.10.0:

[jira] [Updated] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13969: -- Fix Version/s: 1.9.2 > Resuming Externalized Checkpoint (rocks, incremental, scale down)

[jira] [Comment Edited] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969146#comment-16969146 ] Till Rohrmann edited comment on FLINK-12342 at 11/7/19 10:31 AM: - I fear

[jira] [Commented] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969146#comment-16969146 ] Till Rohrmann commented on FLINK-12342: --- I fear that this issue has not been fully fixed with the

[jira] [Updated] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14505: -- Priority: Blocker (was: Critical) > SQL Client end-to-end test for Kafka 0.10 nightly

[jira] [Commented] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969142#comment-16969142 ] Till Rohrmann commented on FLINK-14505: --- I would actually make all failing end-to-end tests a

[jira] [Commented] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969141#comment-16969141 ] Till Rohrmann commented on FLINK-14505: --- I'd be ok with this. Let's make sure that this gets fixed

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Issue Type: Bug (was: Improvement) > Starting a TaskExecutor blocks the

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Priority: Critical (was: Major) > Starting a TaskExecutor blocks the YarnResourceManager's

[jira] [Assigned] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14646: - Assignee: Jiayi Liao > Check non-null for key in KeyGroupStreamPartitioner >

[jira] [Updated] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14646: -- Affects Version/s: (was: 1.9.0) 1.10.0 1.8.2

[jira] [Commented] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969094#comment-16969094 ] Till Rohrmann commented on FLINK-14646: --- Sounds good to me. Do you wanna open a PR for it

[jira] [Updated] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14646: -- Fix Version/s: 1.9.2 1.8.3 1.10.0 > Check non-null for

[jira] [Commented] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969086#comment-16969086 ] Till Rohrmann commented on FLINK-13184: --- cc [~fly_in_gis] let's continue our discussion of

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Description: Currently, YarnResourceManager starts all task executors in main thread. This

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Fix Version/s: 1.9.2 1.8.3 > Starting a TaskExecutor blocks the

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Affects Version/s: 1.10.0 > Starting a TaskExecutor blocks the YarnResourceManager's main

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Description: Currently, YarnResourceManager starts all task executors in main thread. This

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Summary: Starting a TaskExecutor blocks the YarnResourceManager's main thread (was: Support

[jira] [Assigned] (FLINK-13184) Support launching task executors with multi-thread on YARN.

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13184: - Assignee: (was: Xintong Song) > Support launching task executors with multi-thread

[jira] [Closed] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14582. - Resolution: Duplicate Closing this issue as a duplicate of FLINK-13184. Let's move the

[jira] [Updated] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

2019-11-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14582: -- Priority: Major (was: Minor) > Do not upload {uuid}-taskmanager-conf.yaml for each task

[jira] [Resolved] (FLINK-14589) Redundant slot requests with the same AllocationID leads to inconsistent slot table

2019-11-06 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14589. --- Resolution: Fixed Fixed via 1.10.0: 155885cc6d182bf0f6519a9992b21b957444b4fe 1.9.2:

[jira] [Resolved] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-11-06 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-12342. --- Resolution: Fixed Fixed via 1.10.0: b8500691c6b1e23c61c9408b5562d67bb2fc2336 1.9.2:

[jira] [Assigned] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

2019-11-06 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14038: - Assignee: liupengcheng > ExecutionGraph deploy failed due to akka timeout >

[jira] [Created] (FLINK-14630) Yarn tests no longer create jobmanager log files

2019-11-06 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-14630: - Summary: Yarn tests no longer create jobmanager log files Key: FLINK-14630 URL: https://issues.apache.org/jira/browse/FLINK-14630 Project: Flink Issue

[jira] [Commented] (FLINK-14607) SharedSlot cannot fulfill pending slot requests before it's completely released

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967612#comment-16967612 ] Till Rohrmann commented on FLINK-14607: --- Yes exactly. Ideally, the {{ExecutionSlotAllocator}}

[jira] [Commented] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967589#comment-16967589 ] Till Rohrmann commented on FLINK-12342: --- One problem seems to be that we remove the container

[jira] [Commented] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967570#comment-16967570 ] Till Rohrmann commented on FLINK-14582: --- I've reopened FLINK-12342 in order to reorder the

[jira] [Updated] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14582: -- Priority: Minor (was: Critical) > Do not upload {uuid}-taskmanager-conf.yaml for each task

[jira] [Updated] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14582: -- Fix Version/s: (was: 1.9.2) (was: 1.8.3)

[jira] [Updated] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-12342: -- Fix Version/s: (was: 1.8.1) (was: 1.7.3)

[jira] [Reopened] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-12342: --- Assignee: Till Rohrmann (was: Zhenqiu Huang) The problem seems to be not entirely

[jira] [Updated] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14582: -- Fix Version/s: 1.9.2 1.8.3 1.10.0 > Do not upload

[jira] [Updated] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14582: -- Priority: Critical (was: Minor) > Do not upload {uuid}-taskmanager-conf.yaml for each task

[jira] [Commented] (FLINK-14607) SharedSlot cannot fulfill pending slot requests before it's completely released

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967431#comment-16967431 ] Till Rohrmann commented on FLINK-14607: --- Thanks for creating this issue [~zhuzh]. I think your

[jira] [Commented] (FLINK-13708) transformations should be cleared because a table environment could execute multiple job

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967419#comment-16967419 ] Till Rohrmann commented on FLINK-13708: --- Please remove the fixes introduced with

[jira] [Resolved] (FLINK-14060) Set slot sharing groups according to pipelined regions

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14060. --- Fix Version/s: 1.10.0 Resolution: Done Done via

[jira] [Commented] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967368#comment-16967368 ] Till Rohrmann commented on FLINK-14505: --- Another instance:

[jira] [Commented] (FLINK-14603) NetworkBufferPoolTest.testBlockingRequestFromMultiLocalBufferPool timeout in travis

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967365#comment-16967365 ] Till Rohrmann commented on FLINK-14603: --- Another instance:

[jira] [Updated] (FLINK-14603) NetworkBufferPoolTest.testBlockingRequestFromMultiLocalBufferPool timeout in travis

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14603: -- Issue Type: Bug (was: Test) >

[jira] [Commented] (FLINK-14603) NetworkBufferPoolTest.testBlockingRequestFromMultiLocalBufferPool timeout in travis

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967361#comment-16967361 ] Till Rohrmann commented on FLINK-14603: --- cc [~kevin.cyj] >

[jira] [Updated] (FLINK-14603) NetworkBufferPoolTest.testBlockingRequestFromMultiLocalBufferPool timeout in travis

2019-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14603: -- Priority: Critical (was: Major) >

[jira] [Resolved] (FLINK-14462) Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14462. --- Resolution: Done Done via 76225edc3667f69cc4d9c63505ce227d0755449d

[jira] [Commented] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966618#comment-16966618 ] Till Rohrmann commented on FLINK-13969: --- I've assigned this ticket to you [~klion26]. Thanks for

[jira] [Assigned] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13969: - Assignee: Congxian Qiu(klion26) > Resuming Externalized Checkpoint (rocks,

[jira] [Updated] (FLINK-14572) BlobsCleanupITCase failed in Travis stage core - scheduler_ng

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14572: -- Labels: scheduler-ng test-stability (was: test-stability) > BlobsCleanupITCase failed in

[jira] [Commented] (FLINK-14576) Elasticsearch (v6.3.1) sink end-to-end test instable

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966528#comment-16966528 ] Till Rohrmann commented on FLINK-14576: --- [~gjy] which version was affected by this test failure?

[jira] [Updated] (FLINK-14572) BlobsCleanupITCase failed in Travis stage core - scheduler_ng

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14572: -- Labels: test-stability (was: ) > BlobsCleanupITCase failed in Travis stage core -

[jira] [Updated] (FLINK-14576) Elasticsearch (v6.3.1) sink end-to-end test instable

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14576: -- Priority: Critical (was: Major) > Elasticsearch (v6.3.1) sink end-to-end test instable >

[jira] [Updated] (FLINK-14576) Elasticsearch (v6.3.1) sink end-to-end test instable

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14576: -- Labels: test-stability (was: ) > Elasticsearch (v6.3.1) sink end-to-end test instable >

[jira] [Updated] (FLINK-14572) BlobsCleanupITCase failed in Travis stage core - scheduler_ng

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14572: -- Priority: Critical (was: Major) > BlobsCleanupITCase failed in Travis stage core -

[jira] [Updated] (FLINK-14555) Streaming File Sink s3 end-to-end test stalls

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14555: -- Priority: Critical (was: Major) > Streaming File Sink s3 end-to-end test stalls >

[jira] [Assigned] (FLINK-14589) Redundant slot requests with the same AllocationID leads to inconsistent slot table

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14589: - Assignee: Hwanju Kim (was: Till Rohrmann) > Redundant slot requests with the same

[jira] [Assigned] (FLINK-14589) Redundant slot requests with the same AllocationID leads to inconsistent slot table

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14589: - Assignee: Till Rohrmann (was: Hwanju Kim) > Redundant slot requests with the same

[jira] [Assigned] (FLINK-14589) Redundant slot requests with the same AllocationID leads to inconsistent slot table

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14589: - Assignee: Hwanju Kim > Redundant slot requests with the same AllocationID leads to

[jira] [Updated] (FLINK-14589) Redundant slot requests with the same AllocationID leads to inconsistent slot table

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14589: -- Fix Version/s: 1.9.2 1.8.3 1.10.0 > Redundant slot

[jira] [Commented] (FLINK-14589) Redundant slot requests with the same AllocationID leads to inconsistent slot table

2019-11-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966466#comment-16966466 ] Till Rohrmann commented on FLINK-14589: --- Thanks for reporting this issue [~hwanju]. I think your

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

2019-11-03 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966250#comment-16966250 ] Till Rohrmann commented on FLINK-11127: --- You are right [~aroch] that we should try to fix this

[jira] [Resolved] (FLINK-14536) Make clear the way to aggregate specified cpuCores resources

2019-11-03 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14536. --- Resolution: Fixed Fixed via ba068d5657f5037ebaa1a4e59491afb89f03f74e > Make clear the way

[jira] [Commented] (FLINK-14594) Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

2019-11-03 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966245#comment-16966245 ] Till Rohrmann commented on FLINK-14594: --- Sounds like a good solution to me. Go ahead [~zhuzh]. >

[jira] [Assigned] (FLINK-14594) Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

2019-11-03 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14594: - Assignee: Zhu Zhu > Fix matching logics of ResourceSpec/ResourceProfile/Resource

[jira] [Resolved] (FLINK-14562) RMQSource leaves idle consumer after closing

2019-11-03 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14562. --- Fix Version/s: 1.9.2 1.8.3 1.10.0 Resolution:

[jira] [Assigned] (FLINK-14562) RMQSource leaves idle consumer after closing

2019-11-03 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14562: - Assignee: Nicolas Deslandes > RMQSource leaves idle consumer after closing >

[jira] [Commented] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

2019-11-03 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16965721#comment-16965721 ] Till Rohrmann commented on FLINK-14582: --- This could mitigate the problem a bit. But wouldn't it be

[jira] [Resolved] (FLINK-14464) Introduce the 'AbstractUserClassPathJobGraphRetriever' which could construct the 'user code class path' from the "job" dir.

2019-11-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14464. --- Fix Version/s: 1.10.0 Resolution: Done Done via

[jira] [Assigned] (FLINK-14583) Remove progressLock from ExecutionGraph

2019-11-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14583: - Assignee: vinoyang > Remove progressLock from ExecutionGraph >

[jira] [Commented] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

2019-11-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964903#comment-16964903 ] Till Rohrmann commented on FLINK-14566: --- Let's make this then a low priority improvement which do

[jira] [Updated] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

2019-11-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14566: -- Priority: Minor (was: Major) > Enable ResourceSpec to get/set whether managed memory is used

[jira] [Assigned] (FLINK-14536) Make clear the way to aggregate specified cpuCores resources

2019-11-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14536: - Assignee: Zhu Zhu > Make clear the way to aggregate specified cpuCores resources >

[jira] [Commented] (FLINK-14536) Make clear the way to aggregate specified cpuCores resources

2019-11-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964901#comment-16964901 ] Till Rohrmann commented on FLINK-14536: --- I've assigned the ticket to you [~zhuzh]. > Make clear

  1   2   3   4   5   6   7   8   9   10   >