退订
——分割线————
在 2021-09-02 11:18:55，"Wayne" <1...@163.com> 写道：
>
>
>
>我是使用tableEnv.executeSql 执行那两个create 语句 然后用 tableEnv.sqlQuery 执行 select语句
>，然后报错， 没有再执行其他sql额 ， aaa.columnInfos [ 'EVENT_ID' ].newValue 就是取出map里面
>EVENT_ID 的key的 newValue 值，从c
Hi
我这边提交命令如下
/Users/xxx/local/flink-1.12.2/bin/flink run \
-m yarn-cluster \
-yd \
-ynm purchase_hist \
-c com.flink.streaming.core.JobApplication \
flink-streaming-core-2.1.0-1.12.2.jar \
-sql /Users/xxx/Desktop/flinkBigtable/xxx.sql \
-checkpointInterval 6 \
-checkpointingMode
:31:20，"Caizhi Weng" 写道：
>Hi！
>
>没有复现这个问题。后续是还有其他 SQL 吗？特别是对 aaa.columnInfos [ 'EVENT_ID' ].newValue 有
>filter 的 SQL。
>
>可以尝试先在本地找一个能复现的 case，通过 tableEnv.explainSql() 就能快速检查能否产生 plan。如果找到了能复现的
>SQL，可以在 jira 提一个 issue。
>
>Wayne <1...@163.com> 于2021年9月
omer_id = 1 和 id = 1 并分别下推到维表 join 之前。
>
>Wayne <1...@163.com> 于2021年9月1日周三 下午6:27写道：
>
>> 我的flink 版本是 flink-1.12.2-bin-scala_2.12
>> 我的sql 是
>> SELECT o.order_id, o.total, c.country, c.zip
>> FROM Orders AS o
>> JOIN Customers FOR SYSTEM_TIME AS O
我的flink 版本是 flink-1.12.2-bin-scala_2.12
我的sql 是
SELECT o.order_id, o.total, c.country, c.zip
FROM Orders AS o
JOIN Customers FOR SYSTEM_TIME AS OF o.proc_time AS c
ON o.customer_id = c.id and o.customer_id is not null and c.id is not null
;
或者
SELECT o.order_id, o.total, c.country, c.zip
我的执行命令是
flink run -m yarn-cluster -yd -yjm 1024m -ytm 1024m -ys 1 -ynm xxx -C
file:///xxx/flink-connector-kafka_2.12-1.12.2.jar -C
file:///xxx/flink-sql-avro-1.12.2.jar ...
提交到生产集群上提示
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user
class:
我的提交命令
./bin/flink run -d -m yarn-cluster
报错如下
The program finished with the following exception:
java.lang.IllegalStateException: No Executor found. Please make sure to export
the HADOOP_CLASSPATH environment variable or have hadoop in your classpath. For
more information refer to the
i have Apache Avro schema
我的avro schema 如下
{
"type" : "record",
"name" : "KafkaAvroMessage",
"namespace" : "xxx",
"fields" : [ {
"name" : "aaa",
"type" : "string"
}, {
"name" : "bbb",
"type" : [ "null", "string" ],
"default" : null
},{
"name" : "ccc",
i have Apache Avro schema
我的avro schema 如下
{
"type" : "record",
"name" : "KafkaAvroMessage",
"namespace" : "xxx",
"fields" : [ {
"name" : "aaa",
"type" : "string"
}, {
"name" : "bbb",
"type" : [ "null", "string" ],
"default" : null
},{
"name" : "ccc",
i have Apache Avro schema
我的avro schema 如下
{
"type" : "record",
"name" : "KafkaAvroMessage",
"namespace" : "xxx",
"fields" : [ {
"name" : "aaa",
"type" : "string"
}, {
"name" : "bbb",
"type" : [ "null", "string" ],
"default" : null
},{
"name" : "ccc",
12 matches
Mail list logo
