diff --git a/runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java b/runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java index d2fd28a77581..5f3eaf87dafc 100644 --- a/runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java +++ b/runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java @@ -76,8 +76,7 @@ }) public class DoFnOp implements Op { private static final Logger LOG = LoggerFactory.getLogger(DoFnOp.class); - public static final String TIMER_BATCH_LIMIT_CONFIG = - "beam.samza.dofnop.timerBatchLimit"; + public static final String TIMER_BATCH_LIMIT_CONFIG = "beam.samza.dofnop.timerBatchLimit"; private final TupleTag mainOutputTag; private final DoFn doFn;