Michael created FLINK-12301:
-------------------------------
Summary: Scala value classes cannot be serialized anymore in case
classes in Flink 1.8.0
Key: FLINK-12301
URL: https://issues.apache.org/jira/browse/FLINK-12301
Project: Flink
Issue Type: Bug
Components: API / Scala
Affects Versions: 1.8.0
Reporter: Michael
There is a regression in Flink 1.8.0 compared to 1.7.2: Scala [value
classes|https://docs.scala-lang.org/overviews/core/value-classes.html] cannot
be serialized anymore as a case class attribute.
Some short example code:
{code:scala}
package com.example.valueclassissue
import org.apache.flink.streaming.api.scala._
object ValueClassExample extends App {
val env: StreamExecutionEnvironment =
StreamExecutionEnvironment.getExecutionEnvironment
val measurements = env.fromCollection(Seq(Measurement(1, new
DegreeCelsius(32.5f))))
measurements.print()
env.execute()
}
class DegreeCelsius(val value: Float) extends AnyVal {
override def toString: String = s"$value °C"
}
case class Measurement(i: Int, temperature: DegreeCelsius)
{code}
While with Flink 1.7.2 the program outputs _{{3> Measurement(1,32.5 °C)}}_ as
expected, in Flink 1.8.0 an exception is thrown:
{noformat}
java.io.IOException: Failed to deserialize an element from the source. If you
are using user-defined serialization (Value and Writable types), check the
serialization functions.
Serializer is
org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer@466b6f83
at
org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:158)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:93)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)
at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:97)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
at java.lang.Thread.run(Thread.java:748)
{noformat}
Full log:
{noformat}
2019-04-23T09:33:48.485Z [main] INFO
org.apache.flink.api.java.typeutils.TypeExtractor - class
com.example.valueclassissue.DegreeCelsius does not contain a setter for field
value
2019-04-23T09:33:48.487Z [main] INFO
org.apache.flink.api.java.typeutils.TypeExtractor - Class class
com.example.valueclassissue.DegreeCelsius cannot be used as a POJO type because
not all fields are valid POJO fields, and must be processed as GenericType.
Please read the Flink documentation on "Data Types & Serialization" for details
of the effect on performance.
2019-04-23T09:33:49.594Z [main] INFO
org.apache.flink.streaming.api.environment.LocalStreamEnvironment - Running job
on local embedded Flink mini cluster
2019-04-23T09:33:49.616Z [main] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting Flink Mini Cluster
2019-04-23T09:33:49.618Z [main] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting Metrics Registry
2019-04-23T09:33:49.665Z [main] INFO
org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter
configured, no metrics will be exposed/reported.
2019-04-23T09:33:49.665Z [main] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting RPC Service(s)
2019-04-23T09:33:49.896Z [flink-akka.actor.default-dispatcher-3] INFO
akka.event.slf4j.Slf4jLogger - Slf4jLogger started
2019-04-23T09:33:49.913Z [main] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Trying to start actor system
at :0
2019-04-23T09:33:49.952Z [flink-metrics-2] INFO akka.event.slf4j.Slf4jLogger -
Slf4jLogger started
2019-04-23T09:33:50.001Z [flink-metrics-2] INFO akka.remote.Remoting - Starting
remoting
2019-04-23T09:33:50.139Z [flink-metrics-2] INFO akka.remote.Remoting - Remoting
started; listening on addresses :[akka.tcp://[email protected]:36651]
2019-04-23T09:33:50.144Z [main] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Actor system started at
akka.tcp://[email protected]:36651
2019-04-23T09:33:50.146Z [main] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting high-availability
services
2019-04-23T09:33:50.155Z [main] INFO org.apache.flink.runtime.blob.BlobServer -
Created BLOB server storage directory
/tmp/blobStore-0e1c3305-1e6e-47a0-885a-8c82bb5ae09f
2019-04-23T09:33:50.158Z [main] INFO org.apache.flink.runtime.blob.BlobServer -
Started BLOB server at 0.0.0.0:40817 - max concurrent requests: 50 - max
backlog: 1000
2019-04-23T09:33:50.161Z [main] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Created BLOB cache storage
directory /tmp/blobStore-e3046023-c398-4a42-88f4-20949f7876ce
2019-04-23T09:33:50.162Z [main] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Created BLOB cache storage
directory /tmp/blobStore-ef6f2625-afcc-4937-90ba-a981af59bce4
2019-04-23T09:33:50.162Z [main] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting 1 TaskManger(s)
2019-04-23T09:33:50.164Z [main] INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Starting TaskManager
with ResourceID: ce7b0b20-a06b-4135-aa6b-7a051cfc3672
2019-04-23T09:33:50.217Z [main] INFO
org.apache.flink.runtime.taskexecutor.TaskManagerServices - Temporary file
directory '/tmp': total 97 GB, usable 60 GB (61.86% usable)
2019-04-23T09:33:50.325Z [main] INFO
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool - Allocated 246 MB
for network buffer pool (number of memory segments: 7882, bytes per segment:
32768).
2019-04-23T09:33:50.328Z [main] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Starting the network
environment and its components.
2019-04-23T09:33:50.329Z [main] INFO
org.apache.flink.runtime.taskexecutor.TaskManagerServices - Limiting managed
memory to 0.7 of the currently free heap space (1543 MB), memory will be
allocated lazily.
2019-04-23T09:33:50.331Z [main] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager uses
directory /tmp/flink-io-f952881a-df88-4b6f-84fe-1e83412f120b for spill files.
2019-04-23T09:33:50.377Z [main] INFO
org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration - Messages have
a max timeout of 10000 ms
2019-04-23T09:33:50.387Z [main] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for
org.apache.flink.runtime.taskexecutor.TaskExecutor at
akka://flink/user/taskmanager_0 .
2019-04-23T09:33:50.400Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Start job leader
service.
2019-04-23T09:33:50.401Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.filecache.FileCache - User file cache uses directory
/tmp/flink-dist-cache-da57d8de-8359-4f8b-838d-88094398b7cd
2019-04-23T09:33:50.430Z [main] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Starting rest
endpoint.
2019-04-23T09:33:50.573Z [main] WARN
org.apache.flink.runtime.webmonitor.WebMonitorUtils - Log file environment
variable 'log.file' is not set.
2019-04-23T09:33:50.573Z [main] WARN
org.apache.flink.runtime.webmonitor.WebMonitorUtils - JobManager log files are
unavailable in the web dashboard. Log file location not found in environment
variable 'log.file' or configuration key 'Key: 'web.log.path' , default: null
(fallback keys: [{key=jobmanager.web.log.path, isDeprecated=true}])'.
2019-04-23T09:33:50.580Z [main] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Failed to load web
based job submission extension. Probable reason: flink-runtime-web is not in
the classpath.
2019-04-23T09:33:50.715Z [main] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint
listening at localhost:39621
2019-04-23T09:33:50.716Z [main] INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Proposing leadership to contender
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint@25f723b0 @
http://localhost:39621
2019-04-23T09:33:50.718Z [mini-cluster-io-thread-1] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint -
http://localhost:39621 was granted leadership with
leaderSessionID=848a2169-0638-4284-b5b1-c74561a5016d
2019-04-23T09:33:50.718Z [mini-cluster-io-thread-1] INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Received confirmation of leadership for leader http://localhost:39621 ,
session=848a2169-0638-4284-b5b1-c74561a5016d
2019-04-23T09:33:50.728Z [main] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at
akka://flink/user/resourcemanager .
2019-04-23T09:33:50.737Z [main] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for
org.apache.flink.runtime.dispatcher.StandaloneDispatcher at
akka://flink/user/dispatcher .
2019-04-23T09:33:50.745Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Proposing leadership to contender
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager@586de9c6 @
akka://flink/user/resourcemanager
2019-04-23T09:33:50.745Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Proposing leadership to contender
org.apache.flink.runtime.dispatcher.StandaloneDispatcher@171bdca8 @
akka://flink/user/dispatcher
2019-04-23T09:33:50.748Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
ResourceManager akka://flink/user/resourcemanager was granted leadership with
fencing token 8d0000744239b25d92a24a84384e421b
2019-04-23T09:33:50.748Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Starting the
SlotManager.
2019-04-23T09:33:50.750Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Received confirmation of leadership for leader
akka://flink/user/resourcemanager , session=92a24a84-384e-421b-8d00-00744239b25d
2019-04-23T09:33:50.751Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher
akka://flink/user/dispatcher was granted leadership with fencing token
3be1cf58-f256-464c-a503-0130f1d6653a
2019-04-23T09:33:50.755Z [main] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Flink Mini Cluster started
successfully
2019-04-23T09:33:50.759Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Connecting to
ResourceManager
akka://flink/user/resourcemanager(8d0000744239b25d92a24a84384e421b).
2019-04-23T09:33:50.760Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all
persisted jobs.
2019-04-23T09:33:50.761Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Received confirmation of leadership for leader akka://flink/user/dispatcher ,
session=3be1cf58-f256-464c-a503-0130f1d6653a
2019-04-23T09:33:50.767Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Resolved ResourceManager
address, beginning registration
2019-04-23T09:33:50.768Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Registration at
ResourceManager attempt 1 (timeout=100ms)
2019-04-23T09:33:50.771Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
Registering TaskManager with ResourceID ce7b0b20-a06b-4135-aa6b-7a051cfc3672
(akka://flink/user/taskmanager_0) at ResourceManager
2019-04-23T09:33:50.772Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Successful registration at
resource manager akka://flink/user/resourcemanager under registration id
57ee60b35a4b387afe62844e5dd075e5.
2019-04-23T09:33:50.775Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Received JobGraph
submission 0934b4e32657180f004df5cf4e003ab4 (Flink Streaming Job).
2019-04-23T09:33:50.775Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job
0934b4e32657180f004df5cf4e003ab4 (Flink Streaming Job).
2019-04-23T09:33:50.788Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for
org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_1 .
2019-04-23T09:33:50.796Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Initializing job Flink Streaming
Job (0934b4e32657180f004df5cf4e003ab4).
2019-04-23T09:33:50.800Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Using restart strategy
NoRestartStrategy for Flink Streaming Job (0934b4e32657180f004df5cf4e003ab4).
2019-04-23T09:33:50.827Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers via
failover strategy: full graph restart
2019-04-23T09:33:50.847Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master
for job Flink Streaming Job (0934b4e32657180f004df5cf4e003ab4).
2019-04-23T09:33:50.847Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization
on master in 0 ms.
2019-04-23T09:33:50.866Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
2019-04-23T09:33:50.876Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Proposing leadership to contender
org.apache.flink.runtime.jobmaster.JobManagerRunner@6667cd6 @
akka://flink/user/jobmanager_1
2019-04-23T09:33:50.877Z [mini-cluster-io-thread-4] INFO
org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManager runner for job
Flink Streaming Job (0934b4e32657180f004df5cf4e003ab4) was granted leadership
with session id ed72f40e-a416-4efc-856d-27e694574e2f at
akka://flink/user/jobmanager_1.
2019-04-23T09:33:50.879Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job Flink
Streaming Job (0934b4e32657180f004df5cf4e003ab4) under job master id
856d27e694574e2fed72f40ea4164efc.
2019-04-23T09:33:50.879Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Flink Streaming
Job (0934b4e32657180f004df5cf4e003ab4) switched from state CREATED to RUNNING.
2019-04-23T09:33:50.882Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Collection
Source (1/1) (833716fb73726ad792a24c184d5312b2) switched from CREATED to
SCHEDULED.
2019-04-23T09:33:50.890Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot
request, no ResourceManager connected. Adding as pending request
[SlotRequestId{6a6e14d6bca90867458577365cb9721e}]
2019-04-23T09:33:50.894Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (1/4) (6982b1cd1147229d264344ec41df12a9) switched from CREATED to SCHEDULED.
2019-04-23T09:33:50.895Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (2/4) (fcccdf96f9411000517ecc55b620f125) switched from CREATED to SCHEDULED.
2019-04-23T09:33:50.895Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (3/4) (09fdc88b7fe9efe5eeb0d30327eb8c93) switched from CREATED to SCHEDULED.
2019-04-23T09:33:50.895Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (4/4) (27df5777eb4ebd374f003634a00a7cd9) switched from CREATED to SCHEDULED.
2019-04-23T09:33:50.898Z [jobmanager-future-thread-1] INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Received confirmation of leadership for leader akka://flink/user/jobmanager_1
, session=ed72f40e-a416-4efc-856d-27e694574e2f
2019-04-23T09:33:50.898Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager
akka://flink/user/resourcemanager(8d0000744239b25d92a24a84384e421b)
2019-04-23T09:33:50.900Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager
address, beginning registration
2019-04-23T09:33:50.900Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager
attempt 1 (timeout=100ms)
2019-04-23T09:33:50.902Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
Registering job manager
856d27e694574e2fed72f40ea4164efc@akka://flink/user/jobmanager_1 for job
0934b4e32657180f004df5cf4e003ab4.
2019-04-23T09:33:50.908Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registered
job manager 856d27e694574e2fed72f40ea4164efc@akka://flink/user/jobmanager_1 for
job 0934b4e32657180f004df5cf4e003ab4.
2019-04-23T09:33:50.909Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully
registered at ResourceManager, leader id: 8d0000744239b25d92a24a84384e421b.
2019-04-23T09:33:50.910Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Requesting new slot
[SlotRequestId{6a6e14d6bca90867458577365cb9721e}] and profile
ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
2019-04-23T09:33:50.911Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1,
directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job
0934b4e32657180f004df5cf4e003ab4 with allocation id
16865b3b201cc25ae128095d117c2e7d.
2019-04-23T09:33:50.911Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request
16865b3b201cc25ae128095d117c2e7d for job 0934b4e32657180f004df5cf4e003ab4 from
resource manager with leader id 8d0000744239b25d92a24a84384e421b.
2019-04-23T09:33:50.912Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for
16865b3b201cc25ae128095d117c2e7d.
2019-04-23T09:33:50.912Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job
0934b4e32657180f004df5cf4e003ab4 for job leader monitoring.
2019-04-23T09:33:50.914Z [mini-cluster-io-thread-3] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job
manager akka://flink/user/jobmanager_1 with leader id
ed72f40e-a416-4efc-856d-27e694574e2f.
2019-04-23T09:33:50.915Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Resolved JobManager
address, beginning registration
2019-04-23T09:33:50.915Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Registration at
JobManager attempt 1 (timeout=100ms)
2019-04-23T09:33:50.918Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Successful
registration at job manager akka://flink/user/jobmanager_1 for job
0934b4e32657180f004df5cf4e003ab4.
2019-04-23T09:33:50.918Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Establish JobManager
connection for job 0934b4e32657180f004df5cf4e003ab4.
2019-04-23T09:33:50.920Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to
the leader of job 0934b4e32657180f004df5cf4e003ab4.
2019-04-23T09:33:50.923Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Requesting new slot
[SlotRequestId{0889151458281fff281d1f40b8949362}] and profile
ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
2019-04-23T09:33:50.924Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Requesting new slot
[SlotRequestId{6048f2d28bc988068b4f3c09c96e5bf4}] and profile
ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
2019-04-23T09:33:50.924Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1,
directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job
0934b4e32657180f004df5cf4e003ab4 with allocation id
04c413ac1d7681b769798f365e4a8565.
2019-04-23T09:33:50.924Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Requesting new slot
[SlotRequestId{af9271e58daaf7760d2bad798c764943}] and profile
ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
2019-04-23T09:33:50.924Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1,
directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job
0934b4e32657180f004df5cf4e003ab4 with allocation id
4c11ede5a7f087d8653710365e1af854.
2019-04-23T09:33:50.924Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request
04c413ac1d7681b769798f365e4a8565 for job 0934b4e32657180f004df5cf4e003ab4 from
resource manager with leader id 8d0000744239b25d92a24a84384e421b.
2019-04-23T09:33:50.924Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1,
directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job
0934b4e32657180f004df5cf4e003ab4 with allocation id
e31bbfd59504d04ff607286275900171.
2019-04-23T09:33:50.924Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for
04c413ac1d7681b769798f365e4a8565.
2019-04-23T09:33:50.924Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to
the leader of job 0934b4e32657180f004df5cf4e003ab4.
2019-04-23T09:33:50.925Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Received repeated
offer for slot [16865b3b201cc25ae128095d117c2e7d]. Ignoring.
2019-04-23T09:33:50.925Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request
4c11ede5a7f087d8653710365e1af854 for job 0934b4e32657180f004df5cf4e003ab4 from
resource manager with leader id 8d0000744239b25d92a24a84384e421b.
2019-04-23T09:33:50.925Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for
4c11ede5a7f087d8653710365e1af854.
2019-04-23T09:33:50.925Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to
the leader of job 0934b4e32657180f004df5cf4e003ab4.
2019-04-23T09:33:50.925Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Received repeated
offer for slot [04c413ac1d7681b769798f365e4a8565]. Ignoring.
2019-04-23T09:33:50.925Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot
16865b3b201cc25ae128095d117c2e7d.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Received repeated
offer for slot [16865b3b201cc25ae128095d117c2e7d]. Ignoring.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request
e31bbfd59504d04ff607286275900171 for job 0934b4e32657180f004df5cf4e003ab4 from
resource manager with leader id 8d0000744239b25d92a24a84384e421b.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for
e31bbfd59504d04ff607286275900171.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to
the leader of job 0934b4e32657180f004df5cf4e003ab4.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot
04c413ac1d7681b769798f365e4a8565.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Received repeated
offer for slot [04c413ac1d7681b769798f365e4a8565]. Ignoring.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot
16865b3b201cc25ae128095d117c2e7d.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot
04c413ac1d7681b769798f365e4a8565.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Collection
Source (1/1) (833716fb73726ad792a24c184d5312b2) switched from SCHEDULED to
DEPLOYING.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot
16865b3b201cc25ae128095d117c2e7d.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot
4c11ede5a7f087d8653710365e1af854.
2019-04-23T09:33:50.926Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source:
Collection Source (1/1) (attempt #0) to ce7b0b20-a06b-4135-aa6b-7a051cfc3672 @
localhost (dataPort=-1)
2019-04-23T09:33:50.930Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (1/4) (6982b1cd1147229d264344ec41df12a9) switched from SCHEDULED to
DEPLOYING.
2019-04-23T09:33:50.930Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Print
to Std. Out (1/4) (attempt #0) to ce7b0b20-a06b-4135-aa6b-7a051cfc3672 @
localhost (dataPort=-1)
2019-04-23T09:33:50.932Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (2/4) (fcccdf96f9411000517ecc55b620f125) switched from SCHEDULED to
DEPLOYING.
2019-04-23T09:33:50.932Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Print
to Std. Out (2/4) (attempt #0) to ce7b0b20-a06b-4135-aa6b-7a051cfc3672 @
localhost (dataPort=-1)
2019-04-23T09:33:50.932Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (3/4) (09fdc88b7fe9efe5eeb0d30327eb8c93) switched from SCHEDULED to
DEPLOYING.
2019-04-23T09:33:50.932Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Print
to Std. Out (3/4) (attempt #0) to ce7b0b20-a06b-4135-aa6b-7a051cfc3672 @
localhost (dataPort=-1)
2019-04-23T09:33:50.932Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (4/4) (27df5777eb4ebd374f003634a00a7cd9) switched from SCHEDULED to
DEPLOYING.
2019-04-23T09:33:50.932Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Print
to Std. Out (4/4) (attempt #0) to ce7b0b20-a06b-4135-aa6b-7a051cfc3672 @
localhost (dataPort=-1)
2019-04-23T09:33:50.932Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Received repeated
offer for slot [4c11ede5a7f087d8653710365e1af854]. Ignoring.
2019-04-23T09:33:50.943Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source:
Collection Source (1/1).
2019-04-23T09:33:50.943Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot
04c413ac1d7681b769798f365e4a8565.
2019-04-23T09:33:50.943Z [Source: Collection Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Source: Collection Source (1/1)
(833716fb73726ad792a24c184d5312b2) switched from CREATED to DEPLOYING.
2019-04-23T09:33:50.944Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot
e31bbfd59504d04ff607286275900171.
2019-04-23T09:33:50.944Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot
4c11ede5a7f087d8653710365e1af854.
2019-04-23T09:33:50.944Z [Source: Collection Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task Source: Collection Source (1/1)
(833716fb73726ad792a24c184d5312b2) [DEPLOYING]
2019-04-23T09:33:50.948Z [Source: Collection Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source:
Collection Source (1/1) (833716fb73726ad792a24c184d5312b2) [DEPLOYING].
2019-04-23T09:33:50.949Z [Source: Collection Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
Source: Collection Source (1/1) (833716fb73726ad792a24c184d5312b2) [DEPLOYING].
2019-04-23T09:33:50.949Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Sink: Print
to Std. Out (1/4).
2019-04-23T09:33:50.951Z [Sink: Print to Std. Out (1/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (1/4)
(6982b1cd1147229d264344ec41df12a9) switched from CREATED to DEPLOYING.
2019-04-23T09:33:50.951Z [Sink: Print to Std. Out (1/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task Sink: Print to Std. Out (1/4)
(6982b1cd1147229d264344ec41df12a9) [DEPLOYING]
2019-04-23T09:33:50.951Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Sink: Print
to Std. Out (2/4).
2019-04-23T09:33:50.951Z [Sink: Print to Std. Out (1/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Sink:
Print to Std. Out (1/4) (6982b1cd1147229d264344ec41df12a9) [DEPLOYING].
2019-04-23T09:33:50.952Z [Sink: Print to Std. Out (1/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network: Sink:
Print to Std. Out (1/4) (6982b1cd1147229d264344ec41df12a9) [DEPLOYING].
2019-04-23T09:33:50.953Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Sink: Print
to Std. Out (3/4).
2019-04-23T09:33:50.953Z [Sink: Print to Std. Out (2/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (2/4)
(fcccdf96f9411000517ecc55b620f125) switched from CREATED to DEPLOYING.
2019-04-23T09:33:50.953Z [Sink: Print to Std. Out (2/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task Sink: Print to Std. Out (2/4)
(fcccdf96f9411000517ecc55b620f125) [DEPLOYING]
2019-04-23T09:33:50.953Z [Sink: Print to Std. Out (2/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Sink:
Print to Std. Out (2/4) (fcccdf96f9411000517ecc55b620f125) [DEPLOYING].
2019-04-23T09:33:50.954Z [Sink: Print to Std. Out (2/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network: Sink:
Print to Std. Out (2/4) (fcccdf96f9411000517ecc55b620f125) [DEPLOYING].
2019-04-23T09:33:50.955Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Sink: Print
to Std. Out (4/4).
2019-04-23T09:33:50.955Z [Sink: Print to Std. Out (3/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (3/4)
(09fdc88b7fe9efe5eeb0d30327eb8c93) switched from CREATED to DEPLOYING.
2019-04-23T09:33:50.955Z [Sink: Print to Std. Out (3/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task Sink: Print to Std. Out (3/4)
(09fdc88b7fe9efe5eeb0d30327eb8c93) [DEPLOYING]
2019-04-23T09:33:50.955Z [Sink: Print to Std. Out (3/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Sink:
Print to Std. Out (3/4) (09fdc88b7fe9efe5eeb0d30327eb8c93) [DEPLOYING].
2019-04-23T09:33:50.956Z [Sink: Print to Std. Out (3/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network: Sink:
Print to Std. Out (3/4) (09fdc88b7fe9efe5eeb0d30327eb8c93) [DEPLOYING].
2019-04-23T09:33:50.963Z [Sink: Print to Std. Out (4/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (4/4)
(27df5777eb4ebd374f003634a00a7cd9) switched from CREATED to DEPLOYING.
2019-04-23T09:33:50.963Z [Sink: Print to Std. Out (2/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (2/4)
(fcccdf96f9411000517ecc55b620f125) switched from DEPLOYING to RUNNING.
2019-04-23T09:33:50.964Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (2/4) (fcccdf96f9411000517ecc55b620f125) switched from DEPLOYING to RUNNING.
2019-04-23T09:33:50.963Z [Sink: Print to Std. Out (3/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (3/4)
(09fdc88b7fe9efe5eeb0d30327eb8c93) switched from DEPLOYING to RUNNING.
2019-04-23T09:33:50.964Z [Sink: Print to Std. Out (4/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task Sink: Print to Std. Out (4/4)
(27df5777eb4ebd374f003634a00a7cd9) [DEPLOYING]
2019-04-23T09:33:50.965Z [Source: Collection Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Source: Collection Source (1/1)
(833716fb73726ad792a24c184d5312b2) switched from DEPLOYING to RUNNING.
2019-04-23T09:33:50.967Z [Sink: Print to Std. Out (4/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Sink:
Print to Std. Out (4/4) (27df5777eb4ebd374f003634a00a7cd9) [DEPLOYING].
2019-04-23T09:33:50.965Z [Sink: Print to Std. Out (2/4)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
2019-04-23T09:33:50.965Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (3/4) (09fdc88b7fe9efe5eeb0d30327eb8c93) switched from DEPLOYING to RUNNING.
2019-04-23T09:33:50.967Z [Source: Collection Source (1/1)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
2019-04-23T09:33:50.967Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Collection
Source (1/1) (833716fb73726ad792a24c184d5312b2) switched from DEPLOYING to
RUNNING.
2019-04-23T09:33:50.965Z [Sink: Print to Std. Out (3/4)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
2019-04-23T09:33:50.966Z [Sink: Print to Std. Out (1/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (1/4)
(6982b1cd1147229d264344ec41df12a9) switched from DEPLOYING to RUNNING.
2019-04-23T09:33:50.967Z [Sink: Print to Std. Out (1/4)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
2019-04-23T09:33:50.967Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (1/4) (6982b1cd1147229d264344ec41df12a9) switched from DEPLOYING to RUNNING.
2019-04-23T09:33:50.968Z [Sink: Print to Std. Out (4/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network: Sink:
Print to Std. Out (4/4) (27df5777eb4ebd374f003634a00a7cd9) [DEPLOYING].
2019-04-23T09:33:50.969Z [Sink: Print to Std. Out (4/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (4/4)
(27df5777eb4ebd374f003634a00a7cd9) switched from DEPLOYING to RUNNING.
2019-04-23T09:33:50.969Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (4/4) (27df5777eb4ebd374f003634a00a7cd9) switched from DEPLOYING to RUNNING.
2019-04-23T09:33:50.969Z [Sink: Print to Std. Out (4/4)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
2019-04-23T09:33:51.028Z [Source: Collection Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Source: Collection Source (1/1)
(833716fb73726ad792a24c184d5312b2) switched from RUNNING to FAILED.
java.io.IOException: Failed to deserialize an element from the source. If you
are using user-defined serialization (Value and Writable types), check the
serialization functions.
Serializer is
org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer@466b6f83
at
org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:158)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:93)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)
at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:97)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
at java.lang.Thread.run(Thread.java:748)
2019-04-23T09:33:51.029Z [Source: Collection Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Source:
Collection Source (1/1) (833716fb73726ad792a24c184d5312b2).
2019-04-23T09:33:51.045Z [Source: Collection Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task Source: Collection Source (1/1)
(833716fb73726ad792a24c184d5312b2) [FAILED]
2019-04-23T09:33:51.059Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to JobManager for task Source: Collection
Source 833716fb73726ad792a24c184d5312b2.
2019-04-23T09:33:51.064Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Collection
Source (1/1) (833716fb73726ad792a24c184d5312b2) switched from RUNNING to FAILED.
java.io.IOException: Failed to deserialize an element from the source. If you
are using user-defined serialization (Value and Writable types), check the
serialization functions.
Serializer is
org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer@466b6f83
at
org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:158)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:93)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)
at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:97)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
at java.lang.Thread.run(Thread.java:748)
2019-04-23T09:33:51.064Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Flink Streaming
Job (0934b4e32657180f004df5cf4e003ab4) switched from state RUNNING to FAILING.
java.io.IOException: Failed to deserialize an element from the source. If you
are using user-defined serialization (Value and Writable types), check the
serialization functions.
Serializer is
org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer@466b6f83
at
org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:158)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:93)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)
at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:97)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
at java.lang.Thread.run(Thread.java:748)
2019-04-23T09:33:51.065Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (1/4) (6982b1cd1147229d264344ec41df12a9) switched from RUNNING to CANCELING.
2019-04-23T09:33:51.066Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Discarding the results
produced by task execution 833716fb73726ad792a24c184d5312b2.
2019-04-23T09:33:51.066Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Sink:
Print to Std. Out (1/4) (6982b1cd1147229d264344ec41df12a9).
2019-04-23T09:33:51.066Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (1/4)
(6982b1cd1147229d264344ec41df12a9) switched from RUNNING to CANCELING.
2019-04-23T09:33:51.066Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task
code Sink: Print to Std. Out (1/4) (6982b1cd1147229d264344ec41df12a9).
2019-04-23T09:33:51.068Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (2/4) (fcccdf96f9411000517ecc55b620f125) switched from RUNNING to CANCELING.
2019-04-23T09:33:51.069Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (3/4) (09fdc88b7fe9efe5eeb0d30327eb8c93) switched from RUNNING to CANCELING.
2019-04-23T09:33:51.072Z [Sink: Print to Std. Out (1/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (1/4)
(6982b1cd1147229d264344ec41df12a9) switched from CANCELING to CANCELED.
2019-04-23T09:33:51.073Z [Sink: Print to Std. Out (1/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Sink:
Print to Std. Out (1/4) (6982b1cd1147229d264344ec41df12a9).
2019-04-23T09:33:51.073Z [Sink: Print to Std. Out (1/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task Sink: Print to Std. Out (1/4)
(6982b1cd1147229d264344ec41df12a9) [CANCELED]
2019-04-23T09:33:51.075Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (4/4) (27df5777eb4ebd374f003634a00a7cd9) switched from RUNNING to CANCELING.
2019-04-23T09:33:51.081Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Sink:
Print to Std. Out (2/4) (fcccdf96f9411000517ecc55b620f125).
2019-04-23T09:33:51.082Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (2/4)
(fcccdf96f9411000517ecc55b620f125) switched from RUNNING to CANCELING.
2019-04-23T09:33:51.082Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task
code Sink: Print to Std. Out (2/4) (fcccdf96f9411000517ecc55b620f125).
2019-04-23T09:33:51.084Z [Sink: Print to Std. Out (2/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (2/4)
(fcccdf96f9411000517ecc55b620f125) switched from CANCELING to CANCELED.
2019-04-23T09:33:51.084Z [Sink: Print to Std. Out (2/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Sink:
Print to Std. Out (2/4) (fcccdf96f9411000517ecc55b620f125).
2019-04-23T09:33:51.085Z [Sink: Print to Std. Out (2/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task Sink: Print to Std. Out (2/4)
(fcccdf96f9411000517ecc55b620f125) [CANCELED]
2019-04-23T09:33:51.084Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state CANCELED to JobManager for task Sink: Print to
Std. Out 6982b1cd1147229d264344ec41df12a9.
2019-04-23T09:33:51.087Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Sink:
Print to Std. Out (3/4) (09fdc88b7fe9efe5eeb0d30327eb8c93).
2019-04-23T09:33:51.088Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (3/4)
(09fdc88b7fe9efe5eeb0d30327eb8c93) switched from RUNNING to CANCELING.
2019-04-23T09:33:51.088Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task
code Sink: Print to Std. Out (3/4) (09fdc88b7fe9efe5eeb0d30327eb8c93).
2019-04-23T09:33:51.089Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (1/4) (6982b1cd1147229d264344ec41df12a9) switched from CANCELING to
CANCELED.
2019-04-23T09:33:51.099Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Sink:
Print to Std. Out (4/4) (27df5777eb4ebd374f003634a00a7cd9).
2019-04-23T09:33:51.099Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (4/4)
(27df5777eb4ebd374f003634a00a7cd9) switched from RUNNING to CANCELING.
2019-04-23T09:33:51.100Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task
code Sink: Print to Std. Out (4/4) (27df5777eb4ebd374f003634a00a7cd9).
2019-04-23T09:33:51.100Z [Sink: Print to Std. Out (3/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (3/4)
(09fdc88b7fe9efe5eeb0d30327eb8c93) switched from CANCELING to CANCELED.
2019-04-23T09:33:51.100Z [Sink: Print to Std. Out (3/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Sink:
Print to Std. Out (3/4) (09fdc88b7fe9efe5eeb0d30327eb8c93).
2019-04-23T09:33:51.100Z [Sink: Print to Std. Out (3/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task Sink: Print to Std. Out (3/4)
(09fdc88b7fe9efe5eeb0d30327eb8c93) [CANCELED]
2019-04-23T09:33:51.103Z [Sink: Print to Std. Out (4/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Sink: Print to Std. Out (4/4)
(27df5777eb4ebd374f003634a00a7cd9) switched from CANCELING to CANCELED.
2019-04-23T09:33:51.103Z [Sink: Print to Std. Out (4/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Sink:
Print to Std. Out (4/4) (27df5777eb4ebd374f003634a00a7cd9).
2019-04-23T09:33:51.104Z [Sink: Print to Std. Out (4/4)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task Sink: Print to Std. Out (4/4)
(27df5777eb4ebd374f003634a00a7cd9) [CANCELED]
2019-04-23T09:33:51.106Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state CANCELED to JobManager for task Sink: Print to
Std. Out fcccdf96f9411000517ecc55b620f125.
2019-04-23T09:33:51.107Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state CANCELED to JobManager for task Sink: Print to
Std. Out 09fdc88b7fe9efe5eeb0d30327eb8c93.
2019-04-23T09:33:51.108Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (2/4) (fcccdf96f9411000517ecc55b620f125) switched from CANCELING to
CANCELED.
2019-04-23T09:33:51.109Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (3/4) (09fdc88b7fe9efe5eeb0d30327eb8c93) switched from CANCELING to
CANCELED.
2019-04-23T09:33:51.112Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state CANCELED to JobManager for task Sink: Print to
Std. Out 27df5777eb4ebd374f003634a00a7cd9.
2019-04-23T09:33:51.113Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std.
Out (4/4) (27df5777eb4ebd374f003634a00a7cd9) switched from CANCELING to
CANCELED.
2019-04-23T09:33:51.114Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Try to restart or fail
the job Flink Streaming Job (0934b4e32657180f004df5cf4e003ab4) if no longer
possible.
2019-04-23T09:33:51.114Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Flink Streaming
Job (0934b4e32657180f004df5cf4e003ab4) switched from state FAILING to FAILED.
java.io.IOException: Failed to deserialize an element from the source. If you
are using user-defined serialization (Value and Writable types), check the
serialization functions.
Serializer is
org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer@466b6f83
at
org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:158)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:93)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)
at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:97)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
at java.lang.Thread.run(Thread.java:748)
2019-04-23T09:33:51.114Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Could not restart the
job Flink Streaming Job (0934b4e32657180f004df5cf4e003ab4) because the restart
strategy prevented it.
java.io.IOException: Failed to deserialize an element from the source. If you
are using user-defined serialization (Value and Writable types), check the
serialization functions.
Serializer is
org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer@466b6f83
at
org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:158)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:93)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)
at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:97)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
at java.lang.Thread.run(Thread.java:748)
2019-04-23T09:33:51.114Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job 0934b4e32657180f004df5cf4e003ab4.
2019-04-23T09:33:51.114Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
2019-04-23T09:33:51.124Z [main] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
2019-04-23T09:33:51.124Z [main] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
2019-04-23T09:33:51.124Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
0934b4e32657180f004df5cf4e003ab4 reached globally terminal state FAILED.
2019-04-23T09:33:51.124Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_0.
2019-04-23T09:33:51.125Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
2019-04-23T09:33:51.128Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
2019-04-23T09:33:51.136Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
Flink Streaming Job(0934b4e32657180f004df5cf4e003ab4).
2019-04-23T09:33:51.137Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Suspending SlotPool.
2019-04-23T09:33:51.137Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
a7d3b0f5395dbabb2f7c22f3c62765c1: JobManager is shutting down..
2019-04-23T09:33:51.137Z [flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Stopping SlotPool.
2019-04-23T09:33:51.137Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager 856d27e694574e2fed72f40ea4164efc@akka://flink/user/jobmanager_1 for
job 0934b4e32657180f004df5cf4e003ab4 from the resource manager.
2019-04-23T09:33:51.149Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-f952881a-df88-4b6f-84fe-1e83412f120b
2019-04-23T09:33:51.150Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
2019-04-23T09:33:51.154Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
2019-04-23T09:33:51.154Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.filecache.FileCache - removed file cache directory
/tmp/flink-dist-cache-da57d8de-8359-4f8b-838d-88094398b7cd
2019-04-23T09:33:51.154Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_0.
2019-04-23T09:33:51.156Z [ForkJoinPool.commonPool-worker-1] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
2019-04-23T09:33:51.156Z [ForkJoinPool.commonPool-worker-1] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down complete.
2019-04-23T09:33:51.159Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Shut down
cluster because application is in CANCELED, diagnostics
DispatcherResourceManagerComponent has been closed..
2019-04-23T09:33:51.160Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher.
2019-04-23T09:33:51.160Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
2019-04-23T09:33:51.160Z [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
2019-04-23T09:33:51.160Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher akka://flink/user/dispatcher.
2019-04-23T09:33:51.161Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
2019-04-23T09:33:51.161Z [flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher.
2019-04-23T09:33:51.171Z [flink-metrics-2] INFO
akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote
daemon.
2019-04-23T09:33:51.172Z [flink-metrics-2] INFO
akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut
down; proceeding with flushing remote transports.
2019-04-23T09:33:51.191Z [flink-metrics-2] INFO
akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
2019-04-23T09:33:51.206Z [flink-metrics-2] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
2019-04-23T09:33:51.223Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
2019-04-23T09:33:51.223Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
2019-04-23T09:33:51.223Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:40817
2019-04-23T09:33:51.223Z [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
Exception in thread "main"
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:146)
at
org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:638)
at
org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:123)
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1509)
at
org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.scala:645)
at
com.example.valueclassissue.ValueClassExample$.delayedEndpoint$com$gotomeeting$xqm$streamprocessor$ValueClassExample$1(ValueClassExample.scala:11)
at
com.example.valueclassissue.ValueClassExample$delayedInit$body.apply(ValueClassExample.scala:5)
at scala.Function0$class.apply$mcV$sp(Function0.scala:34)
at
scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)
at scala.App$$anonfun$main$1.apply(App.scala:76)
at scala.App$$anonfun$main$1.apply(App.scala:76)
at scala.collection.immutable.List.foreach(List.scala:392)
at
scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:35)
at scala.App$class.main(App.scala:76)
at
com.example.valueclassissue.ValueClassExample$.main(ValueClassExample.scala:5)
at
com.example.valueclassissue.ValueClassExample.main(ValueClassExample.scala)
Caused by: java.io.IOException: Failed to deserialize an element from the
source. If you are using user-defined serialization (Value and Writable types),
check the serialization functions.
Serializer is
org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer@466b6f83
at
org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:158)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:93)
at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)
at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:97)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
at java.lang.Thread.run(Thread.java:748)
{noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
