This is an automated email from the ASF dual-hosted git repository.
vpyatkov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 78472d85c1 IGNITE-23652 Don't swallow component stop exception (#4703)
add 6ac539cb3f IGNITE-20322 Add ability to pass an observable timestamp to
an implicit transaction (#2537)
No new revisions were added by this update.
Summary of changes:
.../handler/ClientInboundMessageHandler.java | 30 +++----
.../handler/requests/table/ClientTableCommon.java | 33 ++++++-
.../table/ClientTupleDeleteAllExactRequest.java | 20 +++--
.../table/ClientTupleDeleteAllRequest.java | 21 +++--
.../table/ClientTupleDeleteExactRequest.java | 16 ++--
.../requests/table/ClientTupleDeleteRequest.java | 16 ++--
.../requests/table/ClientTupleGetAllRequest.java | 1 +
.../table/ClientTupleGetAndDeleteRequest.java | 21 +++--
.../table/ClientTupleGetAndReplaceRequest.java | 21 +++--
.../table/ClientTupleGetAndUpsertRequest.java | 21 +++--
.../requests/table/ClientTupleGetRequest.java | 19 ++--
.../table/ClientTupleInsertAllRequest.java | 21 +++--
.../requests/table/ClientTupleInsertRequest.java | 16 ++--
.../table/ClientTupleReplaceExactRequest.java | 16 ++--
.../requests/table/ClientTupleReplaceRequest.java | 16 ++--
.../table/ClientTupleUpsertAllRequest.java | 20 +++--
.../requests/table/ClientTupleUpsertRequest.java | 21 +++--
.../client/ObservableTimestampPropagationTest.java | 4 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 20 +++--
.../app/client/ItAbstractThinClientTest.java | 6 ++
.../app/client/ItThinClientObservationTsTest.java | 68 ++++++++++++++
.../exec/fsm/CursorInitializationPhaseHandler.java | 4 +-
.../sql/engine/tx/QueryTransactionContextImpl.java | 3 +-
.../sql/engine/tx/QueryTransactionWrapperImpl.java | 12 ++-
.../engine/QueryTransactionWrapperSelfTest.java | 26 +++---
.../sql/engine/exec/ExecutionServiceImplTest.java | 2 +-
.../sql/engine/exec/TransactionEnlistTest.java | 2 +-
.../sql/engine/exec/TxAwareCursorSelfTest.java | 2 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 2 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 8 +-
.../sql/engine/framework/ImplicitTxContext.java | 2 +-
.../sql/engine/framework/NoOpTransaction.java | 40 ++++++---
.../sql/engine/framework/TestBuilders.java | 2 +-
.../sql/engine/planner/SelectCountPlannerTest.java | 4 +-
.../ItInternalTableReadOnlyScanTest.java | 2 +-
.../ItInternalTableReadWriteScanTest.java | 2 +-
.../distributed/storage/InternalTableImpl.java | 100 ++++++++++++---------
.../ignite/internal/table/TxAbstractTest.java | 2 +-
.../ignite/internal/tx/InternalTransaction.java | 15 +++-
.../org/apache/ignite/internal/tx/TxManager.java | 11 +--
.../tx/impl/IgniteAbstractTransactionImpl.java | 34 +++----
.../internal/tx/impl/IgniteTransactionsImpl.java | 14 ++-
.../tx/impl/PublicApiThreadingTransaction.java | 10 +++
.../internal/tx/impl/ReadOnlyTransactionImpl.java | 25 +++++-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 42 +++++++--
.../ignite/internal/tx/impl/TxManagerImpl.java | 16 ++--
.../apache/ignite/internal/tx/TxManagerTest.java | 55 ++++++------
.../tx/impl/ReadOnlyTransactionImplTest.java | 1 +
.../tx/impl/ReadWriteTransactionImplTest.java | 4 +-
49 files changed, 580 insertions(+), 289 deletions(-)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientObservationTsTest.java
