I tried and it didn't work. Is there a way to send refresh through JDBC
driver?
val impalaUrl = "jdbc:hive2://impala:21050/default1;auth=noSasl"
val driverClass = Class.forName("org.apache.hive.jdbc.HiveDriver")
val conn = DriverManager.getConnection(impalaUrl)
val st = conn.createStatement()
st.execute("refresh my_table")
conn.close
Exception in thread "main" java.sql.SQLException: AnalysisException: Syntax
error at:
refresh my_table
^
Encountered: IDENTIFIER
Expected: ALTER, CREATE, DESCRIBE, DROP, SELECT, SHOW, USE, INSERT
CAUSED BY: Exception: Syntax error
at org.apache.hive.jdbc.Utils.verifySuccess(Utils.java:159)
at org.apache.hive.jdbc.Utils.verifySuccessWithInfo(Utils.java:147)