very
interested to have these available in Flink too.
My question, therefore, is, very general - how best to integrate Drools
into Flink? Where should I start?
Thanks and regards
Anton
Thanks Maiek
On Wed, Jun 22, 2016 at 9:00 PM, Maciek Próchniak wrote:
> This is straightforward, it also shouldn't be problematic performance wise
> OTOH, if you want to use stateful sessions things are getting more
> complicated - because if you want to play well with Flink you'd have to
> integ
Hi Maciek
Firstly, thanks for your replies and interest. It is really appreciated. I
am familiar with Drools but am new to Flink. Whereas you seem familiar with
both - so your feedback is really appreciated.
On Thu, Jun 23, 2016 at 8:30 AM, Maciek Próchniak wrote:
>
> you mean - keeping working
Hi All,
I'll review it in the near future.
On Tue, Jul 19, 2016 at 11:53 AM, Denis Magda wrote:
> Hi Saikat,
>
> Thanks for this contribution.
>
> *Anton V.*, please review the following contribution.
>
> —
> Denis
>
> On Jul 16, 2016, at 11:09 PM, Saikat
Hello everybody!
I am novice in community, but I want to participate in community process.
How I can assign https://issues.apache.org/jira/browse/FLINK-4564 to me and I
would discuss it implementation?
alcite.runtime.SqlFunctions.power(double, double)"
at
org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:10062)
at
org.codehaus.janino.UnitCompiler.findMostSpecificIInvocable(UnitCompiler.java:7476)
In this time if I am execute for int column ('_2') i getting result is equals
'0.0'
What am I doing wrong?
Best regards,
Anton Mushin
Hi Timo,
I didn't find the similar issue in Jira and created a new one: FLINK-4743
Thanks for help!
Best regards,
Anton Mushin
-Original Message-
From: Timo Walther [mailto:twal...@apache.org]
Sent: Tuesday, October 04, 2016 8:44 PM
To: dev@flink.apache.org
Subject: Re: Some ques
Hi folks.
I want to do something for flink. As the first step I have started doing
https://issues.apache.org/jira/browse/FLINK-4743, could you assign it for me in
JIRA.
Thanks.
Anton Solovev
Junior Software Engineer
Office: +7 846 200 09 70 x 55621
Email: anton_solo...@epam.com
Anton Solovev would like to recall the message, "Assign issue".
Hi folks.
I want to do something for flink. As the first step I have started doing
https://issues.apache.org/jira/browse/FLINK-4743, could you assign it for me in
JIRA.
Thanks.
Best regards,
Anton Solovev
Anton Solovev would like to recall the message, "Assign issue".
2) //result == " 0,0,0,0,0,0"
Is this the correct solution for this ticket or not?
Best regards,
Anton Mushin
Hello,
I have started doing https://issues.apache.org/jira/browse/FLINK-4743
What should explain of DataStream look like?
Best regards,
Anton
Sorry, wrong issue number
Question is about https://issues.apache.org/jira/browse/FLINK-4623
And in subject should be StreamExecutionEnvironment#explain actually
-Original Message-
From: Anton Solovev [mailto:anton_solo...@epam.com]
Sent: Wednesday, October 26, 2016 12:30 PM
To: dev
, October 27, 2016 12:17 AM
To: dev@flink.apache.org
Subject: Re: DataStream#explain
Hi Anton,
I think you can do it similar as the BatchTableEnvironment#explain(table:
Table, extended: Boolean) which calls
ExecutionEnvironment.getExecutionPlan().
StreamExecutionPlan does also have a getExecutionPlan
anSafelyCast() cannot allow to cast bigDecimal to double
what options I have?
1) let it cast with lose of information
2) don't use bigDecimal in functions, or cast it manually
3) create somewhere a new functions that accept bigDecimal as operand
4) any ideas?
Best,
Anton
I agree with you, Fabian.
I will add a small hint in exception and cast bigDecimal manually in test cases
-Original Message-
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Friday, October 28, 2016 7:17 PM
To: dev@flink.apache.org
Subject: Re: trouble with type casting
Hi Anton
Hi folks,
Can you explain me what ProjectableTableSource is ?
What is it being invented for?
Best,
Anton
can create a new code generation
or let nulls come from CsvInputFormt
Any ideas?
-Original Message-
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Wednesday, November 2, 2016 5:11 PM
To: dev@flink.apache.org
Subject: Re: [FLINK-3848] Add ProjectableTableSource
Hi Anton,
a
/compare/master...tonycox:FLINK-2186
- Use a complex combination of Tuples or/and Pojos
- Somehow use a code generation to create a pojo with huge field count
What do you think?
Best regards,
Anton
Hello,
In Scala case classes can store huge count of fields, it's really helpful for
reading wide csv files, but It uses only in table api.
what about this issue (https://issues.apache.org/jira/browse/FLINK-2186),
should we use table api in machine learning library?
To solve the issue #readC
I agree that we should improve RowTypeInfo. But why not to keep it in Scala?
In case flink-2186 that the "Row" is a "Product" is a reason of supporting wide
columns indeed.
Just for example I tried to move the "Row" to flink-scala module
(https://github.com/apache/flink/compare/master...tonycox:F
Sorry, wrong thread
-Original Message-
From: Anton Solovev [mailto:anton_solo...@epam.com]
Sent: Friday, November 25, 2016 7:20 PM
To: dev@flink.apache.org
Subject: RE: Flink using Yarn on MapR
I agree that we should improve RowTypeInfo. But why not to keep it in Scala?
In case flink
Fully agree with Timo :)
On Fri, Nov 25, 2016 at 2:30 PM, Timo Walther wrote:
> Hi Anton,
>
> I would also support the idea of moving Row and RowTypeInfo to Flink core.
> I think there are many real-world use cases where a variable-length
> record that supports null value
we move it to core, we have to untangle it from Scala, as Timo said. The
reason is that we would like to remove Scala from any user facing API maven
packages and if we had it in core everyone would have to suffix maven packages
with the Scala version.
On Fri, 25 Nov 2016 at 16:47 Anton Solovev w
ards,
Anton Mushin
Hi Timo,
Thanks for your reply!
Could you paste link in FLINK-4604 about calcite issue after you create it?
Best regards,
Anton Mushin
-Original Message-
From: Timo Walther [mailto:twal...@apache.org]
Sent: Thursday, December 01, 2016 5:26 PM
To: dev@flink.apache.org
Subject: Re
ere do need move these classes? Is simple in
`org.apache.flink.table` pacage?
What do you still think about move Table API classes?
[1]https://issues.apache.org/jira/browse/FLINK-4704
Best regards,
Anton Mushin
Hi Timo,
Ok.
In this time this issue assign to you. If you will have no objection early in
January I would assign to me this issue and implement.
Best regards,
Anton Mushin
-Original Message-
From: Timo Walther [mailto:twal...@apache.org]
Sent: Monday, December 05, 2016 12:23 PM
To
Hi Timo,
I try implement issue tomorrow and create PR.
Best regards,
Anton Mushin
-Original Message-
From: Timo Walther [mailto:twal...@apache.org]
Sent: Tuesday, December 06, 2016 2:42 PM
To: dev@flink.apache.org
Cc: Anton Mushin
Subject: Re: [FLINK-4704 ] Move Table API to
Hi, Timo
PR created: https://github.com/apache/flink/pull/2958
Best regards,
Anton Mushin
-Original Message-
From: Anton Mushin [mailto:anton_mus...@epam.com]
Sent: Tuesday, December 06, 2016 6:30 PM
To: dev@flink.apache.org
Cc: Timo Walther
Subject: RE: [FLINK-4704 ] Move Table API
Hi folks
I found a lot of non-relevant issues:
https://issues.apache.org/jira/browse/FLINK-37 -> from stratosphere;
https://issues.apache.org/jira/browse/FLINK-87 -> from stratosphere;
https://issues.apache.org/jira/browse/FLINK-481 -> from stratosphere;
https://issues.apache.org/jira/browse/FLIN
Hi, Alexey
I will check abandoned PRs to reduce obviously outdated ones and add them to a
cleanup list https://issues.apache.org/jira/browse/FLINK-5384
-Original Message-
From: Alexey Demin [mailto:diomi...@gmail.com]
Sent: Monday, January 16, 2017 5:05 PM
To: dev@flink.apache.org
Sub
Hi folk,
I have a failed integration test on travis in flink-ml package.
How can I run specific IT Class of this on my local machine with console logs
output?
Thanks,
Anton Solovev
Thank you Theodore
StochasticOutlierSelectionITSuite has failed twice, but at third time it’s
okey, I can’t share logs it disappeared somewhere in travis
25.01.17, 18:27 пользователь "Theodore Vasiloudis"
написал:
Hello Anton,
I usually run specific local tests throug
Hello guys,
I think there is a sense to tear apart TestBaseUtils into a number of util
classes which it keeps them.
Because some test classes can't extend this base test class, but need in its
result checkers
Best,
Anton
Yes, I had that commit, I tested master branch at that time
-Original Message-
From: Till Rohrmann [mailto:trohrm...@apache.org]
Sent: Thursday, January 26, 2017 6:04 PM
To: dev@flink.apache.org
Subject: Re: flink-ml test
Hi Anton,
which build are you using? I've recently (M
Hi
Can we check connection to remote host before execution a program when start
flink-shell ?
For example, right after `bin/start-scala-shell.sh remote 35007` it
checks and will not start if it wrong connects
Best,
Anton
specific test under flink-ml:
>> mvn test -DwildcardSuites=org.apache.flink.ml.math.BreezeMathSuite
>> BreezeMathSuite
>>
>> Cheers,
>> Stavros
>>
>> On Fri, Jan 27, 2017 at 12:01 PM, Driesprong, Fokko
>> > > wrote:
>>
>>> Hi Anton,
>>>
>>> I&#x
Congrats Jing!
--
Best regards,
Anton Kalashnikov
On 16.02.23 14:38, Austin Cawley-Edwards wrote:
Congrats Jing!
On Thu, Feb 16, 2023 at 01:37 Feng Jin wrote:
Congratulations, Jing!
Best,
Feng
On Thu, Feb 16, 2023 at 2:24 PM Weihua Hu wrote:
Congratulations, Jing!
Best,
Weihua
On
Congrats Rui!
--
Best regards,
Anton Kalashnikov
On 20.02.23 17:53, Matthias Pohl wrote:
Congratulations, Rui :)
On Mon, Feb 20, 2023 at 5:10 PM Jing Ge wrote:
Congrats Rui!
On Mon, Feb 20, 2023 at 3:19 PM Piotr Nowojski
wrote:
Hi, everyone
On behalf of the PMC, I'm very hap
+1 (binding)
Thanks for this FLIP Panos, LGTM.
--
Best regards,
Anton Kalashnikov
On 20.04.23 13:44, Roman Khachatryan wrote:
+1 (binding)
The FLIP LGTM, thanks Panos!
Regards,
Roman
On Thu, Apr 20, 2023 at 1:33 PM Hong Teoh wrote:
+1 (non-binding)
Thank you for driving this effort
Hello.
Early I asked how can I get access to unmatched events in CEP Pattern (
https://lists.apache.org/thread/p7n507jvm5hw0xmpoh0lcf87gf3yk18p).
Unfortunately Biao Geng answered me, that "that currently there is no such
API to access the middle NFA state".
I have reviewed the realization of fli
Congratulations, Yuan!
--
Best regards,
Anton Kalashnikov
14.03.2022 09:13, Leonard Xu пишет:
Congratulations Yuan!
Best,
Leonard
2022年3月14日 下午4:09，Yangze Guo 写道：
Congratulations!
Best,
Yangze Guo
On Mon, Mar 14, 2022 at 4:08 PM Martijn Visser wrote:
Congratulations Yuan!
On Mon, 14
Congrats, Martijn!
--
Best regards,
Anton Kalashnikov
13.03.2022 01:57, Guowei Ma пишет:
Congrats Martijn!
Best,
Guowei
On Fri, Mar 11, 2022 at 10:36 PM Marios Trivyzas wrote:
Congrats Martijn!!
Best,
Marios
On Thu, Mar 10, 2022 at 4:50 PM yu'an huang wrote:
Congrats, Ma
Congratulations, David!
--
Best regards,
Anton Kalashnikov
14.03.2022 09:18, Matthias Pohl пишет:
Congratulations, David!
is not clear how to correctly configure
network buffers with existing configuration and I don't want to
complicate it, especially if it will be possible to resolve the problem
automatically(as described above).
So is my understanding about network memory/buffers correct?
--
Best regards,
.
28.04.2022 06:39, rui fan пишет:
Hi Anton Kalashnikov,
Thanks for your very clear reply, I think you are totally right.
The 'maxBuffersNumber - buffersInUseNumber' can be used as the
overdraft buffer, it won't need the new buffer configuration.Flink users
can turn up the maxBuffersNumber
still need to think about that.
29.04.2022 11:11, rui fan пишет:
Hi Anton Kalashnikov,
I think you agree with we should limit the maximum number of overdraft
segments that each LocalBufferPool can apply for, right?
I prefer to hard code the maxOverdraftBuffers due to don't add the new
con
- Do you think it's ok?
- Actually, we added the checkAvailable logic for LegacySource in our
internal version. It works well.
5. For the benchmark, do you have any suggestions? I submitted the PR
[1].
[1] https://github.com/apache/flink-benchmarks/pull/54
Thanks
fanrui
elism, like 5, increasing overdraft from 1 to 5 still increases
the overdraft by only about 25%. So maybe we can keep the max as it is?
If so, maybe we should change the name from "overdraft" to "buffer reserve"
or "spare buffers"? And document it as "number
s for both implementations a little more.
--
Best regards,
Anton Kalashnikov
04.05.2022 11:28, Dawid Wysakowicz пишет:
Hey all,
I have not replied in the thread yet, but I was following the discussion.
Personally, I like Fanrui's and Anton's idea. As far as I understand
it the idea to
Congrats Yang!
--
Best regards,
Anton Kalashnikov
05.05.2022 13:53, rui fan пишет:
Congratulations Yang!
Best
fanrui
On Thu, May 5, 2022 at 19:47 Martijn Visser wrote:
Congratulations Yang Wang!
On Thu, 5 May 2022 at 13:23, Lijie Wang wrote:
Congratulations Yang!
Best,
Lijie
ually know what
type of invokable we have in case of the chain. But roughly, the idea is
to create LocalBufferPool with/without overdraft based on knowledge of
operator type.
--
Best regards,
Anton Kalashnikov
05.05.2022 11:49, rui fan пишет:
Hi,
Thanks a lot for your discussion.
After seve
Hi.
Thanks Fanrui for this FLIP. I think it will be useful thing for us.
+1(non-binding)
--
Best regards,
Anton Kalashnikov
26.05.2022 06:00, rui fan пишет:
Hi, everyone,
Thanks for your feedback for FLIP-227: Support overdraft buffer[1] on
the discussion thread[2].
I'd like to st
+1 (non-binding)
Thanks Piotr.
--
Best regards,
Anton Kalashnikov
26.01.2022 11:21, David Anderson пишет:
+1 (non-binding)
I'm pleased to see this significant improvement coming along, as well as
the effort made in the FLIP to document what is and isn't supported (and
where ??? re
+1 (non-binding)
- signatures OK
- checksums OK
- tag OK
- all artifacts OK
- PR OK
run examples
--
Best regards,
Anton Kalashnikov
15.02.2022 09:30, Dawid Wysakowicz пишет:
+1 (binding)
- signatures OK
- checksums OK
- tag OK
- PR looks good
- built from sources
- run example
throughput and following changes the buffer
size based on the this throughput. More details about the proposal you
can find here [1].
What are you thoughts about it?
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-183%3A+Dynamic+buffer+size+adjustment
--
Best regards,
Anton
throughput and following changes the buffer
size based on the this throughput. More details about the proposal you
can find here [1].
What are you thoughts about it?
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-183%3A+Dynamic+buffer+size+adjustment
--
Best regards,
Anton
Thanks everyone for sharing your opinion. I updated the FLIP according
to discussion and I'm going to start the vote on this FLIP
--
Best regards,
Anton Kalashnikov
16.07.2021 09:23, Till Rohrmann пишет:
I think this is a good idea. +1 for this approach. Are you gonna update the
[2]
https://lists.apache.org/thread.html/r0d06131b35fe641df787c16e8bcd3784161f901062c25778ed92871b%40%3Cdev.flink.apache.org%3E
--
Best regards,
Anton Kalashnikov
Hi everyone,
I am happy to finish voting for FLIP-183 [1] with approving. The vote [2] is
now closed.
There was no veto and three +1 votes all of which were binding:
- Piotr Nowojski (binding)
- Yuan Mei (binding)
- Till Rohrmann (binding)
Thank everyone for participating!
[1]https://cwiki
-app
[4] https://issues.apache.org/jira/browse/FLINK-28407
--
Best regards,
Anton Kalashnikov
Thanks, everybody for your feedback. It seems no objections to this
proposal. So I will create the ticket with a description and start the
formal voting for this proposal.
--
Best regards,
Anton Kalashnikov
08.07.2022 04:21, Qingsheng Ren пишет:
+1 for this channel in Slack. Only few people
ere[2].
[1] https://www.mail-archive.com/dev@flink.apache.org/msg58666.html
[2] https://issues.apache.org/jira/browse/FLINK-28468
--
Best regards,
Anton Kalashnikov
g (binding)
There is no disapproving vote.
Thanks everyone for votes.
Márton, I think I will reach you later for handling admin steps.
--
Best regards,
Anton Kalashnikov
Hello!
Our team works with Flink CEP library for real time events processing. But
we noticed that some non-matching events are lost. We propose some changes
in the Flink CEP library that provide the ability to handle non-matching
events.
We propose adding a new interface UnmatchedEventsHandler s
Anton Ippolitov created FLINK-32241:
---
Summary: UnsupportedFileSystemException when using the ABFS Hadoop
driver for checkpointing in Flink 1.17
Key: FLINK-32241
URL: https://issues.apache.org/jira/browse/FLINK
Anton Mushin created FLINK-4743:
---
Summary: The sqrt/power function not accept the real data types.
Key: FLINK-4743
URL: https://issues.apache.org/jira/browse/FLINK-4743
Project: Flink
Issue
Anton Solovev created FLINK-5186:
Summary: Move Row and RowTypeInfo into Flink core
Key: FLINK-5186
URL: https://issues.apache.org/jira/browse/FLINK-5186
Project: Flink
Issue Type
Anton Solovev created FLINK-5187:
Summary: Create analog of Row in core
Key: FLINK-5187
URL: https://issues.apache.org/jira/browse/FLINK-5187
Project: Flink
Issue Type: Sub-task
Anton Solovev created FLINK-5188:
Summary: Redirect dependencies
Key: FLINK-5188
URL: https://issues.apache.org/jira/browse/FLINK-5188
Project: Flink
Issue Type: Sub-task
Anton Solovev created FLINK-5189:
Summary: deprecate and delete Row in table api
Key: FLINK-5189
URL: https://issues.apache.org/jira/browse/FLINK-5189
Project: Flink
Issue Type: Sub-task
Anton Solovev created FLINK-5358:
Summary: Support Row in TypeExtractor
Key: FLINK-5358
URL: https://issues.apache.org/jira/browse/FLINK-5358
Project: Flink
Issue Type: Improvement
Anton Solovev created FLINK-5384:
Summary: clean up jira issues
Key: FLINK-5384
URL: https://issues.apache.org/jira/browse/FLINK-5384
Project: Flink
Issue Type: Improvement
Anton Solovev created FLINK-5389:
Summary: Fails #testAnswerFailureWhenSavepointReadFails
Key: FLINK-5389
URL: https://issues.apache.org/jira/browse/FLINK-5389
Project: Flink
Issue Type: Bug
Anton Solovev created FLINK-5401:
Summary: Fails
ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics
Key: FLINK-5401
URL: https://issues.apache.org/jira/browse/FLINK-5401
Project: Flink
Anton Solovev created FLINK-5402:
Summary: Fails AkkaRpcServiceTest#testTerminationFuture
Key: FLINK-5402
URL: https://issues.apache.org/jira/browse/FLINK-5402
Project: Flink
Issue Type: Bug
Anton Solovev created FLINK-5481:
Summary: Cannot create Collection of Row
Key: FLINK-5481
URL: https://issues.apache.org/jira/browse/FLINK-5481
Project: Flink
Issue Type: Bug
Anton Solovev created FLINK-5554:
Summary: Add sql operator to table api for getting columns from
HBase
Key: FLINK-5554
URL: https://issues.apache.org/jira/browse/FLINK-5554
Project: Flink
Anton Solovev created FLINK-5592:
Summary: Wrong number of RowSerializers with nested Rows in
Collection mode
Key: FLINK-5592
URL: https://issues.apache.org/jira/browse/FLINK-5592
Project: Flink
Anton Solovev created FLINK-5671:
Summary: Test ClassLoaderITCase#testJobsWithCustomClassLoader fails
Key: FLINK-5671
URL: https://issues.apache.org/jira/browse/FLINK-5671
Project: Flink
Anton Solovev created FLINK-5698:
Summary: Add NestedFieldsProjectableTableSource interface
Key: FLINK-5698
URL: https://issues.apache.org/jira/browse/FLINK-5698
Project: Flink
Issue Type
Anton Solovev created FLINK-5744:
Summary: Checking remote connection in Flink-shell
Key: FLINK-5744
URL: https://issues.apache.org/jira/browse/FLINK-5744
Project: Flink
Issue Type
Anton Mushin created FLINK-5750:
---
Summary: Incorrect parse of brackets inside VALUES subquery
Key: FLINK-5750
URL: https://issues.apache.org/jira/browse/FLINK-5750
Project: Flink
Issue Type
Anton Kalashnikov created FLINK-30278:
-
Summary: Unexpected config mutation in
SinkTransformationTranslator
Key: FLINK-30278
URL: https://issues.apache.org/jira/browse/FLINK-30278
Project: Flink
Anton Kalashnikov created FLINK-31610:
-
Summary: Refactoring of LocalBufferPool
Key: FLINK-31610
URL: https://issues.apache.org/jira/browse/FLINK-31610
Project: Flink
Issue Type
Anton Kalashnikov created FLINK-25454:
-
Summary: Negative time in throughput calculator
Key: FLINK-25454
URL: https://issues.apache.org/jira/browse/FLINK-25454
Project: Flink
Issue Type
Anton Kalashnikov created FLINK-25556:
-
Summary: Extra waiting of final checkpoint in benchmarks
Key: FLINK-25556
URL: https://issues.apache.org/jira/browse/FLINK-25556
Project: Flink
Anton Kalashnikov created FLINK-25590:
-
Summary: Logging warning of insufficient memory for all configured
buffers
Key: FLINK-25590
URL: https://issues.apache.org/jira/browse/FLINK-25590
Project
Anton Kalashnikov created FLINK-25646:
-
Summary: Document buffer debloating issues with high parallelism
Key: FLINK-25646
URL: https://issues.apache.org/jira/browse/FLINK-25646
Project: Flink
Anton Kalashnikov created FLINK-25650:
-
Summary: Document unaligned checkpoints performance limitations
(larger records/flat map/timers/...)
Key: FLINK-25650
URL: https://issues.apache.org/jira/browse/FLINK
Anton Kalashnikov created FLINK-25891:
-
Summary: NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark
Key: FLINK-25891
URL: https://issues.apache.org/jira/browse/FLINK-25891
Project: Flink
Anton Kalashnikov created FLINK-26002:
-
Summary: Add test coverage for native format job upgrades
Key: FLINK-26002
URL: https://issues.apache.org/jira/browse/FLINK-26002
Project: Flink
Anton Kalashnikov created FLINK-26130:
-
Summary: Document why and when user would like to increase network
buffer size
Key: FLINK-26130
URL: https://issues.apache.org/jira/browse/FLINK-26130
Anton Kalashnikov created FLINK-26134:
-
Summary: Document checkpoint/savepoint guarantees
Key: FLINK-26134
URL: https://issues.apache.org/jira/browse/FLINK-26134
Project: Flink
Issue
Anton Kalashnikov created FLINK-26325:
-
Summary: Add test coverage for native format State Processor API
Key: FLINK-26325
URL: https://issues.apache.org/jira/browse/FLINK-26325
Project: Flink
Anton Kalashnikov created FLINK-26326:
-
Summary: FLIP-203: Support native and incremental savepoints 1.1
Key: FLINK-26326
URL: https://issues.apache.org/jira/browse/FLINK-26326
Project: Flink
Anton Kalashnikov created FLINK-22215:
-
Summary: Rename RECOVERING state to RESTORING
Key: FLINK-22215
URL: https://issues.apache.org/jira/browse/FLINK-22215
Project: Flink
Issue Type
Anton Kalashnikov created FLINK-22379:
-
Summary: Introduce a new JobStatus to avoid premature checkpoint
triggering
Key: FLINK-22379
URL: https://issues.apache.org/jira/browse/FLINK-22379
Project
1 - 100 of 146 matches
Mail list logo
