Application is master is killing the container after it attempts to start the jdbc output operator.
other 2 ports works perfectly fine but jdbcoutput port does not insert data into mysql. I am very new to datatorrent. Kindly help to resolve this issue.
2016-06-17 22:43:21,675 INFO com.datatorrent.stram.StreamingAppMaster: Initializing Application Master.
2016-06-17 22:43:21,700 INFO com.datatorrent.stram.StreamingAppMasterService: Application master, appId=31, clustertimestamp=1466184165614, attemptId=1
2016-06-17 22:43:23,193 INFO com.datatorrent.common.util.AsyncFSStorageAgent: using /mnt1/yarn/usercache/hadoop/appcache/application_1466184165614_0031/container_1466184165614_0031_01_000001/tmp/chkp3415494973576947394 as the basepath for checkpointing.
2016-06-17 22:43:23,835 INFO com.datatorrent.stram.FSEventRecorder: Number of subscribers is now 1
2016-06-17 22:43:24,498 INFO com.datatorrent.stram.FSRecoveryHandler: Creating hdfs://ip-172-30-2-34.us-west-1.compute.internal:8020/user/hadoop/datatorrent/apps/application_1466184165614_0031/recovery/log
2016-06-17 22:43:24,546 INFO com.datatorrent.stram.StreamingAppMasterService: Starting application with 3 operators in 3 containers
2016-06-17 22:43:24,559 INFO org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl: Upper bound of the thread pool size is 500
2016-06-17 22:43:24,561 INFO org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy: yarn.client.max-cached-nodemanagers-proxies : 0
2016-06-17 22:43:24,578 INFO org.apache.hadoop.yarn.client.RMProxy: Connecting to ResourceManager at ip-172-30-2-34.us-west-1.compute.internal/172.30.2.34:8030
2016-06-17 22:43:24,612 INFO com.datatorrent.stram.StreamingContainerParent: Config: Configuration: core-default.xml, core-site.xml, yarn-default.xml, yarn-site.xml, mapred-default.xml, mapred-site.xml, hdfs-default.xml, hdfs-site.xml
2016-06-17 22:43:24,612 INFO com.datatorrent.stram.StreamingContainerParent: Listener thread count 30
2016-06-17 22:43:24,618 INFO org.apache.hadoop.ipc.CallQueueManager: Using callQueue class java.util.concurrent.LinkedBlockingQueue
2016-06-17 22:43:24,621 INFO org.apache.hadoop.ipc.Server: Starting Socket Reader #1 for port 34676
2016-06-17 22:43:24,634 INFO org.apache.hadoop.ipc.Server: IPC Server Responder: starting
2016-06-17 22:43:24,634 INFO org.apache.hadoop.ipc.Server: IPC Server listener on 34676: starting
2016-06-17 22:43:24,640 INFO com.datatorrent.stram.StreamingContainerParent: Container callback server listening at ip-172-30-2-67/172.30.2.67:34676
2016-06-17 22:43:24,661 INFO org.mortbay.log: Logging to org.slf4j.impl.Log4jLoggerAdapter(org.mortbay.log) via org.mortbay.log.Slf4jLog
2016-06-17 22:43:24,747 INFO org.apache.hadoop.security.authentication.server.AuthenticationFilter: Unable to initialize FileSignerSecretProvider, falling back to use random secrets.
2016-06-17 22:43:24,775 INFO org.apache.hadoop.http.HttpRequestLog: Http request log for http.requests.stram is not defined
2016-06-17 22:43:24,782 INFO org.apache.hadoop.http.HttpServer2: Added global filter 'safety' (class=org.apache.hadoop.http.HttpServer2$QuotingInputFilter)
2016-06-17 22:43:24,784 INFO org.apache.hadoop.http.HttpServer2: Added filter static_user_filter (class=org.apache.hadoop.http.lib.StaticUserWebFilter$StaticUserFilter) to context stram
2016-06-17 22:43:24,784 INFO org.apache.hadoop.http.HttpServer2: Added filter static_user_filter (class=org.apache.hadoop.http.lib.StaticUserWebFilter$StaticUserFilter) to context logs
2016-06-17 22:43:24,784 INFO org.apache.hadoop.http.HttpServer2: Added filter static_user_filter (class=org.apache.hadoop.http.lib.StaticUserWebFilter$StaticUserFilter) to context static
2016-06-17 22:43:24,787 INFO org.apache.hadoop.http.HttpServer2: adding path spec: /stram/*
2016-06-17 22:43:24,787 INFO org.apache.hadoop.http.HttpServer2: adding path spec: /ws/*
2016-06-17 22:43:25,109 INFO org.apache.hadoop.yarn.webapp.WebApps: Registered webapp guice modules
2016-06-17 22:43:25,109 INFO org.apache.hadoop.http.HttpServer2: Jetty bound to port 44656
2016-06-17 22:43:32,585 WARN com.datatorrent.stram.webapp.TypeGraphFactory: The size of precomputed type graph is 6307 KB
2016-06-17 22:43:32,981 INFO org.apache.hadoop.yarn.webapp.WebApps: Web app stram started at 44656
2016-06-17 22:43:32,982 INFO com.datatorrent.stram.StreamingAppMasterService: Started web service at port: 44656
2016-06-17 22:43:32,982 INFO com.datatorrent.stram.StreamingAppMasterService: Setting tracking URL to: ip-172-30-2-67:44656
2016-06-17 22:43:32,991 INFO com.datatorrent.stram.StreamingAppMasterService: Starting ApplicationMaster
2016-06-17 22:43:32,992 INFO com.datatorrent.stram.StreamingAppMasterService: number of tokens: 1
2016-06-17 22:43:33,038 INFO com.datatorrent.stram.StreamingAppMasterService: Max mem 11520m, Min mem 32m, Max vcores 80 and Min vcores 1 capabililty of resources in this cluster
2016-06-17 22:43:33,043 INFO org.apache.hadoop.yarn.client.RMProxy: Connecting to ResourceManager at ip-172-30-2-34.us-west-1.compute.internal/172.30.2.34:8032
2016-06-17 22:43:33,258 INFO com.datatorrent.stram.ResourceRequestHandler: Node report: rackName=/default-rack,nodeid=ip-172-30-2-67.us-west-1.compute.internal:8041,numContainers=1,capability=<memory:11520, vCores:8>used=<memory:1024, vCores:1>state=RUNNING
2016-06-17 22:43:33,258 INFO com.datatorrent.stram.ResourceRequestHandler: Node report: rackName=/default-rack,nodeid=ip-172-30-2-68.us-west-1.compute.internal:8041,numContainers=0,capability=<memory:11520, vCores:8>used=<memory:0, vCores:0>state=RUNNING
2016-06-17 22:43:33,972 WARN com.datatorrent.stram.StreamingContainerManager: DEBUG: looking at operator Counter 85
2016-06-17 22:43:33,972 WARN com.datatorrent.stram.StreamingContainerManager: DEBUG: looking at port OutputCounter 85
2016-06-17 22:43:33,972 WARN com.datatorrent.stram.StreamingContainerManager: DEBUG: looking at operator Input 85
2016-06-17 22:43:33,972 WARN com.datatorrent.stram.StreamingContainerManager: DEBUG: looking at port outputPort 85
2016-06-17 22:43:33,972 WARN com.datatorrent.stram.StreamingContainerManager: DEBUG: looking at operator OutPut 85
2016-06-17 22:43:34,070 INFO com.datatorrent.stram.FSEventRecorder: Number of subscribers is now 0
2016-06-17 22:43:34,188 ERROR com.datatorrent.stram.codec.LogicalPlanSerializer: Got exception when trying to get properties for operator OutPut
org.codehaus.jackson.map.JsonMappingException: (was java.lang.NullPointerException) (through reference chain: com.mycompany.test.jdbcOutput["store"]->com.datatorrent.lib.db.jdbc.JdbcTransactionalStore["connected"])
at org.codehaus.jackson.map.JsonMappingException.wrapWithPath(JsonMappingException.java:218)
at org.codehaus.jackson.map.JsonMappingException.wrapWithPath(JsonMappingException.java:183)
at org.codehaus.jackson.map.ser.std.SerializerBase.wrapAndThrow(SerializerBase.java:140)
at org.codehaus.jackson.map.ser.std.BeanSerializerBase.serializeFields(BeanSerializerBase.java:158)
at org.codehaus.jackson.map.ser.std.BeanSerializerBase.serializeWithType(BeanSerializerBase.java:125)
at org.codehaus.jackson.map.ser.BeanPropertyWriter.serializeAsField(BeanPropertyWriter.java:448)
at org.codehaus.jackson.map.ser.std.BeanSerializerBase.serializeFields(BeanSerializerBase.java:150)
at org.codehaus.jackson.map.ser.std.BeanSerializerBase.serializeWithType(BeanSerializerBase.java:125)
at org.codehaus.jackson.map.ser.StdSerializerProvider$WrappedSerializer.serialize(StdSerializerProvider.java:835)
at org.codehaus.jackson.map.ser.StdSerializerProvider._serializeValue(StdSerializerProvider.java:610)
at org.codehaus.jackson.map.ser.StdSerializerProvider.serializeValue(StdSerializerProvider.java:256)
at org.codehaus.jackson.map.ObjectMapper._configAndWriteValue(ObjectMapper.java:2566)
at org.codehaus.jackson.map.ObjectMapper.writeValueAsString(ObjectMapper.java:2088)
at com.datatorrent.stram.codec.LogicalPlanSerializer.convertToMap(LogicalPlanSerializer.java:138)
at com.datatorrent.stram.webapp.StramWebServices.getLogicalPlan(StramWebServices.java:843)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.sun.jersey.spi.container.JavaMethodInvokerFactory$1.invoke(JavaMethodInvokerFactory.java:60)
at com.sun.jersey.server.impl.model.method.dispatch.AbstractResourceMethodDispatchProvider$TypeOutInvoker._dispatch(AbstractResourceMethodDispatchProvider.java:185)
at com.sun.jersey.server.impl.model.method.dispatch.ResourceJavaMethodDispatcher.dispatch(ResourceJavaMethodDispatcher.java:75)
at com.sun.jersey.server.impl.uri.rules.HttpMethodRule.accept(HttpMethodRule.java:288)
at com.sun.jersey.server.impl.uri.rules.RightHandPathRule.accept(RightHandPathRule.java:147)
at com.sun.jersey.server.impl.uri.rules.ResourceClassRule.accept(ResourceClassRule.java:108)
at com.sun.jersey.server.impl.uri.rules.RightHandPathRule.accept(RightHandPathRule.java:147)
at com.sun.jersey.server.impl.uri.rules.RootResourceClassesRule.accept(RootResourceClassesRule.java:84)
at com.sun.jersey.server.impl.application.WebApplicationImpl._handleRequest(WebApplicationImpl.java:1469)
at com.sun.jersey.server.impl.application.WebApplicationImpl._handleRequest(WebApplicationImpl.java:1400)
at com.sun.jersey.server.impl.application.WebApplicationImpl.handleRequest(WebApplicationImpl.java:1349)
at com.sun.jersey.server.impl.application.WebApplicationImpl.handleRequest(WebApplicationImpl.java:1339)
at com.sun.jersey.spi.container.servlet.WebComponent.service(WebComponent.java:416)
at com.sun.jersey.spi.container.servlet.ServletContainer.service(ServletContainer.java:537)
at com.sun.jersey.spi.container.servlet.ServletContainer.doFilter(ServletContainer.java:886)
at com.sun.jersey.spi.container.servlet.ServletContainer.doFilter(ServletContainer.java:834)
at com.sun.jersey.spi.container.servlet.ServletContainer.doFilter(ServletContainer.java:795)
at com.google.inject.servlet.FilterDefinition.doFilter(FilterDefinition.java:163)
at com.google.inject.servlet.FilterChainInvocation.doFilter(FilterChainInvocation.java:58)
at com.google.inject.servlet.ManagedFilterPipeline.dispatch(ManagedFilterPipeline.java:118)
at com.google.inject.servlet.GuiceFilter.doFilter(GuiceFilter.java:113)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1212)
at org.apache.hadoop.http.lib.StaticUserWebFilter$StaticUserFilter.doFilter(StaticUserWebFilter.java:109)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1212)
at org.apache.hadoop.http.HttpServer2$QuotingInputFilter.doFilter(HttpServer2.java:1243)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1212)
at org.apache.hadoop.http.NoCacheFilter.doFilter(NoCacheFilter.java:45)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1212)
at org.apache.hadoop.http.NoCacheFilter.doFilter(NoCacheFilter.java:45)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1212)
at org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:399)
at org.mortbay.jetty.security.SecurityHandler.handle(SecurityHandler.java:216)
at org.mortbay.jetty.servlet.SessionHandler.handle(SessionHandler.java:182)
at org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:766)
at org.mortbay.jetty.webapp.WebAppContext.handle(WebAppContext.java:450)
at org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:230)
at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)
at org.mortbay.jetty.Server.handle(Server.java:326)
at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542)
at org.mortbay.jetty.HttpConnection$RequestHandler.headerComplete(HttpConnection.java:928)
at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:549)
at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:212)
at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404)
at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:410)
at org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582)
Caused by: java.lang.NullPointerException
at com.datatorrent.lib.db.jdbc.JdbcStore.isConnected(JdbcStore.java:189)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.codehaus.jackson.map.ser.BeanPropertyWriter.get(BeanPropertyWriter.java:483)
at org.codehaus.jackson.map.ser.BeanPropertyWriter.serializeAsField(BeanPropertyWriter.java:418)
at org.codehaus.jackson.map.ser.std.BeanSerializerBase.serializeFields(BeanSerializerBase.java:150)
... 60 more
Aucun commentaire:
Enregistrer un commentaire