Hi David,
making the training materials available on flink.apache.org would increase
the reach and improve its visibility. Since this is very helpful material
for our users +1 for contributing the training material.
If we decide not maintain different versions, then we might be able to
highlight
ter the type extraction is done by Operator or Flink core.
> This interface would not gain benefits for type safety.
>
> Best,
> Yangze Guo
>
> On Wed, Apr 15, 2020 at 1:38 AM Till Rohrmann
> wrote:
> >
> > Thanks for updating the FLIP, Yangze.
> >
> > I
Hi Dian,
creating a new 1.9 bug fix release is a very good idea. +1 for creating it
soon. Also thanks for volunteering as our release manager.
Cheers,
Till
On Fri, Apr 10, 2020 at 7:27 AM Dian Fu wrote:
> Hi Jincheng,
>
> Thanks a lot for offering help. It would be very helpful. Thanks again!
; From: Map>
> > > > > > > getExternalResourceInfo(ResourceSpec resourceSpec);
> > > > > > > To: Map>
> > > getExternalResourceInfo();
> > > > > > >
> > > > > > > Best,
> > > > > > > Yan
Till Rohrmann created FLINK-17140:
-
Summary:
AsyncLookupJoinITCase.testAsyncJoinTemporalTableOnMultiFieldsWithUdf failed on
Azure
Key: FLINK-17140
URL: https://issues.apache.org/jira/browse/FLINK-17140
Till Rohrmann created FLINK-17075:
-
Summary: Add task status reconciliation between TM and JM
Key: FLINK-17075
URL: https://issues.apache.org/jira/browse/FLINK-17075
Project: Flink
Issue
I think it is a good idea to make the benchmarks available to the community
via a repo under the Apache project and to make updating it part of the
release process. Hence +1 for the proposal.
Cheers,
Till
On Thu, Apr 9, 2020 at 4:01 PM Piotr Nowojski wrote:
> Hi Yun Tang,
>
> Thanks for proposi
> > to
> > >>>> the
> > >>>>> commit details page[1] to see all Flink JIRA titles within commits
> > has
> > >>>> the
> > >>>>> hyper link underline. Moreover, you don't need to use markdown
> > language
> >
Till Rohrmann created FLINK-17073:
-
Summary: Slow checkpoint cleanup causing OOMs
Key: FLINK-17073
URL: https://issues.apache.org/jira/browse/FLINK-17073
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-17072:
-
Summary: Let Dispatcher and ResourceManager pick random endpoint id
Key: FLINK-17072
URL: https://issues.apache.org/jira/browse/FLINK-17072
Project: Flink
Great news! Thanks a lot for being our release manager Gordon and to
everyone who helped with the release.
Cheers,
Till
On Wed, Apr 8, 2020 at 3:57 AM Congxian Qiu wrote:
> Thanks a lot for the release and your great job, Gordon!
> Also thanks to everyone who made this release possible!
>
> Bes
Thanks for driving this effort Andrey.
+1 (binding)
Cheers,
Till
On Tue, Apr 7, 2020 at 4:48 PM Ufuk Celebi wrote:
> Thanks for starting this FLIP.
>
> +1
>
> On Tue, Apr 7, 2020 at 11:29 AM Andrey Zagrebin
> wrote:
>
> > Hi All,
> >
> > As discussed in these threads [1] and [2],
> > we sugge
Congrats Seth!
Cheers,
Till
On Tue, Apr 7, 2020 at 9:50 AM Danny Chan wrote:
> Congratulations ~
>
> Best,
> Danny Chan
> 在 2020年4月7日 +0800 PM2:56,Congxian Qiu ,写道:
> > Congratulations, Seth!
> >
> > Best,
> > Congxian
> >
> >
> > Kurt Young 于2020年4月7日周二 下午2:53写道:
> >
> > > Congratulations, Se
Hi Chesnay,
thanks for kicking this discussion off. I agree that deduplicating code is
in general a good idea.
The main benefit seems to be that all modules inherit a
log4j2-test.properties file and that this file allows to control the
logging output for several modules.
The main drawback I see
## Python/hadoop versions, activating certain libs/plugins
> > > Users can install extra dependencies and change configs in their custom
> > > image which extends our base image.
> > >
> > > # Logging
> > >
> > > ## Web UI
> > > Modify th
Hi everyone,
just a small inline comment.
On Fri, Apr 3, 2020 at 11:42 AM Ufuk Celebi wrote:
> Hey Yang,
>
> thanks! See inline answers.
>
> On Fri, Apr 3, 2020 at 5:11 AM Yang Wang wrote:
>
> > Hi Ufuk,
> >
> > Thanks for make the conclusion and directly point out what need to be
> done
> > i
Thanks for this reminder Aljoscha. Big +1 for following this practice.
If you want to make the query a bit more generic (not only searching the
summary field), you could also use
project = FLINK AND resolution = Unresolved AND text ~ "FooBarTest*" ORDER
BY priority DESC, updated DESC
That way JI
Congratulations to all of you!
Cheers,
Till
On Thu, Apr 2, 2020 at 7:57 AM Biao Liu wrote:
> Congrats!
>
> Thanks,
> Biao /'bɪ.aʊ/
>
>
>
> On Thu, 2 Apr 2020 at 11:59, Yuan Mei wrote:
>
> > Congrats :-)
> >
> > On Wed, Apr 1, 2020 at 4:52 PM Stephan Ewen wrote:
> >
> > > Hi all!
> > >
> > > H
Nice, this is a cool feature. Thanks for asking INFRA for it.
Cheers,
Till
On Wed, Apr 1, 2020 at 6:52 PM Yun Tang wrote:
> Hi community.
>
> I noticed that Github supports autolink reference recently [1]. This is
> helpful to allow developers could open Jira ticket link from pull requests
> ti
Thanks for driving this effort Yangze.
+1
Cheers,
Till
On Wed, Apr 1, 2020 at 12:41 PM Canbin Zheng wrote:
> Thanks Yangze for driving the initial CPU support!
> +1 (non-binding) from my side.
>
>
> Xintong Song 于2020年4月1日周三 下午6:36写道:
>
> > Thanks Yangze, the FLIP looks good to me.
> > +1 (no
Hi Canbin,
this looks indeed like a bug to me. I'm pulling in Dawid who worked on this
part and might be able to tell us more about it.
If he agrees, then I would suggest to open a JIRA issue and to fix it.
Cheers,
Till
On Wed, Apr 1, 2020 at 11:26 AM Canbin Zheng wrote:
> Hi everyone,
>
> Re
+1
Cheers,
Till
On Tue, Mar 31, 2020 at 5:52 PM Gary Yao wrote:
> Hi all,
>
> I would like to start the vote for FLIP-119 [1], which is discussed and
> reached a consensus in the discussion thread [2].
>
> The vote will be open until April 3 (72h) unless there is an objection
> or not enough vo
gt; > I
> > > > > think
> > > > > you could set the "deployment.meta.name". Since the pod name is
> > > generated
> > > > > by
> > > > > K8s in the pattern {deployment.meta.nane}-{rc.uuid}-{uuid}. On t
Till Rohrmann created FLINK-16866:
-
Summary: Make job submission non-blocking
Key: FLINK-16866
URL: https://issues.apache.org/jira/browse/FLINK-16866
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-16867:
-
Summary: Simplify default timeout configuration
Key: FLINK-16867
URL: https://issues.apache.org/jira/browse/FLINK-16867
Project: Flink
Issue Type
This is great news Jeff! Thanks a lot for sharing it with the community.
Looking forward trying Flink on Zeppelin out :-)
Cheers,
Till
On Mon, Mar 30, 2020 at 2:47 PM Jeff Zhang wrote:
> Hi Folks,
>
> I am very excited to announce the integration work of flink on apache
> zeppelin notebook is c
tions
> > 'external-resource.{resourceName}.yarn/kubernetes.key/amount',
> > we can still fulfill that purpose, without the credential risks.
> >
> >
> > Thank you~
> >
> > Xintong Song
> >
> >
> >
> > On Mon, Mar 30, 20
Hi Sivaprasanna,
thanks for starting this discussion. In general I like the idea to remove
duplications and move common code to a shared module. As a recommendation,
I would exclude the whole part about Flink's Hadoop compatibility modules
because they are legacy code and hardly used anymore. This
Pod`
> > > > (`AbstractKubernetesStepDecorator` directly manipulates on `Pod`) to
> user
> > > > codes. It gives more access to user codes than needed for defining
> > > external
> > > > resource, which might cause problems. Instead, I would suggest to
&g
Till Rohrmann created FLINK-16836:
-
Summary: Losing leadership does not clear rpc connection in
JobManagerLeaderListener
Key: FLINK-16836
URL: https://issues.apache.org/jira/browse/FLINK-16836
Till Rohrmann created FLINK-16834:
-
Summary: Examples cannot be run from IDE
Key: FLINK-16834
URL: https://issues.apache.org/jira/browse/FLINK-16834
Project: Flink
Issue Type: Bug
Thanks for creating this FLIP Zhu Zhu and Gary!
+1 for adding pipelined region scheduling.
Concerning the extended SlotProvider interface I have an idea how we could
further improve it. If I am not mistaken, then you have proposed to
introduce the two timeouts in order to distinguish between batc
Hi Yangze,
thanks for creating this FLIP. I think it is a very good improvement
helping our users and ourselves understanding better what's going on in
Flink.
Creating the ResourceIDs with host information/pod name is a good idea.
Also deriving ExecutionGraph IDs from their superset ID is a good
+1 for a separate repository.
Cheers,
Till
On Thu, Mar 26, 2020 at 5:13 PM Ufuk Celebi wrote:
> +1.
>
> The repo creation process is a light-weight, automated process on the ASF
> side. When Patrick Lucas contributed docker-flink back to the Flink
> community (as flink-docker), there was virtua
Hi everyone,
I'm a bit late to the party. I think the current proposal looks good.
Concerning the ExternalResourceDriver interface defined in the FLIP [1], I
would suggest to not include the decorator calls for Kubernetes and Yarn in
the base interface. Instead I would suggest to segregate the de
Thanks for driving this effort Robert. I'd be in favour of disabling Travis
for PRs once AZP is decently stable.
Cheers,
Till
On Wed, Mar 25, 2020 at 8:28 PM Robert Metzger wrote:
> Thank you for your responses.
>
> @Yu Li: In the current master, the log upload always fails, if the e2e job
> fa
Thanks Robert for this dev blog post. It's a good read.
Cheers,
Till
On Mon, Mar 23, 2020 at 10:24 PM Arvid Heise wrote:
> Thank you Robert! (also thanks for incorporating my feedback so swiftly)
>
> On Mon, Mar 23, 2020 at 8:54 PM Seth Wiesman wrote:
>
> > Very interesting! No questions but t
LIP-102:
>
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-102%3A+Add+More+Metrics+to+TaskManager
> POC web:
>
> http://101.132.122.69:8081/web/#/task-manager/8e1f1beada3859ee8e46d0960bb1da18/metrics
>
> Till Rohrmann 于2020年2月27日周四 下午10:27写道:
>
> > Thinking a bit more ab
Till Rohrmann created FLINK-16751:
-
Summary: Expose bind port for Flink metric query service
Key: FLINK-16751
URL: https://issues.apache.org/jira/browse/FLINK-16751
Project: Flink
Issue Type
Hi Rong Rong,
you are right that it JMX is quite hard to use in production due to the
mentioned problems with discovering the port. There is actually already a
JIRA ticket [1] discussing this problem. It just never gained enough
traction to be tackled.
In general, I agree that it would be nice to
+1 for the list of proposed changes
- What is "Stateful Functions"? link
- Documentation -> Stateful Functions Docs
- StateFun on GitHub
Cheers,
Till
On Thu, Mar 12, 2020 at 12:22 PM Stephan Ewen wrote:
> Thank you all, for chiming in!
>
> I like the ideas suggested to update the website,
Weike
>
> On Tue, Mar 17, 2020 at 11:11 PM tison wrote:
>
>> JIRA created as https://jira.apache.org/jira/browse/FLINK-16637
>>
>> Best,
>> tison.
>>
>>
>> Till Rohrmann 于2020年3月17日周二 下午5:57写道:
>>
>>> @Tison could you create an
Till Rohrmann created FLINK-16684:
-
Summary: StreamingFileSink builder does not work with Scala
Key: FLINK-16684
URL: https://issues.apache.org/jira/browse/FLINK-16684
Project: Flink
Issue
further complications
> for
> > > users.
> > > I will adjust the FLIP.
> > >
> > > > change the default value of JM Metaspace size to 256 MB
> > >
> > > Indeed, no reason to assume that the user code would need less
> Metaspace
+1 (binding)
Cheers,
Till
On Thu, Mar 19, 2020 at 7:29 AM Yang Wang wrote:
> +1 (non-binding).
>
> This FLIP will make jobmanager memory configuration keep up with
> taskmanager.
>
>
> Best,
> Yang
>
> Xintong Song 于2020年3月19日周四 上午11:23写道:
>
> > +1 (non-binding) from my side.
> >
> > Thank you
Thanks for creating this FLIP Andrey. I like the general idea pretty much.
I tried to group some of the above-mentioned points in order to give my 50
cent.
# Configuration
How to configure the Flink process seems to be the biggest question. Due to
historical reasons we have a plethora of differe
+1 for a soonish bug fix release. Thanks for volunteering as our release
manager Yu.
I think we can soon merge the increase of metaspace size and improving the
error message. The assumption is that we currently don't have too many
small Flink 1.10 deployments with a process size <= 1GB. Of course,
Thanks for creating this FLIP Andrey.
I agree with Xintong that we should rename jobmanager.memory.direct.size
into jobmanager.memory.off-heap.size which accounts for native and direct
memory usage. I think it should be good enough and is easier to understand
for the user.
Concerning the default
+1 for removing them.
On Wed, Mar 11, 2020 at 10:06 AM Chesnay Schepler
wrote:
> +1 on removing them.
>
> They are so limited in terms of functionality that I doubt anyone would
> be significantly impaired by us removing them.
>
> On 11/03/2020 02:13, Xintong Song wrote:
> > Thanks for the surve
I'm a bit late to the party but also +1 from my side. Pulling the
dependency graph straight is very good idea and will improve the
maintainability in the long run.
Cheers,
Till
On Tue, Mar 10, 2020 at 5:21 AM tison wrote:
> Thanks for your attention!
>
> Best,
> tison.
>
>
> Aljoscha Krettek 于
Till Rohrmann created FLINK-16635:
-
Summary: Incompatible okio dependency in flink-metrics-influxdb
module
Key: FLINK-16635
URL: https://issues.apache.org/jira/browse/FLINK-16635
Project: Flink
thing strange that this behavior almost reproducible, it
> >> should be a possible order but not always. Maybe previous we have to
> >> firstly cancel the job which has a long call chain so that it happens we
> >> have enough time to delivered the response.
> >>
If you want to change the max parallelism then you need to take a savepoint
and use Flink's state processor API [1] to rewrite the max parallelism by
creating a new savepoint from the old one.
[1]
https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/state_processor_api.html
Cheers,
Til
Hi Weike,
could you share the complete logs with us? Attachments are being filtered
out by the Apache mail server but it works if you upload the logs somewhere
(e.g. https://gist.github.com/) and then share the link with us. Ideally
you run the cluster with DEBUG log settings.
I assume that you a
;
> > > On Thu, Mar 5, 2020 at 4:22 PM Stephan Ewen wrote:
> > >
> > > > Do we have more cases of "common Hadoop Utils"?
> > > >
> > > > If yes, does it make sense to create a "flink-hadoop-utils" module
> with
> >
Hi Sivaprasanna,
we don't upload the source jars for the flink-shaded modules. However you
can build them yourself and install by cloning the flink-shaded repository
[1] and then call `mvn package -Dshade-sources`.
[1] https://github.com/apache/flink-shaded
Cheers,
Till
On Tue, Mar 3, 2020 at 6
Till Rohrmann created FLINK-16408:
-
Summary: Bind user code class loader to lifetime of a slot
Key: FLINK-16408
URL: https://issues.apache.org/jira/browse/FLINK-16408
Project: Flink
Issue
I like the idea. +1 from my side.
Potential topics:
- Scheduling
- Cluster partitions
- Memory configuration
- Recovery
Cheers,
Till
On Tue, Mar 3, 2020 at 3:56 AM Xintong Song wrote:
> Big +1. Thanks for the idea, Arvid.
>
> I'd be excited to read such blogs.
>
> And we would also be happy to
review the pull request
> and drive this FLIP forward?
> We will start to create PR as soon as possible, thanks!
>
> Till Rohrmann 于2020年2月25日周二 下午6:03写道:
>
> > late +1 (binding)
> >
> > Cheers,
> > Till
> >
> > On Tue, Feb 25, 2020 at 4:46 AM Yadong
iew the pull request
> and drive this FLIP forward?
> We will start to create PR as soon as possible, thanks!
>
> Till Rohrmann 于2020年2月25日周二 下午6:12写道:
>
> > late +1 (binding).
> >
> > Cheers,
> > Till
> >
> > On Tue, Feb 25, 2020 at 4:55 AM Yadong
Till Rohrmann created FLINK-16346:
-
Summary: BlobsCleanupITCase.testBlobServerCleanupCancelledJob
fails on Travis
Key: FLINK-16346
URL: https://issues.apache.org/jira/browse/FLINK-16346
Project
Hi,
with Flink 1.10 we changed the behaviour on the client side so that it also
uses the child first class loader [1]. Due to that it might be the case
that you have some conflicting dependencies bundled in your user code jar
which don't play well together with what you have on the system class pa
in the
> other ways (I have tried)
>
> if anyone has a better idea, please feels no hesitates to help me
>
>
> > 4. What does JVM limit mean in Non-heap.JVM-Overhead?
>
> JVM limit is "non-heap max metric minus metaspace configuration" as
> @Xintong
> Song rep
Both solutions are ok for me. What do you think about it?
>
> Till Rohrmann 于2020年2月26日周三 下午10:53写道:
>
> > Fair enough. If this should become a problem we could introduce it later
> as
> > well.
> >
> > What about changing the SubtasksTimeInfo response
he UI to help users filter the
> desired attempt, and all the filtering process is running inside the
> browser side, what do you think about this?
>
>
>
>
> Till Rohrmann 于2020年2月25日周二 下午11:40写道:
>
> > Hi Yadong,
> >
> > thanks for creating this FLIP. I li
Hi Yadong,
thanks for creating this FLIP. I like the idea of exposing more
cluster information to the user.
I share Xintong's concerns that we are about to rework the cluster
entrypoint's memory management. It might make sense to wait for these
changes before starting this effort. Otherwise, we m
Hi Yadong,
thanks for creating this FLIP. I like the idea to make the web-ui
information richer wrt to subtask attempt information.
I have a comment concerning the SubtasksTimesHandler: Should we change the
response type SubtasksTimeInfo so that it simply contains an
array of SubtaskTimeInfo? One
Hi Yadong,
thanks for creating this FLIP. I like the idea to show the user if some
slots are missing in order to run an operator.
However, since we plan to rework the scheduling part and also how resources
are acquired extensively, I'm not entirely sure whether we should add this
functionality no
Thanks for creating this FLIP Yadong. I think your proposal makes it much
easier for the user to understand what's happening on Flink TaskManager's.
I have some comments:
1. Some of the newly introduced metrics involve computations on the
TaskManager. I would like to avoid additional computations
late +1 (binding).
Cheers,
Till
On Tue, Feb 25, 2020 at 4:55 AM Yadong Xie wrote:
> Thanks all for the votes.
>
> So far, we have
>
> - 3 binding +1 votes (Kurt, Jark, zhijiang)
> - 4 non-binding +1 votes (Congxian, Wangyang, Benchao, Yun Gao)
> - No -1 votes
>
> The voting time has past and th
late +1 (binding)
Cheers,
Till
On Tue, Feb 25, 2020 at 4:46 AM Yadong Xie wrote:
> Thanks all for the votes.
>
> So far, we have
>
> - 4 binding +1 votes (Kurt, Jark, jincheng, Zhu Zhu)
> - 5 non-binding +1 votes (Yang Wang, Xintong Song, lining, Yangze, zhenya)
> - No -1 votes
>
> The voting t
+1 (binding)
Cheers,
Till
On Mon, Feb 24, 2020 at 3:04 AM zoudan wrote:
> +1 (non-binding)
>
> Best,
> Dan Zou
>
>>>>
> >>>> BTW, the fabric8 kubernetes-client and Kubernetes api server already
> has
> >>>> the parameters check before starting to create the resources. I think
> >>>> the exceptions
> >>>> are usually meaning and enough for th
Thanks for starting this discussion Canbin. If I understand your proposal
correctly, then you would like to evolve the existing decorator approach so
that decorators are monadic and smaller in size and functionality. The
latter aspect will allow to reuse them between the client and the cluster.
Jus
Hi Dominik,
you can control FlinkCEP's consumption behaviour via the after match skip
strategies [1]. They allow you to control how Flink treats events after a
match has occurred.
If you are interested in the longest possible window of events exceeding
your threshold, then you could also add term
Congratulations Jingsong!
Cheers,
Till
On Fri, Feb 21, 2020 at 4:03 PM Yun Gao wrote:
> Congratulations Jingsong!
>
>Best,
>Yun
>
> --
> From:Jingsong Li
> Send Time:2020 Feb. 21 (Fri.) 21:42
> To:Hequn Cheng
> Cc:Y
Thanks for volunteering as one of our release managers Zhijiang.
+1 for the *anticipated feature freeze date* end of April. As we go along
and collect more data points we might be able to strengthen our
initial anticipation.
Cheers,
Till
On Wed, Feb 19, 2020 at 4:44 AM Zhijiang
wrote:
> Thanks
+1 for Aljoscha's proposal.
This, of course, does not mean that one cannot use Google docs in order to
prepare the FLIP discussion.
Cheers,
Till
On Wed, Feb 19, 2020 at 11:15 AM Xintong Song wrote:
> I'm also not a fun of discussing FLIPs with google docs.
>
> I think google docs is probably o
Thanks for making the release possible Chesnay and everyone who was
involved!
Cheers,
Till
On Wed, Feb 19, 2020 at 7:47 AM jincheng sun
wrote:
> Thanks a lot for the release Chesnay!
> And thanks to everyone who make this release possible!
>
> Best,
> Jincheng
>
>
> Chesnay Schepler 于2020年2月19
+1 for removing ES2 and updating ES5 in 1.11.
+1 for revisiting the removal of ES5 for 1.12.
Cheers,
Till
On Tue, Feb 18, 2020 at 1:28 PM Chesnay Schepler wrote:
> Since one of the reasons for dropping ES2 was that it blocks some
> critical updates for the ES5 connector I'd prefer to keep ES5
Thanks for starting this vote Yadong. Should we split the vote thread into
multiple vote threads for each FLIP? I fear that having them all in one
thread will quickly become confusing.
Cheers,
Till
On Tue, Feb 18, 2020 at 12:27 PM Piotr Nowojski wrote:
> Hi,
>
> +1 (binding) for FLIP-98
> +1 (b
Hi Eduardo,
great to hear that you want to contribute to Flink.
I'm not too deeply involved in idle watermarks but I know that there is
FLIP-27 [1] which has the aim of reworking Flink's source interface. Part
of it is to solve the problem of idle watermarks. The idea would be to
solve the proble
I actually wanted to second Chesnay but apparently my impression is a bit
wrong. Out of the last 10 closed PRs (admittedly a small sample size) only
2 did not fill out the template. I did not check for correctness though.
Assuming that people use the template, I believe it is a good idea to
update
____
> From: Till Rohrmann
> Sent: Tuesday, February 18, 2020 4:43 PM
> To: dev
> Subject: Re: Total recovery time estimation after checkpoint recovery
>
> Hi Jessica,
>
> did you receive my previous email with the explanation?
>
> Cheers,
>
> > > backed up for half a day or more.
> > >
> > > Is our Jira and PR process sufficiently agile to handle these hotfixes?
> > > Will committers simply include hotfixes with other PRs, and would it be
> > > better to retain these as smaller, separate commits?
&g
Till Rohrmann created FLINK-16156:
-
Summary: TableAggregateITCase.testGroupByFlatAggregate failed on
Travis
Key: FLINK-16156
URL: https://issues.apache.org/jira/browse/FLINK-16156
Project: Flink
Hi Jessica,
did you receive my previous email with the explanation?
Cheers,
Till
On Sat, Feb 15, 2020 at 11:45 PM Woods, Jessica Hui <
jessica.wo...@campus.tu-berlin.de> wrote:
> ??Hi,
>
> I am working with Apache Flink and am interested in knowing how one could
> estimate the total amount of t
Thanks for updating the 1.9.2 release wrt Flink's Python API Jincheng!
Cheers,
Till
On Thu, Feb 13, 2020 at 12:25 PM Hequn Cheng wrote:
> Thanks a lot for the release, Jincheng!
> Also thanks to everyone that make this release possible!
>
> Best,
> Hequn
>
> On Thu, Feb 13, 2020 at 2:18 PM Dian
Hi Jessica,
multiple factors affect the total recovery time. First of all, Flink needs
to detect that something went wrong. In the worst case this happens through
the missing heartbeat of a died machine. The default heartbeat value is
configured to 50s but one can tune it.
Next, Flink needs to ca
Sounds good to me Patrick. +1 for these changes.
Cheers,
Till
On Fri, Feb 7, 2020 at 3:25 PM Patrick Lucas wrote:
> Hi all,
>
> For FLINK-15831[1], I think the way to start is for the flink-docker
> repo[2] itself to sufficiently document the workflow for publishing new
> Dockerfiles, and then
follow the new practice if
> possible.
>
> Till Rohrmann 于2020年2月3日周一 下午6:28写道:
>
> > I think there is no such description because we never did it before. I
> just
> > figured that FLIP-75 could actually be a good candidate to start this
> > practice. We would need a c
l>
>> on reducing the amount of jars we ship with the distribution.
>>
>> While there was no definitive conclusion there was a shared sentiment
>> that APIs should be shipped with the distribution.
>>
>> On 04/02/2020 17:25, Till Rohrmann wrote:
>>
>>
it a bit easier to extract information from
the JobGraph. Maybe Aljoscha can chime in on this topic.
Cheers,
Till
On Wed, Feb 5, 2020 at 7:35 PM Gyula Fóra wrote:
> @Till Rohrmann
> You are completely right that the Atlas hook itself should not live inside
> Flink. All other hook
Thanks for starting this discussion Chesnay. +1 for starting a new
flink-shaded release.
Cheers,
Till
On Wed, Feb 5, 2020 at 2:10 PM Chesnay Schepler wrote:
> Hello,
>
> I would like to kick off the next release of flink-shaded. The main
> feature are new modules that bundle zookeeper&curator,
Hi Gyula,
thanks for starting this discussion. Before diving in the details of how to
implement this feature, I wanted to ask whether it is strictly required
that the Atlas integration lives within Flink or not? Could it also work if
you have tool which receives job submissions, extracts the requi
Till Rohrmann created FLINK-15924:
-
Summary: Detect and log blocking main thread operations
Key: FLINK-15924
URL: https://issues.apache.org/jira/browse/FLINK-15924
Project: Flink
Issue Type
Till Rohrmann created FLINK-15911:
-
Summary: Flink does not work over NAT
Key: FLINK-15911
URL: https://issues.apache.org/jira/browse/FLINK-15911
Project: Flink
Issue Type: Bug
may need to find ways to support more
> > versions.
> > On the other hand, the size of the flink-ml libraries now is very
> > small(about 246K), so it would not bring much impact on the size of dist.
> >
> > What do you think?
> >
> > Best,
> > Heq
Till Rohrmann created FLINK-15864:
-
Summary: Upgrade jackson-databind dependency to 2.10.1 for
security reasons
Key: FLINK-15864
URL: https://issues.apache.org/jira/browse/FLINK-15864
Project: Flink
didn’t find how to create of sub flip at cwiki.apache.org
> do you mean to create 9 more FLIPS instead of FLIP-75?
>
> Till Rohrmann 于2020年1月30日周四 下午11:12写道:
>
> > Would it be easier if FLIP-75 would be the umbrella FLIP and we would
> vote
> > on the individual improvem
901 - 1000 of 3414 matches
Mail list logo