Wenzhe Zhou has posted comments on this change. ( 
http://gerrit.cloudera.org:8080/17553 )

Change subject: IMPALA-10557: Support Kudu's multi-row transaction
......................................................................


Patch Set 14:

(4 comments)

http://gerrit.cloudera.org:8080/#/c/17553/13/be/src/exec/kudu-table-sink.cc
File be/src/exec/kudu-table-sink.cc:

http://gerrit.cloudera.org:8080/#/c/17553/13/be/src/exec/kudu-table-sink.cc@330
PS13, Line 330: Retrun
> nit: Return
Done


http://gerrit.cloudera.org:8080/#/c/17553/13/be/src/service/client-request-state.cc
File be/src/service/client-request-state.cc:

http://gerrit.cloudera.org:8080/#/c/17553/13/be/src/service/client-request-state.cc@955
PS13, Line 955: !status.ok()
> nit: maybe wrap in UNLIKELY?
Done


http://gerrit.cloudera.org:8080/#/c/17553/13/be/src/service/client-request-state.cc@1350
PS13, Line 1350: AbortTransaction()
Should be AbortKuduTransaction. Fixed it.


http://gerrit.cloudera.org:8080/#/c/17553/14/tests/custom_cluster/test_kudu.py
File tests/custom_cluster/test_kudu.py:

http://gerrit.cloudera.org:8080/#/c/17553/14/tests/custom_cluster/test_kudu.py@388
PS14, Line 388:     # Verify that multi-row transaction is not opened for 
"update".
              :     self.execute_query(self._update_query.format(table_name))
              :     cursor.execute(self._row_num_query.format(table_name))
              :     assert cursor.fetchall() == [(103,)]
              :     # Verify that multi-row transaction is not opened for 
"upsert".
              :     self.execute_query(self._upsert_query.format(table_name))
              :     cursor.execute(self._row_num_query.format(table_name))
              :     assert cursor.fetchall() == [(103,)]
              :     # Delete all rows from Kudu table. Also verify that 
multi-row transaction is not
              :     # opened for "delete".
              :     self.execute_query(self._delete_query.format(table_name))
> I'm hesitant to allow this case here -- it seems odd to proceed with the op
I will move these tests to a separate test case.



--
To view, visit http://gerrit.cloudera.org:8080/17553
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings

Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-MessageType: comment
Gerrit-Change-Id: I876ada48991afdff5d61b5d6a0417571aba7cb34
Gerrit-Change-Number: 17553
Gerrit-PatchSet: 14
Gerrit-Owner: Wenzhe Zhou <[email protected]>
Gerrit-Reviewer: Alexey Serbin <[email protected]>
Gerrit-Reviewer: Andrew Wong <[email protected]>
Gerrit-Reviewer: Bikramjeet Vig <[email protected]>
Gerrit-Reviewer: Impala Public Jenkins <[email protected]>
Gerrit-Reviewer: Qifan Chen <[email protected]>
Gerrit-Reviewer: Wenzhe Zhou <[email protected]>
Gerrit-Comment-Date: Tue, 15 Jun 2021 00:52:48 +0000
Gerrit-HasComments: Yes

Reply via email to