[ignite-3] branch ignite-15341 updated (d925f31 -> 3824dfb)
This is an automated email from the ASF dual-hosted git repository. amashenkov pushed a change to branch ignite-15341 in repository https://gitbox.apache.org/repos/asf/ignite-3.git. from d925f31 Minors. add 3824dfb Minors. No new revisions were added by this update. Summary of changes: .../apache/ignite/internal/runner/app/jdbc/ITJdbcMetadataSelfTest.java | 2 -- 1 file changed, 2 deletions(-)
[ignite-3] branch ignite-15341 updated (1a32d67 -> d925f31)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15341
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
discard 1a32d67 Minors.
add bba2a15 Minors.
add 2471da3 IGNITE-15187 JDBC driver for 3.0: ResultSet metadata (#345)
add 84c8147 Merge branch 'main' into ignite-15341
add d925f31 Minors.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (1a32d67)
\
N -- N -- N refs/heads/ignite-15341 (d925f31)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../table/TableIndexConfigurationSchema.java | 2 +-
.../processors/query/calcite/SqlCursor.java| 6 +
.../internal/processors/query/calcite/Stubs.java | 8 +
.../query/calcite/exec/ExecutionServiceImpl.java | 4 +-
.../processors/query/calcite/util/Commons.java | 15 +-
.../client/proto/query/JdbcQueryEventHandler.java | 9 ++
.../client/proto/query/event/JdbcColumnMeta.java | 45 +-
.../proto/query/event/JdbcMetaColumnsResult.java | 10 ++
...eRequest.java => JdbcQueryMetadataRequest.java} | 10 +-
.../internal/client/proto/ClientDataType.java | 3 +
.../internal/client/proto/ClientMessagePacker.java | 8 +
.../client/proto/ClientMessageUnpacker.java| 4 +
.../ignite/internal/client/proto/ClientOp.java | 3 +
.../handler/ClientInboundMessageHandler.java | 4 +
.../client/handler/JdbcQueryEventHandlerImpl.java | 64
...est.java => ClientSqlQueryMetadataRequest.java} | 12 +-
.../client/query/JdbcClientQueryEventHandler.java | 10 ++
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 23 ++-
.../internal/jdbc/JdbcResultSetMetadata.java | 163 +
.../org/apache/ignite/client/fakes/FakeCursor.java | 5 +
.../runner/app/jdbc/AbstractJdbcSelfTest.java | 7 +-
...st.java => ITJdbcConnectionPropertiesTest.java} | 2 +-
...SelfTest.java => ITJdbcConnectionSelfTest.java} | 2 +-
...taSelfTest.java => ITJdbcMetadataSelfTest.java} | 61 +---
...tSelfTest.java => ITJdbcResultSetSelfTest.java} | 49 +++
...tSelfTest.java => ITJdbcStatementSelfTest.java} | 8 +-
.../SchemaConfigurationConverterTest.java | 4 +-
.../SchemaDescriptorConverterTest.java | 4 +-
.../internal/table/distributed/TableManager.java | 1 -
29 files changed, 417 insertions(+), 129 deletions(-)
copy
modules/client-common/src/main/java/org/apache/ignite/client/proto/query/event/{QueryCloseRequest.java
=> JdbcQueryMetadataRequest.java} (87%)
copy
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/{ClientSqlColumnMetadataRequest.java
=> ClientSqlQueryMetadataRequest.java} (83%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/jdbc/JdbcResultSetMetadata.java
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/{JdbcConnectionPropertiesTest.java
=> ITJdbcConnectionPropertiesTest.java} (97%)
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/{JdbcConnectionSelfTest.java
=> ITJdbcConnectionSelfTest.java} (99%)
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/{JdbcMetadataSelfTest.java
=> ITJdbcMetadataSelfTest.java} (93%)
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/{JdbcResultSetSelfTest.java
=> ITJdbcResultSetSelfTest.java} (95%)
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/{JdbcStatementSelfTest.java
=> ITJdbcStatementSelfTest.java} (99%)
svn commit: r50019 - /release/ignite/deb/.htaccess
Author: mmuzaf Date: Mon Sep 20 13:32:52 2021 New Revision: 50019 Log: RedirectMatch permanent (.*)ignite/deb/(.*) https://apache.jfrog.io/ui/native/ignite-deb/$2 Modified: release/ignite/deb/.htaccess Modified: release/ignite/deb/.htaccess == --- release/ignite/deb/.htaccess (original) +++ release/ignite/deb/.htaccess Mon Sep 20 13:32:52 2021 @@ -1 +1 @@ -RedirectMatch permanent (.*)ignite/deb/(.*) https://dl.bintray.com/apache/ignite-deb/$2 +RedirectMatch permanent (.*)ignite/deb/(.*) https://apache.jfrog.io/ui/native/ignite-deb/$2
svn commit: r50018 - /release/ignite/rpm/.htaccess
Author: mmuzaf Date: Mon Sep 20 13:32:07 2021 New Revision: 50018 Log: RedirectMatch permanent (.*)ignite/deb/(.*) https://apache.jfrog.io/ui/native/ignite-deb/$2 Modified: release/ignite/rpm/.htaccess Modified: release/ignite/rpm/.htaccess == --- release/ignite/rpm/.htaccess (original) +++ release/ignite/rpm/.htaccess Mon Sep 20 13:32:07 2021 @@ -1 +1 @@ -RedirectMatch permanent (.*)ignite/rpm/(.*) https://dl.bintray.com/apache/ignite-rpm/$2 +RedirectMatch permanent (.*)ignite/rpm/(.*) https://apache.jfrog.io/ui/native/ignite-rpm/$2
[ignite-3] branch main updated: IGNITE-15187 JDBC driver for 3.0: ResultSet metadata (#345)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 2471da3 IGNITE-15187 JDBC driver for 3.0: ResultSet metadata (#345)
2471da3 is described below
commit 2471da39a750537b6b3a1f1ba4273a52bac07245
Author: Vladimir Ermakov <85303706+vladermako...@users.noreply.github.com>
AuthorDate: Mon Sep 20 16:31:53 2021 +0300
IGNITE-15187 JDBC driver for 3.0: ResultSet metadata (#345)
---
.../processors/query/calcite/SqlCursor.java| 6 +
.../internal/processors/query/calcite/Stubs.java | 8 +
.../query/calcite/exec/ExecutionServiceImpl.java | 4 +-
.../processors/query/calcite/util/Commons.java | 15 +-
.../client/proto/query/JdbcQueryEventHandler.java | 9 ++
.../client/proto/query/event/JdbcColumnMeta.java | 45 +-
.../proto/query/event/JdbcMetaColumnsResult.java | 10 ++
...nsResult.java => JdbcQueryMetadataRequest.java} | 72 +++--
.../internal/client/proto/ClientDataType.java | 3 +
.../internal/client/proto/ClientMessagePacker.java | 8 +
.../client/proto/ClientMessageUnpacker.java| 4 +
.../ignite/internal/client/proto/ClientOp.java | 3 +
.../handler/ClientInboundMessageHandler.java | 4 +
.../client/handler/JdbcQueryEventHandlerImpl.java | 64
.../sql/ClientSqlQueryMetadataRequest.java | 54 +++
.../client/query/JdbcClientQueryEventHandler.java | 10 ++
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 23 ++-
.../internal/jdbc/JdbcResultSetMetadata.java | 163 +
.../org/apache/ignite/client/fakes/FakeCursor.java | 5 +
.../runner/app/jdbc/AbstractJdbcSelfTest.java | 7 +-
...st.java => ITJdbcConnectionPropertiesTest.java} | 2 +-
...SelfTest.java => ITJdbcConnectionSelfTest.java} | 2 +-
...taSelfTest.java => ITJdbcMetadataSelfTest.java} | 63 +---
...tSelfTest.java => ITJdbcResultSetSelfTest.java} | 49 +++
...tSelfTest.java => ITJdbcStatementSelfTest.java} | 8 +-
25 files changed, 471 insertions(+), 170 deletions(-)
diff --git
a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlCursor.java
b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlCursor.java
index b5bb641..31007b9 100644
---
a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlCursor.java
+++
b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlCursor.java
@@ -17,6 +17,7 @@
package org.apache.ignite.internal.processors.query.calcite;
+import
org.apache.ignite.internal.processors.query.calcite.prepare.FieldsMetadata;
import org.apache.ignite.internal.util.Cursor;
/**
@@ -29,4 +30,9 @@ public interface SqlCursor extends Cursor {
* @return Query type.
*/
SqlQueryType getQueryType();
+
+/**
+ * @return Column metadata.
+ */
+FieldsMetadata getColumnMetadata();
}
diff --git
a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/Stubs.java
b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/Stubs.java
index 6ebc28c..43d371f 100644
---
a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/Stubs.java
+++
b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/Stubs.java
@@ -17,6 +17,8 @@
package org.apache.ignite.internal.processors.query.calcite;
import java.lang.reflect.Type;
+import java.math.BigDecimal;
+import java.math.BigInteger;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
@@ -83,6 +85,12 @@ public class Stubs {
if (type == String.class)
return UUID.randomUUID().toString();
+if (type == BigDecimal.class)
+return
BigDecimal.valueOf(ThreadLocalRandom.current().nextDouble());
+
+if (type == BigInteger.class)
+return
BigDecimal.valueOf(ThreadLocalRandom.current().nextDouble()).unscaledValue();
+
throw new IllegalStateException("Can't generate value of type " +
type.getTypeName());
}
}
diff --git
a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java
b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java
index 032b3cd..c99eff6 100644
---
a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java
+++
b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java
@@ -522,12 +522,12 @@ public class ExecutionServiceImpl implements
ExecutionService {
res.add(ectx.rowHandler().get(i, row));
return res;
-
[ignite-3] branch ignite-15341 updated (f9bd0a7 -> 1a32d67)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15341
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from f9bd0a7 Merge branch 'main' into ignite-15341
add 7e726b8 IGNITE-15186 Implement basic JDBC client: Statement,
ResultSet (#284)
add 74eef32 IGNITE-15501 Improvements in ConfigurationExtension - support
for listeners and internal schema extensions (#334)
add f1c39fd IGNITE-15520 Fixed NamedListChange class type parameters.
(#341)
add 350fb95 IGNITE-15288 Full-featured RaftGroupService - Fixes #321.
add 83fcbbd IGNITE-15339 Fix broken access methods for column of temporal
types after row upgrade (#335)
add 1f1ca6c IGNITE-15188 JDBC driver for 3.0: Database metadata (#339)
add 403085d IGNITE-15404 Rework disctributed configuration flow. (#330)
add c7d44a5 IGNITE-15519: Make tuples serializable (#343)
add c065cbd IGNITE-15430 .NET: Add Table API (#342)
add 2bea2cc IGNITE-15519: Fix compilation due to competed commits.
add a250e8b IGNITE-15444 Implement MetaStorageManager component stop
(#332)
add 9ab3ae2 IGNITE-15438 Fix unexpectedly large allocations in
InternalTableImpl (#315)
add 9d6f8bf Merge branch 'main' into ignite-15341
add 1a32d67 Minors.
No new revisions were added by this update.
Summary of changes:
.../ignite/internal/affinity/AffinityManager.java | 164 --
.../ignite/internal/affinity/AffinityUtils.java} | 38 +-
.../internal/affinity/event/AffinityEvent.java | 31 -
.../affinity/event/AffinityEventParameters.java| 64 -
.../internal/affinity/AffinityManagerTest.java | 289 ---
.../internal/affinity/AffinityServiceTest.java | 77 +
.../java/org/apache/ignite/table/KeyValueView.java |2 +-
.../java/org/apache/ignite/table/TableView.java|2 +-
.../java/org/apache/ignite/table/TupleImpl.java| 55 +-
.../ExecutionService.java => QueryProcessor.java} | 29 +-
.../{prepare/QueryPlan.java => SqlCursor.java} | 18 +-
.../query/calcite/SqlQueryProcessor.java |7 +-
.../{prepare/DdlPlan.java => SqlQueryType.java}| 52 +-
.../query/calcite/exec/ExecutionService.java |4 +-
.../query/calcite/exec/ExecutionServiceImpl.java | 22 +-
.../processors/query/calcite/util/Commons.java | 16 +-
.../ignite/client/proto/query/ClientMessage.java} | 26 +-
.../client/proto/query/IgniteQueryErrorCode.java | 80 +
.../client/proto/query/JdbcQueryEventHandler.java | 104 ++
.../client/proto/query/JdbcStatementType.java} | 33 +-
.../ignite/client/proto/query/SqlStateCode.java| 81 +
.../proto/query/event/BatchExecuteRequest.java | 120 ++
.../proto/query/event/BatchExecuteResult.java | 94 +
.../proto/query/event/ClientMessageUtils.java} | 51 +-
.../client/proto/query/event/JdbcColumnMeta.java | 344
.../proto/query/event/JdbcMetaColumnsRequest.java | 102 +
.../proto/query/event/JdbcMetaColumnsResult.java | 108 ++
.../query/event/JdbcMetaPrimaryKeysRequest.java| 86 +
.../query/event/JdbcMetaPrimaryKeysResult.java | 114 ++
.../proto/query/event/JdbcMetaSchemasRequest.java | 70 +
.../proto/query/event/JdbcMetaSchemasResult.java | 94 +
.../proto/query/event/JdbcMetaTablesRequest.java | 121 ++
.../proto/query/event/JdbcMetaTablesResult.java| 99 +
.../proto/query/event/JdbcPrimaryKeyMeta.java | 167 ++
.../client/proto/query/event/JdbcTableMeta.java| 138 ++
.../ignite/client/proto/query/event/Query.java | 87 +
.../proto/query/event/QueryCloseRequest.java} | 49 +-
.../proto/query/event/QueryCloseResult.java} | 29 +-
.../proto/query/event/QueryExecuteRequest.java | 137 ++
.../proto/query/event/QueryExecuteResult.java | 117 ++
.../proto/query/event/QueryFetchRequest.java | 86 +
.../client/proto/query/event/QueryFetchResult.java | 123 ++
.../proto/query/event/QuerySingleResult.java | 189 ++
.../ignite/client/proto/query/event/Response.java | 134 ++
.../client/proto/query/event}/package-info.java|5 +-
.../ignite/client/proto/query}/package-info.java |5 +-
.../internal/client/proto/ClientDataType.java |3 +
.../internal/client/proto/ClientMessagePacker.java | 158 ++
.../client/proto/ClientMessageUnpacker.java| 82 +
.../internal/client/proto/ClientMsgPackType.java |3 +
.../ignite/internal/client/proto/ClientOp.java | 24 +
.../proto/ClientMessagePackerUnpackerTest.java | 63 +
modules/client-handler/pom.xml |5 +
.../ignite/client/handler/ITClientHandlerTest.java |3 +-
.../ignite/client/handler/ClientHandlerModule.java | 11 +-
.../handler/ClientInboundMessageHandler.java | 44 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 285 +++
.../ClientSqlCloseRequest.java}| 40 +-
[ignite-3] branch main updated (a250e8b -> 9ab3ae2)
This is an automated email from the ASF dual-hosted git repository. amashenkov pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/ignite-3.git. from a250e8b IGNITE-15444 Implement MetaStorageManager component stop (#332) add 9ab3ae2 IGNITE-15438 Fix unexpectedly large allocations in InternalTableImpl (#315) No new revisions were added by this update. Summary of changes: .../internal/schema/row/TemporalTypesHelper.java | 2 +- .../distributed/storage/InternalTableImpl.java | 76 ++ 2 files changed, 35 insertions(+), 43 deletions(-)
[ignite-3] branch ignite-15382 updated (17dcd41 -> ef595c4)
This is an automated email from the ASF dual-hosted git repository. amashenkov pushed a change to branch ignite-15382 in repository https://gitbox.apache.org/repos/asf/ignite-3.git. from 17dcd41 Minor after review. add 2fa8a85 IGNITE-15047 Implemented internal configuration roots and extensions. (#290) add b8db213 IGNITE-15420 Configuration tests moved to a proper module (#305) add a4b7b88 IGNITE-15417 Creates cursorId on client side. Fixes #307 add 9e814dd IGNITE-15433 Improve network annotation processor error messages (#310) add 0d12630 IGNITE-15393 Add errorprone plugin (#304) add b0ff96e IGNITE-15338 Return null in storage methods if a DataRow is not found (#297) add 9e226df IGNITE-15370 [Ignite 3] Add style check to the build lifecycle (#303) add 309df75 IGNITE-15449 Renamed missed integration test class names to start with IT prefix. Fixes #317 add ab1b43e Revert "IGNITE-15393 Add errorprone plugin (#304)" (#320) add 332092c IGNITE-15440 Fix some WARNINGS in Maven build (#312) add 88ddff2 IGNITE-15398 Fix bugs in nodes start flow and free some netty resources properly. Fixes #314 add 2a26649 IGNITE-15454 Fixed hanging test SchemaChangeTableViewTest. Fixes #318 add 2149ef0 IGNITE-15356 .NET: Add basic thin client (#306) add b1a9355 IGNITE-15356 Fix code style add 4ba31b2 IGNITE-15456 Integrate RocksDBKeyValueStorage into the production code (#323) add aeb8ad6 IGNITE-15486 JUnit configuration extension implemented (#329) add db66f4b IGNITE-15175 Fixed javadoc in Rest module. Fixes #319 add 33403f6 IGNITE-15432 .NET: Fix tests for TeamCity project (#331) add 551a9f0 IGNITE-15361 Thin 3.0: Add KeyValueBinaryView (#328) add 7e726b8 IGNITE-15186 Implement basic JDBC client: Statement, ResultSet (#284) add 74eef32 IGNITE-15501 Improvements in ConfigurationExtension - support for listeners and internal schema extensions (#334) add f1c39fd IGNITE-15520 Fixed NamedListChange class type parameters. (#341) add 350fb95 IGNITE-15288 Full-featured RaftGroupService - Fixes #321. add 83fcbbd IGNITE-15339 Fix broken access methods for column of temporal types after row upgrade (#335) add 1f1ca6c IGNITE-15188 JDBC driver for 3.0: Database metadata (#339) add 403085d IGNITE-15404 Rework disctributed configuration flow. (#330) add c7d44a5 IGNITE-15519: Make tuples serializable (#343) add c065cbd IGNITE-15430 .NET: Add Table API (#342) add 2bea2cc IGNITE-15519: Fix compilation due to competed commits. add a250e8b IGNITE-15444 Implement MetaStorageManager component stop (#332) add ef595c4 Merge branch 'main' into ignite-15382 No new revisions were added by this update. Summary of changes: DEVNOTES.md| 13 +- assembly/assembly.xml |4 +- check-rules/checkstyle-disabled-modules.xml|1 - check-rules/checkstyle-suppressions.xml|1 + .../CheckUnusedDependenciesAndPluginsInParent.sh |3 +- .../ignite/internal/affinity/AffinityManager.java | 164 -- .../ignite/internal/affinity/AffinityUtils.java} | 42 +- .../affinity/event/AffinityEventParameters.java| 64 - .../internal/affinity/AffinityManagerTest.java | 296 --- .../internal/affinity/AffinityServiceTest.java | 77 + .../java/org/apache/ignite/table/KeyValueView.java | 13 +- .../java/org/apache/ignite/table/TableView.java|2 +- .../facebook/presto/bytecode/ClassDefinition.java | 14 +- modules/calcite/pom.xml| 35 +- .../ExecutionService.java => QueryProcessor.java} | 29 +- .../processors/query/calcite/SqlCursor.java} | 16 +- .../query/calcite/SqlQueryProcessor.java |7 +- .../processors/query/calcite/SqlQueryType.java}| 46 +- .../query/calcite/exec/ExecutionService.java |4 +- .../query/calcite/exec/ExecutionServiceImpl.java | 22 +- .../processors/query/calcite/util/Commons.java | 16 +- ...igCommandTest.java => ITConfigCommandTest.java} |2 +- modules/client-common/pom.xml |8 - .../ignite/client/proto/query/ClientMessage.java} | 27 +- .../client/proto/query/IgniteQueryErrorCode.java | 80 + .../client/proto/query/JdbcQueryEventHandler.java | 104 ++ .../client/proto/query/JdbcStatementType.java} | 35 +- .../ignite/client/proto/query/SqlStateCode.java| 81 + .../proto/query/event/BatchExecuteRequest.java | 120 ++ .../proto/query/event/BatchExecuteResult.java | 94 + .../proto/query/event/ClientMessageUtils.java | 52 + .../client/proto/query/event/JdbcColumnMeta.java | 344 .../proto/query/event/JdbcMetaColumnsRequest.java | 102 + .../proto/query/event/JdbcMetaColumnsResult.java | 108 ++ .../query/event/JdbcMetaPrimaryKeysRequest.java| 86 +
[ignite-3] branch ignite-15382 updated (9566e9e -> 17dcd41)
This is an automated email from the ASF dual-hosted git repository. amashenkov pushed a change to branch ignite-15382 in repository https://gitbox.apache.org/repos/asf/ignite-3.git. from 9566e9e Minor. add 17dcd41 Minor after review. No new revisions were added by this update. Summary of changes: .../org/apache/ignite/schema/SchemaBuilders.java | 7 -- .../main/java/org/apache/ignite/table/Tuple.java | 25 +++--- .../ignite/internal/table/TupleFactoryImpl.java| 11 ++ .../apache/ignite/internal/table/TupleImpl.java| 13 ++- 4 files changed, 40 insertions(+), 16 deletions(-)
[ignite-3] branch ignite-15438 updated (e473df5 -> 8ec7e2e)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15438
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from e473df5 Merge branch 'main' into ignite-15438
add 88ddff2 IGNITE-15398 Fix bugs in nodes start flow and free some netty
resources properly. Fixes #314
add 2a26649 IGNITE-15454 Fixed hanging test SchemaChangeTableViewTest.
Fixes #318
add 2149ef0 IGNITE-15356 .NET: Add basic thin client (#306)
add b1a9355 IGNITE-15356 Fix code style
add 4ba31b2 IGNITE-15456 Integrate RocksDBKeyValueStorage into the
production code (#323)
add aeb8ad6 IGNITE-15486 JUnit configuration extension implemented (#329)
add db66f4b IGNITE-15175 Fixed javadoc in Rest module. Fixes #319
add 33403f6 IGNITE-15432 .NET: Fix tests for TeamCity project (#331)
add 551a9f0 IGNITE-15361 Thin 3.0: Add KeyValueBinaryView (#328)
add 7e726b8 IGNITE-15186 Implement basic JDBC client: Statement,
ResultSet (#284)
add 74eef32 IGNITE-15501 Improvements in ConfigurationExtension - support
for listeners and internal schema extensions (#334)
add f1c39fd IGNITE-15520 Fixed NamedListChange class type parameters.
(#341)
add 350fb95 IGNITE-15288 Full-featured RaftGroupService - Fixes #321.
add 83fcbbd IGNITE-15339 Fix broken access methods for column of temporal
types after row upgrade (#335)
add 1f1ca6c IGNITE-15188 JDBC driver for 3.0: Database metadata (#339)
add 403085d IGNITE-15404 Rework disctributed configuration flow. (#330)
add c7d44a5 IGNITE-15519: Make tuples serializable (#343)
add c065cbd IGNITE-15430 .NET: Add Table API (#342)
add 2bea2cc IGNITE-15519: Fix compilation due to competed commits.
add a250e8b IGNITE-15444 Implement MetaStorageManager component stop
(#332)
add 8ec7e2e Merge branch 'main' into ignite-15438
No new revisions were added by this update.
Summary of changes:
check-rules/checkstyle-disabled-modules.xml|1 -
.../ignite/internal/affinity/AffinityManager.java | 164 --
.../ignite/internal/affinity/AffinityUtils.java} | 42 +-
.../affinity/event/AffinityEventParameters.java| 64 -
.../internal/affinity/AffinityManagerTest.java | 297 ---
.../internal/affinity/AffinityServiceTest.java | 77 +
.../java/org/apache/ignite/table/KeyValueView.java | 13 +-
.../java/org/apache/ignite/table/TableView.java|2 +-
.../java/org/apache/ignite/table/TupleImpl.java| 55 +-
.../ExecutionService.java => QueryProcessor.java} | 29 +-
.../processors/query/calcite/SqlCursor.java} | 16 +-
.../query/calcite/SqlQueryProcessor.java |7 +-
.../processors/query/calcite/SqlQueryType.java}| 46 +-
.../query/calcite/exec/ExecutionService.java |4 +-
.../query/calcite/exec/ExecutionServiceImpl.java | 22 +-
.../processors/query/calcite/util/Commons.java | 16 +-
.../ignite/client/proto/query/ClientMessage.java} | 27 +-
.../client/proto/query/IgniteQueryErrorCode.java | 80 +
.../client/proto/query/JdbcQueryEventHandler.java | 104 ++
.../client/proto/query/JdbcStatementType.java} | 35 +-
.../ignite/client/proto/query/SqlStateCode.java| 81 +
.../proto/query/event/BatchExecuteRequest.java | 120 ++
.../proto/query/event/BatchExecuteResult.java | 94 +
.../proto/query/event/ClientMessageUtils.java | 52 +
.../client/proto/query/event/JdbcColumnMeta.java | 344
.../proto/query/event/JdbcMetaColumnsRequest.java | 102 +
.../proto/query/event/JdbcMetaColumnsResult.java | 108 ++
.../query/event/JdbcMetaPrimaryKeysRequest.java| 86 +
.../query/event/JdbcMetaPrimaryKeysResult.java | 114 ++
.../proto/query/event/JdbcMetaSchemasRequest.java | 70 +
.../proto/query/event/JdbcMetaSchemasResult.java | 94 +
.../proto/query/event/JdbcMetaTablesRequest.java | 121 ++
.../proto/query/event/JdbcMetaTablesResult.java| 99 +
.../proto/query/event/JdbcPrimaryKeyMeta.java | 167 ++
.../client/proto/query/event/JdbcTableMeta.java| 138 ++
.../ignite/client/proto/query/event/Query.java | 87 +
.../proto/query/event/QueryCloseRequest.java | 70 +
.../proto/query/event/QueryCloseResult.java} | 36 +-
.../proto/query/event/QueryExecuteRequest.java | 137 ++
.../proto/query/event/QueryExecuteResult.java | 117 ++
.../proto/query/event/QueryFetchRequest.java | 86 +
.../client/proto/query/event/QueryFetchResult.java | 123 ++
.../proto/query/event/QuerySingleResult.java | 189 ++
.../ignite/client/proto/query/event/Response.java | 134 ++
.../proto/{ => query/event}/package-info.java |5 +-
.../client/proto/{ => query}/package-info.java |5 +-
.../client/proto/ClientDataType.java |5 +-
.../client/proto/ClientErrorCode.java |2 +-
[ignite-3] branch main updated: IGNITE-15444 Implement MetaStorageManager component stop (#332)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new a250e8b IGNITE-15444 Implement MetaStorageManager component stop
(#332)
a250e8b is described below
commit a250e8bec609b6c2d02e1391f0493d4ca05329ad
Author: Mirza Aliev
AuthorDate: Mon Sep 20 15:47:24 2021 +0300
IGNITE-15444 Implement MetaStorageManager component stop (#332)
---
.../ignite/internal/util/IgniteSpinBusyLock.java | 91
.../internal/util/IgniteSpinReadWriteLock.java | 406 +
.../internal/metastorage/client/CursorImpl.java| 13 +-
.../metastorage/client/MetaStorageServiceImpl.java | 20 +-
.../internal/metastorage/MetaStorageManager.java | 478 +
.../java/org/apache/ignite/internal/raft/Loza.java | 2 +-
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 5 +-
.../ignite/internal/table/TableManagerTest.java| 37 +-
8 files changed, 937 insertions(+), 115 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteSpinBusyLock.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteSpinBusyLock.java
new file mode 100644
index 000..06a9d48
--- /dev/null
+++
b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteSpinBusyLock.java
@@ -0,0 +1,91 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.util;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Synchronization aid to track "busy" state of a subsystem that owns it.
+ *
+ * This class is implemented
+ * over {@link IgniteSpinReadWriteLock}.
+ *
+ * For example, there may be a manager that have different threads for some
+ * purposes and the manager must not be stopped while at least a single thread
+ * is in "busy" state. In this situation each thread must enter to "busy"
+ * state calling method {@link #enterBusy()} in critical pieces of code
+ * which, i.e. use grid kernal functionality, notifying that the manager
+ * and the whole grid kernal cannot be stopped while it's in progress. Once
+ * the activity is done, the thread should leave "busy" state calling method
+ * {@link #leaveBusy()}. The manager itself, when stopping, should call method
+ * {@link #block} that blocks till all activities leave "busy" state.
+ * @see IgniteSpinReadWriteLock
+ */
+public class IgniteSpinBusyLock {
+/** Underlying read-write lock. */
+private final IgniteSpinReadWriteLock lock = new IgniteSpinReadWriteLock();
+
+/**
+ * Enters "busy" state.
+ *
+ * @return {@code true} if entered to busy state.
+ */
+public boolean enterBusy() {
+return !lock.writeLockedByCurrentThread() && lock.tryReadLock();
+}
+
+/**
+ * Checks if busy lock was blocked by current thread.
+ *
+ * @return {@code True} if busy lock was blocked by current thread.
+ */
+public boolean blockedByCurrentThread() {
+return lock.writeLockedByCurrentThread();
+}
+
+/**
+ * Leaves "busy" state.
+ */
+public void leaveBusy() {
+lock.readUnlock();
+}
+
+/**
+ * Blocks current thread till all activities left "busy" state
+ * and prevents them from further entering to "busy" state.
+ */
+public void block() {
+lock.writeLock();
+}
+
+/**
+ * @param millis Timeout.
+ * @return {@code True} if lock was acquired.
+ * @throws InterruptedException If interrupted.
+ */
+public boolean tryBlock(long millis) throws InterruptedException {
+return lock.tryWriteLock(millis, TimeUnit.MILLISECONDS);
+}
+
+/**
+ * Makes possible for activities entering busy state again.
+ */
+public void unblock() {
+lock.writeUnlock();
+}
+}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteSpinReadWriteLock.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteSpinReadWriteLock.java
new file mode 100644
index 000..f1deb9f
--- /dev/null
+++
[ignite] branch master updated: IGNITE-15328 Consistency recovery command (Read Repair via control.ch) should support cancellation (#9409)
This is an automated email from the ASF dual-hosted git repository.
av pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new baf2c91 IGNITE-15328 Consistency recovery command (Read Repair via
control.ch) should support cancellation (#9409)
baf2c91 is described below
commit baf2c9143d3b0e40e2440baf6b4f99f4bd3041d0
Author: Anton Vinogradov
AuthorDate: Mon Sep 20 12:09:36 2021 +0300
IGNITE-15328 Consistency recovery command (Read Repair via control.ch)
should support cancellation (#9409)
---
docs/_docs/sql-reference/operational-commands.adoc | 24 -
.../consistency/ConsistencyCommand.java| 34 ++-
.../internal/commandline/query/KillCommand.java| 30 +-
.../internal/commandline/query/KillSubcommand.java | 3 +
.../util/GridCommandHandlerAbstractTest.java | 3 +
.../util/GridCommandHandlerConsistencyTest.java| 20 +++-
.../ignite/util/KillCommandsCommandShTest.java | 107 +
.../internal/processors/job/GridJobWorker.java | 6 +-
.../consistency/VisorConsistencyCancelTask.java| 81
.../consistency/VisorConsistencyRepairTask.java| 57 ---
.../VisorConsistencyRepairTaskResult.java | 102
.../main/resources/META-INF/classnames.properties | 2 +
12 files changed, 447 insertions(+), 22 deletions(-)
diff --git a/docs/_docs/sql-reference/operational-commands.adoc
b/docs/_docs/sql-reference/operational-commands.adoc
index be7223f..d1f4641 100644
--- a/docs/_docs/sql-reference/operational-commands.adoc
+++ b/docs/_docs/sql-reference/operational-commands.adoc
@@ -334,7 +334,7 @@ KILL CONTINUOUS
'6fa749ee-7cf8-4635-be10-36a1c75267a7_54321' '6fa749ee-7cf8-4635
== KILL SERVICE
-The `KILL SERVICE` command allows you to cance a running service.
+The `KILL SERVICE` command allows you to cancel a running service.
[tabs]
--
@@ -370,3 +370,25 @@ control.bat --kill SERVICE name
* `name` - corresponds to the name you selected for the service upon the
deployment time.
You can always find it with the
link:monitoring-metrics/system-views#services[SERVICES] view.
+
+
+== KILL CONSISTENCY repair/check operations
+
+The `KILL CONSISTENCY` command allows you to cancel all running consistency
repair/check operations.
+
+[tabs]
+--
+
+tab:Unix[]
+[source,bash]
+
+./control.sh --kill CONSISTENCY
+
+
+tab:Windows[]
+[source,bash]
+
+control.bat --kill CONSISTENCY
+
+
+--
diff --git
a/modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/consistency/ConsistencyCommand.java
b/modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/consistency/ConsistencyCommand.java
index a1f56c4..10ef23a 100644
---
a/modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/consistency/ConsistencyCommand.java
+++
b/modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/consistency/ConsistencyCommand.java
@@ -20,6 +20,7 @@ package org.apache.ignite.internal.commandline.consistency;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.logging.Logger;
+import org.apache.ignite.IgniteCheckedException;
import org.apache.ignite.internal.client.GridClient;
import org.apache.ignite.internal.client.GridClientConfiguration;
import org.apache.ignite.internal.commandline.AbstractCommand;
@@ -27,6 +28,7 @@ import org.apache.ignite.internal.commandline.Command;
import org.apache.ignite.internal.commandline.CommandArgIterator;
import org.apache.ignite.internal.commandline.CommandLogger;
import
org.apache.ignite.internal.visor.consistency.VisorConsistencyRepairTaskArg;
+import
org.apache.ignite.internal.visor.consistency.VisorConsistencyRepairTaskResult;
import static org.apache.ignite.internal.commandline.CommandList.CONSISTENCY;
import static
org.apache.ignite.internal.commandline.TaskExecutor.BROADCAST_UUID;
@@ -46,8 +48,12 @@ public class ConsistencyCommand extends
AbstractCommand {
/** Task name. */
private String taskName;
+/** Node id. */
+private UUID nodeId;
+
/** {@inheritDoc} */
@Override public Object execute(GridClientConfiguration clientCfg, Logger
log) throws Exception {
try (GridClient client = Command.startClient(clientCfg)) {
@@ -84,7 +89,7 @@ public class KillCommand extends AbstractCommand {
client,
taskName,
taskArgs,
-null,
+nodeId,
clientCfg
);
}
@@ -119,6 +124,8 @@ public class KillCommand extends AbstractCommand {
taskName = VisorComputeCancelSessionTask.class.getName();
+nodeId = null;
+
break;
case SERVICE:
@@ -126,6 +133,8 @@ public class KillCommand extends AbstractCommand {
