From 87838e6c31ed8b104f79b7c7930b110e31bf7de7 Mon Sep 17 00:00:00 2001 From: Koji Kawamura Date: Sun, 20 Oct 2019 18:41:05 +0900 Subject: [PATCH] NIFI-6793 Fix NumberFormatException at CaptureChangeMySQL This closes #3827 Signed-off-by: Mike Thomsen --- .../apache/nifi/cdc/mysql/processors/CaptureChangeMySQL.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/processors/CaptureChangeMySQL.java b/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/processors/CaptureChangeMySQL.java index e8c94d1a3b..38d3259733 100644 --- a/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/processors/CaptureChangeMySQL.java +++ b/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/processors/CaptureChangeMySQL.java @@ -489,7 +489,7 @@ public class CaptureChangeMySQL extends AbstractSessionFactoryProcessor { currentSequenceId.set(seqIdProp.evaluateAttributeExpressions().asInteger()); } } else { - currentSequenceId.set(Integer.parseInt(seqIdString)); + currentSequenceId.set(Long.parseLong(seqIdString)); } // Get reference to Distributed Cache if one exists. If it does not, no enrichment (resolution of column names, e.g.) will be performed