Shandy created FLINK-25499:
--
Summary: Column 'window_start' is ambiguous
Key: FLINK-25499
URL: https://issues.apache.org/jira/browse/FLINK-25499
Project: Flink
Issue Type: Bug
Components:
Hi Thomas,
thanks for the feedback and clarification. The Flink community should then
make it clear that downstream developers should keep multiple
implementations for different Flink versions if it is necessary, which is
also a valid concept, so we could focus on the backward compatibility.
Hopef
Yun Gao created FLINK-25498:
---
Summary: FlinkKafkaProducerITCase.
testRestoreToCheckpointAfterExceedingProducersPool failed on azure
Key: FLINK-25498
URL: https://issues.apache.org/jira/browse/FLINK-25498
Pr
+1 （non-binding)
- Verified checksums and signatures
- Pip install the apache-flink-ml package
- Run the apache-flink-ml tests (We will add more python examples in the
next release https://issues.apache.org/jira/browse/FLINK-25497).
Best,
Xingbo
Zhipeng Zhang 于2021年12月31日周五 15:01写道：
> +1 (non-
Huang Xingbo created FLINK-25497:
Summary: Add more ML Python examples
Key: FLINK-25497
URL: https://issues.apache.org/jira/browse/FLINK-25497
Project: Flink
Issue Type: Improvement
Hi Lincoln,
Thanks for the feedback.
> 1. For the hint name, +1 for WenLong's proposal.
I've added add 'SHUFFLE_HASH' to other alternatives in FLIP. Let's waiting
for more voices here.
> Regarding the `SKEW` hint, agree with you that it can be used widely, and
I
prefer to treat it as a metadata
Hi Wei,
Thanks a lot for your feedback. Very good questions!
>>> 1. It seems that we dynamically load an embedded Python and user
dependencies in the TM process. Can they be uninstalled cleanly after the
task finished? i.e. Can we use the Thread Mode in session mode and Pyflink
shell?
I mentione
Hi Martijn,
Thanks for the feedback.
Glad to hear that we reached a consensus on the first and second point.
About whether to use `use_hash` as a term, I think your concern makes sense.
Although the hash lookup join is similar to Hash join in oracle that they
all require hash distribution on inpu
