diff --git a/dbcon/joblist/expressionstep.cpp b/dbcon/joblist/expressionstep.cpp
index 0a9453790..da7b0fd74 100644
--- a/dbcon/joblist/expressionstep.cpp
+++ b/dbcon/joblist/expressionstep.cpp
@@ -555,7 +555,10 @@ void ExpressionStep::substitute(uint64_t i, const SSC& ssc)
 
 void ExpressionStep::functionJoinCheck(SimpleFilter* sf, JobInfo& jobInfo)
 {
-	// only handle one & only one table at each side, and not the same table
+	if ((sf->lhs()->resultType().colDataType == CalpontSystemCatalog::VARBINARY ||
+         sf->lhs()->resultType().colDataType == CalpontSystemCatalog::BLOB) && !fVarBinOK)
+		throw runtime_error("VARBINARY/BLOB in join is not supported.");
+    // only handle one & only one table at each side, and not the same table
 	fFunctionJoinInfo.reset(new FunctionJoinInfo);
 	if ((parseFuncJoinColumn(sf->lhs(), jobInfo) == false) ||
 	    (parseFuncJoinColumn(sf->rhs(), jobInfo) == false) ||
diff --git a/dbcon/joblist/jlf_execplantojoblist.cpp b/dbcon/joblist/jlf_execplantojoblist.cpp
index cbaf94256..c4f81e498 100644
--- a/dbcon/joblist/jlf_execplantojoblist.cpp
+++ b/dbcon/joblist/jlf_execplantojoblist.cpp
@@ -944,6 +944,9 @@ const JobStepVector doFilterExpression(const SimpleColumn* sc1, const SimpleColu
 const JobStepVector doJoin(
 	SimpleColumn* sc1, SimpleColumn* sc2, JobInfo& jobInfo, const SOP& sop, SimpleFilter* sf)
 {
+  	if ((sc1->resultType().colDataType == CalpontSystemCatalog::VARBINARY ||
+         sc1->resultType().colDataType == CalpontSystemCatalog::BLOB))
+		throw runtime_error("VARBINARY/BLOB in join is not supported.");
 	//The idea here is to take the two SC's and pipe them into a HJ step. The output of the HJ step
 	// is 2 DL's (one for each table) that are the minimum rid list for each side of the join.
 	CalpontSystemCatalog::OID tableOid1 = tableOid(sc1, jobInfo.csc);
@@ -1201,6 +1204,9 @@ const JobStepVector doJoin(
 
 const JobStepVector doSemiJoin(const SimpleColumn* sc, const ReturnedColumn* rc, JobInfo& jobInfo)
 {
+   	if ((sc->resultType().colDataType == CalpontSystemCatalog::VARBINARY ||
+         sc->resultType().colDataType == CalpontSystemCatalog::BLOB))
+		throw runtime_error("VARBINARY/BLOB in join is not supported.");
 	CalpontSystemCatalog::OID tableOid1 = tableOid(sc, jobInfo.csc);
 	CalpontSystemCatalog::OID tableOid2 = execplan::CNX_VTABLE_ID;
 	string alias1(extractTableAlias(sc));