src/main/java/org/apache/flink/benchmark/full/SerializationFrameworkAllBenchmarks.java [74:82]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        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 [103:111]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        env.addSource(new PojoSource(RECORDS_PER_INVOCATION, 10))
                .rebalance()
                .addSink(new DiscardingSink<>());

        env.execute();
    }

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