Ask Your Question

Revision history [back]

click to hide/show revision 1
initial version

Platform events processing

I'm having and issue with Salesforce platform events. I configured a new Origin (Salesforce) with a platform event - this event contains just firstname and lastname of Contact object. When I start the pipeline and change Contact object in Salesforce I get Java exception: java.lang.NumberFormatException: For input string: "2018-06-04T08:53:07Z". This date is CreatedDate of the platform event

Platform events processing

I'm having and issue with Salesforce platform events. I configured a new Origin (Salesforce) with a platform event - this event contains just firstname and lastname of Contact object. When I start the pipeline and change Contact object in Salesforce I get Java exception: java.lang.NumberFormatException: For input string: "2018-06-04T08:53:07Z". This date is CreatedDate of the platform event

Platform events processing

I'm having and issue with Salesforce platform events. I configured a new Origin (Salesforce) with a platform event - this event contains just firstname and lastname of Contact object. When I start the pipeline and change Contact object in Salesforce I get Java exception: java.lang.NumberFormatException: For input string: "2018-06-04T08:53:07Z". 2018-06-04T08:53:07Z. This date is CreatedDate CreatedDate of the platform eventevent.

This is the full stack trace:

java.lang.NumberFormatException: For input string: "2018-06-05T06:58:56Z" at 
java.lang.NumberFormatException.forInputString(NumberFormatException.java:65) at 
java.lang.Long.parseLong(Long.java:589) at 
java.lang.Long.parseLong(Long.java:631) at 
com.streamsets.pipeline.api.impl.LongTypeSupport.convert(LongTypeSupport.java:30) at 
com.streamsets.pipeline.api.impl.LongTypeSupport.convert(LongTypeSupport.java:22) at 
com.streamsets.pipeline.api.Field$Type.convert(Field.java:112) at 
com.streamsets.pipeline.api.Field$Type.access$100(Field.java:82) at 
com.streamsets.pipeline.api.Field.create(Field.java:433) at 
com.streamsets.pipeline.api.Field.create(Field.java:417) at 
com.streamsets.pipeline.lib.salesforce.PlatformEventRecordCreator.createField(PlatformEventRecordCreator.java:146) at 
com.streamsets.pipeline.lib.salesforce.PlatformEventRecordCreator.createField(PlatformEventRecordCreator.java:134) at 
com.streamsets.pipeline.lib.salesforce.PlatformEventRecordCreator.createRecord(PlatformEventRecordCreator.java:122) at 
com.streamsets.pipeline.stage.origin.salesforce.ForceSource.processDataMessage(ForceSource.java:802) at 
com.streamsets.pipeline.stage.origin.salesforce.ForceSource.streamingProduce(ForceSource.java:875) at 
com.streamsets.pipeline.stage.origin.salesforce.ForceSource.produce(ForceSource.java:424) at 
com.streamsets.pipeline.api.base.configurablestage.DSource.produce(DSource.java:38) at 
com.streamsets.datacollector.runner.StageRuntime.lambda$execute$2(StageRuntime.java:242) at 
com.streamsets.pipeline.api.impl.CreateByRef.call(CreateByRef.java:40) at 
com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:195) at 
com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:257) at 
com.streamsets.datacollector.runner.StagePipe.process(StagePipe.java:219) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.processPipe(ProductionPipelineRunner.java:801) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.runPollSource(ProductionPipelineRunner.java:548) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.run(ProductionPipelineRunner.java:383) at 
com.streamsets.datacollector.runner.Pipeline.run(Pipeline.java:512) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipeline.run(ProductionPipeline.java:112) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunnable.run(ProductionPipelineRunnable.java:74) at 
com.streamsets.datacollector.execution.runner.standalone.StandaloneRunner.start(StandaloneRunner.java:756) at 
com.streamsets.datacollector.execution.runner.common.AsyncRunner.lambda$start$3(AsyncRunner.java:152) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.lambda$call$0(SafeScheduledExecutorService.java:226) at 
com.streamsets.datacollector.security.GroupsInScope.execute(GroupsInScope.java:33) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.call(SafeScheduledExecutorService.java:222) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.lambda$call$0(SafeScheduledExecutorService.java:226) at 
com.streamsets.datacollector.security.GroupsInScope.execute(GroupsInScope.java:33) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.call(SafeScheduledExecutorService.java:222) at 
java.util.concurrent.FutureTask.run(FutureTask.java:266) at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at 
com.streamsets.datacollector.metrics.MetricSafeScheduledExecutorService$MetricsTask.run(MetricSafeScheduledExecutorService.java:100) at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at 
java.lang.Thread.run(Thread.java:748)

Platform events processing

I'm having and issue with Salesforce platform events. I configured a new Origin (Salesforce) with a platform event - this event contains just firstname and lastname of Contact object. When I start the pipeline and change Contact object in Salesforce I get Java exception: java.lang.NumberFormatException: For input string: 2018-06-04T08:53:07Z. This date is CreatedDate of the platform event.

This is the full stack trace:

java.lang.NumberFormatException: For input string: "2018-06-05T06:58:56Z" at 
java.lang.NumberFormatException.forInputString(NumberFormatException.java:65) at 
java.lang.Long.parseLong(Long.java:589) at 
java.lang.Long.parseLong(Long.java:631) at 
com.streamsets.pipeline.api.impl.LongTypeSupport.convert(LongTypeSupport.java:30) at 
com.streamsets.pipeline.api.impl.LongTypeSupport.convert(LongTypeSupport.java:22) at 
com.streamsets.pipeline.api.Field$Type.convert(Field.java:112) at 
com.streamsets.pipeline.api.Field$Type.access$100(Field.java:82) at 
com.streamsets.pipeline.api.Field.create(Field.java:433) at 
com.streamsets.pipeline.api.Field.create(Field.java:417) at 
com.streamsets.pipeline.lib.salesforce.PlatformEventRecordCreator.createField(PlatformEventRecordCreator.java:146) at 
com.streamsets.pipeline.lib.salesforce.PlatformEventRecordCreator.createField(PlatformEventRecordCreator.java:134) at 
com.streamsets.pipeline.lib.salesforce.PlatformEventRecordCreator.createRecord(PlatformEventRecordCreator.java:122) at 
com.streamsets.pipeline.stage.origin.salesforce.ForceSource.processDataMessage(ForceSource.java:802) at 
com.streamsets.pipeline.stage.origin.salesforce.ForceSource.streamingProduce(ForceSource.java:875) at 
com.streamsets.pipeline.stage.origin.salesforce.ForceSource.produce(ForceSource.java:424) at 
com.streamsets.pipeline.api.base.configurablestage.DSource.produce(DSource.java:38) at 
com.streamsets.datacollector.runner.StageRuntime.lambda$execute$2(StageRuntime.java:242) at 
com.streamsets.pipeline.api.impl.CreateByRef.call(CreateByRef.java:40) at 
com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:195) at 
com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:257) at 
com.streamsets.datacollector.runner.StagePipe.process(StagePipe.java:219) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.processPipe(ProductionPipelineRunner.java:801) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.runPollSource(ProductionPipelineRunner.java:548) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.run(ProductionPipelineRunner.java:383) at 
com.streamsets.datacollector.runner.Pipeline.run(Pipeline.java:512) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipeline.run(ProductionPipeline.java:112) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunnable.run(ProductionPipelineRunnable.java:74) at 
com.streamsets.datacollector.execution.runner.standalone.StandaloneRunner.start(StandaloneRunner.java:756) at 
com.streamsets.datacollector.execution.runner.common.AsyncRunner.lambda$start$3(AsyncRunner.java:152) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.lambda$call$0(SafeScheduledExecutorService.java:226) at 
com.streamsets.datacollector.security.GroupsInScope.execute(GroupsInScope.java:33) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.call(SafeScheduledExecutorService.java:222) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.lambda$call$0(SafeScheduledExecutorService.java:226) at 
com.streamsets.datacollector.security.GroupsInScope.execute(GroupsInScope.java:33) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.call(SafeScheduledExecutorService.java:222) at 
java.util.concurrent.FutureTask.run(FutureTask.java:266) at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at 
com.streamsets.datacollector.metrics.MetricSafeScheduledExecutorService$MetricsTask.run(MetricSafeScheduledExecutorService.java:100) at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at 
java.lang.Thread.run(Thread.java:748)

Exception in Salesforce Platform events Event processing

I'm having and an issue with Salesforce platform events. Platform Events. I configured a new Origin (Salesforce) with a platform event - this event contains just firstname firstname and lastname lastname of Contact Contact object. When I start the pipeline and change Contact object in Salesforce I get Java exception: java.lang.NumberFormatException: For input string: 2018-06-04T08:53:07Z"2018-06-04T08:53:07Z". This date is CreatedDate of the platform event.

This is the full stack trace:

java.lang.NumberFormatException: For input string: "2018-06-05T06:58:56Z" at 
java.lang.NumberFormatException.forInputString(NumberFormatException.java:65) at 
java.lang.Long.parseLong(Long.java:589) at 
java.lang.Long.parseLong(Long.java:631) at 
com.streamsets.pipeline.api.impl.LongTypeSupport.convert(LongTypeSupport.java:30) at 
com.streamsets.pipeline.api.impl.LongTypeSupport.convert(LongTypeSupport.java:22) at 
com.streamsets.pipeline.api.Field$Type.convert(Field.java:112) at 
com.streamsets.pipeline.api.Field$Type.access$100(Field.java:82) at 
com.streamsets.pipeline.api.Field.create(Field.java:433) at 
com.streamsets.pipeline.api.Field.create(Field.java:417) at 
com.streamsets.pipeline.lib.salesforce.PlatformEventRecordCreator.createField(PlatformEventRecordCreator.java:146) at 
com.streamsets.pipeline.lib.salesforce.PlatformEventRecordCreator.createField(PlatformEventRecordCreator.java:134) at 
com.streamsets.pipeline.lib.salesforce.PlatformEventRecordCreator.createRecord(PlatformEventRecordCreator.java:122) at 
com.streamsets.pipeline.stage.origin.salesforce.ForceSource.processDataMessage(ForceSource.java:802) at 
com.streamsets.pipeline.stage.origin.salesforce.ForceSource.streamingProduce(ForceSource.java:875) at 
com.streamsets.pipeline.stage.origin.salesforce.ForceSource.produce(ForceSource.java:424) at 
com.streamsets.pipeline.api.base.configurablestage.DSource.produce(DSource.java:38) at 
com.streamsets.datacollector.runner.StageRuntime.lambda$execute$2(StageRuntime.java:242) at 
com.streamsets.pipeline.api.impl.CreateByRef.call(CreateByRef.java:40) at 
com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:195) at 
com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:257) at 
com.streamsets.datacollector.runner.StagePipe.process(StagePipe.java:219) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.processPipe(ProductionPipelineRunner.java:801) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.runPollSource(ProductionPipelineRunner.java:548) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.run(ProductionPipelineRunner.java:383) at 
com.streamsets.datacollector.runner.Pipeline.run(Pipeline.java:512) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipeline.run(ProductionPipeline.java:112) at 
com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunnable.run(ProductionPipelineRunnable.java:74) at 
com.streamsets.datacollector.execution.runner.standalone.StandaloneRunner.start(StandaloneRunner.java:756) at 
com.streamsets.datacollector.execution.runner.common.AsyncRunner.lambda$start$3(AsyncRunner.java:152) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.lambda$call$0(SafeScheduledExecutorService.java:226) at 
com.streamsets.datacollector.security.GroupsInScope.execute(GroupsInScope.java:33) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.call(SafeScheduledExecutorService.java:222) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.lambda$call$0(SafeScheduledExecutorService.java:226) at 
com.streamsets.datacollector.security.GroupsInScope.execute(GroupsInScope.java:33) at 
com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.call(SafeScheduledExecutorService.java:222) at 
java.util.concurrent.FutureTask.run(FutureTask.java:266) at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at 
com.streamsets.datacollector.metrics.MetricSafeScheduledExecutorService$MetricsTask.run(MetricSafeScheduledExecutorService.java:100) at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at 
java.lang.Thread.run(Thread.java:748)