Компакт-диск WSO2 Streaming Integrator C проблема - PullRequest
0 голосов
/ 12 июля 2020

Я следую документу WSO2 Streaming Integrator, можно запустить CD C. Проблема в том, что когда я устанавливаю строку типа «определить поток» или целое число, CD C является нормальным, но когда я устанавливаю тип с плавающей запятой, возникает ошибка, как показано ниже.

ERROR {io.siddhi. extension.map.keyvalue.sourcemapper.KeyValueSourceMapper} - Сообщение {MemberId = 1000000022, Date = 1594574917953, price = -500.5, price2 = 2000.1} содержит несовместимые типы и значения атрибутов. Значение 2000.1 несовместимо с типом FLOAT, поэтому сообщение

Мой код, как показано ниже, и как я могу решить эту проблему? Спасибо.

@App:name('MemberAPP')
@App:description('Test for member')

@source(type = 'cdc', url = "jdbc:sqlserver://localhost:1433;databaseName=Member", username = "xxx", password = "xxx", table.name = "dbo.MemberData", operation = "insert", connector.properties = "snapshot.mode=initial_schema_only", database.server.name = "localhost\default", 
    @map(type = 'keyvalue'))
define stream test(MemberId int, price float, price2 float, Date string);

@sink(type = 'log', 
    @map(type = 'passThrough'))
define stream Account (MemberId int, price float, price2 float, Date string);

@info(name = 'TotalShow')
from test
select * 
insert into Account;
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...