Function cross_join

datafusion/core/tests/memory_limit/mod.rs:165–175

()

#[tokio::test]
async fn cross_join() {
    TestCase::new()
        .with_query("select t1.*, t2.* from t t1 CROSS JOIN t t2")
        .with_expected_errors(vec![
            "Resources exhausted: Additional allocation failed",
            "with top memory consumers (across reservations) as:\n  CrossJoinExec",
        ])
        .with_memory_limit(1_000)
        .run()
        .await
}

#[tokio::test]
async fn sort_merge_join_no_spill() {