Hi Flink devs,
Recently we had some discussion in the Flink PMC about creating a public
open GitHub organization to host the code repo of some Flink ecosystem
projects. Instead of the Flink PMC doing this, we found that it is more
suitable for someone in the Flink community to do this on their per
Hi all,
Zhipeng and I have created FLIP-175: Compose Estimator/Model/AlgoOperator
from DAG of Estimator/Model/AlgoOperator. Please find the FLIP wiki in the
link
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=181311363.
With this FLIP, users can compose an Estimator from a DAG o
Hi all,
Zhipeng and I have created FLIP-174: Improve the WithParam interface.
Please find the FLIP wiki in the link
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=181311361.
The goal of this FLIP is to improve the experience of defining, saving and
loading parameters of stages (
Thanks Dian, it works
Dian Fu 于2021年9月23日周四 上午9:18写道：
> Hi Jeff,
>
> It has split the jars into a separate package since 1.13 and so there are
> two packages now.
>
> You need install `apache-flink-libraries` firstly:
> pip install apache-flink-libraries-1.14.0.tar.gz
>
> Note that this is only
Xintong Song created FLINK-24358:
Summary: flink-avro-glue-schema-registry fails compiling with
dependency convergence
Key: FLINK-24358
URL: https://issues.apache.org/jira/browse/FLINK-24358
Project:
Thanks for driving this discussion, Martijn. +1 for releasing Flink 1.13.3.
In addition to the issues already listed,
https://issues.apache.org/jira/browse/FLINK-24005 is also an important
fix.
Regarding FLINK-24315, @Yang Wang will help with the review. It is
likely to be merged this week, if not
Please send email to dev-unsubscr...@flink.apache.org if you want to
unsubscribe the mail from dev@flink.apache.org, you can refer[1] for more
details.
[1]https://flink.apache.org/community.html#mailing-lists
> 在 2021年9月23日，09:44，Hunk 写道：
>
>
>
>
>
> 发自 网易邮箱大师
发自 网易邮箱大师
Hi Jeff,
It has split the jars into a separate package since 1.13 and so there are two
packages now.
You need install `apache-flink-libraries` firstly:
pip install apache-flink-libraries-1.14.0.tar.gz
Note that this is only necessary when installing from source. Could also refer
to [1] for mo
Disclaimer: I know close to nothing about python and pip.
I think the problem is that it is not deployed to the ?pip repository?.
It can't be deployed if it was not voted. It said it succeeded if I
passed the apache-flink-libraries to the cli:
pip install apache_flink-1.14.0-cp38-cp38-manylinux1_
Piotr Nowojski created FLINK-24357:
--
Summary:
ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled
fails with an Unhandled error
Key: FLINK-24357
Can anyone successfully install pyflink ? I failed to install it and get
the following error:
(python3.7) [hadoop@emr-header-1 zeppelin]$ pip install
apache_flink-1.14.0-cp37-cp37m-manylinux1_x86_64.whl
Processing ./apache_flink-1.14.0-cp37-cp37m-manylinux1_x86_64.whl
Collecting apache-beam==2.27.
Hi everyone,
Please review and vote on the release candidate #3 for the version
1.14.0, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
*
Hi Martijn,
Thanks for starting the discussion. +1 for a soon Flink 1.13.3. IMHO we
don't need to block the release on FLINK-23519 (an improvement),
FLINK-21853 (seems like a Minor issue with a test) or FLINK-23946 (depends
on https://issues.apache.org/jira/browse/FLINK-23946, which is not started
Hi all,
I would like to start discussing releasing Flink 1.13.3. There are
currently 138 tickets already resolved for 1.13.3, a few important fixes
are:
* https://issues.apache.org/jira/browse/FLINK-24347 (KafkaSource cannot
checkpoint if the parallelism is higher than the partition number)
* htt
Julia Pedrycz created FLINK-24356:
-
Summary: Not able to cancel delayed message using remote stateful
function mode
Key: FLINK-24356
URL: https://issues.apache.org/jira/browse/FLINK-24356
Project: Fli
Dawid Wysakowicz created FLINK-24355:
Summary: Expose the flag for enabling checkpoints after tasks
finish in the Web UI
Key: FLINK-24355
URL: https://issues.apache.org/jira/browse/FLINK-24355
Pro
Dong Lin created FLINK-24354:
Summary: FLIP-174: Improve the WithParam interface
Key: FLINK-24354
URL: https://issues.apache.org/jira/browse/FLINK-24354
Project: Flink
Issue Type: Improvement
Xintong Song created FLINK-24353:
Summary: Bash scripts do not respect dynamic configurations when
calculating memory sizes
Key: FLINK-24353
URL: https://issues.apache.org/jira/browse/FLINK-24353
Proj
Caizhi Weng created FLINK-24352:
---
Summary: Lookup join + WITH clause throws NPE
Key: FLINK-24352
URL: https://issues.apache.org/jira/browse/FLINK-24352
Project: Flink
Issue Type: Bug
20 matches
Mail list logo
