See <https://builds.apache.org/job/pulsar-master/694/display/redirect?page=changes>
Changes: [github] [documentation] Issue 2252: incorrect flags for bin/pulsar (#2341) ------------------------------------------ [...truncated 1.30 MB...] adding 'pulsar_client-2.2.0.dist-info/top_level.txt' adding 'pulsar_client-2.2.0.dist-info/WHEEL' adding 'pulsar_client-2.2.0.dist-info/METADATA' adding 'pulsar_client-2.2.0.dist-info/RECORD' removing build/bdist.linux-x86_64/wheel ---- Installing Python Wheel file Processing ./dist/pulsar_client-2.2.0-cp27-cp27mu-linux_x86_64.whl Collecting protobuf (from pulsar-client==2.2.0) Downloading https://files.pythonhosted.org/packages/27/e7/bf96130ebe633b08a3913da4bb25e50dac5779f1f68e51c99485423f7443/protobuf-3.6.0-cp27-cp27mu-manylinux1_x86_64.whl (7.1MB) Collecting grpcio (from pulsar-client==2.2.0) Downloading https://files.pythonhosted.org/packages/b5/84/c0d0a0355f2e3ea1e49fd81aa123e0bf42bfaa58be56583cc3b9baaf2837/grpcio-1.14.1-cp27-cp27mu-manylinux1_x86_64.whl (9.2MB) Requirement already satisfied: setuptools in /usr/local/lib/python2.7/dist-packages (from protobuf->pulsar-client==2.2.0) (40.0.0) Collecting six>=1.9 (from protobuf->pulsar-client==2.2.0) Downloading https://files.pythonhosted.org/packages/67/4b/141a581104b1f6397bfa78ac9d43d8ad29a7ca43ea90a2d863fe3056e86a/six-1.11.0-py2.py3-none-any.whl Collecting enum34>=1.0.4 (from grpcio->pulsar-client==2.2.0) Downloading https://files.pythonhosted.org/packages/c5/db/e56e6b4bbac7c4a06de1c50de6fe1ef3810018ae11732a50f15f62c7d050/enum34-1.1.6-py2-none-any.whl Collecting futures>=2.2.0 (from grpcio->pulsar-client==2.2.0) Downloading https://files.pythonhosted.org/packages/2d/99/b2c4e9d5a30f6471e410a146232b4118e697fa3ffc06d6a65efde84debd0/futures-3.2.0-py2-none-any.whl Installing collected packages: six, protobuf, enum34, futures, grpcio, pulsar-client Successfully installed enum34-1.1.6 futures-3.2.0 grpcio-1.14.1 protobuf-3.6.0 pulsar-client-2.2.0 six-1.11.0 ---- Running Python unit tests /tmp /pulsar/pulsar-client-cpp/python /pulsar/pulsar-client-cpp 2018-08-08 21:29:23.978 WARN Authentication:158 | Couldn't load auth plugin someoldjunk.so 2018-08-08 21:29:23.979 ERROR ClientConnection:164 | Invalid authentication plugin 2018-08-08 21:29:23.979 INFO ClientConnection:1237 | [<none> -> pulsar+ssl://localhost:9886] Connection closed 2018-08-08 21:29:23.979 INFO ConnectionPool:63 | Created connection for pulsar+ssl://localhost:9886 2018-08-08 21:29:23.979 INFO ClientConnection:195 | [<none> -> pulsar+ssl://localhost:9886] Destroyed connection 2018-08-08 21:29:23.979 ERROR ClientImpl:374 | Error Checking/Getting Partition Metadata while Subscribing- 5 ....2018-08-08 21:29:23.980 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:23.981 INFO ClientConnection:285 | [127.0.0.1:52142 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:23.987 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test-producer, ] Getting connection from pool 2018-08-08 21:29:24.574 INFO ProducerImpl:154 | [persistent://sample/standalone/ns1/my-python-test-producer, ] Created producer on broker [127.0.0.1:52142 -> 127.0.0.1:8885] 2018-08-08 21:29:24.579 INFO ProducerImpl:466 | [persistent://sample/standalone/ns1/my-python-test-producer, standalone-0-125] Closed producer .2018-08-08 21:29:24.580 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:24.580 INFO ClientConnection:285 | [127.0.0.1:52144 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:24.585 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-listener, my-sub, 0] Getting connection from pool 2018-08-08 21:29:25.179 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-listener, my-sub, 0] Created consumer on broker [127.0.0.1:52144 -> 127.0.0.1:8885] 2018-08-08 21:29:25.181 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-listener, ] Getting connection from pool 2018-08-08 21:29:25.187 INFO ProducerImpl:154 | [persistent://sample/standalone/ns/my-python-topic-listener, ] Created producer on broker [127.0.0.1:52144 -> 127.0.0.1:8885] Got message: Message(prod=standalone-0-126, seq=0, publish_time=1533763765187, payload_size=7, msg_id=(245,0,-1,-1), props={}) Got message: Message(prod=standalone-0-126, seq=1, publish_time=1533763765234, payload_size=7, msg_id=(245,1,-1,-1), props={}) Got message: Message(prod=standalone-0-126, seq=2, publish_time=1533763765262, payload_size=7, msg_id=(245,2,-1,-1), props={}) 2018-08-08 21:29:25.414 INFO ProducerImpl:466 | [persistent://sample/standalone/ns/my-python-topic-listener, standalone-0-126] Closed producer ..2018-08-08 21:29:25.414 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns/my-python-topic-listener, my-sub, 0] Closed consumer 0 .2018-08-08 21:29:25.416 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:25.417 INFO ClientConnection:285 | [127.0.0.1:52146 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:25.421 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-producer-consumer, my-sub, 0] Getting connection from pool 2018-08-08 21:29:25.734 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-producer-consumer, my-sub, 0] Created consumer on broker [127.0.0.1:52146 -> 127.0.0.1:8885] 2018-08-08 21:29:25.738 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-producer-consumer, ] Getting connection from pool 2018-08-08 21:29:25.744 INFO ProducerImpl:154 | [persistent://sample/standalone/ns/my-python-topic-producer-consumer, ] Created producer on broker [127.0.0.1:52146 -> 127.0.0.1:8885] 2018-08-08 21:29:25.888 INFO ProducerImpl:466 | [persistent://sample/standalone/ns/my-python-topic-producer-consumer, standalone-0-127] Closed producer 2018-08-08 21:29:25.889 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns/my-python-topic-producer-consumer, my-sub, 0] Closed consumer 0 .2018-08-08 21:29:25.889 INFO ProducerImpl:415 | Producer - [persistent://sample/standalone/ns/my-python-topic-producer-consumer, standalone-0-127] , [batching = off] 2018-08-08 21:29:25.928 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:25.929 INFO ClientConnection:285 | [127.0.0.1:52150 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:25.931 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1533763765.93, my-producer-name] Getting connection from pool 2018-08-08 21:29:26.537 INFO ProducerImpl:154 | [persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1533763765.93, my-producer-name] Created producer on broker [127.0.0.1:52150 -> 127.0.0.1:8885] 2018-08-08 21:29:26.539 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1533763765.93, my-sub, 0] Getting connection from pool 2018-08-08 21:29:26.702 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1533763765.93, my-sub, 0] Created consumer on broker [127.0.0.1:52150 -> 127.0.0.1:8885] 2018-08-08 21:29:27.873 INFO ProducerImpl:466 | [persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1533763765.93, my-producer-name] Closed producer 2018-08-08 21:29:27.875 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1533763765.93, my-producer-name] Getting connection from pool 2018-08-08 21:29:27.877 INFO ProducerImpl:154 | [persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1533763765.93, my-producer-name] Created producer on broker [127.0.0.1:52150 -> 127.0.0.1:8885] .2018-08-08 21:29:28.879 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:28.880 INFO ClientConnection:285 | [127.0.0.1:52152 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:28.883 INFO HandlerBase:53 | [persistent://public/default/my-python-test-producer, ] Getting connection from pool 2018-08-08 21:29:29.053 INFO ProducerImpl:154 | [persistent://public/default/my-python-test-producer, ] Created producer on broker [127.0.0.1:52152 -> 127.0.0.1:8885] 2018-08-08 21:29:29.112 INFO ProducerImpl:466 | [persistent://public/default/my-python-test-producer, standalone-0-128] Closed producer .2018-08-08 21:29:29.113 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:29.114 INFO ClientConnection:285 | [127.0.0.1:52154 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:29.117 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic, ] Getting connection from pool 2018-08-08 21:29:29.322 INFO ProducerImpl:154 | [persistent://sample/standalone/ns/my-python-topic, ] Created producer on broker [127.0.0.1:52154 -> 127.0.0.1:8885] 2018-08-08 21:29:29.323 WARN ConsumerImpl:97 | [persistent://sample/standalone/ns1/my-python-test-producer-deduplication-1533763765.93, my-sub, 0] Destroyed consumer which was not properly closed 2018-08-08 21:29:29.424 INFO ProducerImpl:466 | [persistent://sample/standalone/ns/my-python-topic, standalone-0-129] Closed producer .2018-08-08 21:29:29.464 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:29.465 INFO ClientConnection:285 | [127.0.0.1:52158 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:29.468 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test-producer-sequence-after-reconnection-1533763769.46, my-producer-name] Getting connection from pool 2018-08-08 21:29:29.879 INFO ProducerImpl:154 | [persistent://sample/standalone/ns1/my-python-test-producer-sequence-after-reconnection-1533763769.46, my-producer-name] Created producer on broker [127.0.0.1:52158 -> 127.0.0.1:8885] 2018-08-08 21:29:30.237 INFO ProducerImpl:466 | [persistent://sample/standalone/ns1/my-python-test-producer-sequence-after-reconnection-1533763769.46, my-producer-name] Closed producer 2018-08-08 21:29:30.240 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test-producer-sequence-after-reconnection-1533763769.46, my-producer-name] Getting connection from pool 2018-08-08 21:29:30.242 INFO ProducerImpl:154 | [persistent://sample/standalone/ns1/my-python-test-producer-sequence-after-reconnection-1533763769.46, my-producer-name] Created producer on broker [127.0.0.1:52158 -> 127.0.0.1:8885] .2018-08-08 21:29:30.554 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:30.555 INFO ClientConnection:285 | [127.0.0.1:52170 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:30.558 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-producer-name] Getting connection from pool 2018-08-08 21:29:30.887 INFO ProducerImpl:154 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-producer-name] Created producer on broker [127.0.0.1:52170 -> 127.0.0.1:8885] 2018-08-08 21:29:30.890 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-sub1, 0] Getting connection from pool 2018-08-08 21:29:31.053 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-sub1, 0] Created consumer on broker [127.0.0.1:52170 -> 127.0.0.1:8885] 2018-08-08 21:29:31.054 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-sub1, 0] Closed consumer 0 2018-08-08 21:29:31.056 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-sub2, 1] Getting connection from pool 2018-08-08 21:29:31.235 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-sub2, 1] Created consumer on broker [127.0.0.1:52170 -> 127.0.0.1:8885] 2018-08-08 21:29:31.320 INFO ProducerImpl:466 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-producer-name] Closed producer Compact still running {"status":"RUNNING","lastError":""} Compact still running {"status":"RUNNING","lastError":""} Compact still running {"status":"RUNNING","lastError":""} Compact Complete now {"status":"SUCCESS","lastError":""} 2018-08-08 21:29:32.187 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-sub1, 2] Getting connection from pool 2018-08-08 21:29:32.189 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-sub1, 2] Created consumer on broker [127.0.0.1:52170 -> 127.0.0.1:8885] F2018-08-08 21:29:32.192 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:32.193 INFO ClientConnection:285 | [127.0.0.1:52186 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:32.196 INFO HandlerBase:53 | [persistent://sample/standalone/ns1/my-python-test-producer, reader-d3697a, 0] Getting connection from pool 2018-08-08 21:29:32.197 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns1/my-python-test-producer, reader-d3697a, 0] Created consumer on broker [127.0.0.1:52186 -> 127.0.0.1:8885] 2018-08-08 21:29:32.198 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns1/my-python-test-producer, reader-d3697a, 0] Closed consumer 0 .2018-08-08 21:29:32.199 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:32.200 INFO ClientConnection:285 | [127.0.0.1:52188 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:32.202 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-has-message-available, ] Getting connection from pool 2018-08-08 21:29:32.340 INFO ProducerImpl:154 | [persistent://sample/standalone/ns/my-python-topic-reader-has-message-available, ] Created producer on broker [127.0.0.1:52188 -> 127.0.0.1:8885] 2018-08-08 21:29:32.342 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-has-message-available, reader-7299b4, 0] Getting connection from pool 2018-08-08 21:29:32.345 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-reader-has-message-available, reader-7299b4, 0] Created consumer on broker [127.0.0.1:52188 -> 127.0.0.1:8885] 2018-08-08 21:29:33.054 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns/my-python-topic-reader-has-message-available, reader-7299b4, 0] Closed consumer 0 2018-08-08 21:29:33.055 INFO ProducerImpl:466 | [persistent://sample/standalone/ns/my-python-topic-reader-has-message-available, standalone-0-130] Closed producer .2018-08-08 21:29:33.056 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:33.057 INFO ClientConnection:285 | [127.0.0.1:52190 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:33.060 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-on-last-message, ] Getting connection from pool 2018-08-08 21:29:33.248 INFO ProducerImpl:154 | [persistent://sample/standalone/ns/my-python-topic-reader-on-last-message, ] Created producer on broker [127.0.0.1:52190 -> 127.0.0.1:8885] 2018-08-08 21:29:33.656 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-on-last-message, reader-22ad36, 0] Getting connection from pool 2018-08-08 21:29:33.659 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-reader-on-last-message, reader-22ad36, 0] Created consumer on broker [127.0.0.1:52190 -> 127.0.0.1:8885] 2018-08-08 21:29:33.988 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns/my-python-topic-reader-on-last-message, reader-22ad36, 0] Closed consumer 0 2018-08-08 21:29:33.989 INFO ProducerImpl:466 | [persistent://sample/standalone/ns/my-python-topic-reader-on-last-message, standalone-0-131] Closed producer .2018-08-08 21:29:33.990 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:33.990 INFO ClientConnection:285 | [127.0.0.1:52192 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:33.993 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message, ] Getting connection from pool 2018-08-08 21:29:34.172 INFO ProducerImpl:154 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message, ] Created producer on broker [127.0.0.1:52192 -> 127.0.0.1:8885] 2018-08-08 21:29:34.522 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message, reader-db31ed, 0] Getting connection from pool 2018-08-08 21:29:34.525 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message, reader-db31ed, 0] Created consumer on broker [127.0.0.1:52192 -> 127.0.0.1:8885] 2018-08-08 21:29:34.532 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message, reader-dfc51e, 1] Getting connection from pool 2018-08-08 21:29:34.537 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message, reader-dfc51e, 1] Created consumer on broker [127.0.0.1:52192 -> 127.0.0.1:8885] 2018-08-08 21:29:34.541 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message, reader-db31ed, 0] Closed consumer 0 2018-08-08 21:29:34.542 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message, reader-dfc51e, 1] Closed consumer 1 2018-08-08 21:29:34.543 INFO ProducerImpl:466 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message, standalone-0-132] Closed producer .2018-08-08 21:29:34.544 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:34.545 INFO ClientConnection:285 | [127.0.0.1:52194 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:34.549 INFO BatchMessageContainer:41 | { BatchContainer [size = 0] [batchSizeInBytes_ = 0] [maxAllowedMessageBatchSizeInBytes_ = 131072] [maxAllowedNumMessagesInBatch_ = 1000] [topicName = persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message-with-batches] [producerName_ = ] [batchSizeInBytes_ = 0] [numberOfBatchesSent = 0] [averageBatchSize = 0]} BatchMessageContainer constructed 2018-08-08 21:29:34.549 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message-with-batches, ] Getting connection from pool 2018-08-08 21:29:34.698 INFO ProducerImpl:154 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message-with-batches, ] Created producer on broker [127.0.0.1:52194 -> 127.0.0.1:8885] 2018-08-08 21:29:35.741 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message-with-batches, reader-d5fd88, 0] Getting connection from pool 2018-08-08 21:29:35.745 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message-with-batches, reader-d5fd88, 0] Created consumer on broker [127.0.0.1:52194 -> 127.0.0.1:8885] 2018-08-08 21:29:35.749 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message-with-batches, reader-c17aff, 1] Getting connection from pool 2018-08-08 21:29:35.752 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message-with-batches, reader-c17aff, 1] Created consumer on broker [127.0.0.1:52194 -> 127.0.0.1:8885] 2018-08-08 21:29:35.754 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message-with-batches, reader-d5fd88, 0] Closed consumer 0 2018-08-08 21:29:35.755 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message-with-batches, reader-c17aff, 1] Closed consumer 1 2018-08-08 21:29:35.755 INFO ProducerImpl:466 | [persistent://sample/standalone/ns/my-python-topic-reader-on-specific-message-with-batches, standalone-0-133] Closed producer .2018-08-08 21:29:35.756 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:35.757 INFO ClientConnection:285 | [127.0.0.1:52210 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:35.758 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-simple, reader-46babc, 0] Getting connection from pool 2018-08-08 21:29:35.931 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-reader-simple, reader-46babc, 0] Created consumer on broker [127.0.0.1:52210 -> 127.0.0.1:8885] 2018-08-08 21:29:35.933 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-reader-simple, ] Getting connection from pool 2018-08-08 21:29:35.937 INFO ProducerImpl:154 | [persistent://sample/standalone/ns/my-python-topic-reader-simple, ] Created producer on broker [127.0.0.1:52210 -> 127.0.0.1:8885] 2018-08-08 21:29:36.089 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns/my-python-topic-reader-simple, reader-46babc, 0] Closed consumer 0 2018-08-08 21:29:36.089 INFO ProducerImpl:466 | [persistent://sample/standalone/ns/my-python-topic-reader-simple, standalone-0-134] Closed producer 2018-08-08 21:29:36.090 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 .2018-08-08 21:29:36.092 INFO ClientConnection:285 | [127.0.0.1:52214 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:36.095 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-seek, my-sub, 0] Getting connection from pool 2018-08-08 21:29:36.345 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-seek, my-sub, 0] Created consumer on broker [127.0.0.1:52214 -> 127.0.0.1:8885] 2018-08-08 21:29:36.349 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-seek, ] Getting connection from pool 2018-08-08 21:29:36.355 INFO ProducerImpl:154 | [persistent://sample/standalone/ns/my-python-topic-seek, ] Created producer on broker [127.0.0.1:52214 -> 127.0.0.1:8885] 2018-08-08 21:29:37.537 INFO HandlerBase:129 | [persistent://sample/standalone/ns/my-python-topic-seek, my-sub, 0] Schedule reconnection in 0.1 s 2018-08-08 21:29:37.545 INFO ConsumerImpl:893 | [persistent://sample/standalone/ns/my-python-topic-seek, my-sub, 0] Seek successfully 2018-08-08 21:29:37.637 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic-seek, my-sub, 0] Getting connection from pool 2018-08-08 21:29:37.642 INFO ConsumerImpl:168 | [persistent://sample/standalone/ns/my-python-topic-seek, my-sub, 0] Created consumer on broker [127.0.0.1:52214 -> 127.0.0.1:8885] 2018-08-08 21:29:38.047 INFO ProducerImpl:466 | [persistent://sample/standalone/ns/my-python-topic-seek, standalone-0-135] Closed producer 2018-08-08 21:29:38.048 INFO ConsumerImpl:761 | [persistent://sample/standalone/ns/my-python-topic-seek, my-sub, 0] Closed consumer 0 .2018-08-08 21:29:38.048 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:38.049 INFO ClientConnection:285 | [127.0.0.1:52248 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:38.053 INFO HandlerBase:53 | [persistent://sample/standalone/ns/my-python-topic, ] Getting connection from pool 2018-08-08 21:29:38.059 INFO ProducerImpl:154 | [persistent://sample/standalone/ns/my-python-topic, ] Created producer on broker [127.0.0.1:52248 -> 127.0.0.1:8885] 2018-08-08 21:29:38.087 INFO ProducerImpl:466 | [persistent://sample/standalone/ns/my-python-topic, standalone-0-136] Closed producer .2018-08-08 21:29:38.089 INFO ConnectionPool:63 | Created connection for pulsar+ssl://localhost:9886 2018-08-08 21:29:38.090 INFO ClientConnection:285 | [127.0.0.1:60142 -> 127.0.0.1:9886] Connected to broker 2018-08-08 21:29:38.125 INFO HandlerBase:53 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, my-sub, 0] Getting connection from pool 2018-08-08 21:29:38.129 INFO ConnectionPool:63 | Created connection for pulsar://localhost:9886 2018-08-08 21:29:38.129 INFO ClientConnection:287 | [127.0.0.1:60144 -> 127.0.0.1:9886] Connected to broker through proxy. Logical broker: pulsar://localhost:9886 2018-08-08 21:29:38.341 INFO ConsumerImpl:168 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, my-sub, 0] Created consumer on broker [127.0.0.1:60144 -> 127.0.0.1:9886] 2018-08-08 21:29:38.346 INFO HandlerBase:53 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, ] Getting connection from pool 2018-08-08 21:29:38.352 INFO ProducerImpl:154 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, ] Created producer on broker [127.0.0.1:60144 -> 127.0.0.1:9886] 2018-08-08 21:29:38.500 INFO ProducerImpl:466 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, cluster-0-2] Closed producer 2018-08-08 21:29:38.504 INFO ConsumerImpl:761 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, my-sub, 0] Closed consumer 0 .2018-08-08 21:29:38.506 INFO ConnectionPool:63 | Created connection for pulsar+ssl://localhost:9886 2018-08-08 21:29:38.507 INFO ClientConnection:285 | [127.0.0.1:60150 -> 127.0.0.1:9886] Connected to broker 2018-08-08 21:29:38.541 INFO HandlerBase:53 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, my-sub, 0] Getting connection from pool 2018-08-08 21:29:38.543 INFO ConnectionPool:63 | Created connection for pulsar://localhost:9886 2018-08-08 21:29:38.543 INFO ClientConnection:287 | [127.0.0.1:60152 -> 127.0.0.1:9886] Connected to broker through proxy. Logical broker: pulsar://localhost:9886 2018-08-08 21:29:38.574 INFO ConsumerImpl:168 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, my-sub, 0] Created consumer on broker [127.0.0.1:60152 -> 127.0.0.1:9886] 2018-08-08 21:29:38.579 INFO HandlerBase:53 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, ] Getting connection from pool 2018-08-08 21:29:38.595 INFO ProducerImpl:154 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, ] Created producer on broker [127.0.0.1:60152 -> 127.0.0.1:9886] 2018-08-08 21:29:38.642 INFO ProducerImpl:466 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, cluster-0-3] Closed producer 2018-08-08 21:29:38.644 INFO ConsumerImpl:761 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, my-sub, 0] Closed consumer 0 .2018-08-08 21:29:38.645 INFO ConnectionPool:63 | Created connection for pulsar+ssl://localhost:9886 2018-08-08 21:29:38.646 INFO ClientConnection:285 | [127.0.0.1:60158 -> 127.0.0.1:9886] Connected to broker 2018-08-08 21:29:38.682 INFO HandlerBase:53 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, my-sub, 0] Getting connection from pool 2018-08-08 21:29:38.685 INFO ConnectionPool:63 | Created connection for pulsar://localhost:9886 2018-08-08 21:29:38.686 INFO ClientConnection:287 | [127.0.0.1:60160 -> 127.0.0.1:9886] Connected to broker through proxy. Logical broker: pulsar://localhost:9886 2018-08-08 21:29:38.719 INFO ConsumerImpl:168 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, my-sub, 0] Created consumer on broker [127.0.0.1:60160 -> 127.0.0.1:9886] 2018-08-08 21:29:38.722 INFO HandlerBase:53 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, ] Getting connection from pool 2018-08-08 21:29:38.732 INFO ProducerImpl:154 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, ] Created producer on broker [127.0.0.1:60160 -> 127.0.0.1:9886] 2018-08-08 21:29:38.748 INFO ProducerImpl:466 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, cluster-0-4] Closed producer 2018-08-08 21:29:38.749 INFO ConsumerImpl:761 | [persistent://property/cluster/namespace/my-python-topic-producer-consumer, my-sub, 0] Closed consumer 0 .2018-08-08 21:29:38.750 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:38.751 INFO ClientConnection:285 | [127.0.0.1:52270 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:38.754 INFO HandlerBase:53 | [persistent://public/default/my-v2-topic-producer-consumer, my-sub, 0] Getting connection from pool 2018-08-08 21:29:39.052 INFO ConsumerImpl:168 | [persistent://public/default/my-v2-topic-producer-consumer, my-sub, 0] Created consumer on broker [127.0.0.1:52270 -> 127.0.0.1:8885] 2018-08-08 21:29:39.055 INFO HandlerBase:53 | [persistent://public/default/my-v2-topic-producer-consumer, ] Getting connection from pool 2018-08-08 21:29:39.057 INFO ProducerImpl:154 | [persistent://public/default/my-v2-topic-producer-consumer, ] Created producer on broker [127.0.0.1:52270 -> 127.0.0.1:8885] 2018-08-08 21:29:39.180 INFO ProducerImpl:466 | [persistent://public/default/my-v2-topic-producer-consumer, standalone-0-137] Closed producer 2018-08-08 21:29:39.180 INFO ConsumerImpl:761 | [persistent://public/default/my-v2-topic-producer-consumer, my-sub, 0] Closed consumer 0 .2018-08-08 21:29:39.181 INFO HTTPLookupService:189 | Curl Lookup Request sent for http://localhost:8765/admin/v2/persistent/public/default/my-v2-topic-producer-consumer/partitions 2018-08-08 21:29:39.194 INFO HTTPLookupService:203 | Response received for url http://localhost:8765/admin/v2/persistent/public/default/my-v2-topic-producer-consumer/partitions code 200 2018-08-08 21:29:39.194 INFO HTTPLookupService:244 | parsePartitionData = { LookupDataResult [brokerUrl_ = ] [brokerUrlSsl_ = ] [partitions = 0] [authoritative = 0] [redirect = 0] proxyThroughServiceUrl = 0] } 2018-08-08 21:29:39.194 INFO HandlerBase:53 | [persistent://public/default/my-v2-topic-producer-consumer, my-sub, 0] Getting connection from pool 2018-08-08 21:29:39.195 INFO HTTPLookupService:189 | Curl Lookup Request sent for http://localhost:8765/lookup/v2/topic/persistent/public/default/my-v2-topic-producer-consumer 2018-08-08 21:29:39.203 INFO HTTPLookupService:203 | Response received for url http://localhost:8765/lookup/v2/topic/persistent/public/default/my-v2-topic-producer-consumer code 200 2018-08-08 21:29:39.203 INFO HTTPLookupService:273 | parseLookupData = { LookupDataResult [brokerUrl_ = pulsar://localhost:8885] [brokerUrlSsl_ = ] [partitions = 0] [authoritative = 0] [redirect = 0] proxyThroughServiceUrl = 0] } 2018-08-08 21:29:39.203 INFO ConnectionPool:63 | Created connection for pulsar://localhost:8885 2018-08-08 21:29:39.204 INFO ClientConnection:285 | [127.0.0.1:52282 -> 127.0.0.1:8885] Connected to broker 2018-08-08 21:29:39.207 INFO ConsumerImpl:168 | [persistent://public/default/my-v2-topic-producer-consumer, my-sub, 0] Created consumer on broker [127.0.0.1:52282 -> 127.0.0.1:8885] 2018-08-08 21:29:39.207 INFO HTTPLookupService:189 | Curl Lookup Request sent for http://localhost:8765/admin/v2/persistent/public/default/my-v2-topic-producer-consumer/partitions 2018-08-08 21:29:39.216 INFO HTTPLookupService:203 | Response received for url http://localhost:8765/admin/v2/persistent/public/default/my-v2-topic-producer-consumer/partitions code 200 2018-08-08 21:29:39.216 INFO HTTPLookupService:244 | parsePartitionData = { LookupDataResult [brokerUrl_ = ] [brokerUrlSsl_ = ] [partitions = 0] [authoritative = 0] [redirect = 0] proxyThroughServiceUrl = 0] } 2018-08-08 21:29:39.216 INFO HandlerBase:53 | [persistent://public/default/my-v2-topic-producer-consumer, ] Getting connection from pool 2018-08-08 21:29:39.216 INFO HTTPLookupService:189 | Curl Lookup Request sent for http://localhost:8765/lookup/v2/topic/persistent/public/default/my-v2-topic-producer-consumer 2018-08-08 21:29:39.225 INFO HTTPLookupService:203 | Response received for url http://localhost:8765/lookup/v2/topic/persistent/public/default/my-v2-topic-producer-consumer code 200 2018-08-08 21:29:39.225 INFO HTTPLookupService:273 | parseLookupData = { LookupDataResult [brokerUrl_ = pulsar://localhost:8885] [brokerUrlSsl_ = ] [partitions = 0] [authoritative = 0] [redirect = 0] proxyThroughServiceUrl = 0] } 2018-08-08 21:29:39.226 INFO ProducerImpl:154 | [persistent://public/default/my-v2-topic-producer-consumer, ] Created producer on broker [127.0.0.1:52282 -> 127.0.0.1:8885] 2018-08-08 21:29:39.370 INFO ProducerImpl:466 | [persistent://public/default/my-v2-topic-producer-consumer, standalone-0-138] Closed producer 2018-08-08 21:29:39.370 INFO ConsumerImpl:761 | [persistent://public/default/my-v2-topic-producer-consumer, my-sub, 0] Closed consumer 0 . ====================================================================== FAIL: test_publish_compact_and_consume (__main__.PulsarTest) ---------------------------------------------------------------------- Traceback (most recent call last): File "pulsar_test.py", line 557, in test_publish_compact_and_consume self.assertEqual(msg0.data(), b'hello-1') AssertionError: 'hello-0' != 'hello-1' ---------------------------------------------------------------------- Ran 27 tests in 15.393s FAILED (failures=1) 2018-08-08 21:29:39.375 WARN ConsumerImpl:97 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-sub1, 2] Destroyed consumer which was not properly closed 2018-08-08 21:29:39.375 WARN ConsumerImpl:97 | [persistent://sample/standalone/ns1/my-python-test_publish_compact_and_consume, my-sub2, 1] Destroyed consumer which was not properly closed /pulsar/pulsar-client-cpp/python /pulsar/pulsar-client-cpp /pulsar/pulsar-client-cpp Build step 'Execute shell' marked build as failure Not sending mail to unregistered user nore...@github.com Not sending mail to unregistered user guosi...@gmail.com Not sending mail to unregistered user jiaz...@users.noreply.github.com Not sending mail to unregistered user y.shiga.91+yush...@gmail.com
