[CANCELLED] [VOTE] Pulsar Release 2.5.0 Candidate 1

Cancel rc1 Thanks, Sijie On Fri, Dec 13, 2019 at 10:05 AM Enrico Olivelli wrote: > Matteo, > regarding the upgrade of ZK, in ZooKeeper community it happened to see this > bad problem > https://issues.apache.org/jira/browse/ZOOKEEPER-3644 > > A new 3.5.7 release will be cut "soon" (how much soon

Re: Question/issue wrt running flink window transformations with event time, with pulsar source and sink

A more full featured Pulsar Flink Connector can be found here: https://github.com/streamnative/pulsar-flink On Fri, Dec 13, 2019 at 1:43 PM Jerry Peng wrote: > > Hello Subbu, > > Responding to your comments in Line: > > > When I set the stream characteristic to event time, I do not observe any

Re: Question/issue wrt running flink window transformations with event time, with pulsar source and sink

Hello Subbu, Responding to your comments in Line: > When I set the stream characteristic to event time, I do not observe any data > in the destination topic. Event time is currently not support in this version of of the source > I would like to understand the reason for this above behavior; is

Re: [VOTE] Pulsar Release 2.5.0 Candidate 1

Matteo, regarding the upgrade of ZK, in ZooKeeper community it happened to see this bad problem https://issues.apache.org/jira/browse/ZOOKEEPER-3644 A new 3.5.7 release will be cut "soon" (how much soon I don't know) Maybe it is not worth to block this Pulsar release for that Enrico Il giorno ve

Re: [VOTE] Pulsar Release 2.5.0 Candidate 1

-1 (binding) I'm seeing a couple of problems in starting the standalone in 2.5: * The function workers tries to use "hostname" to connect to local broker. If the hostname is not resolvable the standalone will just fail to start. (we should instead use "localhost" directly) * The ZK upgrade

Question/issue wrt running flink window transformations with event time, with pulsar source and sink

Hi, I've been trying to set up pulsar(2.4.2) with flink(1.8.2) to run window transformations on data being streamed to pulsar topics. I have run into a few issues which I worked around; however I'm not sure if what I've done is the intended way it's supposed to work, or it's a bug or if I'm mi

Re: [VOTE] Pulsar Release 2.5.0 Candidate 1

+1 (non binding) Built from sources with JDK12 Run unit/integration tests of a client application that launches an embedded Pulsar broker (inside the same process of the application), performs writes/reads using the Java client APIs (admin, producer and reader) and uses SubscriptionStats I notic

Re: [VOTE] Pulsar Release 2.5.0 Candidate 1

+1 (non-binding) https://github.com/apache/pulsar/wiki/Release-Candidate-Validation Validate checksum Validate the binary distribution Validate Pub/Sub and Java Functions Validate Connectors Validate Stateful Functions Validate RPM and DEB packages Thanks, Guangning Yong Zhang 于2019年12月13日周五 下午4

PIP-53: Keyed window function

Hi all, Recently, we are facing with the demand to mimic Apache Flink's keyed window operator in Pulsar Functions. This is because, with simple keyed window functions, we could remove the need to deploy and run a separate computing cluster with little computations to do. Therefore, I've drafted

Slack digest for #dev - 2019-12-13

2019-12-12 17:48:37 UTC - Jose Estefania: @Jose Estefania has joined the channel

Re: [VOTE] Pulsar Release 2.5.0 Candidate 1

+1 (non-binding) - download the packages and verify the checksums - compile the source code successfully - produce and consume messages successfully - validate the functions and stateful functions Regards, Yong > On Dec 11, 2019, at 12:44 AM, Sijie Guo wrote: > > This is the first release cand