Re: pyflink问题求助

[hieule <hi...@gmail.com>]

 hello Xingbo Huang,

when I run , I had some error

`TypeError: Could not found the Java class
'org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder'. The Java
dependencies could be specified via command line argument '--jarfile' or the
config option 'pipeline.jars' `


how to solve issue ?

Thank
hieule



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: pyflink问题求助

[Xingbo Huang <hx...@gmail.com>]

Hi hieule,
This work around method is used in flink 1.10, in flink 1.11 you can use
ddl directly (blink planner) which you can refer to [1].
For how to use blink planner in PyFlink, you can refer to following code:

t_env = BatchTableEnvironment.create(
    environment_settings=EnvironmentSettings.new_instance()
    .in_batch_mode().use_blink_planner().build())

t_env.get_config().get_configuration().set_string("taskmanager.memory.task.off-heap.size",
'80m')

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/jdbc.html

Best,
Xingbo

hieule <hi...@gmail.com> 于2020年7月13日周一 下午4:46写道：

>  hello Xingbo Huang,
>
> when I run , I had some error
>
> `TypeError: Could not found the Java class
> 'org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder'. The Java
> dependencies could be specified via command line argument '--jarfile' or
> the
> config option 'pipeline.jars' `
>
>
> how to solve issue ?
>
> Thank
> hieule
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>