[jira] [Created] (FLINK-9381) BlobServer data for a job is not getting cleaned up at JM

2018-05-16 Thread Amit Jain (JIRA) 
Amit Jain created FLINK-9381:


 Summary: BlobServer data for a job is not getting cleaned up at JM
 Key: FLINK-9381
 URL: https://issues.apache.org/jira/browse/FLINK-9381
 Project: Flink
  Issue Type: Bug
Affects Versions: 1.5.0
 Environment: Flink 1.5.0 RC3 Commit e725269
Reporter: Amit Jain


We are running Flink 1.5.0 rc3 with YARN as cluster manager and found
 Job Manager is getting killed due to out of disk error.
 
 Upon further analysis, we found blob server data for a job is not
 getting cleaned up.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

[jira] [Created] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job

2018-04-18 Thread Amit Jain (JIRA) 
Amit Jain created FLINK-9207:


 Summary: Client returns SUCCESS(0) return code for canceled job
 Key: FLINK-9207
 URL: https://issues.apache.org/jira/browse/FLINK-9207
 Project: Flink
  Issue Type: Bug
  Components: Client
Affects Versions: 1.5.0
 Environment: Version: 1.5.0, Commit : 2af481a
Reporter: Amit Jain
 Fix For: 1.5.0


Flink Client returns zero return code when a job is deliberately canceled. 

Steps to reproduced it:

1. bin/flink run -p 10 -m yarn-cluster -yjm 1024 -ytm 12288 WordCount.jar

2. User externally canceled the job.

3. Job Manager marked the job as CANCELED.

4. Although client code emits following logs, however returns zero return code.

org.apache.hadoop.yarn.client.api.impl.YarnClientImpl         - Killed 
application application_1523726493647_.

 

 

 

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)