public SqlType getExpressionSqlType(final Expression expression) {
    return getExpressionSqlType(expression, Collections.emptyMap());
  }
@Test
  public void shouldFailForCheckingComplexTypeEquality() {
    // Given:
    final Expression expression = new ComparisonExpression(Type.EQUAL, MAPCOL, ADDRESS);

    // When:
    final KsqlStatementException e = assertThrows(
        KsqlStatementException.class,
        () -> expressionTypeManager.getExpressionSqlType(expression)
    );

    // Then:
    assertThat(e.getMessage(), containsString(
        "Cannot compare MAP<BIGINT, DOUBLE> "
            + "to STRUCT<`NUMBER` BIGINT, `STREET` STRING, `CITY` STRING,"
            + " `STATE` STRING, `ZIPCODE` BIGINT> with EQUAL."
    ));
    assertThat(e.getUnloggedMessage(), containsString(
        "Cannot compare COL5 (MAP<BIGINT, DOUBLE>) to COL6 "
            + "(STRUCT<`NUMBER` BIGINT, `STREET` STRING, `CITY` STRING, `STATE` STRING, "
            + "`ZIPCODE` BIGINT>) with EQUAL"
    ));
  }