debug - temporary, will be removed

Author: abstractdog

beeline/src/java/org/apache/hive/beeline/BeeLine.java

@@ -560,11 +560,13 @@ public static void mainWithInputRedirection(String[] args, InputStream inputStre
     BeeLine beeLine = new BeeLine();
     try {
       int status = beeLine.begin(args, inputStream);
+      System.out.println("after beeline.begin");
 
       if (!Boolean.getBoolean(BeeLineOpts.PROPERTY_NAME_EXIT)) {
           System.exit(status);
       }
     } finally {
+      System.out.println("mainWithInputRedirection ends, called finally");
       beeLine.close();
     }
   }
@@ -577,6 +579,7 @@ public BeeLine(boolean isBeeLine) {
     this.isBeeLine = isBeeLine;
     this.signalHandler = new SunSignalHandler(this);
     this.shutdownHook = () -> {
+      info("Running shutdown hook");
       try {
         if (history != null) {
           history.save();
@@ -1124,6 +1127,7 @@ public int begin(String[] args, InputStream inputStream, boolean keepHistory) th
     initializeLineReader();
     if (isBeeLine) {
       int code = initArgs(args);
+      info("initArgs returns: " + code);
       if (code != 0) {
         return code;
       }
@@ -1306,6 +1310,7 @@ int runInit() {
         }
       }
     }
+    info(String.format("initialized, exit: %s, executionResult: %d", exit, executionResult));
     return executionResult;
   }
 
@@ -1372,13 +1377,15 @@ private int executeFile(String fileName) {
   }
 
   private int execute(LineReader reader, boolean exitOnError) {
+    System.out.println("Execute with line reader");
     int lastExecutionResult = ERRNO_OK;
     Character mask = (System.getProperty("jline.terminal", "").equals("jline.UnsupportedTerminal")) ? null
                        : LineReaderImpl.NULL_MASK;
 
     String line;
     while (!exit) {
       try {
+        info("trying to parse next line");
         // Execute one instruction; terminate on executing a script if there is an error
         // in silent mode, prevent the query and prompt being echoed back to terminal
         line = (getOpts().isSilent() && getOpts().getScriptFile() != null) ? reader
@@ -1398,6 +1405,7 @@ private int execute(LineReader reader, boolean exitOnError) {
           lastExecutionResult = ERRNO_OK;
         }
       } catch (EndOfFileException t) {
+        info("EndOfFileException caught");
         /*
          * If you're reading from a normal file (not from standard input or a terminal), JLine might raise an
          * EndOfFileException when it reaches the end of the file. JLine uses readLine() for reading input, and it
@@ -1431,6 +1439,7 @@ private void setupHistory() throws IOException {
 
   private void addBeelineShutdownHook() throws IOException {
     // add shutdown hook to flush the history to history file and it also close all open connections
+    info("Add shutdown hook");
     ShutdownHookManager.addShutdownHook(getShutdownHook());
   }
 
@@ -1492,9 +1501,11 @@ private InputStream prepareInputStream(InputStream inputStream) {
 
   protected Terminal buildTerminal(InputStream inputStream) throws IOException {
     if (inputStream != null) { // typically when there is a file script to read from
+      info("Build terminal on stream");
       return TerminalBuilder.builder().streams(inputStream, getErrorStream()).build();
     } else { // no input stream, normal operation: proper behavior needs a system terminal
       // system terminal can only be created with system streams
+      info("Build terminal on system in/err");
       return TerminalBuilder.builder().system(true).dumb(false).streams(System.in, System.err).build();
     }
   }

beeline/src/java/org/apache/hive/beeline/Commands.java

@@ -1514,6 +1514,7 @@ public boolean properties(String line) throws Exception {
 
 
   public boolean connect(String line) throws Exception {
+    beeLine.info("Connect: line: " + line);
     String example = "Usage: connect <url> <username> <password> [driver]"
         + BeeLine.getSeparator();