Alter allowSplittingReadIntoMultipleSubQueries check for systemTables

core/trino-main/src/main/java/io/trino/metadata/MetadataManager.java

@@ -2803,6 +2803,9 @@ public OptionalInt getMaxWriterTasks(Session session, String catalogName)
     public boolean allowSplittingReadIntoMultipleSubQueries(Session session, TableHandle tableHandle)
     {
         CatalogHandle catalogHandle = tableHandle.catalogHandle();
+        if (catalogHandle.getType().isInternal()) {
+            return false;
+        }
         CatalogMetadata catalogMetadata = getCatalogMetadata(session, catalogHandle);
         ConnectorSession connectorSession = session.toConnectorSession(catalogHandle);
         return catalogMetadata.getMetadata(session).allowSplittingReadIntoMultipleSubQueries(connectorSession, tableHandle.connectorHandle());

plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMetadata.java

@@ -4061,8 +4061,8 @@ private Optional<SystemTable> getRawSystemTable(ConnectorSession session, Schema
     @Override
     public boolean allowSplittingReadIntoMultipleSubQueries(ConnectorSession session, ConnectorTableHandle tableHandle)
     {
-        // dont split to subqueries if tableHandle is systemTableHandle, delta lake supports only a columnar (parquet) storage format
-        return tableHandle instanceof DeltaLakeTableHandle;
+        // delta lake supports only a columnar (parquet) storage format
+        return true;
     }
 
     @Override

plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java

@@ -3990,12 +3990,7 @@ private static Optional<CatalogSchemaTableName> redirectTableToHudi(Optional<Str
     @Override
     public boolean allowSplittingReadIntoMultipleSubQueries(ConnectorSession session, ConnectorTableHandle tableHandle)
     {
-        // dont split to subqueries if tableHandle is systemTableHandle
-        if (!(tableHandle instanceof HiveTableHandle hiveTableHandle)) {
-            return false;
-        }
-
-        SchemaTableName tableName = hiveTableHandle.getSchemaTableName();
+        SchemaTableName tableName = ((HiveTableHandle) tableHandle).getSchemaTableName();
 
         Table table = metastore.getTable(tableName.getSchemaName(), tableName.getTableName())
                 .orElseThrow(() -> new TableNotFoundException(tableName));

plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/HudiMetadata.java

@@ -290,8 +290,8 @@ public void validateScan(ConnectorSession session, ConnectorTableHandle handle)
     @Override
     public boolean allowSplittingReadIntoMultipleSubQueries(ConnectorSession session, ConnectorTableHandle tableHandle)
     {
-        // dont split to subqueries if tableHandle is systemTableHandle, hudi supports only a columnar (parquet) storage format
-        return tableHandle instanceof HudiTableHandle;
+        // hudi supports only a columnar (parquet) storage format
+        return true;
     }
 
     HiveMetastore getMetastore()

plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java

@@ -3314,11 +3314,8 @@ public Optional<CatalogSchemaTableName> redirectTable(ConnectorSession session,
     @Override
     public boolean allowSplittingReadIntoMultipleSubQueries(ConnectorSession session, ConnectorTableHandle connectorTableHandle)
     {
-        // dont split to subqueries if tableHandle is systemTableHandle
-        if (!(connectorTableHandle instanceof IcebergTableHandle icebergTableHandle)) {
-            return false;
-        }
-        IcebergFileFormat storageFormat = getFileFormat(icebergTableHandle.getStorageProperties());
+        IcebergTableHandle tableHandle = (IcebergTableHandle) connectorTableHandle;
+        IcebergFileFormat storageFormat = getFileFormat(tableHandle.getStorageProperties());
 
         return storageFormat == IcebergFileFormat.ORC || storageFormat == IcebergFileFormat.PARQUET;
     }

plugin/trino-memory/src/main/java/io/trino/plugin/memory/MemoryMetadata.java

@@ -640,8 +640,7 @@ public Optional<SampleApplicationResult<ConnectorTableHandle>> applySample(Conne
     @Override
     public boolean allowSplittingReadIntoMultipleSubQueries(ConnectorSession session, ConnectorTableHandle tableHandle)
     {
-        // dont split to subqueries if tableHandle is systemTableHandle
-        return tableHandle instanceof MemoryTableHandle;
+        return true;
     }
 
     @Override