failed to create stream test: syntax error
Closed this issue · 0 comments
kongkelin commented
There is an error that the server cannot parse the query.
How to reproduce:
cmd: go run main.go -f ./samples/yaml/timeplus.yaml
error:
FATA[0000] chameleon/generator/job/job.go:137 github.com/timeplus-io/chameleon/generator/job.CreateJob() failed to initialize sink
error="failed to create stream test: request failed with status code 400, response body
Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {\"name\":\"test\",\"columns\":[{\"name\":\"value\",\"type\":\"int64\",\"default\":\"\"},{\"name\":\"time\",\"type\":\"int64\",\"default\":\"\"}],\"ttl_expression\":\"to_datetime(_tp_time) + IN.
---
name: test
timeout: 20
source:
batch_size: 512
concurency: 8
interval: 100
interval_delta: 0
batch_number: 100000000
random_event: true
fields:
- name: value
type: int
limit:
- 0
- 10000
- name: time
type: timestamp_int
sinks:
- type: timeplus
properties:
address: http://localhost:3218
apikey: OgTcKISs6PCK0isAKXMYlNRpI6RgCBvcQWcJbXapNzqMSO4WjoHU1DKbSZl-
observer:
type: timeplus
properties:
address: http://localhost:3218
apikey: OgTcKISs6PCK0isAKXMYlNRpI6RgCBvcQWcJbXapNzqMSO4WjoHU1DKbSZl-
query: select * from test where value=9
time_column: time
metric: latency
metric_store_address: http://localhost:3218
metric_store_apikey: OgTcKISs6PCK0isAKXMYlNRpI6RgCBvcQWcJbXapNzqMSO4WjoHU1DKbSZl-