Fix backward compatibility on server side

This commit is contained in:
alesapin 2020-02-28 12:57:45 +03:00
parent 1b7bf67e2b
commit 46c6897ab5

View File

@ -35,7 +35,6 @@ namespace DataPartsExchange
namespace namespace
{ {
static constexpr auto REPLICATION_PROTOCOL_VERSION_WITHOUT_PARTS_SIZE = 0;
static constexpr auto REPLICATION_PROTOCOL_VERSION_WITH_PARTS_SIZE = 1; static constexpr auto REPLICATION_PROTOCOL_VERSION_WITH_PARTS_SIZE = 1;
static constexpr auto REPLICATION_PROTOCOL_VERSION_WITH_PARTS_SIZE_AND_TTL_INFOS = 2; static constexpr auto REPLICATION_PROTOCOL_VERSION_WITH_PARTS_SIZE_AND_TTL_INFOS = 2;
@ -58,11 +57,6 @@ void Service::processQuery(const Poco::Net::HTMLForm & params, ReadBuffer & /*bo
String part_name = params.get("part"); String part_name = params.get("part");
if (client_protocol_version != REPLICATION_PROTOCOL_VERSION_WITH_PARTS_SIZE_AND_TTL_INFOS
&& client_protocol_version != REPLICATION_PROTOCOL_VERSION_WITH_PARTS_SIZE
&& client_protocol_version != REPLICATION_PROTOCOL_VERSION_WITHOUT_PARTS_SIZE)
throw Exception("Unsupported fetch protocol version", ErrorCodes::UNKNOWN_PROTOCOL);
const auto data_settings = data.getSettings(); const auto data_settings = data.getSettings();
/// Validation of the input that may come from malicious replica. /// Validation of the input that may come from malicious replica.