Re: Flink Kafka connector in Python

2020-07-14 Thread Xingbo Huang
k.table.api.ValidationException: Could not find >>>> the required schema in property 'schema'. >>>>at >>>> org.apache.flink.table.descriptors.SchemaValidator.validate(SchemaValidator.java:90) >>>>at >>>> org.apache.fli

Re: Flink Kafka connector in Python

2020-07-06 Thread Manas Kale
bleSourceFactory.java:49) >>> at >>> org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSource(TableFactoryUtil.java:53) >>> ... 13 more >>> >>> >>> During handling of the above exception, another exception occurred: >>&g

Re: Flink Kafka connector in Python

2020-07-03 Thread Manas Kale
link/table/descriptors.py", >> line 1295, in register_table_source >> self._j_connect_table_descriptor.registerTableSource(name) >> File >> "/home/manas/anaconda3/envs/flink_env/lib/python3.7/site-packages/py4j/java_gateway.py", >> line 1286, in __c

Re: Flink Kafka connector in Python

2020-07-02 Thread Xingbo Huang
what's > wrong with the schema. Is the schema not properly declared? Is some field > missing? > > FWIW I have included the JSON and kafka connector JARs in the required > location. > > > Regards, > Manas > > > On Tue, Jun 30, 2020 at 11:58 AM Manas Kale

Re: Flink Kafka connector in Python

2020-07-02 Thread Manas Kale
ead kafka >> data. Besides, You can refer to the common questions about PyFlink[3] >> >> [1] >> https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sql/create.html#run-a-create-statement >> [2] >> https://ci.apache.org/projects/flink/flink-docs-rele

Re: Flink Kafka connector in Python

2020-06-29 Thread Manas Kale
t; I want to consume and write to Kafak from Flink's python API. >> >> The only way I found to do this was through this >> <https://stackoverflow.com/questions/52744277/apache-flink-kafka-connector-in-python-streaming-api-cannot-load-user-class> >> question &g

Re: Flink Kafka connector in Python

2020-06-29 Thread Xingbo Huang
.html Best, Xingbo Manas Kale 于2020年6月29日周一 下午8:10写道： > Hi, > I want to consume and write to Kafak from Flink's python API. > > The only way I found to do this was through this > <https://stackoverflow.com/questions/52744277/apache-flink-kafka-connector-in-python-streamin

Flink Kafka connector in Python

2020-06-29 Thread Manas Kale
Hi, I want to consume and write to Kafak from Flink's python API. The only way I found to do this was through this <https://stackoverflow.com/questions/52744277/apache-flink-kafka-connector-in-python-streaming-api-cannot-load-user-class> question on SO where the user essentially copies

Re: Apache Flink: Kafka connector in Python streaming API, “Cannot load user class”

2018-10-11 Thread Dawid Wysakowicz
Hi Kostas, As far as I know you cannot just use java classes from within python API. I think Python API does not provide wrapper for kafka connector. I am adding Chesnay to cc to correct me if I am wrong. Best, Dawid On 11/10/18 12:18, Kostas Evangelou wrote: > Hey all,  > > Thank you so much

Apache Flink: Kafka connector in Python streaming API, “Cannot load user class”

2018-10-11 Thread Kostas Evangelou
Hey all, Thank you so much for your efforts. I've already posted this question on stack overflow, but thought I should ask here as well. I am trying out Flink's new Python streaming API and attempting to run my script with ./flink-1.6.1/bin/pyflink-stream.sh examples/read_from_kafka.py. The pytho