Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-326

LogicalTableRouter SMT uses wrong comparison for validation

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 0.5.2
    • 0.5.1
    • core-library
    • None

      The SMT for changing the table router logic contains comparisons by identity where .equals() comparisons are necessary.

      Example excerpt from debezium-core/src/main/java/io/debezium/transforms/ByLogicalTableRouter.java#L317:

      if (keyFieldRegex != null && keyFieldRegex != "") {
            if (keyFieldReplacement == null || keyFieldReplacement == "") {
                problems.accept(KEY_FIELD_REPLACEMENT, keyFieldReplacement,
                        KEY_FIELD_REPLACEMENT.name() + " must be specified if " +
                                KEY_FIELD_REGEX.name() + " is specified");
                return 1;
            }
        }

              mario@xenji.com Mario Mueller (Inactive)
              mario@xenji.com Mario Mueller (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: