Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
0.14.0
-
None
Description
FSDagStateStore#getDags() throws a NPE if the dag checkpoint directory does not exist, since File#listFiles() returns null when the directory does not exist. The fix eagerly creates the checkpoint directory on instantiation of FSDagStateStore.