{"record":{"id":"4a02ab76e704e0db","repo":"prestodb/presto","slug":"parse-error-connectordistributedprocedurehandle","errorCode":null,"errorMessage":"{parse_error} ConnectorDistributedProcedureHandle  ConnectorDistributedProcedureHandle","messagePattern":"(.+?) ConnectorDistributedProcedureHandle  ConnectorDistributedProcedureHandle","errorType":"validation","errorClass":"ParseError","httpStatus":null,"severity":"error","filePath":"presto-native-execution/presto_cpp/presto_protocol/core/presto_protocol_core.cpp","lineNumber":4044,"sourceCode":"namespace facebook::presto::protocol {\nvoid to_json(\n    json& j,\n    const std::shared_ptr<ConnectorDistributedProcedureHandle>& p) {\n  if (p == nullptr) {\n    return;\n  }\n  String type = p->_type;\n  getConnectorProtocol(type).to_json(j, p);\n}\n\nvoid from_json(\n    const json& j,\n    std::shared_ptr<ConnectorDistributedProcedureHandle>& p) {\n  String type;\n  try {\n    type = p->getSubclassKey(j);\n  } catch (json::parse_error& e) {\n    throw ParseError(\n        std::string(e.what()) +\n        \" ConnectorDistributedProcedureHandle  ConnectorDistributedProcedureHandle\");\n  }\n\n  if (j.contains(\"customSerializedValue\")) {\n    VELOX_CHECK(\n        !type.empty() && type[0] != '$',\n        \"Internal handle type '{}' should not have customSerializedValue\",\n        type);\n    std::string binaryData = velox::encoding::Base64::decode(\n        j[\"customSerializedValue\"].get<std::string>());\n    getConnectorProtocol(type).deserialize(binaryData, p);\n    return;\n  }\n\n  getConnectorProtocol(type).from_json(j, p);\n}\n} // namespace facebook::presto::protocol","sourceCodeStart":4026,"sourceCodeEnd":4062,"githubUrl":"https://github.com/prestodb/presto/blob/55bb57d202de3b926896fa966c2c4a44c779634e/presto-native-execution/presto_cpp/presto_protocol/core/presto_protocol_core.cpp#L4026-L4062","documentation":"Velox protocol deserialization error: the JSON for a ConnectorDistributedProcedureHandle could not be parsed — getSubclassKey failed with a parse error. Raised while translating a distributed-procedure (e.g. compaction) plan into the native engine; signals malformed payload or protocol version mismatch.","triggerScenarios":"Thrown at presto-native-execution/presto_cpp/presto_protocol/core/presto_protocol_core.cpp:4044 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Keep Java and Velox protocol jars/binaries in sync","Verify the connector's distributed-procedure handle serialization includes its type key","Inspect the plan JSON for corruption"],"exampleFix":null,"handlingStrategy":"try-catch","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"55bb57d202de3b926896fa966c2c4a44c779634e","analyzedAt":"2026-09-04T12:50:26.162Z","contentChangedAt":"2026-09-04T12:50:26.162Z","schemaVersion":2},"datasetVersion":"2026-09-11T21:17:09.523Z"}