Ada Wong created FLINK-24381: -------------------------------- Summary: Hidden password value when Flink SQL connector throw exception. Key: FLINK-24381 URL: https://issues.apache.org/jira/browse/FLINK-24381 Project: Flink Issue Type: Improvement Components: Table SQL / Planner Affects Versions: 1.13.2 Reporter: Ada Wong
This following is error message. Password is 'bar' and is displayed. Could we hidden it to password='***' or password='<hidden>' inspired by Apache Kafka source code. {code:java} Missing required options are: hosts Unable to create a sink for writing table 'default_catalog.default_database.dws'. Table options are: 'connector'='elasticsearch7-x' 'index'='foo' 'password'='bar' at org.apache.flink.table.factories.FactoryUtil.createTableSink(FactoryUtil.java:208) at org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:369) at org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:221) at org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:159 {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)