[GitHub] [streampipes] SteveYurongSu opened a new issue, #1146: Session based implementation of IoTDB sink (fix issues in current JDBC based implementation)

["SteveYurongSu (via GitHub)" <gi...@apache.org>]

SteveYurongSu opened a new issue, #1146:
URL: https://github.com/apache/streampipes/issues/1146

   ### Apache StreamPipes version
   
   dev (current development state)
   
   ### Affected StreamPipes components
   
   Connect
   
   ### What happened?
   
   Recently, I was trying to play around streampipes and found that iotdb sink could not work properly.
   
   I checked the source code and found that the current JDBC based implementation of iotdb sink is outdated, especially for the current production versions of iotdb (0.13.x and 1.0.x).
   
   I‘d like to contribute a brand new iotdb sink implementation, which has the following features:
   
   - Support production ready versions of IoTDB (version >= 0.13.0)
   - Support by iotdb-session API, which can provide higher throughput and lower latency 
   - Support schema-less write: no need to create storage group (database) before insertion
   
   ### How to reproduce?
   
   Graph:
   Water Level 1 -> IoTDB
   
   I debugged the iotdb sink in pipeline-element mode and found that the current iotdb sink cannot connect to the iotdb instance (version >= 0.13.x).
   
   ### Expected behavior
   
   IoTDB sink should be used with IoTDB (version >= 0.13.0)
   
   ### Additional technical information
   
   OS
   ```
   Mac (Apple M1)
   MacOS 13.0.1 (22A400)
   ```
   
   Java
   ```
   java version "17.0.6" 2023-01-17 LTS
   Java(TM) SE Runtime Environment (build 17.0.6+9-LTS-190)
   Java HotSpot(TM) 64-Bit Server VM (build 17.0.6+9-LTS-190, mixed mode, sharing)
   ```
   
   Maven
   ```
   Java version: 17.0.6, vendor: Oracle Corporation, runtime: /Library/Java/JavaVirtualMachines/jdk-17.jdk/Contents/Home
   Default locale: zh_CN_#Hans, platform encoding: UTF-8
   OS name: "mac os x", version: "13.0.1", arch: "aarch64", family: "mac"
   ```
   
   ### Are you willing to submit a PR?
   
   Yes, I am willing to submit a PR!


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@streampipes.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [streampipes] dominikriemer commented on issue #1146: Session based implementation of IoTDB sink (fix issues in current JDBC based implementation)

["dominikriemer (via GitHub)" <gi...@apache.org>]

dominikriemer commented on issue #1146:
URL: https://github.com/apache/streampipes/issues/1146#issuecomment-1400303218

   Hi @SteveYurongSu, awesome, thanks for the great description!
   Please ask if you have any questions.
   We can also refactor the sink to a one-class structure by extending `StreamPipesDataSink` instead of the currently used model for the IoTDB sink.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@streampipes.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] Session based implementation of IoTDB sink (fix issues in current JDBC based implementation) (streampipes)

["tenthe (via GitHub)" <gi...@apache.org>]

tenthe closed issue #1146: Session based implementation of IoTDB sink (fix issues in current JDBC based implementation)
URL: https://github.com/apache/streampipes/issues/1146


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@streampipes.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org