Kevin Kwon created FLINK-19517:
--
Summary: Support for Confluent Kafka on table creation
Key: FLINK-19517
URL: https://issues.apache.org/jira/browse/FLINK-19517
Project: Flink
Issue Type: Wish
Guowei Ma created FLINK-19512:
-
Summary: Introduce the new sink api
Key: FLINK-19512
URL: https://issues.apache.org/jira/browse/FLINK-19512
Project: Flink
Issue Type: Sub-task
Congratulations Zhu Zhu
Best,
Xingbo
Leonard Xu 于2020年10月6日周二 下午4:50写道：
> Congratulations Zhu Zhu!
>
> Best
> Leonard
>
> > 在 2020年10月6日，14:52，Yuan Mei 写道：
> >
> > Congrats, Zhu Zhu :-)
> >
> > Best
> > Yuan
> >
> > On Tue, Oct 6, 2020 at 1:54 PM Dian Fu wrote:
> >
> >> Congratulations Zhu
hailong wang created FLINK-19509:
Summary: ClassCastException for MULTISET type of
JsonRowDataDeserializationSchema and JsonRowDataSerializationSchema
Key: FLINK-19509
URL:
Congratulations Zhu Zhu!
Best
Leonard
> 在 2020年10月6日，14:52，Yuan Mei 写道：
>
> Congrats, Zhu Zhu :-)
>
> Best
> Yuan
>
> On Tue, Oct 6, 2020 at 1:54 PM Dian Fu wrote:
>
>> Congratulations Zhu Zhu!
>>
>> Regards,
>> Dian
>>
>>> 在 2020年10月6日，下午12:05，Yu Li 写道：
>>>
>>> Congrats and welcome,
Aljoscha Krettek created FLINK-19508:
Summary: Add collect() operation on DataStream
Key: FLINK-19508
URL: https://issues.apache.org/jira/browse/FLINK-19508
Project: Flink
Issue Type:
Guowei Ma created FLINK-19510:
-
Summary: Introduce new unified sink api
Key: FLINK-19510
URL: https://issues.apache.org/jira/browse/FLINK-19510
Project: Flink
Issue Type: New Feature
Guowei Ma created FLINK-19511:
-
Summary: Rename the `SinkTransformation` to
`LegacySinkTransformation`
Key: FLINK-19511
URL: https://issues.apache.org/jira/browse/FLINK-19511
Project: Flink
Congrats, Zhu Zhu :-)
Best
Yuan
On Tue, Oct 6, 2020 at 1:54 PM Dian Fu wrote:
> Congratulations Zhu Zhu!
>
> Regards,
> Dian
>
> > 在 2020年10月6日，下午12:05，Yu Li 写道：
> >
> > Congrats and welcome, Zhu Zhu!
> >
> > Best Regards,
> > Yu
> >
> >
> > On Tue, 6 Oct 2020 at 11:45, Guowei Ma wrote:
> >
Hi All,
I know I know, but please keep reading because I recently learned about
some new developments in the area of coding-style automation.
The tool I would propose we use is Spotless
(https://github.com/diffplug/spotless). This doesn't come with a
formatter but allows using other popular
Congratulations! :)
Best,
Matthias
On Tue, Oct 6, 2020 at 10:55 AM Xingbo Huang wrote:
> Congratulations Zhu Zhu
>
> Best,
> Xingbo
>
> Leonard Xu 于2020年10月6日周二 下午4:50写道：
>
> > Congratulations Zhu Zhu!
> >
> > Best
> > Leonard
> >
> > > 在 2020年10月6日，14:52，Yuan Mei 写道：
> > >
> > > Congrats,
Thanks for being our release manager Robert and thanks to everyone who
contributed to the flink-shaded 12.0 release!
Cheers,
Till
On Tue, Oct 6, 2020 at 2:59 PM Robert Metzger wrote:
> Hi all!
>
> The Apache Flink community is very happy to announce the release of Apache
> Flink-shaded 12.0
>
Hi Aljoscha,
I think that having the style check directly in the IDE is a very good
feature so +1 on my side as a contributor (I also asked once on the mailing
list if there was already something like that)..I never used Spotless so I
can't say if it easy to integrate with the IDE but the nice
Hi all!
The Apache Flink community is very happy to announce the release of Apache
Flink-shaded 12.0
The flink-shaded project contains a number of shaded dependencies for
Apache Flink.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing,
Matthias created FLINK-19513:
Summary: Update docs/build_docs.sh to support the new parameters
for regenerating the docs
Key: FLINK-19513
URL: https://issues.apache.org/jira/browse/FLINK-19513
Project:
Maybe I wasn't very clear on how the ratchet works. The changes are
gradual yes, but it doesn't leave you an option: if you touch a file you
will it will have to conform to the coding style afterwards. It's not
like the previous gradual process we had before where it would be based
on people
Stephan Ewen created FLINK-19514:
Summary:
ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange times
out
Key: FLINK-19514
URL: https://issues.apache.org/jira/browse/FLINK-19514
After having written that I did a quick search, you can even use git blame
with one big massive change commit [1], which would further help the idea
of "just get over with it".
With that option, I'd even change all whitespaces if the community thinks
that it's a better option (a separate
I'm also +1 for automatically enforceable code style.
I also would just go over it as Chesnay said. While it makes some changes a
bit harder to track (inline git blame), it's easy to skip over in any git
history and if it's only one massive commit, then it's also much easier to
ignore than many
Frans King created FLINK-19515:
--
Summary: Async RequestReply handler concurrency bug
Key: FLINK-19515
URL: https://issues.apache.org/jira/browse/FLINK-19515
Project: Flink
Issue Type: Bug
We shouldn't switch to spaces _now_; cutting this bit from your proposal
will massively simplify things and there's hardly any value in changing it.
Also I'm getting rather tired of this constant idea of "gradual
application". We've been doing this for 2-3 years now since we
introduced
Stephan Ewen created FLINK-19516:
Summary: PerJobMiniClusterFactoryTest. testJobClient()
Key: FLINK-19516
URL: https://issues.apache.org/jira/browse/FLINK-19516
Project: Flink
Issue Type:
Thanks, Aljoscha! The context is really helpful!
On Fri, Oct 2, 2020 at 1:19 AM Aljoscha Krettek wrote:
> Unfortunately, there is no such hook right now. However, we're working
> on this in the context of FLIP-134 [1] and FLIP-143 [2].
>
> Best,
> Aljoscha
>
> [1]
Hi!
In case where new state type is incompatible with old one from savepoint, we
get IllegalStateException via org.apache.flink.util.Preconditions.checkState
from checkStateMetaInfo:
24 matches
Mail list logo
