nebulastream/nebulastream-tutorial

[BUG] Executing the example query fails in the tutorial

Closed this issue · 0 comments

he-sk commented

Cannot execute a query with the latest NebulaStream images.

Reproduce

Start NebulaStream instance:

docker-compose pull
docker-compose up

Execute REST example query:

11:20 hesk@dhcp-213-150:~/my/work/nes/nebulastream-tutorial $ curl -d@rest-query-with-csv-sink.json http://localhost:8081/v1/nes/query/execute-query
{"code":400,"message":"No placement strategy specified. Specify a placement strategy using 'placement'.","more_info":"https://docs.nebula.stream/cpp/class_n_e_s_1_1_placement_strategy.html"}

Execute Java example query:

11:17 hesk@dhcp-213-150:~/my/work/nes/nebulastream-tutorial $ cd java-client-example/
11:17 hesk@dhcp-213-150:~/my/work/nes/nebulastream-tutorial/java-client-example $ ./gradlew run
Starting a Gradle Daemon (subsequent builds will be faster)

> Task :run FAILED
{"strategyName":"BottomUp","userQuery":"Query::from(\"wind_turbines\").window(TumblingWindow::of(EventTime(Attribute(\"features_properties_updated\")), Minutes(10))).byKey(Attribute(\"metadata_id\")).apply(Sum(Attribute(\"features_properties_mag\"))).sink(FileSinkDescriptor::create(\"/tutorial/java-query-results.csv\", \"CSV_FORMAT\", \"OVERRIDE\"));"}
Exception in thread "main" stream.nebula.exceptions.RESTException: REST API returned error: [statusCode=400, message=]
        at stream.nebula.runtime.NebulaStreamRuntime.executeQuery(NebulaStreamRuntime.java:123)
        at NebulaStreamTutorial.main(NebulaStreamTutorial.java:32)

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':run'.
> Process 'command '/Users/hesk/Library/Java/JavaVirtualMachines/azul-1.8.0_312/Contents/Home/bin/java'' finished with non-zero exit value 1

* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

BUILD FAILED in 3s
2 actionable tasks: 2 executed

Environment

  • OS: macOS 12.6 (MacBook Air M1)
  • NebulaStream: v0.3.11