fengyue-xve f8d8fe1071 fix: honor the pipeline version header and URL parameter in Elasticsearch _bulk (#9452) ...

* fix: honor the pipeline version header and URL parameter in Elasticsearch _bulk

The Elasticsearch _bulk handlers read only pipeline_name and msg_field and
hardcoded the pipeline version to None, so the x-greptime-pipeline-version
header and the version URL parameter were silently ignored and the latest
version was always used.

Resolve the version from the version query parameter, falling back to the
x-greptime-pipeline-version header, and pass it to
PipelineDefinition::from_name; an unparsable version now fails the request
instead of being ignored. Without either source the latest version is used,
as before.

Signed-off-by: fengyue-xve <1759519137@qq.com>

* fix(elasticsearch): reject invalid pipeline version headers and use HTTP item status

Signed-off-by: fengyue-xve <1759519137@qq.com>

---------

Signed-off-by: fengyue-xve <1759519137@qq.com>

2026-11-12 01:11:21 +00:00

..

admin_function_event.rs

test: cut integration test time and make the storage matrix meaningful (#9308)

2026-09-23 01:52:52 +00:00

build_series_index.rs

feat: add manual series index reconciliation (#9323)

2026-09-24 09:39:21 +00:00

database_ddl_event.rs

test: cut integration test time and make the storage matrix meaningful (#9308)

2026-09-23 01:52:52 +00:00

dict_groupby_sst.rs

fix(query): restore columnar group-by for dictionary-encoded tags (#8902)

2026-08-21 03:50:30 +00:00

drain_datanode.rs

test(meta): cover datanode draining with Kafka and local WAL (#10060)

2026-11-04 18:18:26 +00:00

event_recorder_test_util.rs

feat(procedure): record event actor (#8849)

2026-08-14 09:36:01 +00:00

export_logical_tables.rs

feat: remove the server-side Metric export gate (#9547)

2026-10-13 02:32:30 +00:00

flow_ddl_event.rs

test: cut integration test time and make the storage matrix meaningful (#9308)

2026-09-23 01:52:52 +00:00

gc_event.rs

test: cut integration test time and make the storage matrix meaningful (#9308)

2026-09-23 01:52:52 +00:00

grpc.rs

feat(prometheus): query persisted metric exemplars (#9924)

2026-11-10 08:11:49 +00:00

http.rs

fix: honor the pipeline version header and URL parameter in Elasticsearch _bulk (#9452)

2026-11-12 01:11:21 +00:00

json2.rs

chore(deps): upgrade sqlx to 0.9 to pick up webpki-roots 1.0.10 (#9862)

2026-10-22 07:27:19 +00:00

jsonbench.rs

feat(json2): type hint (#8247)

2026-06-30 07:37:31 +00:00

main.rs

test(meta): cover datanode draining with Kafka and local WAL (#10060)

2026-11-04 18:18:26 +00:00

mysql.rs

fix: match system schema names case-insensitively (#9040)

2026-09-05 08:18:12 +00:00

object_store_wal.rs

test: disable the event recorder in tests that count WAL writes (#10316)

2026-11-10 09:29:35 +00:00

reconciliation_event.rs

test: cut integration test time and make the storage matrix meaningful (#9308)

2026-09-23 01:52:52 +00:00

region_migration.rs

feat(meta): add affinity hooks (#9596)

2026-10-15 09:41:31 +00:00

repartition_event.rs

test: cut integration test time and make the storage matrix meaningful (#9308)

2026-09-23 01:52:52 +00:00

repartition_expr_version.rs

refactor: rename partition rule version to partition expr version (#7696)

2026-02-10 10:12:47 +00:00

repartition.rs

feat(prometheus): query persisted metric exemplars (#9924)

2026-11-10 08:11:49 +00:00

sql.rs

feat: COPY FROM STDIN for postgres interface (#9297)

2026-10-26 07:08:12 +00:00

table_ddl_event.rs

test: cut integration test time and make the storage matrix meaningful (#9308)

2026-09-23 01:52:52 +00:00

truncate.rs

feat: Support procedure_state() using the last procedure ID (#9876)

2026-10-27 07:27:55 +00:00

view_ddl_event.rs

test: cut integration test time and make the storage matrix meaningful (#9308)

2026-09-23 01:52:52 +00:00

wal_prune_event.rs

test: cut integration test time and make the storage matrix meaningful (#9308)

2026-09-23 01:52:52 +00:00