Re: py4j.protocol.Py4JJavaError: An error occurred while calling o21.select. : org.apache.flink.table.api.ValidationException: Undefined function: createTime
Hi, As far as I know, a TimeWindow does not have the attribute createTime? What is the semantics of createTime you want Best, Xingbo anfeng 于2020年11月17日周二 下午5:26写道: > st_env.from_path("mysource") \ > > > .window(Slide.over("10.minutes").every("1.minutes").on("createTime").alias("w")) > \ > .group_by("w") \ > .select("w.createTime as a, w.start as b, w.end as c, uid.count > as > d") \ > .insert_into("mysink") > > > .select("w.createTime as a, w.start as b, w.end as c, uid.count as d") > \ > File > > "/tmp/pyflink/ddbc1fae-54c4-4bd1-8d32-4df36151c419/83b8abce-eed8-4ab4-8ff6-8526c3e04c8fpyflink.zip/pyflink/table/table.py", > line 784, in select > File > > "/tmp/pyflink/ddbc1fae-54c4-4bd1-8d32-4df36151c419/83b8abce-eed8-4ab4-8ff6-8526c3e04c8fpy4j-0.10.8.1-src.zip/py4j/java_gateway.py", > line 1286, in __call__ > File > > "/tmp/pyflink/ddbc1fae-54c4-4bd1-8d32-4df36151c419/83b8abce-eed8-4ab4-8ff6-8526c3e04c8fpyflink.zip/pyflink/util/exceptions.py", > line 147, in deco > File > > "/tmp/pyflink/ddbc1fae-54c4-4bd1-8d32-4df36151c419/83b8abce-eed8-4ab4-8ff6-8526c3e04c8fpy4j-0.10.8.1-src.zip/py4j/protocol.py", > line 328, in get_return_value > py4j.protocol.Py4JJavaError: An error occurred while calling o21.select. > : org.apache.flink.table.api.ValidationException: Undefined function: > createTime > > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >
py4j.protocol.Py4JJavaError: An error occurred while calling o21.select. : org.apache.flink.table.api.ValidationException: Undefined function: createTime
st_env.from_path("mysource") \ .window(Slide.over("10.minutes").every("1.minutes").on("createTime").alias("w")) \ .group_by("w") \ .select("w.createTime as a, w.start as b, w.end as c, uid.count as d") \ .insert_into("mysink") .select("w.createTime as a, w.start as b, w.end as c, uid.count as d") \ File "/tmp/pyflink/ddbc1fae-54c4-4bd1-8d32-4df36151c419/83b8abce-eed8-4ab4-8ff6-8526c3e04c8fpyflink.zip/pyflink/table/table.py", line 784, in select File "/tmp/pyflink/ddbc1fae-54c4-4bd1-8d32-4df36151c419/83b8abce-eed8-4ab4-8ff6-8526c3e04c8fpy4j-0.10.8.1-src.zip/py4j/java_gateway.py", line 1286, in __call__ File "/tmp/pyflink/ddbc1fae-54c4-4bd1-8d32-4df36151c419/83b8abce-eed8-4ab4-8ff6-8526c3e04c8fpyflink.zip/pyflink/util/exceptions.py", line 147, in deco File "/tmp/pyflink/ddbc1fae-54c4-4bd1-8d32-4df36151c419/83b8abce-eed8-4ab4-8ff6-8526c3e04c8fpy4j-0.10.8.1-src.zip/py4j/protocol.py", line 328, in get_return_value py4j.protocol.Py4JJavaError: An error occurred while calling o21.select. : org.apache.flink.table.api.ValidationException: Undefined function: createTime -- Sent from: http://apache-flink.147419.n8.nabble.com/