Skip to content
This repository has been archived by the owner on Apr 1, 2024. It is now read-only.

ISSUE-5270: Intermittent test failures in PulsarFunctionsTest.testSlidingCountWindowTest #310

Closed
sijie opened this issue Dec 27, 2019 · 0 comments
Closed

ISSUE-5270: Intermittent test failures in PulsarFunctionsTest.testSlidingCountWindowTest #310

sijie opened this issue Dec 27, 2019 · 0 comments
Labels
component/test flaky-tests triage/week-43

Comments

@sijie
Copy link
Member

sijie commented Dec 27, 2019

Original Issue: apache#5270

Seen few times in integration tests:

@jerrypeng can you take a look?

Error Message
Expecting:
 <18>
to be greater than or equal to:
 <19> 
Stacktrace
java.lang.AssertionError: 

Expecting:
 <18>
to be greater than or equal to:
 <19> 
	at org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest.testWindowFunction(PulsarFunctionsTest.java:1042)
	at org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest.testSlidingCountWindowTest(PulsarFunctionsTest.java:1076)
	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.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
	at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:54)
	at org.testng.internal.InvokeMethodRunnable.run(InvokeMethodRunnable.java:44)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	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:748)
Standard Output
------- Starting test [TestClass name=class org.apache.pulsar.tests.integration.functions.PulsarFunctionsThreadTest].pulsar-test-suite([])-------
14:51:03.252 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:03.259 [tc-okhttp-stream-177169304:org.apache.pulsar.tests.integration.utils.DockerUtils$2@216] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(babb87fb3516a523b0eed8d51200ff492be2b18c230e380e9a2a5ce87fa4a6e3:sh -c /pulsar/bin/pulsar-admin functions create --tenant public --namespace default --name test-sliding-window-fn-vktkrzog --className org.apache.pulsar.functions.api.examples.WindowDurationFunction --inputs test-sliding-count-window-THREAD-input-vudzexnv --output test-sliding-count-window-THREAD-output-pngvkwek --windowLengthCount 10 --slidingIntervalCount 5 --jar /pulsar/examples/java-test-functions.jar): Executing...
14:51:03.462 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:03.600 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:04.105 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:04.263 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:04.364 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:04.653 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:05.007 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:05.265 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:05.366 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:05.756 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:06.010 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:06.468 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:06.468 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:06.709 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:07.113 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:07.315 [tc-okhttp-stream-177169304:org.apache.pulsar.tests.integration.utils.DockerUtils$2@221] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(babb87fb3516a523b0eed8d51200ff492be2b18c230e380e9a2a5ce87fa4a6e3:sh -c /pulsar/bin/pulsar-admin functions create --tenant public --namespace default --name test-sliding-window-fn-vktkrzog --className org.apache.pulsar.functions.api.examples.WindowDurationFunction --inputs test-sliding-count-window-THREAD-input-vudzexnv --output test-sliding-count-window-THREAD-output-pngvkwek --windowLengthCount 10 --slidingIntervalCount 5 --jar /pulsar/examples/java-test-functions.jar): STDOUT: "Created successfully"
14:51:07.470 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:07.570 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:07.705 [tc-okhttp-stream-177169304:org.apache.pulsar.tests.integration.utils.DockerUtils$2@236] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(babb87fb3516a523b0eed8d51200ff492be2b18c230e380e9a2a5ce87fa4a6e3:sh -c /pulsar/bin/pulsar-admin functions create --tenant public --namespace default --name test-sliding-window-fn-vktkrzog --className org.apache.pulsar.functions.api.examples.WindowDurationFunction --inputs test-sliding-count-window-THREAD-input-vudzexnv --output test-sliding-count-window-THREAD-output-pngvkwek --windowLengthCount 10 --slidingIntervalCount 5 --jar /pulsar/examples/java-test-functions.jar): Done
14:51:07.706 [tc-okhttp-stream-177169304:org.apache.pulsar.tests.integration.utils.DockerUtils$2@254] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(babb87fb3516a523b0eed8d51200ff492be2b18c230e380e9a2a5ce87fa4a6e3:sh -c /pulsar/bin/pulsar-admin functions create --tenant public --namespace default --name test-sliding-window-fn-vktkrzog --className org.apache.pulsar.functions.api.examples.WindowDurationFunction --inputs test-sliding-count-window-THREAD-input-vudzexnv --output test-sliding-count-window-THREAD-output-pngvkwek --windowLengthCount 10 --slidingIntervalCount 5 --jar /pulsar/examples/java-test-functions.jar): completed with 0
14:51:07.709 [tc-okhttp-stream-125680150:org.apache.pulsar.tests.integration.utils.DockerUtils$2@216] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(d134594142b34dc846465b57c954472914100c58d75c825516117181a07c079c:/pulsar/bin/pulsar-admin functions get --tenant public --namespace default --name test-sliding-window-fn-vktkrzog): Executing...
14:51:07.762 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:08.266 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:08.665 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:08.672 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:08.672 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:09.219 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:09.568 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:09.574 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:09.574 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:10.272 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:10.476 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:10.476 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:10.621 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:11.378 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:11.475 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:11.524 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:11.679 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:12.315 [tc-okhttp-stream-125680150:org.apache.pulsar.tests.integration.utils.DockerUtils$2@221] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(d134594142b34dc846465b57c954472914100c58d75c825516117181a07c079c:/pulsar/bin/pulsar-admin functions get --tenant public --namespace default --name test-sliding-window-fn-vktkrzog): STDOUT: {
  "tenant": "public",
  "namespace": "default",
  "name": "test-sliding-window-fn-vktkrzog",
  "className": "org.apache.pulsar.functions.api.examples.WindowDurationFunction",
  "inputSpecs": {
    "test-sliding-count-window-THREAD-input-vudzexnv": {
      "isRegexPattern": false
    }
  },
  "output": "test-sliding-count-window-THREAD-output-pngvkwek",
  "processingGuarantees": "ATLEAST_ONCE",
  "retainOrdering": false,
  "userConfig": {},
  "runtime": "JAVA",
  "autoAck": false,
  "parallelism": 1,
  "resources": {
    "cpu": 1.0,
    "ram": 1073741824,
    "disk": 10737418240
  },
  "windowConfig": {
    "windowLengthCount": 10,
    "slidingIntervalCount": 5,
    "actualWindowFunctionClassName": "org.apache.pulsar.functions.api.examples.WindowDurationFunction"
  },
  "cleanupSubscription": true
}
14:51:12.327 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:12.581 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:12.627 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:12.725 [tc-okhttp-stream-125680150:org.apache.pulsar.tests.integration.utils.DockerUtils$2@236] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(d134594142b34dc846465b57c954472914100c58d75c825516117181a07c079c:/pulsar/bin/pulsar-admin functions get --tenant public --namespace default --name test-sliding-window-fn-vktkrzog): Done
14:51:12.813 [tc-okhttp-stream-125680150:org.apache.pulsar.tests.integration.utils.DockerUtils$2@254] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(d134594142b34dc846465b57c954472914100c58d75c825516117181a07c079c:/pulsar/bin/pulsar-admin functions get --tenant public --namespace default --name test-sliding-window-fn-vktkrzog): completed with 0
14:51:12.813 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1622] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - FUNCTION STATE: {
  "tenant": "public",
  "namespace": "default",
  "name": "test-sliding-window-fn-vktkrzog",
  "className": "org.apache.pulsar.functions.api.examples.WindowDurationFunction",
  "inputSpecs": {
    "test-sliding-count-window-THREAD-input-vudzexnv": {
      "isRegexPattern": false
    }
  },
  "output": "test-sliding-count-window-THREAD-output-pngvkwek",
  "processingGuarantees": "ATLEAST_ONCE",
  "retainOrdering": false,
  "userConfig": {},
  "runtime": "JAVA",
  "autoAck": false,
  "parallelism": 1,
  "resources": {
    "cpu": 1.0,
    "ram": 1073741824,
    "disk": 10737418240
  },
  "windowConfig": {
    "windowLengthCount": 10,
    "slidingIntervalCount": 5,
    "actualWindowFunctionClassName": "org.apache.pulsar.functions.api.examples.WindowDurationFunction"
  },
  "cleanupSubscription": true
}

14:51:12.818 [tc-okhttp-stream-1426201528:org.apache.pulsar.tests.integration.utils.DockerUtils$2@216] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(d134594142b34dc846465b57c954472914100c58d75c825516117181a07c079c:/pulsar/bin/pulsar-admin functions status --tenant public --namespace default --name test-sliding-window-fn-vktkrzog): Executing...
14:51:12.881 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:13.430 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:13.530 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:13.783 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:13.783 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:14.433 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:14.533 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:14.885 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:14.986 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:15.536 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:15.737 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:16.088 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:16.188 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:16.589 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:16.940 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:16.991 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:17.291 [kafka-coordinator-heartbeat-thread | sink-test-rabpbzrc:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-3, groupId=sink-test-rabpbzrc] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:17.444 [tc-okhttp-stream-1426201528:org.apache.pulsar.tests.integration.utils.DockerUtils$2@221] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(d134594142b34dc846465b57c954472914100c58d75c825516117181a07c079c:/pulsar/bin/pulsar-admin functions status --tenant public --namespace default --name test-sliding-window-fn-vktkrzog): STDOUT: {
  "numInstances" : 1,
  "numRunning" : 1,
  "instances" : [ {
    "instanceId" : 0,
    "status" : {
      "running" : true,
      "error" : "",
      "numRestarts" : 0,
      "numReceived" : 0,
      "numSuccessfullyProcessed" : 0,
      "numUserExceptions" : 0,
      "latestUserExceptions" : [ ],
      "numSystemExceptions" : 0,
      "latestSystemExceptions" : [ ],
      "averageLatency" : 0.0,
      "lastInvocationTime" : 0,
      "workerId" : "pulsar-functions-worker-thread-vamtq-1"
    }
  } ]
}
14:51:17.643 [kafka-producer-network-thread | bf719e59-18d1-45a3-bb11-e10f97e8cc4a:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=bf719e59-18d1-45a3-bb11-e10f97e8cc4a] Connection to node 1 (localhost/127.0.0.1:35719) could not be established. Broker may not be available.
14:51:17.852 [tc-okhttp-stream-1426201528:org.apache.pulsar.tests.integration.utils.DockerUtils$2@236] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(d134594142b34dc846465b57c954472914100c58d75c825516117181a07c079c:/pulsar/bin/pulsar-admin functions status --tenant public --namespace default --name test-sliding-window-fn-vktkrzog): Done
14:51:17.857 [tc-okhttp-stream-1426201528:org.apache.pulsar.tests.integration.utils.DockerUtils$2@254] INFO  org.apache.pulsar.tests.integration.utils.DockerUtils - DOCKER.exec(d134594142b34dc846465b57c954472914100c58d75c825516117181a07c079c:/pulsar/bin/pulsar-admin functions status --tenant public --namespace default --name test-sliding-window-fn-vktkrzog): completed with 0
14:51:17.874 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ConnectionPool@155] INFO  org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x59e77861, L:/127.0.0.1:34082 - R:localhost/127.0.0.1:35711]] Connected to server
14:51:17.887 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl@102] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer perf with config: {
  "topicNames" : [ "test-sliding-count-window-THREAD-output-pngvkwek" ],
  "topicsPattern" : null,
  "subscriptionName" : "reader-4db993a88f",
  "subscriptionType" : "Exclusive",
  "receiverQueueSize" : 1000,
  "acknowledgementsGroupTimeMicros" : 100000,
  "negativeAckRedeliveryDelayMicros" : 60000000,
  "maxTotalReceiverQueueSizeAcrossPartitions" : 50000,
  "consumerName" : null,
  "ackTimeoutMillis" : 0,
  "tickDurationMillis" : 1000,
  "priorityLevel" : 0,
  "cryptoFailureAction" : "FAIL",
  "properties" : { },
  "readCompacted" : false,
  "subscriptionInitialPosition" : "Latest",
  "patternAutoDiscoveryPeriod" : 1,
  "regexSubscriptionMode" : "PersistentOnly",
  "deadLetterPolicy" : null,
  "autoUpdatePartitions" : true,
  "replicateSubscriptionState" : false,
  "resetIncludeHead" : false
}
14:51:17.888 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl@103] INFO  org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {
  "serviceUrl" : "pulsar://localhost:35711",
  "authPluginClassName" : null,
  "authParams" : null,
  "operationTimeoutMs" : 30000,
  "statsIntervalSeconds" : 60,
  "numIoThreads" : 1,
  "numListenerThreads" : 1,
  "connectionsPerBroker" : 1,
  "useTcpNoDelay" : true,
  "useTls" : false,
  "tlsTrustCertsFilePath" : "",
  "tlsAllowInsecureConnection" : false,
  "tlsHostnameVerificationEnable" : false,
  "concurrentLookupRequest" : 5000,
  "maxLookupRequest" : 50000,
  "maxNumberOfRejectedRequestPerConnection" : 50,
  "keepAliveIntervalSeconds" : 30,
  "connectionTimeoutMs" : 10000,
  "requestTimeoutMs" : 60000,
  "defaultBackoffIntervalNanos" : 100000000,
  "maxBackoffIntervalNanos" : 30000000000
}
14:51:17.904 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ConnectionPool@155] INFO  org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x0d1d5b52, L:/127.0.0.1:34088 - R:localhost/127.0.0.1:35711]] Connected to server
14:51:17.904 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ClientCnx@189] INFO  org.apache.pulsar.client.impl.ClientCnx - [id: 0x0d1d5b52, L:/127.0.0.1:34088 - R:localhost/127.0.0.1:35711] Connected through proxy to target broker at pulsar-broker-0:6650
14:51:17.911 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ConsumerImpl@492] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [test-sliding-count-window-THREAD-output-pngvkwek][reader-4db993a88f] Subscribing to topic on cnx [id: 0x0d1d5b52, L:/127.0.0.1:34088 - R:localhost/127.0.0.1:35711]
14:51:17.916 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ConsumerImpl@590] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [test-sliding-count-window-THREAD-output-pngvkwek][reader-4db993a88f] Subscribed to topic on localhost/127.0.0.1:35711 -- consumer: 0
14:51:17.924 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ProducerStatsRecorderImpl@101] INFO  org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {
  "topicName" : "test-sliding-count-window-THREAD-input-vudzexnv",
  "producerName" : null,
  "sendTimeoutMs" : 30000,
  "blockIfQueueFull" : false,
  "maxPendingMessages" : 1000,
  "maxPendingMessagesAcrossPartitions" : 50000,
  "messageRoutingMode" : "RoundRobinPartition",
  "hashingScheme" : "JavaStringHash",
  "cryptoFailureAction" : "FAIL",
  "batchingMaxPublishDelayMicros" : 1000,
  "batchingMaxMessages" : 1000,
  "batchingEnabled" : false,
  "compressionType" : "NONE",
  "initialSequenceId" : null,
  "autoUpdatePartitions" : true,
  "properties" : { }
}
14:51:17.925 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ProducerStatsRecorderImpl@102] INFO  org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {
  "serviceUrl" : "pulsar://localhost:35711",
  "authPluginClassName" : null,
  "authParams" : null,
  "operationTimeoutMs" : 30000,
  "statsIntervalSeconds" : 60,
  "numIoThreads" : 1,
  "numListenerThreads" : 1,
  "connectionsPerBroker" : 1,
  "useTcpNoDelay" : true,
  "useTls" : false,
  "tlsTrustCertsFilePath" : "",
  "tlsAllowInsecureConnection" : false,
  "tlsHostnameVerificationEnable" : false,
  "concurrentLookupRequest" : 5000,
  "maxLookupRequest" : 50000,
  "maxNumberOfRejectedRequestPerConnection" : 50,
  "keepAliveIntervalSeconds" : 30,
  "connectionTimeoutMs" : 10000,
  "requestTimeoutMs" : 60000,
  "defaultBackoffIntervalNanos" : 100000000,
  "maxBackoffIntervalNanos" : 30000000000
}
14:51:17.936 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ConnectionPool@155] INFO  org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x6f4ae9a5, L:/127.0.0.1:34096 - R:localhost/127.0.0.1:35711]] Connected to server
14:51:17.936 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ClientCnx@189] INFO  org.apache.pulsar.client.impl.ClientCnx - [id: 0x6f4ae9a5, L:/127.0.0.1:34096 - R:localhost/127.0.0.1:35711] Connected through proxy to target broker at pulsar-broker-1:6650
14:51:17.942 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ProducerImpl@900] INFO  org.apache.pulsar.client.impl.ProducerImpl - [test-sliding-count-window-THREAD-input-vudzexnv] [null] Creating producer on cnx [id: 0x6f4ae9a5, L:/127.0.0.1:34096 - R:localhost/127.0.0.1:35711]
14:51:17.963 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ProducerImpl@949] INFO  org.apache.pulsar.client.impl.ProducerImpl - [test-sliding-count-window-THREAD-input-vudzexnv] [PulsarFunctionsThreadTest-woigj-1-23] Created producer on cnx [id: 0x6f4ae9a5, L:/127.0.0.1:34096 - R:localhost/127.0.0.1:35711]
14:51:17.993 [kafka-coordinator-heartbeat-thread | sink-test-ecckeilb:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=sink-test-ecckeilb] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:18.097 [kafka-producer-network-thread | 928cb16e-668c-46b9-9f02-d82df9fcd4f6:org.apache.kafka.clients.NetworkClient@748] WARN  org.apache.kafka.clients.NetworkClient - [Producer clientId=928cb16e-668c-46b9-9f02-d82df9fcd4f6] Connection to node 1 (localhost/127.0.0.1:35684) could not be established. Broker may not be available.
14:51:18.203 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 0 result: 0,1,2,3,4
14:51:18.204 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.client.impl.ConsumerImpl@1524] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [test-sliding-count-window-THREAD-output-pngvkwek][reader-4db993a88f] Get topic last message Id
14:51:18.205 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ConsumerImpl@1527] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [test-sliding-count-window-THREAD-output-pngvkwek][reader-4db993a88f] Successfully getLastMessageId 88:11
14:51:18.206 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 1 result: 0,1,2,3,4,5,6,7,8,9
14:51:18.206 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 2 result: 5,6,7,8,9,10,11,12,13,14
14:51:18.206 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 3 result: 10,11,12,13,14,15,16,17,18,19
14:51:18.206 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 4 result: 15,16,17,18,19,20,21,22,23,24
14:51:18.207 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 5 result: 20,21,22,23,24,25,26,27,28,29
14:51:18.207 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 6 result: 25,26,27,28,29,30,31,32,33,34
14:51:18.207 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 7 result: 30,31,32,33,34,35,36,37,38,39
14:51:18.207 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 8 result: 35,36,37,38,39,40,41,42,43,44
14:51:18.208 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 9 result: 40,41,42,43,44,45,46,47,48,49
14:51:18.208 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 10 result: 45,46,47,48,49,50,51,52,53,54
14:51:18.208 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 11 result: 50,51,52,53,54,55,56,57,58,59
14:51:18.208 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 12 result: 55,56,57,58,59,60,61,62,63,64
14:51:18.209 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 13 result: 60,61,62,63,64,65,66,67,68,69
14:51:18.209 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 14 result: 65,66,67,68,69,70,71,72,73,74
14:51:18.209 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 15 result: 70,71,72,73,74,75,76,77,78,79
14:51:18.209 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 16 result: 75,76,77,78,79,80,81,82,83,84
14:51:18.209 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest@1037] INFO  org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest - i: 17 result: 80,81,82,83,84,85,86,87,88,89
14:51:18.210 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.client.impl.ConsumerImpl@1524] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [test-sliding-count-window-THREAD-output-pngvkwek][reader-4db993a88f] Get topic last message Id
14:51:18.211 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ConsumerImpl@1527] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [test-sliding-count-window-THREAD-output-pngvkwek][reader-4db993a88f] Successfully getLastMessageId 88:11
14:51:18.213 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ProducerImpl@631] INFO  org.apache.pulsar.client.impl.ProducerImpl - [test-sliding-count-window-THREAD-input-vudzexnv] [PulsarFunctionsThreadTest-woigj-1-23] Closed Producer
14:51:18.216 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ConsumerImpl@694] INFO  org.apache.pulsar.client.impl.ConsumerImpl - [test-sliding-count-window-THREAD-output-pngvkwek] [reader-4db993a88f] Closed consumer
14:51:18.217 [TestNG-method=testSlidingCountWindowTest-1:org.apache.pulsar.client.impl.PulsarClientImpl@534] INFO  org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar://localhost:35711
14:51:18.218 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ClientCnx@219] INFO  org.apache.pulsar.client.impl.ClientCnx - [id: 0x0d1d5b52, L:/127.0.0.1:34088 ! R:localhost/127.0.0.1:35711] Disconnected
14:51:18.219 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ClientCnx@219] INFO  org.apache.pulsar.client.impl.ClientCnx - [id: 0x59e77861, L:/127.0.0.1:34082 ! R:localhost/127.0.0.1:35711] Disconnected
!!!!!!!!! FAILURE-- [TestClass name=class org.apache.pulsar.tests.integration.functions.PulsarFunctionsThreadTest].pulsar-test-suite([])-------
14:51:18.219 [pulsar-client-io-280-1:org.apache.pulsar.client.impl.ClientCnx@219] INFO  org.apache.pulsar.client.impl.ClientCnx - [id: 0x6f4ae9a5, L:/127.0.0.1:34096 ! R:localhost/127.0.0.1:35711] Disconnected
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
component/test flaky-tests triage/week-43
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@sijie