Spark JDBC Oracle陷入了一项任务

Question

我正在Oracle运行下面的查询：

df = spark.read \
.format("jdbc") \
.option("url", "{}".format(db_url)) \
.option("dbtable","({})".format(query)) \
.option("user","{}".format(db_username)) \
.option("numPartitions", 1000) \
.option("partitionColumn", "CD_CONVENIO") \
.option("lowerBound", int(ParameterBound['MIN'])) \
.option("upperBound", int(ParameterBound['MAX'])) \
.option("password","{}".format(db_password)) \
.option("customSchema", schema) \
.option("driver", "oracle.jdbc.driver.OracleDriver") \
.load()

返回了大约19,000行。

”

但是该过程很长一段时间都陷入了一项任务。