Peng Huo
Peng Huo
1. Add concurrent statement limit of each session. if the waiting statement larger than `plugins.query.executionengine.spark.session.interactive_statement.limit`, reject the submit statement request. 2. Default value of plugins.query.executionengine.spark.session.interactive_statement.limit is 10.
* Track all the query state in plugin. currently, we only track interactive queries. we should track batch and streaming queries. * one requirement of this feature is to reduce...
* We should setup OpenSearch EC2 image to let developer could test flint feature. * EC2 image includes * Non-FAGC domain * FGAC domain
**Is your feature request related to a problem?** SQL query field if origin date field in string format (epoch value). A) Create index ``` PUT sample-index ``` B) Put index...
1. currently, submit async query took around 2s to return. 2. we need metrics to measure submit async query api latency.
**What is the bug?** * Implicit cast to timestamp does not work for Text field. ``` select textDate from index where timestamp(textDate) >= \"2023-11-22 23:39:00.000\" ``` * log ``` onException[compare...
Deprecated get JobId and appId from Flint index metadata. https://github.com/opensearch-project/sql/blob/main/spark/src/main/java/org/opensearch/sql/spark/flint/FlintIndexMetadata.java#L35
## Phase - 1: Spark Connector and Flint API Support [Done] * OpenSearch Release: 2.9.0 ## Phase - 2: Support EMR-Serverless as compute engine. ### Goals * OpenSearch Release: 2.11.0...
## Requirements * dependency and configuration should configurable in dev, test, beta.