t8y2/dbx · error

read Hive initFile statement result: %w

Error message

read Hive initFile statement result: %w

What it means

After executing an initFile statement that returned a result set, the driver drains it with rows.Next() and then checks rows.Err(). This error wraps any iteration/driver-level error that occurred while consuming that result set during connection initialization, aborting openConnection.

Source

Thrown at agents/drivers/hive-go/main.go:381

		timeout += server.config.BrowserResponseTimeout
	}
	return timeout
}

func runHiveInitStatements(ctx context.Context, connection *sql.Conn, statements []string, fetchSize int) error {
	for _, statement := range statements {
		rows, _, hasResultSet, err := executeHiveStatement(ctx, connection, statement, fetchSize)
		if err != nil {
			return fmt.Errorf("execute Hive initFile statement: %w", err)
		}
		if !hasResultSet {
			continue
		}
		for rows.Next() {
		}
		if rowsErr := rows.Err(); rowsErr != nil {
			_ = rows.Close()
			return fmt.Errorf("read Hive initFile statement result: %w", rowsErr)
		}
		if closeErr := rows.Close(); closeErr != nil {
			return fmt.Errorf("close Hive initFile statement result: %w", closeErr)
		}
	}
	return nil
}

func (server *server) dispatch(method string, params map[string]json.RawMessage) (any, bool, error) {
	switch method {
	case "validate_connection":
		return map[string]bool{"ok": true}, false, server.validateConnection()
	case "connection_info":
		result, err := server.connectionInfo()
		return result, false, err
	case "list_databases":
		result, err := server.listDatabases()
		return result, false, err

View on GitHub (pinned to c0390bff16)

Solutions

1. Check the wrapped cause after 'read Hive initFile statement result:' to identify the transport or server error
2. Remove result-set-producing statements from the initFile when their output isn't needed
3. Retry the connection — the failure is often transient network/transport related
4. Increase the connect timeout if large results are being drained at init time

Example fix

// before: init statement returns big result set
SELECT * FROM audit_log;
// after: no result set at init time
INSERT OVERWRITE TABLE / SELECT ... LIMIT 0; or remove the SELECT

if err != nil && strings.HasPrefix(err.Error(), "read Hive initFile statement result:") {
    return retryWithBackoff(ctx, 3, openConnection)
}

When it happens

Trigger: An initFile statement that produces a result set (e.g. SELECT or SHOW) whose row iteration fails: network drop mid-result, HiveServer2 operation cancelled or timed out, or a driver-level fetch error while pulling remaining rows.

Common situations: Large initFile result sets hitting fetchSize pagination across an unstable network; a query in the initFile being killed server-side; transient HiveServer2 restart during connect.

Related errors

• execute Hive initFile statement: %w
• close Hive initFile statement result: %w
• Hive host is required
• Hive connection string must start with jdbc:hive2:// or hive
• Hive endpoint is empty

AI-assisted analysis of t8y2/dbx@c0390bff16 (2026-09-05). Data as JSON: /api/errors/dfed34409dc86786. Report an issue: GitHub.