Attached log file. (Log level : Trace)

Is this the issue ? Trying with very minimal graph (execution plan is
printed in log file)

WARN  akka.remote.transport.netty.NettyTransport                    -
Remote connection to [/127.0.0.1:44322] failed with
org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException:
Adjusted frame length exceeds 10485760: 1195725860 - discarded

On Wed, Jul 11, 2018 at 5:44 PM Chesnay Schepler <[EMAIL PROTECTED]> wrote:
1876 - class com.adaequare.etl2.batch.operator.EntityType does not contain a setter for field targetEntity
11 Jul 2018 17:49:08.583 [main] INFO  org.apache.flink.api.java.typeutils.TypeExtractor.analyzePojo
1915 - Class class com.adaequare.etl2.batch.operator.EntityType 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.
11 Jul 2018 17:49:09.027 [main] DEBUG org.apache.flink.api.java.ClosureCleaner.cleanThis0
120 - this$0 is accessed: false
11 Jul 2018 17:49:09.065 [main] INFO  org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan
999 - The job has 2 registered types and 0 default Kryo serializers
11 Jul 2018 17:49:09.068 [main] DEBUG org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan
1012 - Registered Kryo types: [class com.adaequare.etl2.batch.operator.EntityType, interface java.util.List]
11 Jul 2018 17:49:09.068 [main] DEBUG org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan
1013 - Registered Kryo with Serializers types: []
11 Jul 2018 17:49:09.069 [main] DEBUG org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan
1014 - Registered Kryo with Serializer Classes types: []
11 Jul 2018 17:49:09.069 [main] DEBUG org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan
1015 - Registered Kryo default Serializers: []
11 Jul 2018 17:49:09.070 [main] DEBUG org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan
1016 - Registered Kryo default Serializers Classes []
11 Jul 2018 17:49:09.070 [main] DEBUG org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan
1017 - Registered POJO types: []
11 Jul 2018 17:49:09.072 [main] DEBUG org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan
1020 - Static code analysis mode: DISABLE
11 Jul 2018 17:49:09.085 [main] DEBUG org.apache.flink.optimizer.Optimizer.compile
433 - Beginning compilation of program 'plan'
11 Jul 2018 17:49:09.095 [main] DEBUG org.apache.flink.optimizer.Optimizer.compile
442 - Using a default parallelism of 4
11 Jul 2018 17:49:09.095 [main] DEBUG org.apache.flink.optimizer.Optimizer.compile
443 - Using default data exchange mode PIPELINED
11 Jul 2018 17:49:09.120 [main] DEBUG org.apache.flink.core.fs.FileSystem.loadFileSystems
937 - Loading extension file systems via services
11 Jul 2018 17:49:09.124 [main] INFO  org.apache.flink.core.fs.FileSystem.loadHadoopFsFactory
1005 - Hadoop is not in the classpath/dependencies. The extended set of supported File Systems via Hadoop is not available.
11 Jul 2018 17:49:09.136 [main] DEBUG org.apache.flink.api.common.io.FileInputFormat.open
810 - Opening input split file:/tmp/stream2file8333235519400351128.tmp [0,42]
11 Jul 2018 17:49:09.150 [main] DEBUG org.apache.flink.api.common.io.FileInputFormat.open
810 - Opening input split file:/tmp/stream2file8333235519400351128.tmp [21,21]
{
"nodes": [

{
"id": 2,
"type": "source",
"pact": "Data Source",
"contents": "at readFile(ExecutionEnvironment.java:515) (com.adaequare.etl2.batch.operator.EntityCsvInputFormat)",
"parallelism": "4",
"global_properties": [
{ "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
{ "name": "Partitioning Order", "value": "(none)" },
{ "name": "Uniqueness", "value": "not unique" }
],
"local_properties": [
{ "name": "Order", "value": "(none)" },
{ "name": "Grouping", "value": "not grouped" },
{ "name": "Uniqueness", "value": "not unique" }
],
"estimates": [
{ "name": "Est. Output Size", "value": "42.00" },
{ "name": "Est. Cardinality", "value": "3.00" } ],
"costs": [
{ "name": "Network", "value": "0.0" },
{ "name": "Disk I/O", "value": "42.00" },
{ "name": "CPU", "value": "0.0" },
{ "name": "Cumulative Network", "value": "0.0" },
{ "name": "Cumulative Disk I/O", "value": "42.00" },
{ "name": "Cumulative CPU", "value": "0.0" }
],
"compiler_hints": [
{ "name": "Output Size (bytes)", "value": "(none)" },
{ "name": "Output Cardinality", "value": "(none)" },
{ "name": "Avg. Output Record Size (bytes)", "value": "(none)" },
{ "name": "Filter Factor", "value": "(none)" } ]
},
{
"id": 1,
"type": "pact",
"pact": "Map",
"contents": "Map at lambda$configure$0(MapOperator.java:21)",
"parallelism": "4",
"predecessors": [
{"id": 2, "ship_strategy": "Forward", "exchange_mode": "PIPELINED"}
],
"driver_strategy": "Map",
"global_properties": [
{ "name": "Partitioning", "value": "RANDOM_PARTITIONED" },
{ "name": "Partitioning Order", "value": "(none)" },
{ "name": "Uniqueness", "value": "not uni
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB