Skip to content

Issues: pyflink/playgrounds

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Clear current search query, filters, and sorts
22 Open 2 Closed
22 Open 2 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

pyflink 引入模块失败
#27 opened Nov 17, 2023 by Saskuediplomat
执行pyflink报错 py4j.protocol.Py4JError
#24 opened Feb 20, 2023 by JTjeff
examples/2-from_kafka_to_kafka.py执行错误
#23 opened Aug 30, 2022 by huangshishangjiang
failed to compute cache key: "/flink-sql-connector-kafka_2.11-1.13.0.jar" not found: not found
#22 opened Jun 16, 2022 by msute
Can we do multiprocessing or distributed computing through PyFlink?
#21 opened Feb 22, 2022 by abhalawat
10
Pyflink for CEP
#20 opened Feb 11, 2022 by lchunleo
1
Can provide tutorial of walking through code
#19 opened Nov 26, 2021 by liyunrui
RROR [13/15] ADD ./flink-1.13.3 /opt/flink
#18 opened Nov 22, 2021 by nengbai
Example table/2-from_kafka_to_kafka.py reads from Kafka topic "Rides" but nothing writes to that topic?
#17 opened Nov 17, 2021 by jlafer
error when run example -- 1-word_count.py
#16 opened Jul 30, 2021 by pzg250
7
error "java.io.IOException: Mkdirs failed to create" when run the example 1-word_count.py
#15 opened May 26, 2021 by abeermohamed1
9
Error when running example 2 2-from_kafka_to_kafka.py
#14 opened May 25, 2021 by abeermohamed1
1
ubuntu上运行示例失败，放到本地windows环境运行3-udf_add报错，不太明白什么原因，麻烦帮忙看一下
#12 opened May 11, 2021 by sisterBigEye
请问hbase-fat.jar包含些什么内容？
#9 opened Jan 5, 2021 by yz271544
使用 demo 5-word_count-mysql.py 报错 pyflink.util.exceptions.TableException: 'findAndCreateTableSource failed.'
#8 opened Dec 4, 2020 by yangguang0038
1
1.11 TypeError: Could not found the Java class 'Kafka'.
#7 opened Oct 29, 2020 by bochuxt
1.11 taskmanager_1 | 2020-10-29 05:26:36,073 main ERROR Could not create plugin of type class
#6 opened Oct 29, 2020 by bochuxt
Pyflink 1.11 suport
#5 opened Oct 9, 2020 by bochuxt
1-word_count.py运行报错
#4 opened Aug 4, 2020 by Edlen-xulun
1
Created a new mysql job, and it doesn't work。There could be sth wrong with the IntSerializer according to the bug report。
#3 opened Jun 30, 2020 by yyz940922
3
Examples using file system fail - Permission Denied
#2 opened May 25, 2020 by JHSaunders
2
mysql 启动有问题 而且flink任务执行不了
#1 opened Apr 21, 2020 by vissul
2
ProTip! Type g i on any issue or pull request to go back to the issue listing page.