tkhurana opened a new pull request, #2588: URL: https://github.com/apache/phoenix/pull/2588
The forwarder computed the peer destination as getWriterPath(sourceTs, forwardingServerName), keying the dst on the forwarding RS's own name and discarding the origin writer identity. Two source files sharing a timestamp (across RegionServers) then collapsed onto one dst; with FileUtil.copy overwrite=false the second was permanently rejected with PathExistsException, holding the HA group in SYNC_AND_FORWARD long after data was replicated. Key the dst on the origin server name instead, so the forwarded file is byte-identical to what the origin RS would have written natively and inherits the writer's existing (server, timestamp) uniqueness invariant. Add ReplicationLogTracker.getServerName() to extract the origin identity (dot-safe so IP/FQDN host names survive), and route the .plog extension through a shared ReplicationShardDirectoryManager.LOG_FILE_EXTENSION constant. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
