Skip to content

Commit

Permalink
revert format change straggler
Browse files Browse the repository at this point in the history
  • Loading branch information
edman124 committed Sep 19, 2023
1 parent eab8eed commit cf3bc0f
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1407,7 +1407,8 @@ public void close() {
// The coder type that will be present is:
// WindowedValueCoder(TimerOrElementCoder(KvCoder))
@Nullable Coder<?> keyCoder = executionState.getKeyCoder();
@Nullable Object executionKey =
@Nullable
Object executionKey =
keyCoder == null ? null : keyCoder.decode(key.newInput(), Coder.Context.OUTER);

if (workItem.hasHotKeyInfo()) {
Expand Down

0 comments on commit cf3bc0f

Please sign in to comment.