Skip to content

Enable auto scan mode for Spark 4.0.0 #1967

Closed

Description

@andygrove

What is the problem the feature request solves?

For the initial Spark 4.0.0 support, we disabled the auto scan mode:

  private def selectScan(scanExec: FileSourceScanExec, partitionSchema: StructType): String = {

    val fallbackReasons = new ListBuffer[String]()

    if (CometSparkSessionExtensions.isSpark40Plus) {
      fallbackReasons += s"$SCAN_NATIVE_ICEBERG_COMPAT  is not implemented for Spark 4.0.0"
    }

We should now remove this limitation. However, some other issues need resolving first:

  • The native_iceberg_compat reader fails at runtime with Unsupported data type: string collate UTF8_LCASE, so we need to fall back to native_comet for now if we see collation types. This error is thrown in Utils.toArrowType.

Describe the potential solution

No response

Additional context

No response

Activity

  1. added this to the 0.10.0 milestone on Jul 1, 2025
  2. self-assigned this
    on Jul 2, 2025
  3. removed this from the 0.10.0 milestone on Jul 31, 2025
  4. removed their assignment
    on Aug 11, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature or request

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions