Penguin created FLINK-27088:
---
Summary: The example of using StringDeserializer for deserializing
Kafka message value as string has an error
Key: FLINK-27088
URL: https://issues.apache.org/jira/browse/FLINK-27088
Hi,
I click the reply button every time... Does this mean that only the replied
person can see the email?
If Maven fails to download plugins or dependencies, is mvn -clean install
-DskipTests a must?
I'll try first.
penguin
在 2021-01-13 16:35:10，"Matthias Pohl&qu
Hello,
When importing the Flink source code into idea, the following error occurred.
And several mirrors were configured in the setting file of maven, which did not
solve the problem
Hello,
When importing the Flink source code into idea, the following error occurred.
And several mirrors were configured in the setting file of maven, which did not
solve the problem
Hi，
Does anyone know how to compile the Flink runtime module separately ?
Is it possible to replace the directory(org.apache.flink.runtime) in the
flink-dist.jar with the changed part I changed?
It's too slow to compile all at once.
thank you!
penguin
lly in the absence of comments.
It would be a great pleasure if more people come to study and discuss this
topic.
Best,
Penguin
At 2021-01-08 06:58:54, "Lasantha Fernando" wrote:
>Hi Penguin,
>
>Jumping into this conversation since I worked on the same code base
efaultScheduler#allocateSlotsAndDeploy .
(The version of Flink I use is Flink-1.11.1)
I'm going to try to see the following code first, but the code annotation seem
to be very few.I feel very difficult for my goal and I hope I can get your help
later.
Sincerely,
Penguin
At
Hello! Do you know how to modify the task scheduling method of Flink?
