Skip to content

Added options to fine-tune settings for bulk operations #43509

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.

Sign up for GitHub

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

Merged
FabianMeiswinkel merged 3 commits into from
Dec 26, 2024

Update PartitionScopeThresholds.java

158caeb
Select commit
Loading
Failed to load commit list.
Merged

Added options to fine-tune settings for bulk operations #43509

Update PartitionScopeThresholds.java
158caeb
Select commit
Loading
Failed to load commit list.
Azure Pipelines / java - cosmos - ci succeeded Dec 26, 2024 in 1h 12m 59s

Build #20241223.1 had test failures

0 errors / 8,554 warnings

Details

Tests

  • Failed: 3 (0.00%)
  • Passed: 131,818 (98.81%)
  • Other: 1,587 (1.19%)
  • Total: 133,408
Code coverage

  • 2174 of 82476 lines covered (2.64%)

Annotations

Check failure on line 1 in FullFidelityChangeFeedProcessorTest::fullFidelityChangeFeedProcessorWithThroughputControl[Gateway with Session consistency][false](4)

See this annotation in the file changed.

@azure-pipelines azure-pipelines / java - cosmos - ci

FullFidelityChangeFeedProcessorTest::fullFidelityChangeFeedProcessorWithThroughputControl[Gateway with Session consistency][false](4) 

expected: 200
 but was: 187
Raw output 
java.lang.AssertionError: 

expected: 200
 but was: 187
	at com.azure.cosmos.rx.changefeed.epkversion.FullFidelityChangeFeedProcessorTest.validateChangeFeedProcessing(FullFidelityChangeFeedProcessorTest.java:1758)
	at com.azure.cosmos.rx.changefeed.epkversion.FullFidelityChangeFeedProcessorTest.fullFidelityChangeFeedProcessorWithThroughputControl(FullFidelityChangeFeedProcessorTest.java:1633)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.testng.internal.invokers.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:136)
	at org.testng.internal.invokers.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:44)
	at org.testng.internal.invokers.InvokeMethodRunnable.call(InvokeMethodRunnable.java:72)
	at org.testng.internal.invokers.InvokeMethodRunnable.call(InvokeMethodRunnable.java:10)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:750)

Check failure on line 1 in fullFidelityChangeFeedProcessorWithThroughputControl

See this annotation in the file changed.

@azure-pipelines azure-pipelines / java - cosmos - ci

fullFidelityChangeFeedProcessorWithThroughputControl 

 expected: 200  but was: 187
Raw output 
java.lang.AssertionError: 
expected: 200
 but was: 187
at com.azure.cosmos.rx.changefeed.epkversion.FullFidelityChangeFeedProcessorTest.validateChangeFeedProcessing(FullFidelityChangeFeedProcessorTest.java:1758)
at com.azure.cosmos.rx.changefeed.epkversion.FullFidelityChangeFeedProcessorTest.fullFidelityChangeFeedProcessorWithThroughputControl(FullFidelityChangeFeedProcessorTest.java:1633)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.invokers.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:136)
at org.testng.internal.invokers.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:44)
at org.testng.internal.invokers.InvokeMethodRunnable.call(InvokeMethodRunnable.java:72)
at org.testng.internal.invokers.InvokeMethodRunnable.call(InvokeMethodRunnable.java:10)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)

Check failure on line 1 in spark change feed micro batch (incremental) can use default schema

See this annotation in the file changed.

@azure-pipelines azure-pipelines / java - cosmos - ci

spark change feed micro batch (incremental) can use default schema 

true did not equal false
Raw output 
      org.scalatest.exceptions.TestFailedException: true did not equal false
      at org.scalatest.matchers.MatchersHelper$.indicateFailure(MatchersHelper.scala:344)
      at org.scalatest.matchers.should.Matchers$AnyShouldWrapper.shouldEqual(Matchers.scala:6860)
      at com.azure.cosmos.spark.MetricAssertions.assertMetrics(TestUtils.scala:136)
      at com.azure.cosmos.spark.MetricAssertions.assertMetrics$(TestUtils.scala:115)
      at com.azure.cosmos.spark.SparkE2EGatewayChangeFeedITest.assertMetrics(SparkE2EGatewayChangeFeedITest.scala:10)
      at com.azure.cosmos.spark.SparkE2EGatewayChangeFeedITest.$anonfun$new$1(SparkE2EGatewayChangeFeedITest.scala:119)
      at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
      at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
      at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)
      at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
      at org.scalatest.Transformer.apply(Transformer.scala:22)
      at org.scalatest.Transformer.apply(Transformer.scala:20)
      at org.scalatest.flatspec.AnyFlatSpecLike$$anon$5.apply(AnyFlatSpecLike.scala:1684)
      at org.scalatest.TestSuite.withFixture(TestSuite.scala:196)
      at org.scalatest.TestSuite.withFixture$(TestSuite.scala:195)
      at org.scalatest.flatspec.AnyFlatSpec.withFixture(AnyFlatSpec.scala:1685)
      at org.scalatest.flatspec.AnyFlatSpecLike.invokeWithFixture$1(AnyFlatSpecLike.scala:1682)
      at org.scalatest.flatspec.AnyFlatSpecLike.$anonfun$runTest$1(AnyFlatSpecLike.scala:1694)
      at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
      at org.scalatest.flatspec.AnyFlatSpecLike.runTest(AnyFlatSpecLike.scala:1694)
      at org.scalatest.flatspec.AnyFlatSpecLike.runTest$(AnyFlatSpecLike.scala:1676)
      at com.azure.cosmos.spark.IntegrationSpec.org$scalatest$BeforeAndAfterEach$$super$runTest(IntegrationSpec.scala:10)
      at org.scalatest.BeforeAndAfterEach.runTest(BeforeAndAfterEach.scala:234)
      at org.scalatest.BeforeAndAfterEach.runTest$(BeforeAndAfterEach.scala:227)
      at com.azure.cosmos.spark.IntegrationSpec.runTest(IntegrationSpec.scala:10)
      at org.scalatest.flatspec.AnyFlatSpecLike.$anonfun$runTests$1(AnyFlatSpecLike.scala:1752)
      at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:413)
      at scala.collection.immutable.List.foreach(List.scala:431)
      at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
      at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:390)
      at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:427)
      at scala.collection.immutable.List.foreach(List.scala:431)
      at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
      at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:396)
      at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:475)
      at org.scalatest.flatspec.AnyFlatSpecLike.runTests(AnyFlatSpecLike.scala:1752)
      at org.scalatest.flatspec.AnyFlatSpecLike.runTests$(AnyFlatSpecLike.scala:1751)
      at org.scalatest.flatspec.AnyFlatSpec.runTests(AnyFlatSpec.scala:1685)
      at org.scalatest.Suite.run(Suite.scala:1112)
      at org.scalatest.Suite.run$(Suite.scala:1094)
      at org.scalatest.flatspec.AnyFlatSpec.org$scalatest$flatspec$AnyFlatSpecLike$$super$run(AnyFlatSpec.scala:1685)
      at org.scalatest.flatspec.AnyFlatSpecLike.$anonfun$run$1(AnyFlatSpecLike.scala:1797)
      at org.scalatest.SuperEngine.runImpl(Engine.scala:535)
      at org.scalatest.flatspec.AnyFlatSpecLike.run(AnyFlatSpecLike.scala:1797)
      at org.scalatest.flatspec.AnyFlatSpecLike.run$(AnyFlatSpecLike.scala:1795)
      at com.azure.cosmos.spark.IntegrationSpec.org$scalatest$BeforeAndAfterAll$$super$run(IntegrationSpec.scala:10)
      at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:213)
      at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:210)
      at org.scalatest.BeforeAndAfterAll.
View more details on Azure Pipelines