[STREAMPIPES-127] [Postgres Sink] Using Wrong datatype while cerating table

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.67.0
• Fix Version/s: 0.68.0
• Assignee: Tim Bossenmaier
• Reporter: Florian Micklich
• Created: 14/May/20 13:05
• Updated: 26/Nov/22 12:56
• Resolved: 08/Jun/21 14:05

Description

Starting the default ISS adapter and using th postgres sink together with the internal docker container.

I get following error:

org.apache.streampipes.commons.exceptions.SpRuntimeException: ERROR: type "double" does not exist
  Position: 56

This happens during creating the table.

Following create statement is used:

CREATE TABLE "tabler" ( "timestamp" FLOAT, "longitude" DOUBLE, "latitude" DOUBLE );

but instead of double, float should be used like in timestamp.
But don't know why double is used only in this case. This happens in the

statement.append(extractEventProperties(eventProperties))

Method in the JdbcClient.class

The generel error is:

org.apache.streampipes.commons.exceptions.SpRuntimeException: ERROR: type "double" does not exist
  Position: 55
	at org.apache.streampipes.sinks.databases.jvm.jdbcclient.JdbcClient.createTable(JdbcClient.java:446)
	at org.apache.streampipes.sinks.databases.jvm.jdbcclient.JdbcClient.ensureTableExists(JdbcClient.java:258)
	at org.apache.streampipes.sinks.databases.jvm.jdbcclient.JdbcClient.connect(JdbcClient.java:212)
	at org.apache.streampipes.sinks.databases.jvm.jdbcclient.JdbcClient.initializeJdbc(JdbcClient.java:196)
	at org.apache.streampipes.sinks.databases.jvm.postgresql.PostgreSql.onInvocation(PostgreSql.java:39)
	at org.apache.streampipes.sinks.databases.jvm.postgresql.PostgreSql.onInvocation(PostgreSql.java:28)
...

Issue Links

• is blocked by: STREAMPIPES-320 Create general SQL client to support all existing SQL-based sinks