Urmi Mustafi created GOBBLIN-2113:
-------------------------------------
Summary: Process HB messages with empty FlowExecutionId str
Key: GOBBLIN-2113
URL: https://issues.apache.org/jira/browse/GOBBLIN-2113
Project: Apache Gobblin
Issue Type: Bug
Components: gobblin-service
Reporter: Urmi Mustafi
Assignee: Abhishek Tiwari
{{After changing flowExecutionID from a Str to a long in a previous PR, we
encounter NumberFormatException in the DagActionStoreChangeMonitor when
processing HB events. This ends up killing the HighLevelConsumer queues for the
hosts that receive the HB events in their partition. }}
{{Encountered exception while processing record so stopping queue processing.
Record: LiKafka10ConsumerRecord(consumerRecord=ConsumerRecord(topic =
ds_mysql_makto-db-152_prod_SHARED_GOBBLIN_DAG_ACTION_STORE_20221208211255,
partition = 0, leaderEpoch = null, offset = 905733, NoTimestampType = -1,
serialized key size = -1, serialized value size = -1, headers =
RecordHeaders(headers = [], isReadOnly = false), key = , value =
\{"changeEventIdentifier": {"key": "", "txId": "", "produceTimestampMillis":
1721078158347, "operationType": "HEARTBEAT"}, "flowGroup": "", "flowName": "",
"flowExecutionId": "", "jobName": "", "dagAction": null})) Exception:
java.lang.NumberFormatException: For input string: ""}}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
