Merge pull request #1 from sasamuku/workaroud_for_decimal_point_missing

Support float value without decimal point
sasamuku · Dec 21, 2023 · fab0eeb · fab0eeb
2 parents 1adde64 + 833ad74
commit fab0eeb
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/main/java/org/embulk/filter/expand_json/FilteredPageOutput.java b/src/main/java/org/embulk/filter/expand_json/FilteredPageOutput.java
@@ -359,7 +359,13 @@ else if (Types.DOUBLE.equals(expandedJsonColumn.getColumn().getType())) {
                     pageBuilder.setDouble(expandedJsonColumn.getColumn(), value.asFloatValue().toDouble());
                 }
                 catch (MessageTypeCastException e) {
-                    throw new JsonValueInvalidException(String.format("Failed to parse '%s' as double", expandedJsonColumn.getKey()), e);
+                    try {
+                        // ad-hoc workaround for decimal point missing
+                        pageBuilder.setDouble(expandedJsonColumn.getColumn(), (double) value.asIntegerValue().toLong());
+                    }
+                    catch (MessageTypeCastException e2) {
+                        throw new JsonValueInvalidException(String.format("Failed to parse '%s' as double", expandedJsonColumn.getKey()), e);
+                    }
                 }
             }
             else if (Types.LONG.equals(expandedJsonColumn.getColumn().getType())) {