Hi Michele, when did you update the system? I updated the version of the IOTDB client to 0.12.0 a couple of days ago. I also used the 0.12.1 for database itself and it worked on my machine.
If you run StreamPipes it in docker, please update the containers with. If you run it in an IDE please pull the latest changes from the git repository. Can you please try it with the latest version and tell me if the problem still exists? Kind regards, Philipp > On 7. Jul 2021, at 09:56, Canteri, Michele <[email protected]> wrote: > > Hi Dominik, > > thank you for you're your answer, I am using the dev version of SP > (0.68-snapshot) and the DB is version 0.12.1. > Let me know if you need other information. > > Best regards, > Michele > Michele Canteri > _________________________________________________________________ > > GFT Italia S.r.l. > VIA SILE 18 / floor 4 > 20139 Milano, Italy > > T +39 02 58158503 > F +39 02 58158621 > [email protected] <mailto:[email protected]> > <http://www.gft.com/>www.gft.com/it <https://www.gft.com/it> > https://blog.gft.com <https://blog.gft.com/> > https://www.linkedin.com/company/gft-group/ > <https://www.linkedin.com/company/gft-group/> > www.twitter.com/gft_it <https://www.twitter.com/gft_it> > > Registered office: GFT Italia S.r.l., Via Sile 18, 20139 Milan (Italy) > VAT Code and number of registration with the Companies' Register of Milan: > 00819200478 > Corporate capital: Euro 1,000,000 fully paid-in > > Company subject to the direction and coordination activity of GFT > Technologies SE > > Ai sensi del Regolamento UE 2016/679 (GDPR) e delle Linee Guida per posta > elettronica ed Internet del Garante Privacy si rende noto che le informazioni > contenute nella presente comunicazione e i relativi allegati possono essere > riservate e sono, comunque, destinate esclusivamente alle persone o alla > Società sopraindicati. Le stesse non sono da considerarsi comunicazioni > personali, quindi eventuali risposte potranno essere conosciute da persone > appartenenti all’azienda. > > In accordance with Regulation EU 2016/679 (General Data Protection > Regulation) and Guidelines Applying to the Use of E-Mails and the Internet in > the Employment Context of Italian Data Protection Authority it is announced > that the information in this communication (which includes any documents with > it) is confidential and meant only for above-mentioned persons and/or > Companies; the information is not personal therefore, It is intended for the > addressee only and any replies will be known by people belonging to the > company. > _________________________________________________________________ > > > -----Original Message----- > From: Dominik Riemer <[email protected] <mailto:[email protected]>> > Sent: mercoledì 7 luglio 2021 09:46 > To: [email protected] <mailto:[email protected]> > Subject: Re: Issue with IoTDB sink > > [EXTERNAL EMAIL] > This email originated from outside of the organization or was sent > unauthenticated. Do not click links or open attachments unless you confirm > the sender and know the content is safe. > > Hi Michele, > > I think we've seen this problem in cases where the database version did not > match the IoTDB version of the data sink. > Release 0.67.0 supports IoTDB 0.8.0, the current dev version and the next > release will support the latest version 0.12.0. > > Which StreamPipes version are you currently using? > > Best > Dominik > > On 2021/07/06 16:56:10, "Canteri, Michele" <[email protected]> wrote: > > Hello everyone, > > > > We are trying to use a DB to store the time series and with our partner > > Branislav we give a shot to InfluxDB but didn't worked so I tried now IoTDB > > and creating a pipeline with only the data generator and the IoTDB data > > sink like the following figure represent: > > > > [cid:[email protected]] > > And I can see that the data are not stored into the DB. > > I am using the current version of IoTDB installed on the same machine where > > SP is running and I can normally connect using: > > sbin/start-cli.sh -h 10.114.0.4 -p 6667 -u root -pw xxxx and using > > SHOW TIMESERIES I can see there is nothing in the DB. > > > > In the SP log I found the following error: > > > > pipeline-elements-all-jvm_1 | org.apache.iotdb.jdbc.IoTDBSQLException: > > 401: Error occurred while parsing SQL to physical plan: line 1:17 > > mismatched input 'root' expecting {CREATE, INSERT, UPDATE, DELETE, SELECT, > > SHOW, GRANT, INTO, SET, WHERE, FROM, TO, BY, DEVICE, CONFIGURATION, > > DESCRIBE, SLIMIT, LIMIT, UNLINK, OFFSET, SOFFSET, FILL, LINEAR, PREVIOUS, > > PREVIOUSUNTILLAST, METADATA, TIMESERIES, TIMESTAMP, PROPERTY, WITH, > > DATATYPE, COMPRESSOR, STORAGE, GROUP, LABEL, INT32, INT64, FLOAT, DOUBLE, > > BOOLEAN, TEXT, PLAIN, PLAIN_DICTIONARY, RLE, DIFF, TS_2DIFF, GORILLA, > > REGULAR, ADD, UPSERT, VALUES, NOW, LINK, INDEX, USING, TRACING, ON, OFF, > > DROP, MERGE, LIST, USER, PRIVILEGES, ROLE, ALL, OF, ALTER, PASSWORD, > > REVOKE, LOAD, WATERMARK_EMBEDDING, UNSET, TTL, FLUSH, TASK, INFO, VERSION, > > REMOVE, MOVE, CHILD, PATHS, DEVICES, COUNT, NODES, LEVEL, MIN_TIME, > > MAX_TIME, MIN_VALUE, MAX_VALUE, AVG, FIRST_VALUE, SUM, LAST_VALUE, LAST, > > DISABLE, ALIGN, COMPRESSION, TIME, ATTRIBUTES, TAGS, RENAME, GLOBAL, > FULL, CLEAR, CACHE, TRUE, FALSE, UNCOMPRESSED, SNAPPY, GZIP, LZ4, PARTITION, > SNAPSHOT, FOR, SCHEMA, DESC, ASC, '*', OPERATOR_IN, '-', '[', INT, EXPONENT, > DURATION, DATETIME, ID, DOUBLE_QUOTE_STRING_LITERAL} > > pipeline-elements-all-jvm_1 | at > > org.apache.iotdb.jdbc.IoTDBStatement.executeSQL(IoTDBStatement.java:258) > > pipeline-elements-all-jvm_1 | at > > org.apache.iotdb.jdbc.IoTDBStatement.execute(IoTDBStatement.java:216) > > pipeline-elements-all-jvm_1 | at > > org.apache.streampipes.sinks.databases.jvm.iotdb.IotDb.save(IotDb.java:109) > > pipeline-elements-all-jvm_1 | at > > org.apache.streampipes.sinks.databases.jvm.iotdb.IotDb.onEvent(IotDb.java:73) > > pipeline-elements-all-jvm_1 | at > > org.apache.streampipes.wrapper.standalone.runtime.StandaloneEventSinkRuntime.process(StandaloneEventSinkRuntime.java:50) > > pipeline-elements-all-jvm_1 | at > > org.apache.streampipes.wrapper.standalone.routing.StandaloneSpInputCollector.send(StandaloneSpInputCollector.java:54) > > pipeline-elements-all-jvm_1 | at > > org.apache.streampipes.wrapper.standalone.routing.StandaloneSpInputCollector.lambda$onEvent$0(StandaloneSpInputCollector.java:48) > > pipeline-elements-all-jvm_1 | at > > org.apache.streampipes.wrapper.standalone.routing.StandaloneSpInputCollector$$Lambda$881/0x000000003c07ddd0.accept(Unknown > > Source) > > pipeline-elements-all-jvm_1 | at > > java.util.concurrent.ConcurrentHashMap.forEach(ConcurrentHashMap.java:1597) > > pipeline-elements-all-jvm_1 | at > > org.apache.streampipes.wrapper.standalone.routing.StandaloneSpInputCollector.onEvent(StandaloneSpInputCollector.java:48) > > pipeline-elements-all-jvm_1 | at > > org.apache.streampipes.wrapper.standalone.routing.StandaloneSpInputCollector.onEvent(StandaloneSpInputCollector.java:29) > > pipeline-elements-all-jvm_1 | at > > org.apache.streampipes.messaging.kafka.SpKafkaConsumer.run(SpKafkaConsumer.java:120) > > pipeline-elements-all-jvm_1 | at > > java.lang.Thread.run(Thread.java:823) > > > > I have verified that with a statement I can store into the DB some data so > > I can say that the problem is the IoTDB data sink. > > Let us know if you need anything else. > > > > Kindest regards, > > Michele > > > > Michele Canteri > > _________________________________________________________________ > > > > GFT Italia S.r.l. > > VIA SILE 18 / floor 4 > > 20139 Milano, Italy > > > > T +39 02 58158503 > > F +39 02 58158621 > > [email protected] > > < > > <applewebdata://550EEC7C-9A60-4A0A-8502-A0A6292C5C96>https://eur02.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww > > <https://eur02.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww>. > > gft.com <http://gft.com/>%2F&data=04%7C01%7CMichele.Canteri%40gft.com > > <http://40gft.com/>%7C961277b31e4c > > 424e810708d9411b38f0%7C55a2bc67aec14ad29a9c5b2457b91dcd%7C0%7C0%7C6376 > > 12407436643804%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2l > > uMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=Igkba%2FNPK8Amyu2 > > %2FdA7mMB8EaaTqyxiZMYpYL64Pu%2BQ%3D&reserved=0>https://eur02.safel > > <https://eur02.safel/> > > inks.protection.outlook.com/?url=http%3A%2F%2Fwww.gft.com%2Fit&dat > > <http://inks.protection.outlook.com/?url=http%3A%2F%2Fwww.gft.com%2Fit&dat> > > a=04%7C01%7CMichele.Canteri%40gft.com > > <http://40gft.com/>%7C961277b31e4c424e810708d9411b38 > > f0%7C55a2bc67aec14ad29a9c5b2457b91dcd%7C0%7C0%7C637612407436643804%7CU > > nknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1ha > > WwiLCJXVCI6Mn0%3D%7C1000&sdata=M8I95%2BXKXAp6y8tHGQc5ea4Oxqn3%2Brq > > H42vvF%2BE6TKs%3D&reserved=0<https://eur02.safelinks.protection.ou > > <https://eur02.safelinks.protection.ou/> > > tlook.com/?url=https%3A%2F%2Fwww.gft.com%2Fit&data=04%7C01%7CMiche > > <http://tlook.com/?url=https%3A%2F%2Fwww.gft.com%2Fit&data=04%7C01%7CMiche> > > le.Canteri%40gft.com > > <http://40gft.com/>%7C961277b31e4c424e810708d9411b38f0%7C55a2bc67aec1 > > 4ad29a9c5b2457b91dcd%7C0%7C0%7C637612407436643804%7CUnknown%7CTWFpbGZs > > b3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D > > %7C1000&sdata=g8WzPFfd%2FikN%2FkbK%2B4R6I%2Fep6x3iMG7cYc6oAKcGKCA% > > 3D&reserved=0> > > https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fblog > > <https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fblog> > > .gft.com <http://gft.com/>%2F&data=04%7C01%7CMichele.Canteri%40gft.com > > <http://40gft.com/>%7C961277b31e4 > > c424e810708d9411b38f0%7C55a2bc67aec14ad29a9c5b2457b91dcd%7C0%7C0%7C637 > > 612407436643804%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2 > > luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=Yg%2Bf9ZmBajMslx > > %2FaHnFXrvcRB3%2BaY54Aen8v%2FWtA0a0%3D&reserved=0 > > https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fwww > > <https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fwww>. > > linkedin.com > > <http://linkedin.com/>%2Fcompany%2Fgft-group%2F&data=04%7C01%7CMichele.Cante > > ri%40gft.com > > <http://40gft.com/>%7C961277b31e4c424e810708d9411b38f0%7C55a2bc67aec14ad29a9c > > 5b2457b91dcd%7C0%7C0%7C637612407436643804%7CUnknown%7CTWFpbGZsb3d8eyJW > > IjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000& > > amp;sdata=4T7vx3HzkLTlRU1oyLITQlX%2BSXf2oJNtYMGjLwteJdk%3D&reserve > > d=0 > > https://eur02.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww.t > > <https://eur02.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww.t> > > witter.com > > <http://witter.com/>%2Fgft_it&data=04%7C01%7CMichele.Canteri%40gft.com > > <http://40gft.com/>%7C961 > > 277b31e4c424e810708d9411b38f0%7C55a2bc67aec14ad29a9c5b2457b91dcd%7C0%7 > > C0%7C637612407436643804%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLC > > JQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=3MhqZZ3x > > 3ZV6kGoiH7zchCWDlt2fOePXWUXUyCdNohg%3D&reserved=0 > > < > > <applewebdata://550EEC7C-9A60-4A0A-8502-A0A6292C5C96>https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fwww > > <https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fwww> > > .twitter.com > > <http://twitter.com/>%2Fgft_it&data=04%7C01%7CMichele.Canteri%40gft.com > > <http://40gft.com/>%7C9 > > 61277b31e4c424e810708d9411b38f0%7C55a2bc67aec14ad29a9c5b2457b91dcd%7C0 > > %7C0%7C637612407436643804%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAi > > LCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C1000&sdata=0GeHF2 > > gKYCS7Z%2FzUhoM64y0D54SdjctVjQqqbMcykis%3D&reserved=0> > > > > Registered office: GFT Italia S.r.l., Via Sile 18, 20139 Milan (Italy) > > VAT Code and number of registration with the Companies' Register of > > Milan: 00819200478 Corporate capital: Euro 1,000,000 fully paid-in > > > > Company subject to the direction and coordination activity of GFT > > Technologies SE > > > > Ai sensi del Regolamento UE 2016/679 (GDPR) e delle Linee Guida per posta > > elettronica ed Internet del Garante Privacy si rende noto che le > > informazioni contenute nella presente comunicazione e i relativi allegati > > possono essere riservate e sono, comunque, destinate esclusivamente alle > > persone o alla Societ? sopraindicati. Le stesse non sono da considerarsi > > comunicazioni personali, quindi eventuali risposte potranno essere > > conosciute da persone appartenenti all'azienda. > > > > In accordance with Regulation EU 2016/679 (General Data Protection > > Regulation) and Guidelines Applying to the Use of E-Mails and the Internet > > in the Employment Context of Italian Data Protection Authority it is > > announced that the information in this communication (which includes any > > documents with it) is confidential and meant only for above-mentioned > > persons and/or Companies; the information is not personal therefore, It is > > intended for the addressee only and any replies will be known by people > > belonging to the company. > > _________________________________________________________________ > >
