diff --git a/flow/e2e/bigquery/peer_flow_bq_test.go b/flow/e2e/bigquery/peer_flow_bq_test.go
index 2b92176cef..ca7d3e3b1e 100644
--- a/flow/e2e/bigquery/peer_flow_bq_test.go
+++ b/flow/e2e/bigquery/peer_flow_bq_test.go
@@ -738,7 +738,7 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Types_BQ() {
 		ARRAY[10299301,2579827],
 		ARRAY[0.0003, 8902.0092],
 		ARRAY['hello','bye'],
-		'key1=>value1, key2=>value2'::hstore
+		'key1=>value1, key2=>NULL'::hstore
 		`, srcTableName))
 		e2e.EnvNoError(s.t, env, err)
 	}()
@@ -771,6 +771,8 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Types_BQ() {
 	// check if HSTORE on bigquery side is a good JSON
 	err = s.checkJSONValue(dstTableName, "c45", "key1", "\"value1\"")
 	require.NoError(s.t, err)
+	err = s.checkJSONValue(dstTableName, "c45", "key2", "\"\"")
+	require.NoError(s.t, err)
 
 	env.AssertExpectations(s.t)
 }