{"record":{"id":"5e3a7e5a076dd6ed","repo":"apache/beam","slug":"encountered-an-atomic-type-that-is-not-currently-supported","errorCode":null,"errorMessage":"Encountered an Atomic type that is not currently supported by RowCoder: ${atomicType}","messagePattern":"Encountered an Atomic type that is not currently supported by RowCoder: (.+?)","errorType":"exception","errorClass":null,"httpStatus":null,"severity":"error","filePath":"sdks/typescript/src/apache_beam/coders/row_coder.ts","lineNumber":267,"sourceCode":"    switch (typeInfo.oneofKind) {\n      case \"atomicType\":\n        let atomicType: AtomicType = typeInfo.atomicType;\n        switch (atomicType) {\n          case AtomicType.INT16:\n          case AtomicType.INT32:\n          case AtomicType.INT64:\n            return new VarIntCoder();\n          // case AtomicType.BYTE:\n          case AtomicType.BYTES:\n            return new BytesCoder();\n          // case AtomicType.FLOAT:\n          // case AtomicType.DOUBLE:\n          case AtomicType.STRING:\n            return new StrUtf8Coder();\n          case AtomicType.BOOLEAN:\n            return new BoolCoder();\n          default:\n            throw new Error(\n              `Encountered an Atomic type that is not currently supported by RowCoder: ${atomicType}`,\n            );\n        }\n        break;\n      case \"arrayType\":\n        if (typeInfo.arrayType.elementType !== undefined) {\n          return new IterableCoder(\n            this.getCoderFromType(typeInfo.arrayType.elementType),\n          );\n        } else {\n          throw new Error(\"ElementType missing on ArrayType\");\n        }\n      // case \"iterableType\":\n      // case \"mapType\":\n      case \"rowType\":\n        if (typeInfo.rowType.schema !== undefined) {\n          return RowCoder.fromSchema(typeInfo.rowType.schema);\n        } else {","sourceCodeStart":249,"sourceCodeEnd":285,"githubUrl":"https://github.com/apache/beam/blob/12126d8942aaf848030c478b4c6a28c6af861c66/sdks/typescript/src/apache_beam/coders/row_coder.ts#L249-L285","documentation":"ManagedRead.__init__ validates the `source` argument against the _READ_TRANSFORMS registry (case-insensitively) and raises ValueError when no matching identifier exists. Only a fixed set of managed read sources (e.g. iceberg, kafka, bigquery) is supported; anything else is rejected before any expansion service work starts.","triggerScenarios":"ManagedRead(source='s3'), ManagedRead(source='Ice Berg'), or any source string whose .lower() is not a key of _READ_TRANSFORMS.","commonSituations":"Typos or unsupported connectors (e.g. trying s3/jdbc when only iceberg/kafka/bigquery are supported); casing confusion is tolerated (lowercased) but wrong names are not; reading docs for a newer Beam that supports more sources.","solutions":["Use one of the supported sources listed in the error message (e.g. 'iceberg', 'kafka', 'bigquery').","Fix spelling of the source name (matching is on the lowercased string).","Upgrade apache-beam if the desired managed source was added in a newer release; otherwise use the non-managed connector or an external Java transform."],"exampleFix":"// before\nbeam.ManagedRead(source='S3')\n// after\nbeam.ManagedRead(source='iceberg')  # or kafka / bigquery","handlingStrategy":"validation","validationCode":"from apache_beam.transforms.managed import ManagedRead\nassert str(source).lower() in ManagedRead._READ_TRANSFORMS, f'{source} not supported; use {list(ManagedRead._READ_TRANSFORMS)}'","typeGuard":"def is_supported_source(source: str) -> bool:\n    from apache_beam.transforms.managed import ManagedRead\n    return str(source).lower() in ManagedRead._READ_TRANSFORMS","tryCatchPattern":"try:\n    p | beam.ManagedRead(source=src, config=cfg)\nexcept ValueError as e:\n    logger.error('Bad managed source %r: %s', src, e)\n    raise","preventionTips":["Copy source names from the error message's allowed list","Use the managed source names supported by your installed Beam version","For unlisted connectors, use the dedicated I/O connector or external Java transform instead"],"tags":["python","apache-beam","managed-transform","invalid-argument","io"],"backgroundTag":"invalid-enum-value","analyzedSha":"12126d8942aaf848030c478b4c6a28c6af861c66","analyzedAt":"2026-09-13T01:50:10.254Z","contentChangedAt":"2026-09-13T01:50:10.254Z","schemaVersion":2},"datasetVersion":"2026-09-14T16:17:12.679Z"}