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
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:
https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/state/Registered
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] https://cwiki.apache.org/conflu
Stephan Ewen created FLINK-19516:
Summary: PerJobMiniClusterFactoryTest. testJobClient()
Key: FLINK-19516
URL: https://issues.apache.org/jira/browse/FLINK-19516
Project: Flink
Issue Type: Bug
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 ac
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 discussio
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 gr
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 Checkst
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
Af
Stephan Ewen created FLINK-19514:
Summary:
ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange times
out
Key: FLINK-19514
URL: https://issues.apache.org/jira/browse/FLINK-19514
Pr
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
>
>
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, Zh
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, always-available,
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: Fl
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 thin
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 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 Zh
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, Zh
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
Component
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
Issu
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
Co
hailong wang created FLINK-19509:
Summary: ClassCastException for MULTISET type of
JsonRowDataDeserializationSchema and JsonRowDataSerializationSchema
Key: FLINK-19509
URL: https://issues.apache.org/jira/browse/FL
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: Imp
23 matches
Mail list logo
