Skip to content

Commit

Permalink
Correct mismatches after accepting suggestions
Browse files Browse the repository at this point in the history
  • Loading branch information
muthumala19 committed Jan 12, 2025
1 parent f679c5d commit e9a9823
Showing 1 changed file with 6 additions and 7 deletions.
13 changes: 6 additions & 7 deletions src/frontend/JasmineGraphFrontEnd.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1320,8 +1320,8 @@ void addStreamHDFSCommand(std::string masterIP, int connFd, std::string &hdfsSer
std::thread &inputStreamHandlerThread, int numberOfPartitions,
SQLiteDBInterface *sqlite, bool *loop_exit_p) {
std::string hdfsPort;
std::string message = "Do you want to use the default HDFS server(y/n)?";
int resultWr = write(connFd, msg1.c_str(), msg1.length());
std::string message1 = "Do you want to use the default HDFS server(y/n)?";
int resultWr = write(connFd, message1.c_str(), message1.length());
if (resultWr < 0) {
frontend_logger.error("Error writing to socket");
*loop_exit_p = true;
Expand Down Expand Up @@ -1354,7 +1354,8 @@ void addStreamHDFSCommand(std::string masterIP, int connFd, std::string &hdfsSer
*loop_exit_p = true;
return;
}
resultWr = write(connFd, "\r\n", 2);
resultWr = write(connFd, Conts::CARRIAGE_RETURN_NEW_LINE.c_str(),
Conts::CARRIAGE_RETURN_NEW_LINE.size());
if (resultWr < 0) {
frontend_logger.error("Error writing to socket");
*loop_exit_p = true;
Expand Down Expand Up @@ -1393,8 +1394,8 @@ void addStreamHDFSCommand(std::string masterIP, int connFd, std::string &hdfsSer
frontend_logger.error("HDFS server port is empty.");
}

std::string message = "HDFS file path: ";
resultWr = write(connFd, message.c_str(), message.length());
std::string message2 = "HDFS file path: ";
resultWr = write(connFd, message2.c_str(), message2.length());
if (resultWr < 0) {
frontend_logger.error("Error writing to socket");
*loop_exit_p = true;
Expand Down Expand Up @@ -1449,8 +1450,6 @@ void addStreamHDFSCommand(std::string masterIP, int connFd, std::string &hdfsSer
bool directed = false;
if (isDirectedS == "y") {
directed = true;
} else {
directed = false;
}

std::string path = "hdfs:" + hdfsFilePathS;
Expand Down

0 comments on commit e9a9823

Please sign in to comment.