ERROR   2022-03-21 20:05:40,241 0       io.debezium.connector.mysql.MySqlStreamingChangeEventSource     [blc-127.0.0.1:3306]    Error during binlog processing. Last offset stored = \{transaction_id=null, ts_sec=1647918340, file=master.000002, pos=26566, gtids=3b0f51ee-a08e-11ec-86ff-000c29221572:1-105, server_id=999, event=1}, binlog reader near position = master.000002/26566
ERROR   2022-03-21 20:05:40,242 1       io.debezium.pipeline.ErrorHandler       [blc-127.0.0.1:3306]    Producer failure
io.debezium.DebeziumException: Error processing binlog event
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:369)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$25(MySqlStreamingChangeEventSource.java:860)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1125)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:973)
        at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:599)
        at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:857)
        at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE DEFINER=`leapdb`@`localhost` PROCEDURE `leapdb`.`create_child_views`(IN v_mview_id INT)
BEGIN
  DECLARE v_new_mview_id INT;
  DECLARE v_needs_dependent_view BOOLEAN DEFAULT FALSE;


  SELECT count(*)
    INTO v_needs_dependent_view
    FROM leapdb.mview_expression
   WHERE mview_id = v_mview_id
     AND mview_expr_type in ('PERCENTILE','MIN','MAX','COUNT_DISTINCT', 'STDDEV_POP','VAR_POP', 'STDDEV_SAMP','VAR_SAMP','GROUP_CONCAT','BIT_AND','BIT_OR','BIT_XOR');

   
   SET v_new_mview_id := leapdb.get_id(leapdb.get_setting('mvlog_db'), concat('mv$', v_mview_id));
   IF v_new_mview_id is not null and v_new_mview_id != 0 THEN
     set @fv_force := 1;
     set @fv_silent := 1;
     CALL leapdb.drop(v_new_mview_id);
     DELETE from leapdb.mview_expression where mview_id = v_new_mview_id;
     DELETE from leapdb.mview_table where mview_id = v_new_mview_id;
     DELETE from leapdb.mview where mview_id = v_new_mview_id;
     SET v_new_mview_id := NULL;
   END IF;

  IF v_needs_dependent_view is not null and v_needs_dependent_view > 0 THEN

      
      CALL leapdb.create(leapdb.get_setting('mvlog_db'), concat('mv$',v_mview_id),'INCREMENTAL');
      SET v_new_mview_id := LAST_INSERT_ID();
      UPDATE leapdb.mview set parent_mview_id = v_mview_id where mview_id = v_new_mview_id;


      
      REPLACE INTO leapdb.mview_table
      (mview_table_id, mview_id, mview_table_name, mview_table_schema, mview_table_alias, mview_join_condition, mview_join_order)
      SELECT NULL,
             v_new_mview_id,
             mview_table_name,
             mview_table_schema,
             mview_table_alias,
             mview_join_condition,
             mview_join_order
        FROM leapdb.mview_table
       WHERE mview_id = v_mview_id;


      
      REPLACE INTO leapdb.mview_expression
      (mview_expression_id, mview_id, mview_expr_type, mview_expression, mview_alias, mview_expr_order)
      SELECT NULL,
             v_new_mview_id,
             if(mview_expr_type not in ('PERCENTILE','MIN','MAX','COUNT_DISTINCT','STDDEV_POP','STDDEV_SAMP','VAR_POP','VAR_SAMP','BIT_AND','BIT_OR','BIT_XOR','GROUP_CONCAT'), mview_expr_type, 'GROUP'),
             IF(mview_expr_type = 'GROUP_CONCAT', leapdb.extract_gc_col(mview_expression), mview_expression),
             mview_alias,         
             mview_expr_order
        FROM leapdb.mview_expression
       WHERE mview_id = v_mview_id
         AND mview_expr_type in ('GROUP','WHERE','PERCENTILE','MIN','MAX','COUNT_DISTINCT', 'STDDEV_POP','STDDEV_SAMP','VAR_SAMP','VAR_POP','BIT_AND','BIT_OR','BIT_XOR','GROUP_CONCAT');

       
       CALL leapdb.add_expr(v_new_mview_id, 'COUNT', '*', 'CNT');

       

       
       SET max_sp_recursion_depth=255;
       SET unique_checks=off;
       CALL leapdb.enable(v_new_mview_id);
       SET unique_checks=on;

  END IF;
END'
no viable alternative at input 'CREATE DEFINER=`leapdb`@`localhost` PROCEDURE `leapdb`.`create_child_views`(IN v_mview_id INT)\nBEGIN\n  DECLARE v_new_mview_id INT;\n  DECLARE v_needs_dependent_view BOOLEAN DEFAULT FALSE;\n\n\n  SELECT count(*)\n    INTO v_needs_dependent_view\n    FROM leapdb.mview_expression\n   WHERE mview_id = v_mview_id\n     AND mview_expr_type in ('PERCENTILE','MIN','MAX','COUNT_DISTINCT', 'STDDEV_POP','VAR_POP', 'STDDEV_SAMP','VAR_SAMP','GROUP_CONCAT','BIT_AND','BIT_OR','BIT_XOR');\n\n   \n   SET v_new_mview_id := leapdb.get_id(leapdb.get_setting('mvlog_db'), concat('mv$', v_mview_id));\n   IF v_new_mview_id is not null and v_new_mview_id != 0 THEN\n     set @fv_force := 1;\n     set @fv_silent := 1;\n     CALL leapdb.drop(v_new_mview_id);\n     DELETE from leapdb.mview_expression where mview_id = v_new_mview_id;\n     DELETE from leapdb.mview_table where mview_id = v_new_mview_id;\n     DELETE from leapdb.mview where mview_id = v_new_mview_id;\n     SET v_new_mview_id := NULL;\n   END IF;\n\n  IF v_needs_dependent_view is not null and v_needs_dependent_view > 0 THEN\n\n      \n      CALL leapdb.create(leapdb.get_setting('mvlog_db'), concat('mv$',v_mview_id),'INCREMENTAL');\n      SET v_new_mview_id := LAST_INSERT_ID();\n      UPDATE leapdb.mview set parent_mview_id = v_mview_id where mview_id = v_new_mview_id;\n\n\n      \n      REPLACE INTO leapdb.mview_table\n      (mview_table_id, mview_id, mview_table_name, mview_table_schema, mview_table_alias, mview_join_condition, mview_join_order)\n      SELECT NULL,\n             v_new_mview_id,\n             mview_table_name,\n             mview_table_schema,\n             mview_table_alias,\n             mview_join_condition,\n             mview_join_order\n        FROM leapdb.mview_table\n       WHERE mview_id = v_mview_id;\n\n\n      \n      REPLACE INTO leapdb.mview_expression\n      (mview_expression_id, mview_id, mview_expr_type, mview_expression, mview_alias, mview_expr_order)\n      SELECT NULL,\n\t     v_new_mview_id,\n             if(mview_expr_type not in ('PERCENTILE','MIN','MAX','COUNT_DISTINCT','STDDEV_POP','STDDEV_SAMP','VAR_POP','VAR_SAMP','BIT_AND','BIT_OR','BIT_XOR','GROUP_CONCAT'), mview_expr_type, 'GROUP'),\n             IF(mview_expr_type = 'GROUP_CONCAT', leapdb.extract_gc_col(mview_expression), mview_expression),\n             mview_alias,         \n             mview_expr_order\n        FROM leapdb.mview_expression\n       WHERE mview_id = v_mview_id\n         AND mview_expr_type in ('GROUP','WHERE','PERCENTILE','MIN','MAX','COUNT_DISTINCT', 'STDDEV_POP','STDDEV_SAMP','VAR_SAMP','VAR_POP','BIT_AND','BIT_OR','BIT_XOR','GROUP_CONCAT');\n\n       \n       CALL leapdb.add_expr(v_new_mview_id, 'COUNT', '*', 'CNT');\n\n       \n\n       \n       SET max_sp_recursion_depth=255;\n       SET unique_checks=off;\n       CALL leapdb.enable(v_new_mview_id);\n       SET unique_checks=on;'
        at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43)
        at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)
        at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544)
        at org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:310)
        at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136)
        at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1223)
        at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:945)
        at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:73)
        at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:45)
        at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82)
        at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:223)
        at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:209)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:576)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$14(MySqlStreamingChangeEventSource.java:832)
        at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:349)
        ... 6 more
Caused by: org.antlr.v4.runtime.NoViableAltException
        at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2026)
        at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467)
        at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393)
        at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1021)
        ... 15 more
ERROR   2022-03-21 20:05:40,268 27      io.debezium.embedded.EmbeddedEngine     [pool-1-thread-1]       Stopping connector after error in the application's handler method: null
java.lang.NullPointerException
        at com.leapdb.cdc.LeapCDC.sendRecord(LeapCDC.java:321)
        at io.debezium.embedded.EmbeddedEngine$1.handleBatch(EmbeddedEngine.java:473)
        at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:821)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:829)
Engine terminated
Requesting embedded engine to shut down