samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Shekar Tippur <>
Subject Deserializing issue
Date Fri, 20 Feb 2015 00:00:31 GMT

As I am trying to extend what we have to other sources, I changed some
code. Looks like deserialization is broken.

Here is a sample stream input:

Policy","application_name":"PROD AWS","business_unit_l1":"CEG"}


Transforms it to:

{creation_time=2015-02-04T20:41:36Z, alert_policy_name=Alert
Policy,application_name=Prod AWS,business_unit_l1=CEG}

As we can see, the json structure seem to be broken.

I have this in the config file:



Wondering what could be wrong.

- Shekar

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message