fix years

Author: dszakallas

src/main/java/ldbc/snb/datagen/util/DateUtils.java

@@ -16,11 +16,6 @@ public static LocalDate utcDateOfEpochMilli(long epochMilli) {
         return Instant.ofEpochMilli(epochMilli).atZone(UTC).toLocalDate();
     }
 
-    public static String formatYear(long epochMilli) {
-        LocalDate date = utcDateOfEpochMilli(epochMilli);
-        return Integer.toString(date.getYear());
-    }
-
     public static boolean isTravelSeason(long epochMilli) {
         LocalDate date = utcDateOfEpochMilli(epochMilli);
 

src/main/scala/ldbc/snb/datagen/generator/serializers/PersonOutputStream.scala

@@ -4,6 +4,7 @@ import ldbc.snb.datagen.entities.dynamic.person.Person
 import ldbc.snb.datagen.generator.dictionary.Dictionaries
 import ldbc.snb.datagen.io.raw.RecordOutputStream
 import ldbc.snb.datagen.model.raw
+import ldbc.snb.datagen.util.DateUtils
 
 import java.util
 import scala.collection.JavaConverters._
@@ -62,7 +63,7 @@ class PersonOutputStream(
         person.getDeletionDate,
         person.getAccountId,
         universityId,
-        person.getClassYear.toInt
+        DateUtils.getYear(person.getClassYear)
       )
       personStudyAtUniversityStream.write(personStudyAtUniversity)
     }
@@ -73,7 +74,7 @@ class PersonOutputStream(
         person.getDeletionDate,
         person.getAccountId,
         companyId,
-        person.getCompanies.get(companyId).toInt
+        DateUtils.getYear(person.getCompanies.get(companyId))
       )
       personWorkAtCompanyStream.write(personWorkAtCompany)
     }