Remove access tokens which are no more valid

Author: Amogh Shetkar

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 '0Xo8rg3W0SOiqu14HZYeyFPZi', " +
-        "consumerSecret 'gieTDrdzFS4b1g9mcvyyyadOkKoHqbVQALoxfZ19eHJzV9CpLR', " +
-        "accessToken '43324358-0KiFugPFlZNfYfib5b6Ah7c2NdHs1524v7LM2qaUq', " +
-        "accessTokenSecret 'aB1AXHaRiE3g2d7tLgyASdgIg9J7CzbPKBkNfvK8Y88bu', " +
+        "consumerKey '**REMOVED**', " +
+        "consumerSecret '**REMOVED**', " +
+        "accessToken '**REMOVED**', " +
+        "accessTokenSecret '**REMOVED**', " +
         "rowConverter 'io.snappydata.streaming.TweetToRowsConverter')")
   }
 

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 '0Xo8rg3W0SOiqu14HZYeyFPZi', " +
-        "consumerSecret 'gieTDrdzFS4b1g9mcvyyyadOkKoHqbVQALoxfZ19eHJzV9CpLR', " +
-        "accessToken '43324358-0KiFugPFlZNfYfib5b6Ah7c2NdHs1524v7LM2qaUq', " +
-        "accessTokenSecret 'aB1AXHaRiE3g2d7tLgyASdgIg9J7CzbPKBkNfvK8Y88bu', " +
+        "consumerKey '**REMOVED**', " +
+        "consumerSecret '**REMOVED**', " +
+        "accessToken '**REMOVED**', " +
+        "accessTokenSecret '**REMOVED**', " +
         "rowConverter 'io.snappydata.streaming.TweetToRowsConverter')")
     s.execute("streaming start")
     s.execute("streaming start")

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://AKIAILHSQ3FINHV473RQ:Tnn6GOHhjaayIRtVNApYQgNLU3FxXkw9albr9hVJ@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://AKIAILHSQ3FINHV473RQ:Tnn6GOHhjaayIRtVNApYQgNLU3FxXkw9albr9hVJ@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);