From f740fee7ad3b120979469df0f0678449280204d4 Mon Sep 17 00:00:00 2001 From: Amogh Shetkar Date: Mon, 19 Apr 2021 18:10:11 +0530 Subject: [PATCH] Remove access tokens which are no more valid --- .../externalstore/CatalogConsistencyDUnitTest.scala | 8 ++++---- .../io/snappydata/streaming/StreamingDUnitTest.scala | 8 ++++---- .../concurrency/airline/create_and_load_airline_table.sql | 6 +++--- 3 files changed, 11 insertions(+), 11 deletions(-) diff --git a/cluster/src/dunit/scala/io/snappydata/externalstore/CatalogConsistencyDUnitTest.scala b/cluster/src/dunit/scala/io/snappydata/externalstore/CatalogConsistencyDUnitTest.scala index 1793c9e3cd..ced100eef3 100644 --- a/cluster/src/dunit/scala/io/snappydata/externalstore/CatalogConsistencyDUnitTest.scala +++ b/cluster/src/dunit/scala/io/snappydata/externalstore/CatalogConsistencyDUnitTest.scala @@ -57,10 +57,10 @@ class CatalogConsistencyDUnitTest(s: String) extends ClusterManagerTestBase(s) { snc.sql("create stream table tweetsTable (id long, text string, fullName string, " + "country string, retweets int, hashtag string) using twitter_stream options (" + - "consumerKey '***REMOVED***', " + - "consumerSecret '***REMOVED***', " + - "accessToken '***REMOVED***', " + - "accessTokenSecret '***REMOVED***', " + + "consumerKey '**REMOVED**', " + + "consumerSecret '**REMOVED**', " + + "accessToken '**REMOVED**', " + + "accessTokenSecret '**REMOVED**', " + "rowConverter 'io.snappydata.streaming.TweetToRowsConverter')") } diff --git a/cluster/src/dunit/scala/io/snappydata/streaming/StreamingDUnitTest.scala b/cluster/src/dunit/scala/io/snappydata/streaming/StreamingDUnitTest.scala index 0d89cb4e06..723f54b37f 100644 --- a/cluster/src/dunit/scala/io/snappydata/streaming/StreamingDUnitTest.scala +++ b/cluster/src/dunit/scala/io/snappydata/streaming/StreamingDUnitTest.scala @@ -46,10 +46,10 @@ class StreamingDUnitTest(val s: String) extends ClusterManagerTestBase(s) { "(id long, text string, fullName string, " + "country string, retweets int, hashtag string) " + "using twitter_stream options (" + - "consumerKey '***REMOVED***', " + - "consumerSecret '***REMOVED***', " + - "accessToken '***REMOVED***', " + - "accessTokenSecret '***REMOVED***', " + + "consumerKey '**REMOVED**', " + + "consumerSecret '**REMOVED**', " + + "accessToken '**REMOVED**', " + + "accessTokenSecret '**REMOVED**', " + "rowConverter 'io.snappydata.streaming.TweetToRowsConverter')") s.execute("streaming start") s.execute("streaming start") diff --git a/dtests/src/resources/scripts/concurrency/airline/create_and_load_airline_table.sql b/dtests/src/resources/scripts/concurrency/airline/create_and_load_airline_table.sql index 9561a4bd47..05d84a7afa 100644 --- a/dtests/src/resources/scripts/concurrency/airline/create_and_load_airline_table.sql +++ b/dtests/src/resources/scripts/concurrency/airline/create_and_load_airline_table.sql @@ -4,7 +4,7 @@ DROP TABLE IF EXISTS AIRLINE ; ----- CREATE TEMPORARY STAGING TABLE TO LOAD PARQUET FORMATTED DATA ----- CREATE EXTERNAL TABLE STAGING_AIRLINE - -- USING parquet OPTIONS(path 's3a://***REMOVED***:***REMOVED***@zeppelindemo/airlinedata_cleaned'); + -- USING parquet OPTIONS(path 's3a://:@zeppelindemo/airlinedata_cleaned'); USING parquet OPTIONS(path '/export/shared/QA_DATA/airlinedata_cleaned'); ----- CREATE COLUMN TABLE ----- @@ -19,9 +19,9 @@ DROP TABLE IF EXISTS AIRLINEREF; ----- CREATE TEMPORARY STAGING TABLE TO LOAD PARQUET FORMATTED DATA ----- CREATE EXTERNAL TABLE STAGING_AIRLINEREF - -- USING parquet OPTIONS(path 's3a://***REMOVED***:***REMOVED***@zeppelindemo/airportdata'); + -- USING parquet OPTIONS(path 's3a://:@zeppelindemo/airportdata'); USING parquet OPTIONS(path '/export/shared/QA_DATA/airportdata'); ----- CREATE ROW TABLE ----- -CREATE TABLE AIRLINEREF USING row OPTIONS(PERSISTENT 'SYNCHRONOUS') AS (SELECT CODE, DESCRIPTION FROM STAGING_AIRLINEREF); \ No newline at end of file +CREATE TABLE AIRLINEREF USING row OPTIONS(PERSISTENT 'SYNCHRONOUS') AS (SELECT CODE, DESCRIPTION FROM STAGING_AIRLINEREF);