Remove access tokens which are no more valid

TIBCOSoftware · Apr 19, 2021 · f740fee · f740fee
1 parent 85e1e73
commit f740fee
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 11 deletions.
diff --git 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
@@ -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
@@ -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://<aws_access_key_id>:<aws_secret_access_key>@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://<aws_access_key_id>:<aws_secret_access_key>@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);
+CREATE TABLE AIRLINEREF USING row OPTIONS(PERSISTENT 'SYNCHRONOUS') AS (SELECT CODE, DESCRIPTION FROM STAGING_AIRLINEREF);