I think you should use [1] or [2] instead. See [3] for more details. PS: This question is more fit for the user mailing list.
Regards, Dian [1] https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch6_2.11/1.14.4/flink-sql-connector-elasticsearch6_2.11-1.14.4.jar [2] https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7_2.11/1.14.4/flink-sql-connector-elasticsearch7_2.11-1.14.4.jar [3] https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/table/elasticsearch/ On Wed, Apr 6, 2022 at 2:43 PM Muhammad Umar Gulzar <umargulzar...@gmail.com> wrote: > I’m using Python 3.7, Apache-Flink 1.14 and want to sink to ElasticSearch. > > I have added the jar using this code: > > table_env.get_config().get_configuration().set_string('pipeline.jars', > > 'file:///C:/Users/me/PycharmProjects/flink/Lib/flink-connector-elasticsearch-base_2.12-1.14.4.jar') > > > > Here is my sink code > > table_env.execute_sql(""" > CREATE TABLE `Result` ( > date_received DATE, > product_name STRING, > issue STRING, > zip_code INT > ) WITH ( > 'connector' = 'elasticsearch-7', > 'hosts' = ‘host_url', > 'index' = 'index_name’, > 'username' = dummy, > 'password' = '**********’ > ) > """) > > > > But when I run the program, I get this error. > > > > *Could not find any factory for identifier 'elasticsearch-7' that > implements 'org.apache.flink.table.factories.DynamicTableFactory' in the > classpath.* > > > > *Available factory identifiers are:* > > > > *blackhole* > > *datagen* > > *filesystem* > > *print* >
