examples/2-from_kafka_to_kafka.py执行错误

[huangshishangjiang]

(base) @MacBook-Pro-2 playgrounds % docker-compose exec jobmanager ./bin/flink run -py /opt/examples/2-from_kafka_to_kafka.py
Traceback (most recent call last):
File "/opt/examples/2-from_kafka_to_kafka.py", line 98, in
from_kafka_to_kafka_demo()
File "/opt/examples/2-from_kafka_to_kafka.py", line 21, in from_kafka_to_kafka_demo
register_rides_source(st_env)
File "/opt/examples/2-from_kafka_to_kafka.py", line 34, in register_rides_source
Kafka()
File "/opt/flink/opt/python/pyflink.zip/pyflink/table/descriptors.py", line 900, in init
File "/opt/flink/opt/python/pyflink.zip/pyflink/util/exceptions.py", line 184, in wrapped_call
TypeError: Could not found the Java class 'Kafka'. The Java dependencies could be specified via command line argument '--jarfile' or the config option 'pipeline.jars'
org.apache.flink.client.program.ProgramAbortException
at org.apache.flink.client.python.PythonDriver.main(PythonDriver.java:95)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:288)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198)
at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:149)
at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:699)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:232)
at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:916)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:992)
at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:992)