[#1078] fixed parallelism bug (#1079)

fixes #1078
dbs-leipzig · Nov 12, 2018 · 123f601 · 123f601
1 parent b074161
commit 123f601
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/gradoop-flink/src/main/java/org/gradoop/flink/io/impl/csv/CSVBase.java b/gradoop-flink/src/main/java/org/gradoop/flink/io/impl/csv/CSVBase.java
@@ -242,7 +242,7 @@ protected <E extends Element> DataSet<Tuple3<String, String, String>> createMeta
     DataSet<E> elements) {
     return elements
       .map(new ElementToPropertyMetaData<>())
-      .groupBy(1)
+      .groupBy(0, 1)
       .reduce(new ReducePropertyMetaData())
       .map(tuple -> Tuple3.of(tuple.f0, tuple.f1, MetaDataParser.getPropertiesMetaData(tuple.f2)))
       .returns(new TupleTypeInfo<>(