Flaky `testAggregation` in Pinot smoke test #14239

findepi · 2022-09-21T15:17:21Z

https://github.com/trinodb/trino/actions/runs/3097813235/jobs/5015484200

Error:  io.trino.plugin.pinot.TestPinotWithoutAuthenticationIntegrationLatestVersionNoGrpcConnectorSmokeTest.testAggregation  Time elapsed: 13.462 s  <<< FAILURE!
java.lang.AssertionError: Execution of 'actual' query failed: SELECT sum(regionkey) FROM nation
	at org.testng.Assert.fail(Assert.java:83)
	at io.trino.testing.QueryAssertions.assertQuery(QueryAssertions.java:150)
	at io.trino.testing.QueryAssertions.assertQuery(QueryAssertions.java:106)
	at io.trino.testing.AbstractTestQueryFramework.assertQuery(AbstractTestQueryFramework.java:247)
	at io.trino.testing.AbstractTestQueryFramework.assertQuery(AbstractTestQueryFramework.java:242)
	at io.trino.testing.BaseConnectorSmokeTest.testAggregation(BaseConnectorSmokeTest.java:112)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:104)
	at org.testng.internal.Invoker.invokeMethod(Invoker.java:645)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.trino.testing.QueryFailedException: Query select sum("regionkey") from nation encountered exception org.apache.pinot.common.response.broker.QueryProcessingException@65555cc7 with query "select sum("regionkey") from nation"
	at io.trino.testing.AbstractTestingTrinoClient.execute(AbstractTestingTrinoClient.java:123)
	at io.trino.testing.DistributedQueryRunner.execute(DistributedQueryRunner.java:480)
	at io.trino.testing.QueryAssertions.assertQuery(QueryAssertions.java:147)
	... 17 more
	Suppressed: java.lang.Exception: SQL: SELECT sum(regionkey) FROM nation
		at io.trino.testing.DistributedQueryRunner.execute(DistributedQueryRunner.java:483)
		... 18 more
Caused by: io.trino.plugin.pinot.PinotException: Query select sum("regionkey") from nation encountered exception org.apache.pinot.common.response.broker.QueryProcessingException@65555cc7 with query "select sum("regionkey") from nation"
	at io.trino.plugin.pinot.client.PinotClient.lambda$submitBrokerQueryJson$6(PinotClient.java:553)
	at io.trino.plugin.pinot.client.PinotClient.doWithRetries(PinotClient.java:621)
	at io.trino.plugin.pinot.client.PinotClient.submitBrokerQueryJson(PinotClient.java:533)
	at io.trino.plugin.pinot.client.PinotClient.createResultIterator(PinotClient.java:578)
	at io.trino.plugin.pinot.PinotBrokerPageSource.getNextPage(PinotBrokerPageSource.java:112)
	at io.trino.operator.TableScanOperator.getOutput(TableScanOperator.java:311)
	at io.trino.operator.Driver.processInternal(Driver.java:411)
	at io.trino.operator.Driver.lambda$process$10(Driver.java:314)
	at io.trino.operator.Driver.tryWithLock(Driver.java:706)
	at io.trino.operator.Driver.process(Driver.java:306)
	at io.trino.operator.Driver.processForDuration(Driver.java:277)
	at io.trino.execution.SqlTaskExecution$DriverSplitRunner.processFor(SqlTaskExecution.java:736)
	at io.trino.execution.executor.PrioritizedSplitRunner.process(PrioritizedSplitRunner.java:164)
	at io.trino.execution.executor.TaskExecutor$TaskRunner.run(TaskExecutor.java:515)
	at io.trino.$gen.Trino_testversion____20220921_142351_106.run(Unknown Source)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)

The text was updated successfully, but these errors were encountered:

findepi · 2022-09-26T15:11:13Z

https://github.com/trinodb/trino/actions/runs/3127676861/jobs/5075173404

cc @elonazoulay @xiangfu0

findinpath · 2022-10-27T10:02:05Z

https://github.com/trinodb/trino/actions/runs/3334421612/jobs/5517681544

xiangfu0 · 2022-10-27T10:30:52Z

This is a fix: #14304

nevillelyh · 2022-10-27T14:18:55Z

Related: TestPinotWithoutAuthenticationIntegrationLatestVersionConnectorSmokeTest>BaseConnectorSmokeTest.testAggregation
https://github.com/trinodb/trino/actions/runs/3334604928/jobs/5518590450

vlad-lyutenko · 2022-10-31T12:32:25Z

I have randomly failing tests for TestPinotWithoutAuthenticationIntegrationLatestVersionConnectorSmokeTest
it varies from 10 to 17 tests like:
testTimestamp:

Expecting:
  <>
to contain exactly in any order:
  <[(1970-01-01T00:00)]>
but could not find the following elements:
  <(1970-01-01T00:00)>

testVarbinary
e.t.c
Looks like we got empty responses, when smth goes wrong:

https://github.com/trinodb/trino/actions/runs/3360648854/jobs/5570242351

It pass locally, not sure should it be separate issue or it's somehow connected with this one

My PR #14570 is about changes to SQL server only

Dith3r · 2022-11-09T13:01:49Z

https://github.com/trinodb/trino/actions/runs/3427029825/jobs/5709909246

ebyhr · 2022-12-12T04:31:42Z

I have randomly failing tests for TestPinotWithoutAuthenticationIntegrationLatestVersionConnectorSmokeTest

@vlad-lyutenko The stacktrace is different from the issue description. Filed #15367

findepi · 2023-01-05T15:33:00Z

https://github.com/trinodb/trino/actions/runs/3847136098/jobs/6553734233

Error:  io.trino.plugin.pinot.TestPinotWithoutAuthenticationIntegrationLatestVersionNoGrpcConnectorSmokeTest.testAggregation  Time elapsed: 11.127 s  <<< FAILURE!
java.lang.AssertionError: Execution of 'actual' query failed: SELECT sum(regionkey) FROM nation
	at org.testng.Assert.fail(Assert.java:83)
	at io.trino.testing.QueryAssertions.assertQuery(QueryAssertions.java:150)
	at io.trino.testing.QueryAssertions.assertQuery(QueryAssertions.java:106)
	at io.trino.testing.AbstractTestQueryFramework.assertQuery(AbstractTestQueryFramework.java:299)
	at io.trino.testing.AbstractTestQueryFramework.assertQuery(AbstractTestQueryFramework.java:294)
	at io.trino.testing.BaseConnectorSmokeTest.testAggregation(BaseConnectorSmokeTest.java:117)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:104)
	at org.testng.internal.Invoker.invokeMethod(Invoker.java:645)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.trino.testing.QueryFailedException: Query select sum("regionkey") from nation encountered exception code: '427' message: '1 servers [f303697005f9_R] not responded' with query "select sum("regionkey") from nation"
	at io.trino.testing.AbstractTestingTrinoClient.execute(AbstractTestingTrinoClient.java:122)
	at io.trino.testing.DistributedQueryRunner.execute(DistributedQueryRunner.java:490)
	at io.trino.testing.QueryAssertions.assertQuery(QueryAssertions.java:147)
	... 17 more
	Suppressed: java.lang.Exception: SQL: SELECT sum(regionkey) FROM nation
		at io.trino.testing.DistributedQueryRunner.execute(DistributedQueryRunner.java:493)
		... 18 more
Caused by: io.trino.plugin.pinot.PinotException: Query select sum("regionkey") from nation encountered exception code: '427' message: '1 servers [f303697005f9_R] not responded' with query "select sum("regionkey") from nation"
	at io.trino.plugin.pinot.client.PinotClient.lambda$submitBrokerQueryJson$7(PinotClient.java:563)
	at io.trino.plugin.pinot.client.PinotClient.doWithRetries(PinotClient.java:631)
	at io.trino.plugin.pinot.client.PinotClient.submitBrokerQueryJson(PinotClient.java:540)
	at io.trino.plugin.pinot.client.PinotClient.createResultIterator(PinotClient.java:588)
	at io.trino.plugin.pinot.PinotBrokerPageSource.getNextPage(PinotBrokerPageSource.java:112)
	at io.trino.operator.TableScanOperator.getOutput(TableScanOperator.java:311)
	at io.trino.operator.Driver.processInternal(Driver.java:411)
	at io.trino.operator.Driver.lambda$process$10(Driver.java:314)
	at io.trino.operator.Driver.tryWithLock(Driver.java:706)
	at io.trino.operator.Driver.process(Driver.java:306)
	at io.trino.operator.Driver.processForDuration(Driver.java:277)
	at io.trino.execution.SqlTaskExecution$DriverSplitRunner.processFor(SqlTaskExecution.java:752)
	at io.trino.execution.executor.PrioritizedSplitRunner.process(PrioritizedSplitRunner.java:164)
	at io.trino.execution.executor.TaskExecutor$TaskRunner.run(TaskExecutor.java:519)
	at io.trino.$gen.Trino_testversion____20230105_144724_2145.run(Unknown Source)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)

[INFO] 
[INFO] Results:

@elonazoulay

findepi · 2023-04-22T19:41:10Z

https://github.com/trinodb/trino/actions/runs/4766640955/jobs/8475851653?pr=17175

Error:  io.trino.plugin.pinot.TestPinotConnectorSmokeTest.testAggregation  Time elapsed: 0.308 s  <<< FAILURE!
java.lang.AssertionError: Execution of 'actual' query 20230421_214636_00002_vyvf7 failed: SELECT sum(regionkey) FROM nation
	at org.testng.Assert.fail(Assert.java:83)
	at io.trino.testing.QueryAssertions.assertDistributedQuery(QueryAssertions.java:286)
	at io.trino.testing.QueryAssertions.assertQuery(QueryAssertions.java:184)
	at io.trino.testing.QueryAssertions.assertQuery(QueryAssertions.java:157)
	at io.trino.testing.AbstractTestQueryFramework.assertQuery(AbstractTestQueryFramework.java:334)
	at io.trino.testing.AbstractTestQueryFramework.assertQuery(AbstractTestQueryFramework.java:329)
	at io.trino.testing.BaseConnectorSmokeTest.testAggregation(BaseConnectorSmokeTest.java:119)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:104)
	at org.testng.internal.Invoker.invokeMethod(Invoker.java:645)
	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.trino.testing.QueryFailedException: Query SELECT sum("regionkey") FROM nation encountered exception code: '427' message: '1 servers [d56d168eb72a_R] not responded' with query "SELECT sum("regionkey") FROM nation"
	at io.trino.testing.AbstractTestingTrinoClient.execute(AbstractTestingTrinoClient.java:122)
	at io.trino.testing.DistributedQueryRunner.executeWithQueryId(DistributedQueryRunner.java:493)
	at io.trino.testing.QueryAssertions.assertDistributedQuery(QueryAssertions.java:277)
	... 18 more
	Suppressed: java.lang.Exception: SQL: SELECT sum(regionkey) FROM nation
		at io.trino.testing.DistributedQueryRunner.executeWithQueryId(DistributedQueryRunner.java:497)
		... 19 more
Caused by: io.trino.plugin.pinot.PinotException: Query SELECT sum("regionkey") FROM nation encountered exception code: '427' message: '1 servers [d56d168eb72a_R] not responded' with query "SELECT sum("regionkey") FROM nation"
	at io.trino.plugin.pinot.client.PinotClient.lambda$submitBrokerQueryJson$7(PinotClient.java:563)
	at io.trino.plugin.pinot.client.PinotClient.doWithRetries(PinotClient.java:631)
	at io.trino.plugin.pinot.client.PinotClient.submitBrokerQueryJson(PinotClient.java:540)
	at io.trino.plugin.pinot.client.PinotClient.createResultIterator(PinotClient.java:588)
	at io.trino.plugin.pinot.PinotBrokerPageSource.getNextPage(PinotBrokerPageSource.java:112)
	at io.trino.operator.TableScanOperator.getOutput(TableScanOperator.java:301)
	at io.trino.operator.Driver.processInternal(Driver.java:402)
	at io.trino.operator.Driver.lambda$process$8(Driver.java:305)
	at io.trino.operator.Driver.tryWithLock(Driver.java:701)
	at io.trino.operator.Driver.process(Driver.java:297)
	at io.trino.operator.Driver.processForDuration(Driver.java:268)
	at io.trino.execution.SqlTaskExecution$DriverSplitRunner.processFor(SqlTaskExecution.java:888)
	at io.trino.execution.executor.PrioritizedSplitRunner.process(PrioritizedSplitRunner.java:187)
	at io.trino.execution.executor.TaskExecutor$TaskRunner.run(TaskExecutor.java:561)
	at io.trino.$gen.Trino_testversion____20230421_214553_2256.run(Unknown Source)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)

ebyhr · 2023-07-14T08:26:32Z

https://github.com/trinodb/trino/actions/runs/5548635127/jobs/10136844578?pr=17667

 io.trino.plugin.pinot.TestPinotSecuredConnectorSmokeTest.testAggregation  Time elapsed: 0.932 s  <<< FAILURE!

findepi changed the title ~~TestPinotWithoutAuthenticationIntegrationLatestVersionNoGrpcConnectorSmokeTest~~ Flaky test TestPinotWithoutAuthenticationIntegrationLatestVersionNoGrpcConnectorSmokeTest.testAggregation Sep 21, 2022

findepi added the bug Something isn't working label Sep 21, 2022

findepi assigned elonazoulay Sep 21, 2022

findepi mentioned this issue Sep 21, 2022

Support arbitrary aggregation functions during ANALYZE (v2) #14233

Merged

findepi mentioned this issue Sep 26, 2022

Calculate Iceberg NDV with a Theta sketch #14290

Merged

hashhar added the test label Oct 13, 2022

findinpath mentioned this issue Oct 27, 2022

Split the Delta Lake product test suite per Databricks runtime #14549

Merged

xiangfu0 mentioned this issue Oct 27, 2022

Retry on Pinot Controller/Broker Rest calls and check data readiness for BasePinotIntegrationConnectorSmokeTest #14304

Closed

nevillelyh mentioned this issue Oct 27, 2022

Lower log level in Kafka product tests #14645

Merged

findepi mentioned this issue Jan 5, 2023

Skip 404 in Trino compatibility tests #15610

Merged

findepi mentioned this issue Apr 22, 2023

Shutdown BigQuery, Kinesis, Redis and Memory connectors #17175

Merged

hashhar mentioned this issue May 11, 2023

Correct illegal import from shaded code #17441

Merged

vlad-lyutenko mentioned this issue Jun 28, 2023

Add support for materialized view column comments #18016

Merged

ebyhr changed the title ~~Flaky test TestPinotWithoutAuthenticationIntegrationLatestVersionNoGrpcConnectorSmokeTest.testAggregation~~ Flaky testAggregation in Pinot smoke test Jul 14, 2023

ebyhr mentioned this issue Jul 14, 2023

Install JDBC drivers for Delta product tests at runtime and upgrade docker-images to version 81 #17667

Merged

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Flaky `testAggregation` in Pinot smoke test #14239

Flaky `testAggregation` in Pinot smoke test #14239

findepi commented Sep 21, 2022 •

edited

Loading

findepi commented Sep 26, 2022

findinpath commented Oct 27, 2022

xiangfu0 commented Oct 27, 2022 •

edited

Loading

nevillelyh commented Oct 27, 2022

vlad-lyutenko commented Oct 31, 2022 •

edited

Loading

Dith3r commented Nov 9, 2022

ebyhr commented Dec 12, 2022

findepi commented Jan 5, 2023

findepi commented Apr 22, 2023

ebyhr commented Jul 14, 2023

Flaky testAggregation in Pinot smoke test #14239

Flaky testAggregation in Pinot smoke test #14239

Comments

findepi commented Sep 21, 2022 • edited Loading

findepi commented Sep 26, 2022

findinpath commented Oct 27, 2022

xiangfu0 commented Oct 27, 2022 • edited Loading

nevillelyh commented Oct 27, 2022

vlad-lyutenko commented Oct 31, 2022 • edited Loading

Dith3r commented Nov 9, 2022

ebyhr commented Dec 12, 2022

findepi commented Jan 5, 2023

findepi commented Apr 22, 2023

ebyhr commented Jul 14, 2023

Flaky `testAggregation` in Pinot smoke test #14239

Flaky `testAggregation` in Pinot smoke test #14239

findepi commented Sep 21, 2022 •

edited

Loading

xiangfu0 commented Oct 27, 2022 •

edited

Loading

vlad-lyutenko commented Oct 31, 2022 •

edited

Loading