看起来是jar的路径的问题，你需要看一下在windows上，jar的路径用URL表示应该是什么样的。另外也可以直接把jar包放到pyflink安装目录中的lib目录下。
> 在 2020年12月17日，下午3:04，肖越 <18242988...@163.com> 写道：
>
> 您好，这是完整的报错信息：
> Traceback (most recent call last):
>
> File
> "C:\projects\dataService-calculate-code-python\src\test\test_oracle_connector.py",
> line
您好，这是完整的报错信息：
Traceback (most recent call last):
File
"C:\projects\dataService-calculate-code-python\src\test\test_oracle_connector.py",
line 24, in
"C:\projects\dataService-calculate-code-python\src\\test\\flink_connector-jdbc\\flink-connector-jdbc_2.11-1.12.0.jar")
File
"C:\Users\
发一下完整的异常信息？
> 在 2020年12月17日，上午11:53，肖越 <18242988...@163.com> 写道：
>
> 好的，非常感谢您的帮助，刚根据分享的连接，显示增加了jar包依赖，报错：py4j.protocol.Py4JJavaError: An error
> occurred while calling None.java.net.URL，应该就是没有对应的Oracle connector处理的原因吧？
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2020-12-17 10:44:56，"D
好的，非常感谢您的帮助，刚根据分享的连接，显示增加了jar包依赖，报错：py4j.protocol.Py4JJavaError: An error
occurred while calling None.java.net.URL，应该就是没有对应的Oracle connector处理的原因吧？
在 2020-12-17 10:44:56，"Dian Fu" 写道：
>1）如Leonard Xu老师所说，目前JDBC connector还不支持oracle
>2）从报错看，你这还都没有走到那一步就报错了，可以检查一下这些：
> a. JDBC co
1）如Leonard Xu老师所说，目前JDBC connector还不支持oracle
2）从报错看，你这还都没有走到那一步就报错了，可以检查一下这些：
a. JDBC connector的使用方式参考[1]，比如'connector' = 'jdbc'，而不是'connector.type' =
'jdbc'，这个是老的使用方式
b. JDBC
connector的jar需要显式添加相关依赖，可以如何在PyFlink中添加jar依赖，可以看一下[2]。其中JDBC需要的的jar，可以参考[1]
[1]
https://ci.apache.org/project
谢谢您的帮助，所以没有办法通过定义connector的方式获取连接是么？ 有没有其他办法呢？
在 2020-12-17 09:55:08，"Leonard Xu" 写道：
>目前 JDBC connector 只支持 MySQL, Pg和Derby(一般测试用)这几种dialect， Oracle还不支持。
>
>祝好，
>Leonard
>
>> 在 2020年12月17日，09:47，肖越 <18242988...@163.com> 写道：
>>
>> pyflink小白，测试pyflink1.12功能，想通过定义connector从oracle数据
目前 JDBC connector 只支持 MySQL, Pg和Derby(一般测试用)这几种dialect， Oracle还不支持。
祝好，
Leonard
> 在 2020年12月17日，09:47，肖越 <18242988...@163.com> 写道：
>
> pyflink小白，测试pyflink1.12功能，想通过定义connector从oracle数据库中获取数据
> 通过如下方式定义：
> env = StreamExecutionEnvironment.get_execution_environment()
> env.set_parallelism(1)
> env
pyflink小白，测试pyflink1.12功能，想通过定义connector从oracle数据库中获取数据
通过如下方式定义：
env = StreamExecutionEnvironment.get_execution_environment()
env.set_parallelism(1)
env = StreamTableEnvironment \
.create(env, environment_settings=EnvironmentSettings
.new_instance()
.use_bli
pyflink小白，测试pyflink1.12功能，想通过定义connector从oracle数据库中获取数据
通过如下方式定义：
env = StreamExecutionEnvironment.get_execution_environment()
env.set_parallelism(1)
env = StreamTableEnvironment \
.create(env, environment_settings=EnvironmentSettings
.new_instance()
.use_bli
