[jira] [Created] (FLINK-24449) PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure fails with record mismatch
Dawid Wysakowicz created FLINK-24449:
Summary:
PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure fails with record
mismatch
Key: FLINK-24449
URL: https://issues.apache.org/jira/browse/FLINK-24449
Project: Flink
Issue Type: Bug
Components: Connectors / Pulsar
Affects Versions: 1.14.0
Reporter: Dawid Wysakowicz
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=24750&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461&l=25095
{code}
Oct 04 15:58:40 [ERROR] Tests run: 8, Failures: 1, Errors: 0, Skipped: 0, Time
elapsed: 111.559 s <<< FAILURE! - in
org.apache.flink.connector.pulsar.source.PulsarSourceITCase
Oct 04 15:58:40 [ERROR] testTaskManagerFailure{TestEnvironment,
ExternalContext, ClusterControllable}[1] Time elapsed: 24.22 s <<< FAILURE!
Oct 04 15:58:40 java.lang.AssertionError:
Oct 04 15:58:40
Oct 04 15:58:40 Expected: Records consumed by Flink should be identical to test
data and preserve the order in split
Oct 04 15:58:40 but: Mismatched record at position 38: Expected '0-WU6W5B'
but was '0-fiuOx4ttSEqVI0aaTMoF2'
Oct 04 15:58:40 at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
Oct 04 15:58:40 at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8)
Oct 04 15:58:40 at
org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testTaskManagerFailure(SourceTestSuiteBase.java:274)
Oct 04 15:58:40 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
Oct 04 15:58:40 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Oct 04 15:58:40 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
Oct 04 15:58:40 at java.lang.reflect.Method.invoke(Method.java:498)
Oct 04 15:58:40 at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
Oct 04 15:58:40 at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
Oct 04 15:58:40 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
Oct 04 15:58:40 at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
Oct 04 15:58:40 at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
Oct 04 15:58:40 at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
Oct 04 15:58:40 at
org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
Oct 04 15:58:40 at
org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
Oct 04 15:58:40 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
Oct 04 15:58:40 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
Oct 04 15:58:40 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
Oct 04 15:58:40 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
Oct 04 15:58:40 at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
Oct 04 15:58:40 at
org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
Oct 04 15:58:40 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
Oct 04 15:58:40 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
Oct 04 15:58:40 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Created] (FLINK-24450) OuterJoinITCase fails on azure
Dawid Wysakowicz created FLINK-24450:
Summary: OuterJoinITCase fails on azure
Key: FLINK-24450
URL: https://issues.apache.org/jira/browse/FLINK-24450
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.13.2
Reporter: Dawid Wysakowicz
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=24762&view=logs&j=955770d3-1fed-5a0a-3db6-0c7554c910cb&t=14447d61-56b4-5000-80c1-daa459247f6a&l=6879
{code}
Oct 05 01:26:04 [ERROR] Tests run: 48, Failures: 0, Errors: 1, Skipped: 0, Time
elapsed: 22.485 s <<< FAILURE! - in
org.apache.flink.table.planner.runtime.batch.sql.join.OuterJoinITCase
Oct 05 01:26:04 [ERROR]
testFullEmptyOuter[SortMergeJoin](org.apache.flink.table.planner.runtime.batch.sql.join.OuterJoinITCase)
Time elapsed: 0.396 s <<< ERROR!
Oct 05 01:26:04 java.lang.RuntimeException: Job restarted
Oct 05 01:26:04 at
org.apache.flink.streaming.api.operators.collect.UncheckpointedCollectResultBuffer.sinkRestarted(UncheckpointedCollectResultBuffer.java:42)
Oct 05 01:26:04 at
org.apache.flink.streaming.api.operators.collect.AbstractCollectResultBuffer.dealWithResponse(AbstractCollectResultBuffer.java:87)
Oct 05 01:26:04 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
Oct 05 01:26:04 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
Oct 05 01:26:04 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
Oct 05 01:26:04 at
org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.hasNext(TableResultImpl.java:370)
Oct 05 01:26:04 at
java.util.Iterator.forEachRemaining(Iterator.java:115)
Oct 05 01:26:04 at
org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:109)
Oct 05 01:26:04 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:300)
Oct 05 01:26:04 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:140)
Oct 05 01:26:04 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:106)
Oct 05 01:26:04 at
org.apache.flink.table.planner.runtime.batch.sql.join.OuterJoinITCase.testFullEmptyOuter(OuterJoinITCase.scala:156)
Oct 05 01:26:04 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
Oct 05 01:26:04 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Oct 05 01:26:04 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
Oct 05 01:26:04 at java.lang.reflect.Method.invoke(Method.java:498)
Oct 05 01:26:04 at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
Oct 05 01:26:04 at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
Oct 05 01:26:04 at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
Oct 05 01:26:04 at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
Oct 05 01:26:04 at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
Oct 05 01:26:04 at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
Oct 05 01:26:04 at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
Oct 05 01:26:04 at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
Oct 05 01:26:04 at org.junit.rules.RunRules.evaluate(RunRules.java:20)
Oct 05 01:26:04 at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
Oct 05 01:26:04 at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
Oct 05 01:26:04 at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
Oct 05 01:26:04 at
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
Oct 05 01:26:04 at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Created] (FLINK-24451) Replace the scattered objects with encapsulated LeaderInformation in DefaultLeaderElectionService
Aitozi created FLINK-24451: -- Summary: Replace the scattered objects with encapsulated LeaderInformation in DefaultLeaderElectionService Key: FLINK-24451 URL: https://issues.apache.org/jira/browse/FLINK-24451 Project: Flink Issue Type: Improvement Components: Runtime / Coordination Reporter: Aitozi A minor code refactor -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-24452) Move REST API state into dispatcher
Chesnay Schepler created FLINK-24452: Summary: Move REST API state into dispatcher Key: FLINK-24452 URL: https://issues.apache.org/jira/browse/FLINK-24452 Project: Flink Issue Type: Improvement Components: Runtime / REST Reporter: Chesnay Schepler Various REST API handlers maintain state, which is problematic in HA mode as standby JobManagers are not aware of said state. We should make sure state is only kept in the leading Dispatcher. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-24453) StaticFileServerHandler does not redirect
Chesnay Schepler created FLINK-24453: Summary: StaticFileServerHandler does not redirect Key: FLINK-24453 URL: https://issues.apache.org/jira/browse/FLINK-24453 Project: Flink Issue Type: Sub-task Components: Runtime / REST Reporter: Chesnay Schepler The StaticFileServerHandler currently does not redirect requests to the leading JM. This _can_ be surprising to users that in particular requests the JM logs. -- This message was sent by Atlassian Jira (v8.3.4#803005)
Cannot run Flink tests in Azure Pipeline - S3 credentials
Hi dev, I have test failures irrelevant to my modifications ( https://issues.apache.org/jira/browse/FLINK-23972), but very annoying. Tests fail because they cannot properly use S3 credentials. Could someone help me to make those tests running? Examples: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=24748&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=070ff179-953e-5bda-71fa-d6599415701c&l=11859 https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=24748&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461&l=29552 If we check the URIs, we see the following: s3://$(SECRET_S3_BUCKET)/temp/test_file_sink-d402aca3-66e9-4faf-ae27-f5ba8556606b-chk s3n://$(SECRET_S3_BUCKET)/temp/tests-9e728f65-14c6-4fa2-aa4d-9e61e994efe0 In other words, the S3-related variables (declared in the Azure Pipeline definition build-apache-repo.yaml) are not properly expanded. This is annoying because: 1. I cannot finish my PR - some tests irrelevant to my modifications are failing. 2. The S3-related tests start, despite there are no required credentials. In the output of test_file_sink.sh we can see: Found AWS bucket $(SECRET_S3_BUCKET), running the e2e test. Compare with the output from a passing test (with access to S3 credentials): Found AWS bucket ***, running the e2e test. This is quite misleading behavior. It would be better to skip the S3 tests with a corresponding message on the stderr. The other possible way for me to progress on my PR is to ignore the failures of S3-related tests. However, it smells... Arseniy Tashoyan
[jira] [Created] (FLINK-24454) Consolidate all CAST related test into the new CastFunctionITCase class
Marios Trivyzas created FLINK-24454: --- Summary: Consolidate all CAST related test into the new CastFunctionITCase class Key: FLINK-24454 URL: https://issues.apache.org/jira/browse/FLINK-24454 Project: Flink Issue Type: Sub-task Components: Table SQL / API Reporter: Marios Trivyzas Check and possibly move all related CAST tests into one place, i.e.: *DecimalCastTests,* *CalcITCase,* *etc* -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-24455) FallbackAkkaRpcSystemLoader can't run through with
Aitozi created FLINK-24455:
--
Summary: FallbackAkkaRpcSystemLoader can't run through with
Key: FLINK-24455
URL: https://issues.apache.org/jira/browse/FLINK-24455
Project: Flink
Issue Type: Bug
Components: Tests
Reporter: Aitozi
Attachments: image-2021-10-06-00-27-19-848.png
After [FLINK-24367|https://github.com/apache/flink/pull/17385/files], a
{{FallbackAkkaRpcSystemLoader}} is provided, which should make it possible to
run test directly without execute {{mvn package -pl
flink-rpc/flink-rpc-akka,flink-rpc/flink-rpc-akka-loader}} in command line, but
I still meet the exception
!image-2021-10-06-00-27-19-848.png!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Created] (FLINK-24456) Support bounded offset in the Kafka table connector
Haohui Mai created FLINK-24456:
--
Summary: Support bounded offset in the Kafka table connector
Key: FLINK-24456
URL: https://issues.apache.org/jira/browse/FLINK-24456
Project: Flink
Issue Type: Improvement
Reporter: Haohui Mai
The {{setBounded}} API in the DataStream connector of Kafka is particularly
useful when writing tests. Unfortunately the table connector of Kafka lacks the
same API.
It would be good to have this API added.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Created] (FLINK-24457) FileSourceTextLinesITCase.testContinuousTextFileSourceWithJobManagerFailover fails with NoSuchElement
Dawid Wysakowicz created FLINK-24457:
Summary:
FileSourceTextLinesITCase.testContinuousTextFileSourceWithJobManagerFailover
fails with NoSuchElement
Key: FLINK-24457
URL: https://issues.apache.org/jira/browse/FLINK-24457
Project: Flink
Issue Type: Bug
Components: Connectors / FileSystem
Affects Versions: 1.15.0
Reporter: Dawid Wysakowicz
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=24781&view=logs&j=a5ef94ef-68c2-57fd-3794-dc108ed1c495&t=2c68b137-b01d-55c9-e603-3ff3f320364b&l=23849
{code}
Oct 06 00:07:54 [ERROR] Tests run: 5, Failures: 0, Errors: 1, Skipped: 0, Time
elapsed: 41.682 s <<< FAILURE! - in
org.apache.flink.connector.file.src.FileSourceTextLinesITCase
Oct 06 00:07:54 [ERROR] testContinuousTextFileSourceWithJobManagerFailover
Time elapsed: 10.826 s <<< ERROR!
Oct 06 00:07:54 java.util.NoSuchElementException
Oct 06 00:07:54 at java.util.LinkedList.removeLast(LinkedList.java:283)
Oct 06 00:07:54 at
org.apache.flink.streaming.api.operators.collect.AbstractCollectResultBuffer.revert(AbstractCollectResultBuffer.java:112)
Oct 06 00:07:54 at
org.apache.flink.streaming.api.operators.collect.CheckpointedCollectResultBuffer.sinkRestarted(CheckpointedCollectResultBuffer.java:37)
Oct 06 00:07:54 at
org.apache.flink.streaming.api.operators.collect.AbstractCollectResultBuffer.dealWithResponse(AbstractCollectResultBuffer.java:87)
Oct 06 00:07:54 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:147)
Oct 06 00:07:54 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
Oct 06 00:07:54 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
Oct 06 00:07:54 at
org.apache.flink.streaming.api.datastream.DataStreamUtils.collectRecordsFromUnboundedStream(DataStreamUtils.java:142)
Oct 06 00:07:54 at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.testContinuousTextFileSource(FileSourceTextLinesITCase.java:224)
Oct 06 00:07:54 at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.testContinuousTextFileSourceWithJobManagerFailover(FileSourceTextLinesITCase.java:180)
Oct 06 00:07:54 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
Oct 06 00:07:54 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Oct 06 00:07:54 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
Oct 06 00:07:54 at java.lang.reflect.Method.invoke(Method.java:498)
Oct 06 00:07:54 at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
Oct 06 00:07:54 at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
Oct 06 00:07:54 at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
Oct 06 00:07:54 at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
Oct 06 00:07:54 at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
Oct 06 00:07:54 at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
Oct 06 00:07:54 at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
Oct 06 00:07:54 at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
Oct 06 00:07:54 at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
Oct 06 00:07:54 at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
Oct 06 00:07:54 at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
Oct 06 00:07:54 at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
Oct 06 00:07:54 at
org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
Oct 06 00:07:54 at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
Oct 06 00:07:54 at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
Oct 06 00:07:54 at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
Oct 06 00:07:54 at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
Oct 06 00:07:54 at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
Oct 06 00:07:54 at org.junit.rules.RunRules.evaluate(RunRules.java:20)
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Created] (FLINK-24458) ParquetFsStreamingSinkITCase fails with time out
Dawid Wysakowicz created FLINK-24458:
Summary: ParquetFsStreamingSinkITCase fails with time out
Key: FLINK-24458
URL: https://issues.apache.org/jira/browse/FLINK-24458
Project: Flink
Issue Type: Bug
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
Affects Versions: 1.14.0
Reporter: Dawid Wysakowicz
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=24784&view=logs&j=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89&t=4cf71635-d33f-53ff-7185-c5abb11ae3a0&l=14970
{code}
Oct 05 23:16:10 [ERROR] Tests run: 3, Failures: 0, Errors: 1, Skipped: 0, Time
elapsed: 32.276 s <<< FAILURE! - in
org.apache.flink.formats.parquet.ParquetFsStreamingSinkITCase
Oct 05 23:16:10 [ERROR] testPart Time elapsed: 20.787 s <<< ERROR!
Oct 05 23:16:10 org.junit.runners.model.TestTimedOutException: test timed out
after 20 seconds
Oct 05 23:16:10 at java.lang.Thread.sleep(Native Method)
Oct 05 23:16:10 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sleepBeforeRetry(CollectResultFetcher.java:237)
Oct 05 23:16:10 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:113)
Oct 05 23:16:10 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
Oct 05 23:16:10 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
Oct 05 23:16:10 at
org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.hasNext(TableResultImpl.java:370)
Oct 05 23:16:10 at
java.util.Iterator.forEachRemaining(Iterator.java:115)
Oct 05 23:16:10 at
org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:109)
Oct 05 23:16:10 at
org.apache.flink.table.planner.runtime.stream.FsStreamingSinkITCaseBase.check(FsStreamingSinkITCaseBase.scala:133)
Oct 05 23:16:10 at
org.apache.flink.table.planner.runtime.stream.FsStreamingSinkITCaseBase.test(FsStreamingSinkITCaseBase.scala:120)
Oct 05 23:16:10 at
org.apache.flink.table.planner.runtime.stream.FsStreamingSinkITCaseBase.testPart(FsStreamingSinkITCaseBase.scala:84)
Oct 05 23:16:10 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
Oct 05 23:16:10 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Oct 05 23:16:10 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
Oct 05 23:16:10 at java.lang.reflect.Method.invoke(Method.java:498)
Oct 05 23:16:10 at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
Oct 05 23:16:10 at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
Oct 05 23:16:10 at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
Oct 05 23:16:10 at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
Oct 05 23:16:10 at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
Oct 05 23:16:10 at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
Oct 05 23:16:10 at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:299)
Oct 05 23:16:10 at
org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:293)
Oct 05 23:16:10 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
Oct 05 23:16:10 at java.lang.Thread.run(Thread.java:748)
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
