Problem
Problem: a task in LegoFlow-SWE (Harbor dataset). The Elasticsearch sink currently lacks the ability to handle schema evolution in streaming pipelines, even when schema save mode is set to CREATE SCHEMA WHEN NOT EXIST . Two related scenarios fail:
The task
The Elasticsearch sink currently lacks the ability to handle schema evolution in streaming pipelines, even when `schema_save_mode` is set to `CREATE_SCHEMA_WHEN_NOT_EXIST`. Two related scenarios fail:
Part of Lego-X/LegoFlow-SWE.