Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-24381

Table API exceptions may leak sensitive configuration values

    XMLWordPrintableJSON

Details

    Description

      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.

      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
      

      Attachments

        Issue Links

          Activity

            People

              ana4 Luning Wang
              ana4 Luning Wang
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: