search

snowplow / enrich

Snowplow Enrichment jobs and library
https://snowplowanalytics.com
Other
21 stars 38 forks source link

Common: catch exception with corrupt URI in MandrillAdapter #191

Open chuwy opened 4 years ago

chuwy commented 4 years ago 
Caused by: java.lang.IllegalArgumentException: Malformed escape pair at index 72648: http://localhost/?mandrill_events=...
    at java.net.URI.create(URI.java:859)
    at com.snowplowanalytics.snowplow.enrich.common.adapters.registry.MandrillAdapter$.payloadBodyToEvents(MandrillAdapter.scala:161)
    at com.snowplowanalytics.snowplow.enrich.common.adapters.registry.MandrillAdapter$.toRawEvents(MandrillAdapter.scala:110)
    at com.snowplowanalytics.snowplow.enrich.common.adapters.AdapterRegistry$.toRawEvents(AdapterRegistry.scala:75)
    at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1.apply(EtlPipeline.scala:78)
    at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1$$anonfun$apply$1.apply(EtlPipeline.scala:76)
    at scala.Option.map(Option.scala:145)
    at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1.apply(EtlPipeline.scala:76)
    at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$$anonfun$1.apply(EtlPipeline.scala:74)
    at scalaz.Validation$class.map(Validation.scala:114)
    at scalaz.Success.map(Validation.scala:329)
    at com.snowplowanalytics.snowplow.enrich.common.EtlPipeline$.processEvents(EtlPipeline.scala:74)
    at com.snowplowanalytics.snowplow.enrich.hadoop.EtlJob$$anonfun$7.apply(EtlJob.scala:172)
    at com.snowplowanalytics.snowplow.enrich.hadoop.EtlJob$$anonfun$7.apply(EtlJob.scala:171)
    at com.twitter.scalding.MapFunction.operate(Operations.scala:58)
    at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
chuwy commented 4 years ago

Migrated from https://github.com/snowplow/snowplow/issues/1569 (comments are auto-generated)