Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Ready: Update TS objects and Commands for TS 1.4 #651

Merged
merged 9 commits into from
Aug 9, 2016

Conversation

alexmoore
Copy link
Contributor

@alexmoore alexmoore commented Jul 28, 2016

  • Add Quantum info to the DescribeTable command's results.
  • Use FullColumnDescription.Quantum with the CreateTable command.
  • Add Local Key ASC/DESC ordering to the DescribeTable command's results. Moved to 1.5

@alexmoore alexmoore changed the title Not Ready: Update TS objects and Commands for TS 1.4 Ready: Update TS objects and Commands for TS 1.4 Aug 2, 2016
@@ -80,13 +81,18 @@ private static ColumnDescription convertPBColumnDescription(RiakTsPB.TsColumnDes
private static FullColumnDescription convertDescribeResultRowToFullColumnDescription(Row row)
{
/*
* Expected Format for the DESCRIBE function is 5 columns:
* Expected Format for the DESCRIBE function is 5 or 7 columns depending on the version.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

IMO it worth to mention Riak TS version that support each format

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Isn't this eventually going to be 8 cols in 1.4?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The ASC/DESC features got moved to 1.5.

@@ -338,7 +337,7 @@ public void test_p_TestDescribeTable() throws InterruptedException, ExecutionExc

final QueryResult tableDescription = resultFuture.get();
assertEquals(7, tableDescription.getRowsCount());
assertEquals(5, tableDescription.getColumnDescriptionsCopy().size());
assertEquals(7, tableDescription.getColumnDescriptionsCopy().size());
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Throws failure on TS 1.3.1, actual = 5.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@christophermancini Ok, try the new commit.

@alexmoore alexmoore added this to the riak-java-client-2.0.7 milestone Aug 5, 2016
@srgg
Copy link
Contributor

srgg commented Aug 9, 2016

👍

@christophermancini
Copy link
Contributor

Still getting errors against 1.3.1 with the latest commit.

Running com.basho.riak.client.api.commands.indexes.itest.ITestFullBucketRead
Tests run: 5, Failures: 0, Errors: 3, Skipped: 0, Time elapsed: 8.208 sec <<< FAILURE! - in com.basho.riak.client.api.commands.indexes.itest.ITestFullBucketRead
queryDataByUsingAnAlternateCoveragePlan(com.basho.riak.client.api.commands.indexes.itest.ITestFullBucketRead)  Time elapsed: 1.616 sec  <<< ERROR!
java.util.concurrent.ExecutionException: com.basho.riak.client.core.netty.RiakResponseException: primary_partition_unavailable
    at com.basho.riak.client.api.commands.indexes.itest.ITestFullBucketRead.queryDataByUsingAnAlternateCoveragePlan(ITestFullBucketRead.java:187)
Caused by: com.basho.riak.client.core.netty.RiakResponseException: primary_partition_unavailable

readPlainTextValuesWithReturnBody(com.basho.riak.client.api.commands.indexes.itest.ITestFullBucketRead)  Time elapsed: 1.459 sec  <<< ERROR!
com.basho.riak.client.api.cap.UnresolvedConflictException: Siblings found
    at com.basho.riak.client.api.commands.indexes.itest.ITestFullBucketRead.readPlainTextValuesWithReturnBody(ITestFullBucketRead.java:120)

readPlainTextValuesWithCoverageContextContinuouslyWithReturnBody(com.basho.riak.client.api.commands.indexes.itest.ITestFullBucketRead)  Time elapsed: 1.665 sec  <<< ERROR!
com.basho.riak.client.api.cap.UnresolvedConflictException: Siblings found
    at com.basho.riak.client.api.commands.indexes.itest.ITestFullBucketRead.transformChunkedKeysToRiakObjects(ITestFullBucketRead.java:332)
    at com.basho.riak.client.api.commands.indexes.itest.ITestFullBucketRead.performFBReadWithCoverageContext(ITestFullBucketRead.java:236)
    at com.basho.riak.client.api.commands.indexes.itest.ITestFullBucketRead.readPlainTextValuesWithCoverageContextContinuouslyWithReturnBody(ITestFullBucketRead.java:148)
Running com.basho.riak.client.api.commands.itest.ITestTimeSeries
Tests run: 19, Failures: 0, Errors: 2, Skipped: 1, Time elapsed: 2.348 sec <<< FAILURE! - in com.basho.riak.client.api.commands.itest.ITestTimeSeries
test_l_TestFetchingSingleRowsWorks(com.basho.riak.client.api.commands.itest.ITestTimeSeries)  Time elapsed: 0.026 sec  <<< ERROR!
java.util.concurrent.ExecutionException: com.basho.riak.client.core.netty.RiakResponseException: timeout
    at com.basho.riak.client.api.commands.itest.ITestTimeSeries.test_l_TestFetchingSingleRowsWorks(ITestTimeSeries.java:263)
Caused by: com.basho.riak.client.core.netty.RiakResponseException: timeout

test_n_TestDeletingRowRemovesItFromQueries(com.basho.riak.client.api.commands.itest.ITestTimeSeries)  Time elapsed: 0.019 sec  <<< ERROR!
java.util.concurrent.ExecutionException: com.basho.riak.client.core.netty.RiakResponseException: timeout
    at com.basho.riak.client.api.commands.itest.ITestTimeSeries.test_n_TestDeletingRowRemovesItFromQueries(ITestTimeSeries.java:294)
Caused by: com.basho.riak.client.core.netty.RiakResponseException: timeout
Running com.basho.riak.client.core.operations.itest.ITestCoveragePlan
Tests run: 4, Failures: 0, Errors: 3, Skipped: 0, Time elapsed: 1.035 sec <<< FAILURE! - in com.basho.riak.client.core.operations.itest.ITestCoveragePlan
obtainAlternativeCoveragePlan(com.basho.riak.client.core.operations.itest.ITestCoveragePlan)  Time elapsed: 0.022 sec  <<< ERROR!
java.util.concurrent.ExecutionException: com.basho.riak.client.core.netty.RiakResponseException: primary_partition_unavailable
    at com.basho.riak.client.core.operations.itest.ITestCoveragePlan.obtainAlternativeCoveragePlan(ITestCoveragePlan.java:68)
Caused by: com.basho.riak.client.core.netty.RiakResponseException: primary_partition_unavailable

fetchAllDataByUsingCoverageContext(com.basho.riak.client.core.operations.itest.ITestCoveragePlan)  Time elapsed: 0.323 sec  <<< ERROR!
java.lang.NullPointerException
    at com.basho.riak.client.core.operations.itest.ITestCoveragePlan.fetchAllDataByUsingCoverageContext(ITestCoveragePlan.java:157)

alternativeCoveragePlanShouldFailIfNoPrimaryPartitionAvailable(com.basho.riak.client.core.operations.itest.ITestCoveragePlan)  Time elapsed: 0.087 sec  <<< ERROR!
java.util.concurrent.ExecutionException: com.basho.riak.client.core.netty.RiakResponseException: primary_partition_unavailable
    at com.basho.riak.client.core.operations.itest.ITestCoveragePlan.alternativeCoveragePlanShouldFailIfNoPrimaryPartitionAvailable(ITestCoveragePlan.java:234)
Caused by: com.basho.riak.client.core.netty.RiakResponseException: primary_partition_unavailable
Running com.basho.riak.client.core.operations.itest.ts.ITestListKeysOperation
Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 0.533 sec <<< FAILURE! - in com.basho.riak.client.core.operations.itest.ts.ITestListKeysOperation
testSingleFetch(com.basho.riak.client.core.operations.itest.ts.ITestListKeysOperation)  Time elapsed: 0.026 sec  <<< FAILURE!
java.lang.AssertionError
    at com.basho.riak.client.core.operations.itest.ts.ITestListKeysOperation.testSingleFetch(ITestListKeysOperation.java:55)

@christophermancini
Copy link
Contributor

Tests against Riak KV 2.1.4 pass.

@alexmoore
Copy link
Contributor Author

Hmm, tests locally against TS 1.3.1 & TS 1.4 work. primary_partition_unavailable is an error from Riak that means it thinks something is offline. Maybe your TS VM isn't quite there?

@alexmoore
Copy link
Contributor Author

The Siblings issue could be caused by a slow Riak too, we use ListKeys + MultiDelete to clean up, so if something isn't listed in time for deletion you could get siblings when the next test run's data is written.

@alexmoore
Copy link
Contributor Author

Going to merge for now.

@alexmoore alexmoore merged commit 9b700f0 into develop Aug 9, 2016
@alexmoore alexmoore deleted the 928-update-describe-ts1.4 branch August 9, 2016 21:50
@alexmoore
Copy link
Contributor Author

@christophermancini Almost forgot, but I was getting some failures on 1.3.1, when I ran a single node - the coverage api tests won't work with that test configuration.

Tests in error:
  ITestFullBucketRead.setupData:62 » Runtime CoveragePlanOperation returns at le...
  ITestFullBucketRead.setupData:62 » Runtime CoveragePlanOperation returns at le...
  ITestFullBucketRead.setupData:62 » Runtime CoveragePlanOperation returns at le...
  ITestFullBucketRead.setupData:62 » Runtime CoveragePlanOperation returns at le...
  ITestFullBucketRead.setupData:62 » Runtime CoveragePlanOperation returns at le...
  ITestCoveragePlan.alternativeCoveragePlanShouldFailIfNoPrimaryPartitionAvailable:215 » Runtime
  ITestCoveragePlan.fetchAllDataByUsingCoverageContext:115 » Runtime CoveragePla...
  ITestCoveragePlan.obtainAlternativeCoveragePlan:52 » Runtime CoveragePlanOpera...
  ITestCoveragePlan.obtainCoveragePlan:91 » Runtime CoveragePlanOperation return...
  ITestCoveragePlan.obtainCoveragePlan:66 » Runtime CoveragePlanOperation return...
  ITestCoveragePlan.obtainCoveragePlanForNonExistingData:127 » Runtime CoverageP...
  ITestCoveragePlan.queryWithCoveragePlan:87 » Runtime CoveragePlanOperation ret...

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

5 participants