[nifi] branch master updated: NIFI-6793 Fix NumberFormatException at CaptureChangeMySQL

[mt...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mthomsen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/master by this push:
     new 87838e6  NIFI-6793 Fix NumberFormatException at CaptureChangeMySQL
87838e6 is described below

commit 87838e6c31ed8b104f79b7c7930b110e31bf7de7
Author: Koji Kawamura <ko...@Kojis-MacBook-Pro.local>
AuthorDate: Sun Oct 20 18:41:05 2019 +0900

    NIFI-6793 Fix NumberFormatException at CaptureChangeMySQL
    
    This closes #3827
    
    Signed-off-by: Mike Thomsen <mt...@apache.org>
---
 .../java/org/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 e8c94d1..38d3259 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