Thanks Dawid for the explanation.
Your suggested approach makes things work.
Regards,
Satyam
On Mon, Jun 8, 2020 at 1:18 AM Dawid Wysakowicz
wrote:
> Hi Satyam,
>
> The thing is that Types.SQL_TIMESTAMP uses java.sql.Timestamp and
> serializes it as long (millis since epoch) and thus have mill
Hi Satyam,
The thing is that Types.SQL_TIMESTAMP uses java.sql.Timestamp and
serializes it as long (millis since epoch) and thus have milliseconds
precision. The default precision for a DataTypes.TIMESTAMP is 6 and the
default bridging class is LocalDataTime.
It should work if you return
DataType
Hello,
I am running into an issue while trying to create a TableSource with
rowtime attribute. I have configured TableSource to return produced
type of Row(DataTypes.BIGINT,
DataTypes.TIMESTAMP) via DataType TableSource::getProducedDataType(). The
returned DataStream has a flatmap operator that im
