apache / apache/fluss

[test] Unstable test RemoteLogScannerITCase.testPartitionTableFetchFromRemote

Open
#3,879 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
2.1k
Forks
625
Avg merge
3d 14h
Merged PRs (30d)
97

Description

https://github.com/apache/fluss/actions/runs/31044443802/job/92436411656

```
[ERROR] org.apache.fluss.client.table.scanner.log.RemoteLogScannerITCase.testPartitionTableFetchFromRemote Time elapsed: 7.07 s <<< ERROR!
org.apache.fluss.exception.FetchException: Received exception when fetching the next record from TableBucket{tableId=2, partitionId=1, bucket=0}. If needed, please back to past the record to continue scanning.
at org.apache.fluss.client.table.scanner.log.CompletedFetch.fetchRecords(CompletedFetch.java:213)
at org.apache.fluss.client.table.scanner.log.LogFetchCollector.doFetchRecords(LogFetchCollector.java:59)
at org.apache.fluss.client.table.scanner.log.AbstractLogFetchCollector.fetchRecords(AbstractLogFetchCollector.java:262)
at org.apache.fluss.client.table.scanner.log.AbstractLogFetchCollector.collectFetch(AbstractLogFetchCollector.java:108)
at org.apache.fluss.client.table.scanner.log.LogFetcher.collectFetch(LogFetcher.java:200)
at org.apache.fluss.client.table.scanner.log.AbstractLogScanner.pollForFetches(AbstractLogScanner.java:121)
at org.apache.fluss.client.table.scanner.log.AbstractLogScanner.poll(AbstractLogScanner.java:94)
at org.apache.fluss.client.table.scanner.log.LogScannerImpl.poll(LogScannerImpl.java:54)
at org.apache.fluss.client.admin.ClientToServerITCaseBase.verifyPartitionLogs(ClientToServerITCaseBase.java:225)
at org.apache.fluss.client.table.scanner.log.RemoteLogScannerITCase.testPartitionTableFetchFromRemote(RemoteLogScannerITCase.java:244)
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.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
... (truncated)
```

Contributor guide

No contributing guide indexed for this repository

Research direction

Start by running RemoteLogScannerITCase.testPartitionTableFetchFromRemote and compare the failure with the linked GitHub Actions run. Trace the FetchException through CompletedFetch.java, LogFetchCollector.java, AbstractLogFetchCollector.java, and ClientToServerITCaseBase.java. Done means the integration test passes reliably without the reported remote partition-table fetch failure.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
distributed-systems, testing
Issue type
Bug
Difficulty
3/5
Estimated time
1-2 days
Activity status
Quiet
Clarity
Mostly clear
Newbie friendliness
45/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.