开发者社区> 问答> 正文

blink的 sql-client使用 多表join

三个源
create table csv_source1(
id varchar,
name varchar
) with (
type ='csv',
path = '/Users/IdeaProjects/github/apache-flink/build-target/bin/test1.csv'
);

create table csv_source2(
id varchar,
name varchar
) with (
type ='csv',
path = '/Users/IdeaProjects/github/apache-flink/build-target/bin/test2.csv'
);

create table csv_source3(
id varchar,
name varchar
) with (
type ='csv',
path = '/Users/IdeaProjects/github/apache-flink/build-target/bin/test3.csv'
);

执行sql

select t2.name,t3.id from csv_source1 t1
join csv_source2 t2 on t1.id=t2.id
left join csv_source3 t3 on t3.id=t1.id;

一直hold 没有出结果。五分钟后

[ERROR] Could not execute SQL statement. Reason:

org.apache.flink.client.program.ProgramInvocationException: Job failed. (JobID: bd827832c329aa11647083d862a049f3)

java.util.concurrent.TimeoutException

at org.apache.flink.runtime.concurrent.FutureUtils$Timeout.run(FutureUtils.java:834)

at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)

at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)

at java.lang.Thread.run(Thread.java:748)

我的使用方式不对吗

展开
收起
岳过山丘 2019-02-15 13:26:59 3147 0
1 条回答
写回答
取消 提交回答
  • 多大的数据量啊

    2019-07-17 23:28:19
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
SQL Server在电子商务中的应用与实践 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载