如何使用python以Apache Beam的方式连接oracle数据库？

import apache_beam as beam
from apache_beam.io.jdbc import ReadFromJdbc

with beam.Pipeline() as p:
    result = (p
              | 'Read from jdbc' >> ReadFromJdbc(
                fetch_size=None,
                table_name='table_name',
                driver_class_name='oracle.jdbc.driver.OracleDriver',
                jdbc_url='jdbc:oracle:thin:@localhost:1521:orcl',
                username='xxx',
                password='xxx',
                query='selec * from table_name'
              )
              |beam.Map(print)
              )

当我运行上面的代码时，会报错：
RuntimeError: org.apache.beam.sdk.io.jdbc.BeamSchemaInferenceException: Failed to infer Beam schema
...
Caused by: java.sql.SQLException: Cannot load JDBC driver class 'oracle.jdbc.driver.OracleDriver'
...
ValueError: Unsupported signal: 2

driver_class_name='oracle.jdbc.driver.OracleDriver', 应该是 oracle.jdbc.OracleDriver这个吧 多了个driver