re-interrupt the current thread, in order to restore the thread's interrupt status.

src/main/java/com/microsoft/sqlserver/jdbc/IOBuffer.java

@@ -6882,6 +6882,8 @@ public void run() {
             while (--secondsRemaining > 0);
         }
         catch (InterruptedException e) {
+            // re-interrupt the current thread, in order to restore the thread's interrupt status.
+            Thread.currentThread().interrupt();
             return;
         }
 

src/main/java/com/microsoft/sqlserver/jdbc/SQLServerBulkCopy.java

@@ -289,6 +289,8 @@ public void run() {
                 while (--secondsRemaining > 0);
             }
             catch (InterruptedException e) {
+                // re-interrupt the current thread, in order to restore the thread's interrupt status.
+                Thread.currentThread().interrupt();
                 return;
             }
 

src/main/java/com/microsoft/sqlserver/jdbc/SQLServerConnection.java

@@ -1723,7 +1723,8 @@ else if (null == currentPrimaryPlaceHolder) {
                     Thread.sleep(sleepInterval);
                 }
                 catch (InterruptedException e) {
-                    // continue if the thread is interrupted. This really should not happen.
+                    // re-interrupt the current thread, in order to restore the thread's interrupt status.
+                    Thread.currentThread().interrupt();
                 }
                 sleepInterval = (sleepInterval < 500) ? sleepInterval * 2 : 1000;
             }
@@ -3531,7 +3532,8 @@ else if (authenticationString.trim().equalsIgnoreCase(SqlAuthentication.ActiveDi
                         Thread.sleep(sleepInterval);
                     }
                     catch (InterruptedException e1) {
-                        // continue if the thread is interrupted. This really should not happen.
+                        // re-interrupt the current thread, in order to restore the thread's interrupt status.
+                        Thread.currentThread().interrupt();
                     }
                     sleepInterval = sleepInterval * 2;
                 }

src/test/java/com/microsoft/sqlserver/jdbc/connection/ConnectionDriverTest.java

@@ -19,8 +19,11 @@
 import java.sql.SQLFeatureNotSupportedException;
 import java.sql.Statement;
 import java.util.Properties;
+import java.util.UUID;
 import java.util.concurrent.Executor;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
 import java.util.logging.Logger;
 
 import javax.sql.ConnectionEvent;
@@ -510,4 +513,45 @@ public void testGetSchema() throws SQLException {
         SQLServerConnection conn = (SQLServerConnection) DriverManager.getConnection(connectionString);
         conn.getSchema();
     }
+
+    static Boolean isInterrupted = false;
+
+    /**
+     * Test thread's interrupt status is not cleared.
+     * 
+     * @throws InterruptedException
+     */
+    @Test
+    public void testThreadInterruptedStatus() throws InterruptedException {
+        Runnable runnable = new Runnable() {
+            public void run() {
+                SQLServerDataSource ds = new SQLServerDataSource();
+
+                ds.setURL(connectionString);
+                ds.setServerName("invalidServerName" + UUID.randomUUID());
+                ds.setLoginTimeout(5);
+
+                try {
+                    ds.getConnection();
+                }
+                catch (SQLException e) {
+                    isInterrupted = Thread.currentThread().isInterrupted();
+                }
+            }
+        };
+
+        ExecutorService executor = Executors.newFixedThreadPool(1);
+        Future<?> future = executor.submit(runnable);
+
+        Thread.sleep(1000);
+
+        // interrupt the thread in the Runnable
+        future.cancel(true);
+
+        Thread.sleep(8000);
+
+        executor.shutdownNow();
+
+        assertTrue(isInterrupted, "Thread's interrupt status is not set.");
+    }
 }