src/main/java/org/apache/flink/benchmark/full/SerializationFrameworkAllBenchmarks.java [85:97]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        StreamExecutionEnvironment env = context.env;
        env.setParallelism(4);
        ((SerializerConfigImpl) env.getConfig().getSerializerConfig()).setForceAvro(true);

        env.addSource(new PojoSource(RECORDS_PER_INVOCATION, 10))
                .rebalance()
                .addSink(new DiscardingSink<>());

        env.execute();
    }

    @Benchmark
    @OperationsPerInvocation(value = RECORDS_PER_INVOCATION)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/benchmark/full/SerializationFrameworkAllBenchmarks.java [99:111]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        StreamExecutionEnvironment env = context.env;
        env.setParallelism(4);
        ((SerializerConfigImpl) env.getConfig().getSerializerConfig()).setForceAvro(true);

        env.addSource(new PojoSource(RECORDS_PER_INVOCATION, 10))
                .rebalance()
                .addSink(new DiscardingSink<>());

        env.execute();
    }

    @Benchmark
    @OperationsPerInvocation(value = RECORDS_PER_INVOCATION)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -