You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2022/10/12 07:11:48 UTC
[pulsar] branch master updated (7e420c6bfd7 -> 2b5b92ce57d)
This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 7e420c6bfd7 Fix flaky test `testSplitBundleForMultiTimes`. (#17993)
add 2b5b92ce57d [improve][client] Refactor SchemaHash to reduce call of hashFunction in SchemaHash (#17948)
No new revisions were added by this update.
Summary of changes:
.../org/apache/pulsar/client/impl/MessageImpl.java | 2 +-
.../pulsar/client/impl/schema/BooleanSchema.java | 8 ++---
.../pulsar/client/impl/schema/ByteBufSchema.java | 8 ++---
.../client/impl/schema/ByteBufferSchema.java | 8 ++---
.../pulsar/client/impl/schema/ByteSchema.java | 8 ++---
.../pulsar/client/impl/schema/BytesSchema.java | 8 ++---
.../pulsar/client/impl/schema/DateSchema.java | 8 ++---
.../pulsar/client/impl/schema/DoubleSchema.java | 8 ++---
.../pulsar/client/impl/schema/FloatSchema.java | 8 ++---
.../pulsar/client/impl/schema/InstantSchema.java | 8 ++---
.../pulsar/client/impl/schema/IntSchema.java | 8 ++---
.../pulsar/client/impl/schema/JSONSchema.java | 11 ++++---
.../pulsar/client/impl/schema/LocalDateSchema.java | 8 ++---
.../client/impl/schema/LocalDateTimeSchema.java | 8 ++---
.../pulsar/client/impl/schema/LocalTimeSchema.java | 8 ++---
.../pulsar/client/impl/schema/LongSchema.java | 8 ++---
.../pulsar/client/impl/schema/ShortSchema.java | 8 ++---
.../pulsar/client/impl/schema/StringSchema.java | 19 ++++++-----
.../pulsar/client/impl/schema/TimeSchema.java | 8 ++---
.../pulsar/client/impl/schema/TimestampSchema.java | 8 ++---
.../client/impl/schema/KeyValueSchemaInfoTest.java | 10 +++---
.../client/impl/schema/StringSchemaTest.java | 20 ++++++------
.../pulsar/client/impl/schema/SchemaInfoImpl.java | 34 ++++++++++++++++---
.../pulsar/common/protocol/schema/SchemaHash.java | 25 +++++++++-----
.../io/kafka/connect/KafkaConnectSinkTest.java | 38 ++++++++++++----------
25 files changed, 168 insertions(+), 127 deletions(-)