Why does Apache Flink stall in method org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.getContainedGenericTypes?
While implementing my algorithm I have created a long chain of operators in Apache Flink with for loop. Starting from some length processing stalls in method org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.getContainedGenericTypes for a long time before actual processing. How can be explained this phenomenon? How can it be addressed in order to reduce this method time?
The Serializers.getContainedGenericTypes() method is only called during the plan creation of your DataSet application.
Setting ExecutionConfig.disableAutoTypeRegistration() will disable this registration.
I assume you are running your Flink application locally without a lot of data. Usually, the plan creation takes only a small fraction of the available CPU time, and the actual processing eats up most of it.
- netbeans 7.0 and scala results in stackoverflow
- Why did the Scala compiler get more strict regarding self types in 2.10?
- Execute parallel requests in Gatling
- Scala: comparing fresh objects
- Akka HTTP SBT modules were resolved with conflicting cross-version suffixes in ProjectRrf
- Scala 3 macro: how to get the return type of a method by its `Symbol`?
- Gatling: how can I log only failed requests?
- Akka HTTP new SBT dependencies not installing with 'Unresolved dependencies path' ERROR
- Proguard warnings: can't find referenced class scala.*
- Logging using Logback on Spark StandAlone
- Why is reference to overloaded definition ambiguous when types are known?
- How to construct Dataframe from a Excel (xls,xlsx) file in Scala Spark?
- Pattern matching in conjunciton with filter
- Difference between ReduceByKey and CombineByKey in Spark
- Requesting more information about @inline from the compiler?
- Scala Class Name via TypeTag is simply written as "TypeTagImpl"
- How do I test that an offset has been committed or not to Kafka
- How to exclude cucumber tags
- Jvm takes a long time to resolve ip-address for localhost
- How to define partitioning of DataFrame?
- Why is the creation of multi-dimensional arrays so slow in Scala?
- How to pass along CSRF token in an AJAX post request for a form?
- How can two coupled Scala generic type constructors refer to each other as type parameters?
- Read CSV with "§" as delimiter using Databricks autoloader
- OAuth 1.0 and X API v2 with Scala and sttp
- Scala problem reading parameter values inside List Classes
- Scala Akka HTTP issue accessing post request parameters wrapped in Option[String]
- akka 2.0 send message to self
- Scala Akka HTTP problem accessing post request parameters
- Problems with Java Vector API to sum a list of doubles