0

我已经建立了一个两个节点工作人员和一个单节点管理器 WSO2 SP 集群。但是当我将我的规则推送给管理器时,它似乎将它部署在工作节点中,因为它打印出日志“Siddhi app siddhi-app-name-1 of siddhi-app-name-1 成功部署在 ResourceNode { id: wso2-sp -worker-33-123, host: 10.112.33.123, port: 9090 } . 但是当我查看 10.112.33.123 中的 wso2/worker/deplyment/siddhi 文件时,它没有出现。

那么它部署在哪里呢?

 my query is as follows:

  @App:name("siddhi-app-name-1")
  @App:description("rule for siddhi-app-name-1")

  @source(
       type="kafka",topic.list="input-topic",
       group.id="group1",threading.option="single.thread",
       bootstrap.servers="<list of kafka brokers>",
       @map(type="json"))
  define stream inputstream (tag_id string, tag_type int, timestamp long, value double, quality int, datatype string);

  @sink(
      type="kafka",
      topic="output-topic",
      bootstrap.servers="<list of kafka brokers>",
      @map(type="json"))
  Define stream outputstream (message string);

  @dist(execGroup="group1")
  from inputstream[name=="penta"]
  select tag_id as message
  insert into outputstream;'
4

0 回答 0