distributed exception handling

stanford-futuredata · May 22, 2018 · 9dc864d · 9dc864d
1 parent 1fad6ed
commit 9dc864d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...a/edu/stanford/futuredata/macrobase/distributed/ingest/CSVDataFrameParserDistributed.java b/...a/edu/stanford/futuredata/macrobase/distributed/ingest/CSVDataFrameParserDistributed.java
@@ -116,7 +116,7 @@ public DistributedDataFrame load(JavaSparkContext sparkContext, int numPartition
                                     } else if (t == Schema.ColType.DOUBLE) {
                                         try {
                                             doubleRow[doubleColNum] = Double.parseDouble(rowValue);
-                                        } catch (NumberFormatException e) {
+                                        } catch (NumberFormatException | NullPointerException e) {
                                             doubleRow[doubleColNum] = Double.NaN;
                                         }
                                         doubleColNum++;