diff --git a/writeengine/bulk/we_columninfo.cpp b/writeengine/bulk/we_columninfo.cpp
index 7d59d6da9..f2e4d0e7d 100644
--- a/writeengine/bulk/we_columninfo.cpp
+++ b/writeengine/bulk/we_columninfo.cpp
@@ -1672,7 +1672,7 @@ int ColumnInfo::updateDctnryStore(char* buf, ColPosPair** pos, const int totalRo
   // column.
   // This only applies to default text mode.  This step is bypassed for
   // binary imports, because in that case, the data is already true binary.
-  if (((curCol.colType == WR_VARBINARY) || (curCol.colType == WR_BLOB)) &&
+  if (((curCol.colType == WR_VARBINARY) || (curCol.colType == WR_BLOB && fpTableInfo->readFromSTDIN())) &&
       (fpTableInfo->getImportDataMode() == IMPORT_DATA_TEXT))
   {
 #ifdef PROFILE
diff --git a/writeengine/bulk/we_tableinfo.cpp b/writeengine/bulk/we_tableinfo.cpp
index 8876b64b7..011c70b5c 100644
--- a/writeengine/bulk/we_tableinfo.cpp
+++ b/writeengine/bulk/we_tableinfo.cpp
@@ -2381,5 +2381,10 @@ int TableInfo::allocateBRMColumnExtent(OID columnOID, uint16_t dbRoot, uint32_t&
   return rc;
 }
 
+bool TableInfo::readFromSTDIN()
+{
+  return fReadFromStdin;
+}
+
 }  // namespace WriteEngine
 // end of namespace
diff --git a/writeengine/bulk/we_tableinfo.h b/writeengine/bulk/we_tableinfo.h
index f5a09ec90..d7ba5ab56 100644
--- a/writeengine/bulk/we_tableinfo.h
+++ b/writeengine/bulk/we_tableinfo.h
@@ -77,7 +77,7 @@ class TableInfo : public WeUIDGID
   FILE* fHandle;           // Handle to the input load file
   int fCurrentReadBuffer;  // Id of current buffer being popu-
   //   lated by the read thread
-  RID fTotalReadRows;               // Total number of rows read
+  RID fTotalReadRows;      // Total number of rows read
   unsigned fTotalErrRows;  // Total error rows among all input
   //   for this table.  Is volatile to
   //   insure parser & reader threads
@@ -459,6 +459,8 @@ class TableInfo : public WeUIDGID
 
   void setJobUUID(const boost::uuids::uuid& jobUUID);
 
+  bool readFromSTDIN();
+
  public:
   friend class BulkLoad;
   friend class ColumnInfo;