Hi Puneet,
Flink SQL does only supports java.sql.Timestamp. You need to convert it
in a user-defined function or map function accordingly.
Regards,
Timo
Am 1/22/18 um 11:38 AM schrieb Puneet Kinra:
Hi
I am getting the above error when deployed to the cluster ,trying to
set the System Property but not getting reflected inside the jobs.
I need to schedule the job as well on periodic basis , i was thinking
of calling the
jar from the CLI & put into script & schedule using cron job in linux
but stuck with the below issue.
java.lang.ClassCastException: oracle.sql.TIMESTAMP cannot be cast to
java.sql.Timestamp
at
org.apache.flink.api.common.typeutils.base.SqlTimestampSerializer.serialize(SqlTimestampSerializer.java:27)
at
org.apache.flink.api.java.typeutils.runtime.RowSerializer.serialize(RowSerializer.java:160)
at
org.apache.flink.api.java.typeutils.runtime.RowSerializer.serialize(RowSerializer.java:46)
at
org.apache.flink.runtime.plugable.SerializationDelegate.write(SerializationDelegate.java:54)
at
org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializer.addRecord(SpanningRecordSerializer.java:93)
at
org.apache.flink.runtime.io.network.api.writer.RecordWriter.sendToTarget(RecordWriter.java:114)
at
org.apache.flink.runtime.io.network.api.writer.RecordWriter.emit(RecordWriter.java:89)
at
org.apache.flink.runtime.operators.shipping.OutputCollector.collect(OutputCollector.java:65)
at
org.apache.flink.runtime.operators.util.metrics.CountingCollector.collect(CountingCollector.java:35)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:168)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
at java.lang.Thread.run(Unknown Source)
--
*Cheers *
*
*
*Puneet Kinra*
*
*
*Mobile:+918800167808 | Skype : puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>*
*e-mail :puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>*
