Skip to content

Commit d79431c

Browse files
authored
fix typo (alibaba#3532)
1 parent 9117112 commit d79431c

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public class MysqlConnector {
4646

4747
private SocketChannel channel;
4848
private volatile boolean dumping = false;
49-
// mysql connectinnId
49+
// mysql connectionId
5050
private long connectionId = -1;
5151
private AtomicBoolean connected = new AtomicBoolean(false);
5252
// serverVersion
@@ -169,7 +169,7 @@ private void negotiate(SocketChannel channel) throws IOException {
169169
} else if (body[0] == -2) {
170170
throw new IOException("Unexpected EOF packet at handshake phase.");
171171
} else {
172-
throw new IOException("unpexpected packet with field_count=" + body[0]);
172+
throw new IOException("Unexpected packet with field_count=" + body[0]);
173173
}
174174
}
175175
HandshakeInitializationPacket handshakePacket = new HandshakeInitializationPacket();
@@ -273,7 +273,7 @@ private void negotiate(SocketChannel channel) throws IOException {
273273
err.fromBytes(body);
274274
throw new IOException("Error When doing Client Authentication:" + err.toString());
275275
} else {
276-
throw new IOException("unpexpected packet with field_count=" + body[0]);
276+
throw new IOException("Unexpected packet with field_count=" + body[0]);
277277
}
278278
}
279279
}
@@ -304,7 +304,7 @@ private void auth323(SocketChannel channel, byte packetSequenceNumber, byte[] se
304304
err.fromBytes(body);
305305
throw new IOException("Error When doing Client Authentication:" + err.toString());
306306
default:
307-
throw new IOException("unpexpected packet with field_count=" + body[0]);
307+
throw new IOException("Unexpected packet with field_count=" + body[0]);
308308
}
309309
}
310310

parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -303,7 +303,7 @@ private void sendRegisterSlave() throws IOException {
303303
err.fromBytes(body);
304304
throw new IOException("Error When doing Register slave:" + err.toString());
305305
} else {
306-
throw new IOException("unpexpected packet with field_count=" + body[0]);
306+
throw new IOException("Unexpected packet with field_count=" + body[0]);
307307
}
308308
}
309309
}

parse/src/test/java/com/alibaba/otter/canal/parse/DirectLogFetcherTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,7 @@ private void sendRegisterSlave(MysqlConnector connector, int slaveId) throws IOE
149149
err.fromBytes(body);
150150
throw new IOException("Error When doing Register slave:" + err.toString());
151151
} else {
152-
throw new IOException("unpexpected packet with field_count=" + body[0]);
152+
throw new IOException("Unexpected packet with field_count=" + body[0]);
153153
}
154154
}
155155
}

0 commit comments

Comments
 (0)