diff --git a/src/main/java/com/microsoft/sqlserver/jdbc/SQLServerBlob.java b/src/main/java/com/microsoft/sqlserver/jdbc/SQLServerBlob.java
index 6d23038f9..be5a9e465 100644
--- a/src/main/java/com/microsoft/sqlserver/jdbc/SQLServerBlob.java
+++ b/src/main/java/com/microsoft/sqlserver/jdbc/SQLServerBlob.java
@@ -232,7 +232,7 @@ public byte[] getBytes(long pos,
      */
     public long length() throws SQLException {
         checkClosed();
-        if (value == null)
+        if (value == null && activeStreams.get(0) instanceof PLPInputStream)
         	return (long)((PLPInputStream)activeStreams.get(0)).payloadLength;
         getBytesFromStream();
         return value.length;