更新

bigdataf · Sep 12, 2018 · 3e07808 · 3e07808
1 parent 46376fa
commit 3e07808
Show file tree

Hide file tree

Showing 175 changed files with 54 additions and 2 deletions.
diff --git a/docs/en/msql-auth-contorl.md b/docs/en/msql-auth-contorl.md
@@ -32,6 +32,7 @@ class DefaultConsoleClient extends TableAuth with Logging with WowLog {
 Suppose you run MLSQL script like this:
 
 ```sql
+set __auth_client__="streaming.dsl.auth.meta.client.DefaultConsoleClient";
 load parquet.`/tmp/abc` as newtable;
 select * from default.abc as cool;
 ```

diff --git a/streamingpro-crawler/metastore_db/README_DO_NOT_TOUCH_FILES.txt b/streamingpro-crawler/metastore_db/README_DO_NOT_TOUCH_FILES.txt
@@ -0,0 +1,9 @@
+
+# *************************************************************************
+# ***              DO NOT TOUCH FILES IN THIS DIRECTORY!                ***
+# *** FILES IN THIS DIRECTORY AND SUBDIRECTORIES CONSTITUTE A DERBY     ***
+# *** DATABASE, WHICH INCLUDES THE DATA (USER AND SYSTEM) AND THE       ***
+# *** FILES NECESSARY FOR DATABASE RECOVERY.                            ***
+# *** EDITING, ADDING, OR DELETING ANY OF THESE FILES MAY CAUSE DATA    ***
+# *** CORRUPTION AND LEAVE THE DATABASE IN A NON-RECOVERABLE STATE.     ***
+# *************************************************************************
diff --git a/streamingpro-crawler/metastore_db/db.lck b/streamingpro-crawler/metastore_db/db.lck
diff --git a/streamingpro-crawler/metastore_db/dbex.lck b/streamingpro-crawler/metastore_db/dbex.lck
diff --git a/streamingpro-crawler/metastore_db/log/README_DO_NOT_TOUCH_FILES.txt b/streamingpro-crawler/metastore_db/log/README_DO_NOT_TOUCH_FILES.txt
@@ -0,0 +1,8 @@
+
+# *************************************************************************
+# ***              DO NOT TOUCH FILES IN THIS DIRECTORY!                ***
+# *** FILES IN THIS DIRECTORY ARE USED BY THE DERBY DATABASE RECOVERY   ***
+# *** SYSTEM. EDITING, ADDING, OR DELETING FILES IN THIS DIRECTORY      ***
+# *** WILL CAUSE THE DERBY RECOVERY SYSTEM TO FAIL, LEADING TO          ***
+# *** NON-RECOVERABLE CORRUPT DATABASES.                                ***
+# *************************************************************************
diff --git a/streamingpro-crawler/metastore_db/log/log.ctrl b/streamingpro-crawler/metastore_db/log/log.ctrl
diff --git a/streamingpro-crawler/metastore_db/log/log1.dat b/streamingpro-crawler/metastore_db/log/log1.dat
diff --git a/streamingpro-crawler/metastore_db/log/logmirror.ctrl b/streamingpro-crawler/metastore_db/log/logmirror.ctrl
diff --git a/streamingpro-crawler/metastore_db/seg0/README_DO_NOT_TOUCH_FILES.txt b/streamingpro-crawler/metastore_db/seg0/README_DO_NOT_TOUCH_FILES.txt
@@ -0,0 +1,8 @@
+
+# *************************************************************************
+# ***              DO NOT TOUCH FILES IN THIS DIRECTORY!                ***
+# *** FILES IN THIS DIRECTORY ARE USED BY THE DERBY DATABASE TO STORE   *** 
+# *** USER AND SYSTEM DATA. EDITING, ADDING, OR DELETING FILES IN THIS  ***
+# *** DIRECTORY WILL CORRUPT THE ASSOCIATED DERBY DATABASE AND MAKE     ***
+# *** IT NON-RECOVERABLE.                                               ***
+# *************************************************************************
diff --git a/streamingpro-crawler/metastore_db/seg0/c10.dat b/streamingpro-crawler/metastore_db/seg0/c10.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c101.dat b/streamingpro-crawler/metastore_db/seg0/c101.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c111.dat b/streamingpro-crawler/metastore_db/seg0/c111.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c121.dat b/streamingpro-crawler/metastore_db/seg0/c121.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c130.dat b/streamingpro-crawler/metastore_db/seg0/c130.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c141.dat b/streamingpro-crawler/metastore_db/seg0/c141.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c150.dat b/streamingpro-crawler/metastore_db/seg0/c150.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c161.dat b/streamingpro-crawler/metastore_db/seg0/c161.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c171.dat b/streamingpro-crawler/metastore_db/seg0/c171.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c180.dat b/streamingpro-crawler/metastore_db/seg0/c180.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c191.dat b/streamingpro-crawler/metastore_db/seg0/c191.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c1a1.dat b/streamingpro-crawler/metastore_db/seg0/c1a1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c1b1.dat b/streamingpro-crawler/metastore_db/seg0/c1b1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c1c0.dat b/streamingpro-crawler/metastore_db/seg0/c1c0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c1d1.dat b/streamingpro-crawler/metastore_db/seg0/c1d1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c1e0.dat b/streamingpro-crawler/metastore_db/seg0/c1e0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c1f1.dat b/streamingpro-crawler/metastore_db/seg0/c1f1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c20.dat b/streamingpro-crawler/metastore_db/seg0/c20.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c200.dat b/streamingpro-crawler/metastore_db/seg0/c200.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c211.dat b/streamingpro-crawler/metastore_db/seg0/c211.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c221.dat b/streamingpro-crawler/metastore_db/seg0/c221.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c230.dat b/streamingpro-crawler/metastore_db/seg0/c230.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c241.dat b/streamingpro-crawler/metastore_db/seg0/c241.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c251.dat b/streamingpro-crawler/metastore_db/seg0/c251.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c260.dat b/streamingpro-crawler/metastore_db/seg0/c260.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c271.dat b/streamingpro-crawler/metastore_db/seg0/c271.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c281.dat b/streamingpro-crawler/metastore_db/seg0/c281.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c290.dat b/streamingpro-crawler/metastore_db/seg0/c290.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c2a1.dat b/streamingpro-crawler/metastore_db/seg0/c2a1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c2b1.dat b/streamingpro-crawler/metastore_db/seg0/c2b1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c2c1.dat b/streamingpro-crawler/metastore_db/seg0/c2c1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c2d0.dat b/streamingpro-crawler/metastore_db/seg0/c2d0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c2e1.dat b/streamingpro-crawler/metastore_db/seg0/c2e1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c2f0.dat b/streamingpro-crawler/metastore_db/seg0/c2f0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c300.dat b/streamingpro-crawler/metastore_db/seg0/c300.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c31.dat b/streamingpro-crawler/metastore_db/seg0/c31.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c311.dat b/streamingpro-crawler/metastore_db/seg0/c311.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c321.dat b/streamingpro-crawler/metastore_db/seg0/c321.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c331.dat b/streamingpro-crawler/metastore_db/seg0/c331.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c340.dat b/streamingpro-crawler/metastore_db/seg0/c340.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c351.dat b/streamingpro-crawler/metastore_db/seg0/c351.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c361.dat b/streamingpro-crawler/metastore_db/seg0/c361.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c371.dat b/streamingpro-crawler/metastore_db/seg0/c371.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c380.dat b/streamingpro-crawler/metastore_db/seg0/c380.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c391.dat b/streamingpro-crawler/metastore_db/seg0/c391.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c3a1.dat b/streamingpro-crawler/metastore_db/seg0/c3a1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c3b1.dat b/streamingpro-crawler/metastore_db/seg0/c3b1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c3c0.dat b/streamingpro-crawler/metastore_db/seg0/c3c0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c3d1.dat b/streamingpro-crawler/metastore_db/seg0/c3d1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c3e1.dat b/streamingpro-crawler/metastore_db/seg0/c3e1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c3f1.dat b/streamingpro-crawler/metastore_db/seg0/c3f1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c400.dat b/streamingpro-crawler/metastore_db/seg0/c400.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c41.dat b/streamingpro-crawler/metastore_db/seg0/c41.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c411.dat b/streamingpro-crawler/metastore_db/seg0/c411.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c421.dat b/streamingpro-crawler/metastore_db/seg0/c421.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c430.dat b/streamingpro-crawler/metastore_db/seg0/c430.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c441.dat b/streamingpro-crawler/metastore_db/seg0/c441.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c451.dat b/streamingpro-crawler/metastore_db/seg0/c451.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c461.dat b/streamingpro-crawler/metastore_db/seg0/c461.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c470.dat b/streamingpro-crawler/metastore_db/seg0/c470.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c481.dat b/streamingpro-crawler/metastore_db/seg0/c481.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c490.dat b/streamingpro-crawler/metastore_db/seg0/c490.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c4a1.dat b/streamingpro-crawler/metastore_db/seg0/c4a1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c4b0.dat b/streamingpro-crawler/metastore_db/seg0/c4b0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c4c1.dat b/streamingpro-crawler/metastore_db/seg0/c4c1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c4d1.dat b/streamingpro-crawler/metastore_db/seg0/c4d1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c4e1.dat b/streamingpro-crawler/metastore_db/seg0/c4e1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c4f0.dat b/streamingpro-crawler/metastore_db/seg0/c4f0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c501.dat b/streamingpro-crawler/metastore_db/seg0/c501.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c51.dat b/streamingpro-crawler/metastore_db/seg0/c51.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c510.dat b/streamingpro-crawler/metastore_db/seg0/c510.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c521.dat b/streamingpro-crawler/metastore_db/seg0/c521.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c530.dat b/streamingpro-crawler/metastore_db/seg0/c530.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c541.dat b/streamingpro-crawler/metastore_db/seg0/c541.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c550.dat b/streamingpro-crawler/metastore_db/seg0/c550.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c561.dat b/streamingpro-crawler/metastore_db/seg0/c561.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c570.dat b/streamingpro-crawler/metastore_db/seg0/c570.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c581.dat b/streamingpro-crawler/metastore_db/seg0/c581.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c590.dat b/streamingpro-crawler/metastore_db/seg0/c590.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c5a1.dat b/streamingpro-crawler/metastore_db/seg0/c5a1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c5b0.dat b/streamingpro-crawler/metastore_db/seg0/c5b0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c5c1.dat b/streamingpro-crawler/metastore_db/seg0/c5c1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c5d0.dat b/streamingpro-crawler/metastore_db/seg0/c5d0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c5e1.dat b/streamingpro-crawler/metastore_db/seg0/c5e1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c5f0.dat b/streamingpro-crawler/metastore_db/seg0/c5f0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c60.dat b/streamingpro-crawler/metastore_db/seg0/c60.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c601.dat b/streamingpro-crawler/metastore_db/seg0/c601.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c610.dat b/streamingpro-crawler/metastore_db/seg0/c610.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c621.dat b/streamingpro-crawler/metastore_db/seg0/c621.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c630.dat b/streamingpro-crawler/metastore_db/seg0/c630.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c641.dat b/streamingpro-crawler/metastore_db/seg0/c641.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c650.dat b/streamingpro-crawler/metastore_db/seg0/c650.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c661.dat b/streamingpro-crawler/metastore_db/seg0/c661.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c670.dat b/streamingpro-crawler/metastore_db/seg0/c670.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c681.dat b/streamingpro-crawler/metastore_db/seg0/c681.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c690.dat b/streamingpro-crawler/metastore_db/seg0/c690.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c6a1.dat b/streamingpro-crawler/metastore_db/seg0/c6a1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c6b0.dat b/streamingpro-crawler/metastore_db/seg0/c6b0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c6c1.dat b/streamingpro-crawler/metastore_db/seg0/c6c1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c6d0.dat b/streamingpro-crawler/metastore_db/seg0/c6d0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c6e1.dat b/streamingpro-crawler/metastore_db/seg0/c6e1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c6f0.dat b/streamingpro-crawler/metastore_db/seg0/c6f0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c701.dat b/streamingpro-crawler/metastore_db/seg0/c701.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c71.dat b/streamingpro-crawler/metastore_db/seg0/c71.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c711.dat b/streamingpro-crawler/metastore_db/seg0/c711.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c721.dat b/streamingpro-crawler/metastore_db/seg0/c721.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c731.dat b/streamingpro-crawler/metastore_db/seg0/c731.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c741.dat b/streamingpro-crawler/metastore_db/seg0/c741.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c751.dat b/streamingpro-crawler/metastore_db/seg0/c751.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c761.dat b/streamingpro-crawler/metastore_db/seg0/c761.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c771.dat b/streamingpro-crawler/metastore_db/seg0/c771.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c781.dat b/streamingpro-crawler/metastore_db/seg0/c781.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c791.dat b/streamingpro-crawler/metastore_db/seg0/c791.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c7a1.dat b/streamingpro-crawler/metastore_db/seg0/c7a1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c7b1.dat b/streamingpro-crawler/metastore_db/seg0/c7b1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c7c1.dat b/streamingpro-crawler/metastore_db/seg0/c7c1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c7d1.dat b/streamingpro-crawler/metastore_db/seg0/c7d1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c7e1.dat b/streamingpro-crawler/metastore_db/seg0/c7e1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c7f1.dat b/streamingpro-crawler/metastore_db/seg0/c7f1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c801.dat b/streamingpro-crawler/metastore_db/seg0/c801.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c81.dat b/streamingpro-crawler/metastore_db/seg0/c81.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c811.dat b/streamingpro-crawler/metastore_db/seg0/c811.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c821.dat b/streamingpro-crawler/metastore_db/seg0/c821.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c831.dat b/streamingpro-crawler/metastore_db/seg0/c831.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c840.dat b/streamingpro-crawler/metastore_db/seg0/c840.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c851.dat b/streamingpro-crawler/metastore_db/seg0/c851.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c860.dat b/streamingpro-crawler/metastore_db/seg0/c860.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c871.dat b/streamingpro-crawler/metastore_db/seg0/c871.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c880.dat b/streamingpro-crawler/metastore_db/seg0/c880.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c891.dat b/streamingpro-crawler/metastore_db/seg0/c891.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c8a0.dat b/streamingpro-crawler/metastore_db/seg0/c8a0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c8b1.dat b/streamingpro-crawler/metastore_db/seg0/c8b1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c8c1.dat b/streamingpro-crawler/metastore_db/seg0/c8c1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c8d1.dat b/streamingpro-crawler/metastore_db/seg0/c8d1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c8e1.dat b/streamingpro-crawler/metastore_db/seg0/c8e1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c8f1.dat b/streamingpro-crawler/metastore_db/seg0/c8f1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c90.dat b/streamingpro-crawler/metastore_db/seg0/c90.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c901.dat b/streamingpro-crawler/metastore_db/seg0/c901.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c911.dat b/streamingpro-crawler/metastore_db/seg0/c911.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c920.dat b/streamingpro-crawler/metastore_db/seg0/c920.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c931.dat b/streamingpro-crawler/metastore_db/seg0/c931.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c940.dat b/streamingpro-crawler/metastore_db/seg0/c940.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c951.dat b/streamingpro-crawler/metastore_db/seg0/c951.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c960.dat b/streamingpro-crawler/metastore_db/seg0/c960.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c971.dat b/streamingpro-crawler/metastore_db/seg0/c971.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c981.dat b/streamingpro-crawler/metastore_db/seg0/c981.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c990.dat b/streamingpro-crawler/metastore_db/seg0/c990.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c9a1.dat b/streamingpro-crawler/metastore_db/seg0/c9a1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c9b1.dat b/streamingpro-crawler/metastore_db/seg0/c9b1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c9c0.dat b/streamingpro-crawler/metastore_db/seg0/c9c0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c9d1.dat b/streamingpro-crawler/metastore_db/seg0/c9d1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c9e0.dat b/streamingpro-crawler/metastore_db/seg0/c9e0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/c9f1.dat b/streamingpro-crawler/metastore_db/seg0/c9f1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/ca01.dat b/streamingpro-crawler/metastore_db/seg0/ca01.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/ca1.dat b/streamingpro-crawler/metastore_db/seg0/ca1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/ca11.dat b/streamingpro-crawler/metastore_db/seg0/ca11.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/ca21.dat b/streamingpro-crawler/metastore_db/seg0/ca21.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/cb1.dat b/streamingpro-crawler/metastore_db/seg0/cb1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/cc0.dat b/streamingpro-crawler/metastore_db/seg0/cc0.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/cd1.dat b/streamingpro-crawler/metastore_db/seg0/cd1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/ce1.dat b/streamingpro-crawler/metastore_db/seg0/ce1.dat
diff --git a/streamingpro-crawler/metastore_db/seg0/cf0.dat b/streamingpro-crawler/metastore_db/seg0/cf0.dat
diff --git a/streamingpro-crawler/metastore_db/service.properties b/streamingpro-crawler/metastore_db/service.properties
@@ -0,0 +1,23 @@
+#/Users/allwefantasy/CSDNWorkSpace/streamingpro/streamingpro-crawler/metastore_db
+# ********************************************************************
+# ***                Please do NOT edit this file.                 ***
+# *** CHANGING THE CONTENT OF THIS FILE MAY CAUSE DATA CORRUPTION. ***
+# ********************************************************************
+#Tue Sep 11 21:47:22 CST 2018
+SysschemasIndex2Identifier=225
+SyscolumnsIdentifier=144
+SysconglomeratesIndex1Identifier=49
+SysconglomeratesIdentifier=32
+SyscolumnsIndex2Identifier=177
+SysschemasIndex1Identifier=209
+SysconglomeratesIndex3Identifier=81
+SystablesIndex2Identifier=129
+SyscolumnsIndex1Identifier=161
+derby.serviceProtocol=org.apache.derby.database.Database
+SysschemasIdentifier=192
+derby.storage.propertiesId=16
+SysconglomeratesIndex2Identifier=65
+derby.serviceLocale=en_US
+SystablesIdentifier=96
+SystablesIndex1Identifier=113
+#--- last line, don't put anything after this line ---
diff --git a/streamingpro-mlsql/src/main/java/streaming/dsl/ScriptSQLExec.scala b/streamingpro-mlsql/src/main/java/streaming/dsl/ScriptSQLExec.scala
@@ -78,7 +78,7 @@ object ScriptSQLExec extends Logging with WowLog {
       // setListener.env()
       val authListener = new AuthProcessListener(setListener)
       _parse(input, authListener)
-      val tableAuth = Class.forName(authListener.listener.env().getOrElse("auth_client", "streaming.dsl.auth.meta.client.DefaultConsoleClient")).newInstance().asInstanceOf[TableAuth]
+      val tableAuth = Class.forName(authListener.listener.env().getOrElse("__auth_client__", "streaming.dsl.auth.meta.client.DefaultConsoleClient")).newInstance().asInstanceOf[TableAuth]
       tableAuth.auth(authListener.tables().tables.toList)
     }
     _parse(wow, listener)

diff --git a/streamingpro-mlsql/src/main/java/streaming/dsl/auth/meta/client/DefaultConsoleClient.scala b/streamingpro-mlsql/src/main/java/streaming/dsl/auth/meta/client/DefaultConsoleClient.scala
@@ -1,5 +1,6 @@
 package streaming.dsl.auth.meta.client
 
+import streaming.dsl.ScriptSQLExec
 import streaming.dsl.auth.{MLSQLTable, TableAuth, TableAuthResult}
 import streaming.log.{Logging, WowLog}
 
@@ -8,7 +9,8 @@ import streaming.log.{Logging, WowLog}
   */
 class DefaultConsoleClient extends TableAuth with Logging with WowLog {
   override def auth(tables: List[MLSQLTable]): List[TableAuthResult] = {
-    logInfo(format(s"auth ${tables.mkString(",")}"))
+    val owner = ScriptSQLExec.contextGetOrForTest().owner
+    logInfo(format(s"auth ${owner}  want access tables: ${tables.mkString(",")}"))
     throw new RuntimeException("auth fail")
   }
 }
diff --git a/streamingpro-mlsql/src/test/scala/streaming/core/DslSpec.scala b/streamingpro-mlsql/src/test/scala/streaming/core/DslSpec.scala
@@ -850,6 +850,7 @@ class DslSpec extends BasicSparkOperation with SpecFunctions with BasicMLSQLConf
       val ssel = createSSEL
       val mlsql =
         """
+          |set auth_client="streaming.dsl.auth.meta.client.DefaultConsoleClient";
           |load parquet.`/tmp/abc` as newtable;
           |select * from default.abc as cool;
         """.stripMargin