diff --git a/flow/e2e/bigquery/peer_flow_bq_test.go b/flow/e2e/bigquery/peer_flow_bq_test.go index 5da81a3e3e..b7b4177aab 100644 --- a/flow/e2e/bigquery/peer_flow_bq_test.go +++ b/flow/e2e/bigquery/peer_flow_bq_test.go @@ -713,7 +713,7 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Types_BQ() { c14 INET,c15 INTEGER,c16 INTERVAL,c17 JSON,c18 JSONB,c21 MACADDR,c22 MONEY, c23 NUMERIC,c24 OID,c28 REAL,c29 SMALLINT,c30 SMALLSERIAL,c31 SERIAL,c32 TEXT, c33 TIMESTAMP,c34 TIMESTAMPTZ,c35 TIME, c36 TIMETZ,c37 TSQUERY,c38 TSVECTOR, - c39 TXID_SNAPSHOT,c40 UUID,c41 XML, c42 INT[], c43 FLOAT[], c44 TEXT[]); + c39 TXID_SNAPSHOT,c40 UUID,c41 XML, c42 INT[], c43 FLOAT[], c44 TEXT[], c45 HSTORE); `, srcTableName)) require.NoError(s.t, err) @@ -750,7 +750,8 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Types_BQ() { '66073c38-b8df-4bdb-bbca-1c97596b8940'::uuid,xmlcomment('hello'), ARRAY[10299301,2579827], ARRAY[0.0003, 8902.0092], - ARRAY['hello','bye']; + ARRAY['hello','bye'], + 'key1=>value1, key2=>value2'::hstore `, srcTableName)) e2e.EnvNoError(s.t, env, err) }() @@ -768,7 +769,7 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Types_BQ() { "c41", "c1", "c2", "c3", "c4", "c6", "c39", "c40", "id", "c9", "c11", "c12", "c13", "c14", "c15", "c16", "c17", "c18", "c21", "c22", "c23", "c24", "c28", "c29", "c30", "c31", "c33", "c34", "c35", "c36", - "c37", "c38", "c7", "c8", "c32", "c42", "c43", "c44", + "c37", "c38", "c7", "c8", "c32", "c42", "c43", "c44", "c45", }) if err != nil { s.t.Log(err) @@ -780,6 +781,10 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Types_BQ() { err = s.checkJSONValue(dstTableName, "c17", "sai", "-8.021390374331551") require.NoError(s.t, err) + // check if HSTORE on bigquery side is a good JSON + err = s.checkJSONValue(dstTableName, "c45", "key1", "\"value1\"") + require.NoError(s.t, err) + env.AssertExpectations(s.t) }