 		outStream = new HadoopUtils::FileOutStream();
 		outStream->open(out_stream);
 
-		printf("SocketClient is connect to port %d ...\n", SERVER_SOCKET_PORT);
+		printf("SocketClient is connected to port %d ...\n", port);
 	}
 
 	~SocketClient() {

class SocketServer {
private:
	int sock;
	bool done;
	sockaddr_in addr;

public:
	SocketServer() {
		sock = -1;
		done = false;

		sock = socket(PF_INET, SOCK_STREAM, 0);
		if (sock == -1) {
			fprintf(stderr, "problem creating socket: %s\n", strerror(errno));
		}

		addr.sin_family = AF_INET;
		addr.sin_port = htons(SERVER_SOCKET_PORT);
		addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
	}

	~SocketServer() {


		} while (!done);

		printf("SocketServer stopped!\n");
		pthread_exit(0);
	}

	static void *SocketServer_thread(void *context) {
