Re: pyflink1.11 window groupby出错

[anfeng]

我是在playgrounds环境跑到,  不过我检查的apache flink 是1.11.2;
跟这个会有关系吗




--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: pyflink1.11 window groupby出错

[anfeng]

使用了你说的DDL的方式   可还是报错

kafka_source_ddl = """CREATE TABLE mysource (createTime STRING,
 type BIGINT,
 uid STRING,
 countryId BIGINT,
 data STRING,
 rowtime as
TO_TIMESTAMP(createTime),
 WATERMARK FOR rowtime AS
rowtime - INTERVAL '2' SECOND
 ) WITH (...)


py4j.protocol.Py4JJavaError: An error occurred while calling o21.select.
: org.apache.flink.table.api.ValidationException: A group window expects a
time attribute for grouping in a stream environment.



--
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

[anfeng]

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/