在spark中怎样让一段代码只在一个task内执行

为什么要在task里面建表呢?你完全可以先在driver建好表,再去执行你的Spark job。或者在task那边建表的时候,如果失败了,就检查一下表在不在,如果在的话,就忽略之前建表失败的错误,继续执行。至于你提到的广播,如果是指Spark提供的Broadcast的话,这是不能在task里面创建的。只支持在driver创建,然后广播到executor上。
■网友
建议在driver 端建表,这是后续操作的基础,如果失败直接终止job。


    推荐阅读