Skip to content

Commit f087487

Browse files
leesfdawidwys
authored andcommitted
[hotfix][runtime, docs] Fixed typo in SingleInputGate
1 parent 8a56b89 commit f087487

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -486,7 +486,7 @@ public void requestPartitions() throws IOException, InterruptedException {
486486

487487
// Sanity checks
488488
if (numberOfInputChannels != inputChannels.size()) {
489-
throw new IllegalStateException("Bug in input gate setup logic: mismatch between" +
489+
throw new IllegalStateException("Bug in input gate setup logic: mismatch between " +
490490
"number of total input channels and the currently set number of input " +
491491
"channels.");
492492
}

0 commit comments

Comments
 (0)