[APEXCORE-113] Application Master not setting correct temp location

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.2.0
• Assignee: gaurav gupta
• Reporter: Chandni Singh
• Created: 10/Sep/15 23:49
• Updated: 27/Dec/15 21:04
• Resolved: 27/Dec/15 21:04

Description

2015-09-10 16:44:03,791 INFO org.apache.hadoop.service.AbstractService: Service com.datatorrent.stram.StreamingAppMasterService failed in state INITED; cause: java.lang.IllegalStateException: Failed to write operator state after partition change PTOperator[id=3,name=Writer]
java.lang.IllegalStateException: Failed to write operator state after partition change PTOperator[id=3,name=Writer]
at com.datatorrent.stram.plan.physical.PhysicalPlan.initCheckpoint(PhysicalPlan.java:1063)
at com.datatorrent.stram.plan.physical.PhysicalPlan.<init>(PhysicalPlan.java:373)
at com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:338)
at com.datatorrent.stram.StreamingContainerManager.getInstance(StreamingContainerManager.java:2870)
at com.datatorrent.stram.StreamingAppMasterService.serviceInit(StreamingAppMasterService.java:516)
at org.apache.hadoop.service.AbstractService.init(AbstractService.java:163)
at com.datatorrent.stram.StreamingAppMaster.main(StreamingAppMaster.java:98)
Caused by: java.io.FileNotFoundException: /tmp/localcheckpoint/3/-1 (Permission denied)
at java.io.FileOutputStream.open(Native Method)
at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
at com.datatorrent.common.util.AsyncFSStorageAgent.save(AsyncFSStorageAgent.java:78)
at com.datatorrent.stram.plan.physical.PhysicalPlan.initCheckpoint(PhysicalPlan.java:1054)
... 6 more
2015-09-10 16:44:03,795 ERROR com.datatorrent.stram.StreamingAppMaster: Exiting Application Master
java.lang.IllegalStateException: Failed to write operator state after partition change PTOperator[id=3,name=Writer]
at com.datatorrent.stram.plan.physical.PhysicalPlan.initCheckpoint(PhysicalPlan.java:1063)
at com.datatorrent.stram.plan.physical.PhysicalPlan.<init>(PhysicalPlan.java:373)
at com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:338)
at com.datatorrent.stram.StreamingContainerManager.getInstance(StreamingContainerManager.java:2870)
at com.datatorrent.stram.StreamingAppMasterService.serviceInit(StreamingAppMasterService.java:516)
at org.apache.hadoop.service.AbstractService.init(AbstractService.java:163)
at com.datatorrent.stram.StreamingAppMaster.main(StreamingAppMaster.java:98)
Caused by: java.io.FileNotFoundException: /tmp/localcheckpoint/3/-1 (Permission denied)
at java.io.FileOutputStream.open(Native Method)
at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
at com.datatorrent.common.util.AsyncFSStorageAgent.save(AsyncFSStorageAgent.java:78)
at com.datatorrent.stram.plan.physical.PhysicalPlan.initCheckpoint(PhysicalPlan.java:1054)

Issue Links

• links to: https://malhar.atlassian.net/browse/APEX-113