gaborgsomogyi commented on code in PR #26916:
URL: https://github.com/apache/flink/pull/26916#discussion_r2281855466
##########
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala:
##########
@@ -1375,6 +1375,81 @@ class CatalogTableITCase(isStreamingMode: Boolean)
extends TableITCaseBase {
"+I[bob]",
tableEnv.executeSql("select lowerUdf(a) from
t1").collect().next().toString)
}
+
+ @TestTemplate
+ def testSensitiveInfoMasking(): Unit = {
+ // Create tables with sensitive info
+ val tableDDL =
+ """
+ |create table t1(
+ | a bigint,
+ | b varchar,
+ | c int
+ |) with (
+ | 'connector' = 'values',
+ | 'password' = 'Secret1',
+ | 'secret' = 'Secret2',
+ | 'fs.azure.account.key' = 'Secret3',
+ | 'apikey' = 'Secret4',
+ | 'api-key' = 'Secret5',
+ | 'auth-params' = 'Secret6',
+ | 'service-key' = 'Secret7',
+ | 'token' = 'Secret8',
+ | 'basic-auth' = 'Secret9',
+ | 'jaas.config' = 'Secret10',
+ | 'http-headers' = '{"Authorization": "Secret11"}'
+ |)
+ """.stripMargin
+
+ tableEnv.executeSql(tableDDL)
+
+ // Test source table validation
+ try {
Review Comment:
Seems like the diff between the 2 try blocks the difference is the SQL
statement and source/sink word. If that so we can just extract it into a
function with 2 params, right?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
