由于转换 groovy 脚本，springxd 流创建失败

Question

[![在此处输入图片描述][1]][1]我想使用 springXD 创建流。根据流的基本定义，我有：

Source :  http

Transform script : I written one groovy script which I stored at 
/xd/modules/processor/script/transform.groovy            

Sink : cassandra

我想存储我从 http 发布到 cassandra table 的非结构化 json 数据。我运行单节点模式的springXD，然后运行xd-shell。对于流创建，我使用：

stream create --name test2 --definition "http --port=9000 | transform --   
script=insert_transform.groovy |cassandra --contactPoints=127.0.0.1 --
keyspace=db1 --ingestQuery='insert into table1 (emp_id,emp_name,amount,time)
values (?,?,?,?)'" –deploy

我收到消息：创建并部署了新流 'test2'

之后，当我通过 http 发布数据时出现以下错误：

500 INTERNAL_SERVER_ERROR

在xd-singlenode上，出现如下错误日志：

Caused by: java.io.FileNotFoundException: class path resource [insert_transform.groovy] cannot be opened because it does not exist.

Answer 1

哪个版本的 Spring XD？我刚刚用 1.3.0.RELEASE 测试了它，它运行良好...

xd:>stream create foo --definition "time | transform --script=test.groovy | log" --deploy

.

$ cat xd/modules/processor/scripts/test.groovy
'Time = ' + payload

.

2016-01-11T09:45:19-0500 1.3.0.RELEASE INFO xdbus.foo.1-1 sink.foo - Time = 2016-01-11 09:45:19
2016-01-11T09:45:20-0500 1.3.0.RELEASE INFO xdbus.foo.1-1 sink.foo - Time = 2016-01-11 09:45:20
2016-01-11T09:45:21-0500 1.3.0.RELEASE INFO xdbus.foo.1-1 sink.foo - Time = 2016-01-11 09:45:21

由于转换 groovy 脚本，springxd 流创建失败

springxd stream creation failed due to transform groovy script

groovy

cassandra

spring-xd