diff --git a/core/src/main/java/org/polypheny/db/docker/DockerContainer.java b/core/src/main/java/org/polypheny/db/docker/DockerContainer.java index ffb11771f3..d13ba1f30f 100644 --- a/core/src/main/java/org/polypheny/db/docker/DockerContainer.java +++ b/core/src/main/java/org/polypheny/db/docker/DockerContainer.java @@ -189,8 +189,8 @@ private void startProxyForConnection( DockerInstance dockerInstance, Socket loca OutputStream remoteOut = client.getOutputStream().get(); try { remoteOut.write( (containerId + ":" + port + "\n").getBytes( StandardCharsets.UTF_8 ) ); - Thread copyToRemote = pipe( local.getInputStream(), remoteOut, String.format( "polypheny => %s", uniqueName ) ); - Thread copyFromRemote = pipe( client.getInputStream().get(), local.getOutputStream(), String.format( "polypheny <= %s", uniqueName ) ); + Thread copyToRemote = pipe( local.getInputStream(), remoteOut, String.format( "polypheny -> %s", uniqueName ) ); + Thread copyFromRemote = pipe( client.getInputStream().get(), local.getOutputStream(), String.format( "polypheny <- %s", uniqueName ) ); new Thread( () -> { while ( true ) { try {