See
<https://builds.apache.org/job/pulsar-website-build/590/display/redirect?page=changes>
Changes:
[github] Use `PULSAR_PREFIX_` for appending new keys (#3858)
[github] [stats] Expose namespace topics count when exposing topic level metrics
[github] Fix set-project-version.sh (#3847)
[guosijie] fix s3 spport for s3 api (#3845)
[guosijie] hide kafka-connecter details for easy use debezium connector (#3825)
[mmerli] [pulsar-client] Fix pulsar-cpp crash on lookup timeout (#3862)
[github] Issue #3211: Fix NPE when creating schema after deleting a schema
[guosijie] kerberos: authentication between client and broker (#3821)
[mmerli] copy logs from presto server container on teardown in integration tests
[guosijie] revise the schema default type not null (#3752)
[guosijie] [Issue #3712][python-client] exposing InitialPosition management in
the
[guosijie] issue#3838 : Allow incompatible schemas to co-exist on a topic, allow
[mmerli] Fix the loop of consumer poll, so the consumer can cache more than one
[mmerli] [pulsar-client-tools] Add support for websocket produce/consume command
[mmerli] [Issue 3806] Fix NPE while call PartitionedProducerImpl.getStats()
[mmerli] update partition doc (#3846)
[mmerli] Implementing authentication for Pulsar Functions (#3735)
[mmerli] [pulsar-broker] Fix deadlock: add zk-operation timeout for blocking
call
[mmerli] [issue 3839][doc] Document default of schema-autoupdate-strategy : FULL
[guosijie] Fix read batching message by pulsar reader (#3830)
[guosijie] fix some LGTM alerts (#3531)
[guosijie] Add a wrapper around Kafka's ProducerInterceptor to support Kafka's
[github] Create ManagedCursor with initial properties (#3857)
------------------------------------------
[...truncated 1.18 MB...]
import com.google.common.base.MoreObjects;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/SubscribeRate.java:21:
error: package com.google.common.base does not exist
import com.google.common.base.MoreObjects;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/AuthPolicies.java:25:
error: package com.google.common.collect does not exist
import com.google.common.collect.Maps;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/BookiesRackConfiguration.java:21:
error: package com.google.common.base does not exist
import static com.google.common.base.Preconditions.checkNotNull;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/BookiesRackConfiguration.java:21:
error: static import only from classes and interfaces
import static com.google.common.base.Preconditions.checkNotNull;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/BookieInfo.java:21:
error: package lombok does not exist
import lombok.AllArgsConstructor;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/BookieInfo.java:22:
error: package lombok does not exist
import lombok.Data;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/BookieInfo.java:23:
error: package lombok does not exist
import lombok.NoArgsConstructor;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/BookieInfo.java:25:
error: cannot find symbol
@Data
^
symbol: class Data
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/BookieInfo.java:26:
error: cannot find symbol
@AllArgsConstructor
^
symbol: class AllArgsConstructor
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/BookieInfo.java:27:
error: cannot find symbol
@NoArgsConstructor
^
symbol: class NoArgsConstructor
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/OffloadProcessStatus.java:21:
error: package org.apache.pulsar.client.api does not exist
import org.apache.pulsar.client.api.MessageId;
^
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/OffloadProcessStatus.java:22:
error: package org.apache.pulsar.client.impl does not exist
import org.apache.pulsar.client.impl.MessageIdImpl;
^
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/OffloadProcessStatus.java:29:
error: cannot find symbol
public MessageIdImpl firstUnoffloadedMessage;
^
symbol: class MessageIdImpl
location: class OffloadProcessStatus
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/OffloadProcessStatus.java:37:
error: cannot find symbol
MessageIdImpl firstUnoffloadedMessage) {
^
symbol: class MessageIdImpl
location: class OffloadProcessStatus
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/OffloadProcessStatus.java:52:
error: cannot find symbol
public static OffloadProcessStatus forSuccess(MessageIdImpl messageId) {
^
symbol: class MessageIdImpl
location: class OffloadProcessStatus
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Brokers.java:26:
error: package org.apache.pulsar.common.conf does not exist
import org.apache.pulsar.common.conf.InternalConfigurationData;
^
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Brokers.java:115:
error: cannot find symbol
InternalConfigurationData getInternalConfigurationData() throws
PulsarAdminException;
^
symbol: class InternalConfigurationData
location: interface Brokers
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Source.java:24:
error: package org.apache.pulsar.common.io does not exist
import org.apache.pulsar.common.io.ConnectorDefinition;
^
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Source.java:25:
error: package org.apache.pulsar.common.io does not exist
import org.apache.pulsar.common.io.SourceConfig;
^
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Source.java:77:
error: cannot find symbol
SourceConfig getSource(String tenant, String namespace, String source)
throws PulsarAdminException;
^
symbol: class SourceConfig
location: interface Source
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Source.java:88:
error: cannot find symbol
void createSource(SourceConfig sourceConfig, String fileName) throws
PulsarAdminException;
^
symbol: class SourceConfig
location: interface Source
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Source.java:104:
error: cannot find symbol
void createSourceWithUrl(SourceConfig sourceConfig, String pkgUrl) throws
PulsarAdminException;
^
symbol: class SourceConfig
location: interface Source
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Source.java:120:
error: cannot find symbol
void updateSource(SourceConfig sourceConfig, String fileName) throws
PulsarAdminException;
^
symbol: class SourceConfig
location: interface Source
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Source.java:142:
error: cannot find symbol
void updateSourceWithUrl(SourceConfig sourceConfig, String pkgUrl) throws
PulsarAdminException;
^
symbol: class SourceConfig
location: interface Source
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/SourceStatus.java:21:
error: package lombok does not exist
import lombok.Data;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/SourceStatus.java:22:
error: package org.apache.pulsar.common.util does not exist
import org.apache.pulsar.common.util.ObjectMapperFactory;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/SourceStatus.java:28:
error: cannot find symbol
@Data
^
symbol: class Data
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/SourceStatus.java:36:
error: cannot find symbol
@Data
^
symbol: class Data
location: class SourceStatus
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/SourceStatus.java:41:
error: cannot find symbol
@Data
^
symbol: class Data
location: class SourceInstanceStatus
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Source.java:307:
error: cannot find symbol
List<ConnectorDefinition> getBuiltInSources() throws PulsarAdminException;
^
symbol: class ConnectorDefinition
location: interface Source
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/ExceptionInformation.java:21:
error: package lombok does not exist
import lombok.Data;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/ExceptionInformation.java:23:
error: cannot find symbol
@Data
^
symbol: class Data
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Worker.java:25:
error: package org.apache.pulsar.common.functions does not exist
import org.apache.pulsar.common.functions.WorkerInfo;
^
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/WorkerFunctionInstanceStats.java:21:
error: package lombok does not exist
import lombok.Data;
^
100 warnings
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/WindowContext.java:21:
error: package org.slf4j does not exist
import org.slf4j.Logger;
^
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/WindowContext.java:106:
error: cannot find symbol
Logger getLogger();
^
symbol: class Logger
location: interface WindowContext
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Context.java:22:
error: package org.slf4j does not exist
import org.slf4j.Logger;
^
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Context.java:117:
error: cannot find symbol
Logger getLogger();
^
symbol: class Logger
location: interface Context
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/utils/JavaSerDe.java:26:
error: package lombok.extern.slf4j does not exist
import lombok.extern.slf4j.Slf4j;
^
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/utils/JavaSerDe.java:32:
error: cannot find symbol
@Slf4j
^
symbol: class Slf4j
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Context.java:41:
warning - @return tag has no arguments.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
javadoc: warning - Class Slf4j not found.
28 warnings
+ ./python-doc-gen.sh
++ git rev-parse --show-toplevel
+ ROOT_DIR=/pulsar
+ pip install pulsar-client
Collecting pulsar-client
Downloading
https://files.pythonhosted.org/packages/4c/eb/976c9c261a5f4854b06daa4f8b5f4f096775ea31acfd4a8cf1f328afd6c2/pulsar_client-2.3.0-cp27-cp27mu-manylinux1_x86_64.whl
(18.2MB)
Collecting fastavro (from pulsar-client)
Downloading
https://files.pythonhosted.org/packages/67/69/be1402c904506a5ec79ba65c7f0035342d506d5305cfd9ae8bc6f1c8db47/fastavro-0.21.19-cp27-cp27mu-manylinux1_x86_64.whl
(1.0MB)
Collecting prometheus-client (from pulsar-client)
Downloading
https://files.pythonhosted.org/packages/4c/bd/b42db3ec90ffc6be805aad09c1cea4bb13a620d0cd4b21aaa44d13541d71/prometheus_client-0.6.0.tar.gz
Collecting ratelimit (from pulsar-client)
Downloading
https://files.pythonhosted.org/packages/ab/38/ff60c8fc9e002d50d48822cc5095deb8ebbc5f91a6b8fdd9731c87a147c9/ratelimit-2.2.1.tar.gz
Collecting enum34 (from pulsar-client)
Downloading
https://files.pythonhosted.org/packages/c5/db/e56e6b4bbac7c4a06de1c50de6fe1ef3810018ae11732a50f15f62c7d050/enum34-1.1.6-py2-none-any.whl
Collecting protobuf (from pulsar-client)
Downloading
https://files.pythonhosted.org/packages/65/31/00ba247814289a000f56d89cb0257448efdaa1b79aee62bfb974d0da2e8b/protobuf-3.7.0-cp27-cp27mu-manylinux1_x86_64.whl
(1.2MB)
Collecting grpcio (from pulsar-client)
Downloading
https://files.pythonhosted.org/packages/b8/be/3bb6d8241b5ed1f8437169df53e7dd6ca986174e022585de15087a848c99/grpcio-1.19.0-cp27-cp27mu-manylinux1_x86_64.whl
(10.7MB)
Collecting six (from pulsar-client)
Downloading
https://files.pythonhosted.org/packages/73/fb/00a976f728d0d1fecfe898238ce23f502a721c0ac0ecfedb80e0d88c64e9/six-1.12.0-py2.py3-none-any.whl
Collecting apache-bookkeeper-client (from pulsar-client)
Downloading
https://files.pythonhosted.org/packages/04/24/20f690f6019b8bd3856a1c2a2a1378c49f931a37b28161d19332fefc5ff1/apache_bookkeeper_client-4.9.0-py2.py3-none-any.whl
(70kB)
Requirement already satisfied: setuptools in
/usr/local/lib/python2.7/dist-packages (from protobuf->pulsar-client) (40.6.2)
Collecting futures>=2.2.0 (from grpcio->pulsar-client)
Downloading
https://files.pythonhosted.org/packages/2d/99/b2c4e9d5a30f6471e410a146232b4118e697fa3ffc06d6a65efde84debd0/futures-3.2.0-py2-none-any.whl
Collecting pytz (from apache-bookkeeper-client->pulsar-client)
Downloading
https://files.pythonhosted.org/packages/61/28/1d3920e4d1d50b19bc5d24398a7cd85cc7b9a75a490570d5a30c57622d34/pytz-2018.9-py2.py3-none-any.whl
(510kB)
Collecting mmh3>=2.5.1 (from apache-bookkeeper-client->pulsar-client)
Downloading
https://files.pythonhosted.org/packages/fa/7e/3ddcab0a9fcea034212c02eb411433db9330e34d626360b97333368b4052/mmh3-2.5.1.tar.gz
Collecting requests<3.0.0dev,>=2.18.0 (from
apache-bookkeeper-client->pulsar-client)
Downloading
https://files.pythonhosted.org/packages/7d/e3/20f3d364d6c8e5d2353c72a67778eb189176f08e873c9900e10c0287b84b/requests-2.21.0-py2.py3-none-any.whl
(57kB)
Collecting certifi>=2017.4.17 (from
requests<3.0.0dev,>=2.18.0->apache-bookkeeper-client->pulsar-client)
Downloading
https://files.pythonhosted.org/packages/60/75/f692a584e85b7eaba0e03827b3d51f45f571c2e793dd731e598828d380aa/certifi-2019.3.9-py2.py3-none-any.whl
(158kB)
Collecting chardet<3.1.0,>=3.0.2 (from
requests<3.0.0dev,>=2.18.0->apache-bookkeeper-client->pulsar-client)
Downloading
https://files.pythonhosted.org/packages/bc/a9/01ffebfb562e4274b6487b4bb1ddec7ca55ec7510b22e4c51f14098443b8/chardet-3.0.4-py2.py3-none-any.whl
(133kB)
Collecting idna<2.9,>=2.5 (from
requests<3.0.0dev,>=2.18.0->apache-bookkeeper-client->pulsar-client)
Downloading
https://files.pythonhosted.org/packages/14/2c/cd551d81dbe15200be1cf41cd03869a46fe7226e7450af7a6545bfc474c9/idna-2.8-py2.py3-none-any.whl
(58kB)
Collecting urllib3<1.25,>=1.21.1 (from
requests<3.0.0dev,>=2.18.0->apache-bookkeeper-client->pulsar-client)
Downloading
https://files.pythonhosted.org/packages/62/00/ee1d7de624db8ba7090d1226aebefab96a2c71cd5cfa7629d6ad3f61b79e/urllib3-1.24.1-py2.py3-none-any.whl
(118kB)
Building wheels for collected packages: prometheus-client, ratelimit, mmh3
Running setup.py bdist_wheel for prometheus-client: started
Running setup.py bdist_wheel for prometheus-client: finished with status
'done'
Stored in directory:
/root/.cache/pip/wheels/4b/04/b8/3709c73e7453f311ebd46ad581b89642543213f995e2659b9e
Running setup.py bdist_wheel for ratelimit: started
Running setup.py bdist_wheel for ratelimit: finished with status 'done'
Stored in directory:
/root/.cache/pip/wheels/05/d9/82/3c6044cf1a54aab9151612458446d9b17a38416869e1b1d9b8
Running setup.py bdist_wheel for mmh3: started
Running setup.py bdist_wheel for mmh3: finished with status 'done'
Stored in directory:
/root/.cache/pip/wheels/38/b4/ea/6e4e321c625d3320c0c496bf4088371546d8fce5f1dd71b219
Successfully built prometheus-client ratelimit mmh3
Installing collected packages: fastavro, prometheus-client, ratelimit, enum34,
six, protobuf, futures, grpcio, pytz, mmh3, certifi, chardet, idna, urllib3,
requests, apache-bookkeeper-client, pulsar-client
Successfully installed apache-bookkeeper-client-4.9.0 certifi-2019.3.9
chardet-3.0.4 enum34-1.1.6 fastavro-0.21.19 futures-3.2.0 grpcio-1.19.0
idna-2.8 mmh3-2.5.1 prometheus-client-0.6.0 protobuf-3.7.0 pulsar-client-2.3.0
pytz-2018.9 ratelimit-2.2.1 requests-2.21.0 six-1.12.0 urllib3-1.24.1
You are using pip version 18.1, however version 19.0.3 is available.
You should consider upgrading via the 'pip install --upgrade pip' command.
+ DESTINATION=/pulsar/generated-site/api/python
+ rm -fr /pulsar/generated-site/api/python/index.html
/pulsar/generated-site/api/python/functions
/pulsar/generated-site/api/python/pulsar
+ PYTHONPATH=/pulsar/pulsar-client-cpp/python
+ pdoc pulsar --html --html-dir /pulsar/generated-site/api/python
Traceback (most recent call last):
File "/usr/local/bin/pdoc", line 477, in <module>
module = pdoc.import_module(args.module_name)
File "/usr/local/lib/python2.7/dist-packages/pdoc/__init__.py", line 326, in
import_module
__import__(module_name)
File "/pulsar/pulsar-client-cpp/python/pulsar/__init__.py", line 104, in
<module>
from _pulsar import Result, CompressionType, ConsumerType, InitialPosition,
PartitionsRoutingMode # noqa: F401
ImportError: cannot import name InitialPosition
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user [email protected]
Not sending mail to unregistered user [email protected]
