[
https://issues.apache.org/jira/browse/SAMZA-608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Riccomini updated SAMZA-608:
----------------------------------
Attachment: SAMZA-608-0.patch
Attaching patch. This appears to fix the problem. Output after the patch is
applied:
{noformat}
IncomingMessageEnvelope [systemStreamPartition=SystemStreamPartition [kafka,
sunky-raw, 0], offset=0, key=[B@c27d163, message={qwevent=ACCOUNT_CREATE,
localtime=2014-07-14T01:22:37+02:00,
event_id=c7027d65-ff89-493f-bdf7-a93db8179001, client_info={distributor=amazon,
device=pc, os=windows, platform=portal, type=browser},
client_id=db78acd2-dfe7-453c-9922-7b21bb770afe,
partner_id=a1f9ec7a-db95-4154-b755-85916f2c7927,
game_id=a39b4ddb-b00c-4f4a-9761-9e1a7dc76aaa,
user_id=0b838454-fe38-4043-8643-0cecd77c9ae7,
account_id=7010f724-5ab1-42d7-beb4-b1cc4c532aaa, guls={game=GAME1, user=111,
lang=de, server=dev-1}, display_name=NICKNAME1, usernames=[NICKNAME1,
NICKNAME2], migration={signup_time=2009-07-14T15:22:37+02:00,
validation_time=2009-07-14T15:24:45+02:00,
last_login=2014-07-14T15:22:37+02:00, first_login=2009-07-14T15:25:33+02:00}}]
IncomingMessageEnvelope [systemStreamPartition=SystemStreamPartition [kafka,
sunky-raw, 0], offset=2, key=[B@22d9c961, message={qwevent=USER_VERIFY,
localtime=2014-07-14T15:22:37+02:00,
event_id=c7027d65-ff89-493f-bdf7-a93db8179680, client_info={distributor=amazon,
device=pc, os=windows, platform=portal, type=browser},
user_id=0b838454-fe38-4043-8643-0cecd77c9ae7, [email protected]}]
{noformat}
Before, I wasn't seeing the second message.
Before we commit this, we'll need to:
# Write a unit test.
# Validate against Zopkio tests.
# Validate against SAMZA-394 torture test.
# Coordinate with SAMZA-571, which is going to change the way serialization is
handled.
> Deserialization error causes SystemConsumers to hang
> ----------------------------------------------------
>
> Key: SAMZA-608
> URL: https://issues.apache.org/jira/browse/SAMZA-608
> Project: Samza
> Issue Type: Task
> Components: container
> Affects Versions: 0.9.0
> Reporter: Chris Riccomini
> Fix For: 0.10.0
>
> Attachments: SAMZA-608-0.patch, SAMZA-608-hello-samza.diff
>
>
> SamzaContainers seem to wedge if malformed messages are sent to it, even if
> {{task.drop.deserialization.errors=true}}. This was initially raised on the
> mailing list
> [here|http://mail-archives.apache.org/mod_mbox/samza-dev/201503.mbox/%3C94CF0C2E22F96641A963FB3B6D2911213A2715B2%40GF-KA-EX01.gf.local%3E].
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
