@Override
    public void init(Context context) throws Exception {
      profileViewTable = context.getTaskContext().getUpdatableTable("profile-view-store");
    }
Samza job logic expects integers, but doubles are passed here which results in failure
samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationTest.java