@Override
    public void close() throws Exception {
        if (null != es && !es.isShutdown()) {
            es.shutdown();
        }
    }
covert flink time attribute.Type information for indicating event or processing time.
However, it behaves like a regular SQL timestamp but is serialized as Long.

@param entry
@param obj
@return
core/src/main/java/com/dtstack/flink/sql/side/BaseAllReqRow.java