Redact sensitive information in Spark Thrift Server log

  override def runInternal(): Unit = {
    setState(OperationState.PENDING)
    logInfo(s"Submitting query '$statement' with $statementId")

21/08/03 20:49:46 INFO SparkExecuteStatementOperation: Submitting query 'CREATE OR REPLACE TEMPORARY VIEW test_view
    USING org.apache.spark.sql.jdbc
    OPTIONS (
        url="jdbc:mysql://example.com:3306",
        driver="com.mysql.jdbc.Driver",
        dbtable="example.test",
        user="my_username",
        password="my_password"
    )' with 37e5d2cb-aa96-407e-b589-7cb212324100
21/08/03 20:49:46 INFO SparkExecuteStatementOperation: Running query with 37e5d2cb-aa96-407e-b589-7cb212324100