grow indefinitely and finally cause
an OOM kill.
[1]. https://issues.apache.org/jira/browse/FLINK-16225
[2].
https://ci.apache.org/projects/flink/flink-docs-release-1.9/monitoring/debugging_classloading.html#unloading-of-dynamically-loaded-classes-in-user-code
Regards
Smile
On 2021/07/15 18:22:56, ba
JM log shows this:
INFO org.apache.flink.yarn.YarnResourceManager - The
heartbeat of JobManager with id 41e3ef1f248d24ddefdccd1887947106 timed out.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi Alexey,
We also have the same problem running on Yarn using Flink 1.9.0.
JM log shows this:
We are also looking for a way to troubleshoot this problem.
Best regards.
Smile
Alexey Trenikhun wrote
> Hello,
>
> I periodically see in JM log (Flink 12.2):
>
> {"ts":
those records
with an empty key got the wrong key.
Should EmptyRowDataKeySelector also returns a copy of
BinaryRowDataUtil.EMPTY_ROW? Otherwise, the key should never be changed
because it may also be used by other records.
Smile
[1].
https://github.com/apache/flink/blob/master/flink-table/flink-
happens or where to check next?
Thank you.
Smile
<http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t2787/EmptyRowDebug-20210511-1.png>
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
link/streaming/api/functions/source/SourceFunction.html
[3].
https://ci.apache.org/projects/flink/flink-docs-release-1.12/concepts/stateful-stream-processing.html
[4].
https://ci.apache.org/projects/flink/flink-docs-release-1.12/api/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.html
Regards,
Smile
-docs-release-1.12/api/java/org/apache/flink/streaming/api/functions/source/SourceFunction.html
[2].
https://ci.apache.org/projects/flink/flink-docs-release-1.12/try-flink/datastream_api.html
Regards,
Smile
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
g/api/environment/StreamExecutionEnvironment.html#readTextFile-java.lang.String-
Regards,
Smile
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
rwise, you can use sideOutputLateData() to get the late
data of the window and have a look at them. See [1] for more information
about sideOutputLateData().
[1].
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/stream/operators/windows.html#getting-late-data-as-a-side-output
Rega
#scala-versions
Regards,
Smile
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
=5.5.2 -Dpackaging=jar -Dfile=common-utils-5.5.2.jar
-DpomFile=common-utils-5.5.2.pom
At 2021-01-25 16:36:12, "Matthias Pohl" wrote:
Hi Smile,
you missed installing the pom provided by mvnrepository.org [1]. Maven will
install a basic pom if none is provided [2]. This basic pom fil
luent/kafka-avro-serializer/5.5.2/kafka-avro-serializer-5.5.2.pom
[3]. https://mvnrepository.com/artifact/io.confluent/kafka-avro-serializer
At 2021-01-22 21:22:51, "Matthias Pohl" wrote:
Hi Smile,
Have you used a clean checkout? I second Robert's statement considering that
t
uild is failing when you build Flink from the root
directory (not calling maven from within a maven module?)
On Tue, Jan 19, 2021 at 11:19 AM Smile@LETTers wrote:
Hi,
I got an error when tried to compile & package Flink (version 1.12 & current
master).
It can be reproduced by run &
classes can not be found.
After adding the dependency kafka-avro-serializer to the pom of
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka everything goes well.
And I just wonder that is this a bug or I missed some local setting?
Best regards.
Smile
Error logs a
14 matches
Mail list logo
