@@ -215,8 +215,9 @@ private void sendQueued(int threshhold) {
215
215
tabletFiles .values ().stream ().mapToInt (Map ::size ).sum (), tabletFiles .size ());
216
216
}
217
217
218
- // Tablet servers process tablets serially and perform a single metadata table write for each tablet.
219
- // Break the work into per-tablet chunks so it can be sent over multiple connections
218
+ // Tablet servers process tablets serially and perform a single metadata table write for
219
+ // each tablet.
220
+ // Break the work into per-tablet chunks so it can be sent over multiple connections
220
221
// to the tserver, allowing each chunk to be run in parallel on the server side.
221
222
// This allows multiple threads on a single tserver to do metadata writes for this bulk
222
223
// import.
@@ -259,20 +260,20 @@ private void sendQueued(int threshhold) {
259
260
} catch (TException ex ) {
260
261
String additionalInfo = "" ;
261
262
if (ex instanceof TApplicationException && ((TApplicationException ) ex ).getType ()
262
- == TApplicationException .UNKNOWN_METHOD ) {
263
- // A new RPC method was added in 2.1.4, a tserver running 2.1.3 or earlier will
264
- // not have this RPC. This should not kill the fate operation, it can wait until
265
- // all tablet servers are upgraded.
266
- outdatedTservers ++;
267
- additionalInfo = " (tserver may be running older version)" ;
268
- }
263
+ == TApplicationException .UNKNOWN_METHOD ) {
264
+ // A new RPC method was added in 2.1.4, a tserver running 2.1.3 or earlier will
265
+ // not have this RPC. This should not kill the fate operation, it can wait until
266
+ // all tablet servers are upgraded.
267
+ outdatedTservers ++;
268
+ additionalInfo = " (tserver may be running older version)" ;
269
269
}
270
- log .debug ("rpc recv failed server{}: {}, {}" , additionalInfo , client .server , fmtTid , ex );
270
+ log .debug ("rpc recv failed server{}: {}, {}" , additionalInfo , client .server , fmtTid ,
271
+ ex );
271
272
}
272
273
}
273
274
274
275
if (outdatedTservers > 0 ) {
275
- log .info (
276
+ log .warn (
276
277
"{} can not proceed with bulk import because {} tablet servers are likely running "
277
278
+ "an older version. Please update tablet servers to same patch level as manager." ,
278
279
fmtTid , outdatedTservers );
0 commit comments