diff --git a/hopsworks-IT/src/test/ruby/spec/bigquery_storage_connector_spec.rb b/hopsworks-IT/src/test/ruby/spec/bigquery_storage_connector_spec.rb index 489719ab6e..5030e0f7db 100644 --- a/hopsworks-IT/src/test/ruby/spec/bigquery_storage_connector_spec.rb +++ b/hopsworks-IT/src/test/ruby/spec/bigquery_storage_connector_spec.rb @@ -141,7 +141,7 @@ def create_connector_materializationDataset expect(parsed_result_update['dataset']).to eql(dataset) expect(parsed_result_update['queryTable']).to eql(table) expect(parsed_result_update['queryTable']).to eql(table) - expect(parsed_result_update['arguments']).to eql(nil) + expect(parsed_result_update['arguments']).to eql([]) end it 'should fail to update non existing connector' do diff --git a/hopsworks-IT/src/test/ruby/spec/storage_connector_spec.rb b/hopsworks-IT/src/test/ruby/spec/storage_connector_spec.rb index de467cd947..3d10d36f6c 100644 --- a/hopsworks-IT/src/test/ruby/spec/storage_connector_spec.rb +++ b/hopsworks-IT/src/test/ruby/spec/storage_connector_spec.rb @@ -557,14 +557,13 @@ @connector_name = parsed_json["name"] # disable kafka storage connectors - setVar('enable_kafka_storage_connectors', @enable_kafka_storage_connectors[:value]) + setVar('enable_kafka_storage_connectors',"false") create_session(@project[:username], "Pass123") end after :all do # enable kafka storage connectors temporarily - @enable_kafka_storage_connectors = getVar('enable_kafka_storage_connectors') setVar('enable_kafka_storage_connectors', "true") create_session(@project[:username], "Pass123")