Hello all,
I noticed the PubSub example jar is not included in the examples/ dir of
flink-dist. I've created https://issues.apache.org/jira/browse/FLINK-13700
+ https://github.com/apache/flink/pull/9424/files to fix this.
I will leave it up to you to decide if we want to add this to 1.9.0.
Rega
Richard Deurwaarder created FLINK-13700:
---
Summary: PubSub connector example not included in flink-dist
Key: FLINK-13700
URL: https://issues.apache.org/jira/browse/FLINK-13700
Project: Flink
Congrats Becket! :)
Richard
On Thu, Jul 18, 2019 at 5:52 PM Xuefu Z wrote:
> Congratulation, Becket! At least you're able to assign JIRAs now!
>
> On Thu, Jul 18, 2019 at 8:22 AM Rong Rong wrote:
>
> > Congratulations Becket!
> >
> > --
> > Rong
> >
> > On Thu, Jul 18, 2019 at 7:05 AM Xingcan
Richard Deurwaarder created FLINK-13231:
---
Summary: Add a ratelimiter to pubsub source
Key: FLINK-13231
URL: https://issues.apache.org/jira/browse/FLINK-13231
Project: Flink
Issue Type
Richard Deurwaarder created FLINK-13230:
---
Summary: Retry acknowledgement calls
Key: FLINK-13230
URL: https://issues.apache.org/jira/browse/FLINK-13230
Project: Flink
Issue Type: Sub
Richard Deurwaarder created FLINK-13133:
---
Summary: Correct error in PubSub documentation
Key: FLINK-13133
URL: https://issues.apache.org/jira/browse/FLINK-13133
Project: Flink
Issue
Richard Deurwaarder created FLINK-13083:
---
Summary: Various improvements PubSub Connector
Key: FLINK-13083
URL: https://issues.apache.org/jira/browse/FLINK-13083
Project: Flink
Issue
Hello,
I am running into the problem where (avro) schema evolution works perfectly
for operator/keyed state but does not work when used with keyBy().
For example:
I have a job like so:
env.addSource(someSource())
.keyBy(object -> getMyAvroObject())
.process(doSomething()
Richard Deurwaarder created FLINK-12325:
---
Summary: Statsd reporter gives wrong metrics when using negative
numbers
Key: FLINK-12325
URL: https://issues.apache.org/jira/browse/FLINK-12325
Very nice! Thanks Aljoscha and all contributors!
I have one question, will the docker image for 1.8.0 be released soon as
well? https://hub.docker.com/_/flink has the versions up to 1.7.2.
Regards,
Richard
On Wed, Apr 10, 2019 at 4:54 PM Rong Rong wrote:
> Congrats! Thanks Aljoscha for being
oscha Krettek
> wrote:
>
> > @Richard Did this work for you previously? From the change, it seems that
> > the port was always set to 0 on YARN even before.
> >
> > > On 28. Mar 2019, at 16:13, Richard Deurwaarder
> wrote:
> > >
> > > -1 (non-b
Richard Deurwaarder created FLINK-12075:
---
Summary: Not able to submit jobs on YARN when there's a firewall
Key: FLINK-12075
URL: https://issues.apache.org/jira/browse/FLINK-12075
Project:
-1 (non-binding)
- Ran integration tests locally (1000+) of our flink job, all succeeded.
- Attempted to run job on hadoop, failed. It failed because we have a
firewall in place and we cannot set the rest port to a specific port/port
range.
Unless I am mistaken, it seems like FLINK-11081 broke the
oduction and thought it would be
> > best if it can be a native part of the Flink toolset.
> > Please indicate what we need to change/improve in order to get this
> committed.
> >
> > Thank you.
> >
> > Niels Basjes
> >
> > On Mon, Sep 10, 2018
oduction and thought it would be
> > best if it can be a native part of the Flink toolset.
> > Please indicate what we need to change/improve in order to get this
> committed.
> >
> > Thank you.
> >
> > Niels Basjes
> >
> > On Mon, Sep 10, 2018
,
Richard Deurwaarder
Richard Deurwaarder created FLINK-9311:
--
Summary: PubSub connector
Key: FLINK-9311
URL: https://issues.apache.org/jira/browse/FLINK-9311
Project: Flink
Issue Type: New Feature
17 matches
Mail list logo
