Branch | Build Status |
---|---|
master |
Please refer the Getting Started section.
You can reachout through Slack channel, Google mail group and etc. Please refer the community contribution site for more informati
Siddhi SDK for IntelliJ Idea Plugin & PySiddhi
License: Apache License 2.0
Branch | Build Status |
---|---|
master |
Please refer the Getting Started section.
You can reachout through Slack channel, Google mail group and etc. Please refer the community contribution site for more informati
Description:
I try to run siddhi application with the siddhi-sdk but ,I found that the siddhi-application will always repeated start-action.
This is the command-line when I started application:
F:/studySoftware/siddhi-sdk-1.0.0\bin\siddhi.bat run E:/CompanyProj/siddhiDemo/src/com/pop.siddhi
Here is the result :
[org.wso2.extension.siddhi.io.http.source.HttpConnectorPortBindingListener] : siddhi: started HTTP server connector localhost:8081
[org.wso2.extension.siddhi.io.http.source.HttpSourceListener] : Source Listener has created for url http://localhost:8081/Api/public/test
[org.wso2.extension.siddhi.io.http.source.HttpSourceListener] : Source Listener has created for url http://localhost:8081/Api/public/test
ERROR [org.wso2.siddhi.core.stream.input.source.Source] - Error on 'TestExecutSionPlan'. Listener URL http://localhost:8081/Api/public/test already connectedError while connecting at Source 'http' at 'FooStream'.
org.wso2.siddhi.core.exception.SiddhiAppCreationException: Error on 'TestExecutSionPlan'. Listener URL http://localhost:8081/Api/public/test already connected
at org.wso2.extension.siddhi.io.http.source.HttpConnectorRegistry.registerSourceListener(HttpConnectorRegistry.java:143)
The bug info obviously show the problem,the application will start when it is already started
Also,I use the siddhi-io-kafka,the problem exist too.the log shows that the kafka-consumer will be created again and again.
So, I guess that this may be a bug
siddhi application source code:
@App:name('testSiddhi')
--@source(type='kafka',
-- topic.list='localtopic',
-- partition.no='1',
-- threading.option='single.thread',
-- group.id="test",
-- bootstrap.servers='localhost:9092',
-- @map(type='json'))
@source(type = 'http',
receiver.url='http://localhost:8081/Api/public/test',
basic.auth.enabled='false',@map(type='json'))
define stream FooStream (symbol string, price float, volume long);
--
--@sink(type='kafka',
-- topic='resulttopic',
-- partition.no='0',
-- bootstrap.servers='localhost:9092',
-- @map(type='json')
--)
@sink(type='log', prefix="LOGGER")
define stream OutputStream (symbol string, price float, volume long,multiple float);
@info(name = 'query1')
from FooStream select symbol, price, volume,(price * volume) as multiple insert into OutputStream;
By the way,I also use Stream Processor Studio to test my code.it run successfully~
Affected Product Version:
Siddhi-SDK 1.0.0
OS, DB, other environment details and versions:
Windows 10 , Idea Version: 2017.3.3 ,Siddhi-plugin-Idea 1.1.0
Steps to reproduce:
Thank you ~QvQ
Description:
Hello, when I was using siddhi,I found that something about the error of siddhiAppCreationException would be reported as I used the statement of from in partition.What's more,no detailed message about this error was described.
@App:name("firstrule")
@App:description("Description of the plan")
@source(type='http',receiver.url = 'http://localhost:8080/exchange',headers = "'content-type:application/json'",@map(type='json'))
define stream exchangeStream(id int, price double, exchangeWay int, exChangeNum long);
@sink(type='log',@map(type='json'))
define stream outputStream(times string, id int, invalidCount long,price double);
define window dataCacheWindow (times string, id int, invalidCount long,price double) timeBatch(10 second);
partition with (id of exchangeStream)
begin
from exchangeStream select time:currentTime() as times, id, count(id) as invalidCount, price group by id having invalidCount > 1 insert into dataCacheWindow;
from dataCacheWindow select times, id, invalidCount, price insert into outputStream;
end
Suggested Labels:
Suggested Assignees:
Affected Product Version:
OS, DB, other environment details and versions:
Steps to reproduce:
Related Issues:
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.