Я следую документу 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;