Fix misleading log message

Fix DLQ error log message incorrectly referring to PQ.

Fixes #11063
This commit is contained in:
Rob Bavey 2019-08-20 10:57:10 -04:00
parent fe6783b3cb
commit 0f25107cde

View file

@ -59,7 +59,7 @@ public final class RecordIOReader implements Closeable {
if (versionInFile != VERSION) {
this.channel.close();
throw new RuntimeException(String.format(
"Invalid version on PQ data file %s. Expected version: %c. Version found on file: %c",
"Invalid version on DLQ data file %s. Expected version: %c. Version found on file: %c",
path, VERSION, versionInFile));
}
this.channelPosition = this.channel.position();