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

support UsernamePasswordCredentials for elasticsearch sink via SQL DDL

    XMLWordPrintableJSON

Details

    Description

      support UsernamePasswordCredentials for elasticsearch sink via SQL DDL.

      For example:

      
      CREATE TABLE es_sink (
          ...
      ) WITH (
        'connector.type' = 'elasticsearch',
        'connector.version' = '6',
        'connector.hosts' = 'host:port',
        'connector.index' = 'index_name',
        'connector.document-type' = 'type_name',
        'connector.credential.username' = 'es_username',
        'connector.credential.password' = 'es_password'
        ...
      );
      

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              yuchuanchen Kai Chen
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 10m
                  10m