Open
Description
I am trying to migrate data from Elasticsearch to Milvus and below is my configuration:
env {
parallelism = 1
job.mode = "BATCH"
}
source{
Elasticsearch {
tls_verify_hostname = false
tls_verify_certificate = false
hosts = ["http://127.0.0.1:9200/"]
api_key = "APIkey"
index = "books"
}
}
transform {
FieldMapper {
field_mapper = {
_id = _id
vector = vector
}
}
}
sink {
Milvus {
url="http://localhost:19530/"
token=""
database="default"
batch_size=10
}
}
When try to run ./bin/seatunnel.sh --config ./es_to_milvus.conf -m local, getting the below error:
[Factory initialize failed] - Unable to create a source for identifier 'Elasticsearch'.
Metadata
Metadata
Assignees
Labels
No labels