Details
-
Bug
-
Status: Open
-
Not a Priority
-
Resolution: Unresolved
-
None
-
None
Description
Simplified code:
FilterPredicate filterPredicate = eq(intColumn("intField"), 10);
parquetInputFormat.setFilterPredicate(filterPredicate);
env.createInput(parquetInputFormat);
produces no records whereas
env.createInput(parquetInputFormat)
.filter((FilterFunction) value -> value.get("intField") == 10);
produces records.