{"record":{"id":"f3ba1d0edef402e9","repo":"apache/seatunnel","slug":"illegal-argument-f3ba1d","errorCode":"ILLEGAL_ARGUMENT","errorMessage":"Column not found in Kudu schema: ","messagePattern":"Column not found in Kudu schema: ","errorType":"error_code","errorClass":"KuduConnectorException","httpStatus":null,"severity":"error","filePath":"seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/util/KuduUtil.java","lineNumber":224,"sourceCode":"\n        Pattern pattern = Pattern.compile(\"(\\\\w+)\\\\s*([=><]=?|<=|>=)\\\\s*(.+)\");\n        for (String condition : conditions) {\n            Matcher matcher = pattern.matcher(condition.trim());\n\n            String column = null;\n            String op = null;\n            String value = null;\n\n            if (matcher.matches()) {\n                column = matcher.group(1);\n                op = matcher.group(2);\n                value = matcher.group(3);\n            } else {\n                throw new IllegalArgumentException(\"Invalid filter condition: \" + condition);\n            }\n\n            if (!schema.hasColumn(column)) {\n                throw new KuduConnectorException(\n                        CommonErrorCodeDeprecated.ILLEGAL_ARGUMENT,\n                        \"Column not found in Kudu schema: \" + column);\n            }\n\n            Type type = schema.getColumn(column).getType();\n\n            KuduPredicate.ComparisonOp comparisonOp = null;\n            switch (op) {\n                case \"=\":\n                    comparisonOp = KuduPredicate.ComparisonOp.EQUAL;\n                    break;\n                case \">\":\n                    comparisonOp = KuduPredicate.ComparisonOp.GREATER;\n                    break;\n                case \">=\":\n                    comparisonOp = KuduPredicate.ComparisonOp.GREATER_EQUAL;\n                    break;\n                case \"<\":","sourceCodeStart":206,"sourceCodeEnd":242,"githubUrl":"https://github.com/apache/seatunnel/blob/cf67b549a7a6c35fa0beb12d83c62892427ea919/seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/util/KuduUtil.java#L206-L242","documentation":"KuduUtil.addPredicates validates each parsed filter condition against the Kudu table schema using schema.hasColumn(column); if the referenced column does not exist in the Kudu table, it throws a KuduConnectorException with CommonErrorCodeDeprecated.ILLEGAL_ARGUMENT. The message includes the offending column name.","triggerScenarios":"A filter condition references a column name that is not present in the Kudu table's schema, e.g. due to a typo, case-sensitivity mismatch, or the column having been dropped/renamed in Kudu.","commonSituations":"Case sensitivity: filter uses 'Name' but Kudu column is 'name'; config written for a different table; schema drift after table migration; column renamed without updating the filter config.","solutions":["Verify the column name against the actual Kudu table schema (kudu table describe or describe_table) and fix the filter","Check case: Kudu column names are case-sensitive; match exactly","If the table was migrated/renamed, update filter configuration to the new schema"],"exampleFix":"// before\n\"filters\": [\"UserName = 'alice'\"]\n// after (actual column is user_name)\n\"filters\": [\"user_name = 'alice'\"]","handlingStrategy":"validation","validationCode":"for (String condition : filters) {\n    String col = condition.trim().split(\"\\\\s+\")[0];\n    if (!kuduSchema.hasColumn(col)) {\n        throw new IllegalArgumentException(\"Column not in Kudu schema: \" + col);\n    }\n}","typeGuard":null,"tryCatchPattern":"try {\n    kuduUtil.getKuduScanToken(filters, schema, ...);\n} catch (KuduConnectorException e) {\n    // verify column names against Kudu schema and retry\n}","preventionTips":["Match column names exactly (case-sensitive) as defined in Kudu","Refresh filter configs after schema migrations or renames","Validate filter columns against table schema at job startup","Keep filter configuration alongside the table DDL in version control"],"tags":["schema","kudu","filters"],"backgroundTag":"schema-validation-failed","analyzedSha":"cf67b549a7a6c35fa0beb12d83c62892427ea919","analyzedAt":"2026-09-10T21:44:55.265Z","contentChangedAt":"2026-09-10T21:44:55.265Z","schemaVersion":2},"datasetVersion":"2026-09-14T11:17:12.474Z"}