Skip to content

Commit 1bb0c9a

Browse files
authored
MINOR: Fix an incorrect assignment in StreamsUncaughtExceptionHandlerIntegrationTest (apache#18837)
This constructor was not initializing a field with the constructor argument, the extra `} {` was ending the constructor body and creating an instance initializer block that assigned the field to itself. Reviewers: Matthias J. Sax <[email protected]>
1 parent effbad9 commit 1bb0c9a

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamsUncaughtExceptionHandlerIntegrationTest.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -183,17 +183,14 @@ public void shouldShutdownSingleThreadApplication() throws Exception {
183183

184184
private static class ShutdownProcessor<KIn, VIn, KOut, VOut> implements Processor<KIn, VIn, KOut, VOut> {
185185

186-
private ProcessorContext<KOut, VOut> context;
187-
188186
final List<String> valueList;
189187

190188
ShutdownProcessor(final List<String> valueList) {
191189
this.valueList = valueList;
192190
}
193191

194192
@Override
195-
public void init(final ProcessorContext<KOut, VOut> context) {} {
196-
this.context = context;
193+
public void init(final ProcessorContext<KOut, VOut> context) {
197194
}
198195

199196
@Override

0 commit comments

Comments
 (0)