StarRocks/dbt-starrocks

mysql.connector.errors.InternalError: Unread result found

Closed this issue · 1 comments

Invoking dbt with ['seed']
02:55:39  Running with dbt=1.6.2
02:55:39  Registered adapter: starrocks=1.4.2
02:55:39  Unable to do partial parsing because saved manifest not found. Starting full parse.
02:55:40  Found 3 models, 1 seed, 1 source, 0 exposures, 0 metrics, 335 macros, 0 groups, 0 semantic models
02:55:40  
02:55:40  Concurrency: 1 threads (target='default')
02:55:40  
02:55:40  1 of 1 START seed file test17102121381979843801_test_basic.base ................ [RUN]
02:55:41  1 of 1 OK loaded seed file test17102121381979843801_test_basic.base ............ [INSERT 10 in 0.44s]
02:55:41  
02:55:41  Finished running 1 seed in 0 hours 0 minutes and 0.56 seconds (0.56s).
02:55:41  
02:55:41  Completed successfully
02:55:41  
02:55:41  Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1


Invoking dbt with ['run']
02:55:41  Running with dbt=1.6.2
02:55:41  Registered adapter: starrocks=1.4.2
02:55:41  Found 3 models, 1 seed, 1 source, 0 exposures, 0 metrics, 335 macros, 0 groups, 0 semantic models
02:55:41  
02:55:41  Concurrency: 1 threads (target='default')
02:55:41  
02:55:41  1 of 3 START sql table model test17102121381979843801_test_basic.swappable ..... [RUN]
02:55:41  1 of 3 OK created sql table model test17102121381979843801_test_basic.swappable  [SUCCESS 10 in 0.41s]
02:55:41  2 of 3 START sql table model test17102121381979843801_test_basic.table_model ... [RUN]
02:55:42  2 of 3 OK created sql table model test17102121381979843801_test_basic.table_model  [SUCCESS 10 in 0.27s]
02:55:42  3 of 3 START sql view model test17102121381979843801_test_basic.view_model ..... [RUN]
02:55:42  3 of 3 OK created sql view model test17102121381979843801_test_basic.view_model  [SUCCESS 0 in 0.11s]
02:55:42  
02:55:42  Finished running 2 table models, 1 view model in 0 hours 0 minutes and 0.88 seconds (0.88s).
02:55:42  
02:55:42  Completed successfully
02:55:42  
02:55:42  Done. PASS=3 WARN=0 ERROR=0 SKIP=0 TOTAL=3
select count(*) as num_rows from `test17102121381979843801_test_basic`.`base`
Unread result found
F

=================================== FAILURES ===================================
________________ TestSimpleMaterializationsMyAdapter.test_base _________________

self = <test_basic.TestSimpleMaterializationsMyAdapter object at 0x108e611c0>
project = <dbt.tests.fixtures.project.TestProjInfo object at 0x1060fa9a0>

    def test_base(self, project):
    
        # seed command
        results = run_dbt(["seed"])
        # seed result length
        assert len(results) == 1
    
        # run command
        results = run_dbt()
        # run result length
        assert len(results) == 3
    
        # names exist in result nodes
        check_result_nodes_by_name(results, ["view_model", "table_model", "swappable"])
    
        # check relation types
        expected = {
            "base": "table",
            "view_model": "view",
            "table_model": "table",
            "swappable": "table",
        }
        check_relation_types(project.adapter, expected)
    
        # base table rowcount
        relation = relation_from_name(project.adapter, "base")
>       result = project.run_sql(f"select count(*) as num_rows from {relation}", fetch="one")

/Users/atwong/dbt-env/lib/python3.9/site-packages/dbt/tests/adapter/basic/test_base.py:66: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/Users/atwong/dbt-env/lib/python3.9/site-packages/dbt/tests/fixtures/project.py:431: in run_sql
    return run_sql_with_adapter(self.adapter, sql, fetch=fetch)
/Users/atwong/dbt-env/lib/python3.9/site-packages/dbt/tests/util.py:304: in run_sql_with_adapter
    return adapter.run_sql_for_tests(sql, fetch, conn)
/Users/atwong/dbt-env/lib/python3.9/site-packages/dbt/adapters/sql/impl.py:256: in run_sql_for_tests
    conn.handle.commit()
/Users/atwong/dbt-env/lib/python3.9/site-packages/mysql/connector/connection_cext.py:531: in commit
    self.handle_unread_result()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <mysql.connector.connection_cext.CMySQLConnection object at 0x10a4ccf40>
prepared = False

    def handle_unread_result(self, prepared: bool = False) -> None:
        """Check whether there is an unread result"""
        unread_result = self._unread_result if prepared is True else self.unread_result
        if self.can_consume_results:
            self.consume_results()
        elif unread_result:
>           raise InternalError("Unread result found")
E           mysql.connector.errors.InternalError: Unread result found

/Users/atwong/dbt-env/lib/python3.9/site-packages/mysql/connector/connection_cext.py:990: InternalError
=========================== short test summary info ============================
FAILED tests/functional/adapter/test_basic.py::TestSimpleMaterializationsMyAdapter::test_base
============================== 1 failed in 4.52s ===============================