Congratulations!!!
On Thu, Apr 3, 2025 at 4:47 AM Andriy Redko wrote:
> Congrats Sergey!!!
>
>
> > Hi everyone,
>
> > On behalf of the PMC, I'm very happy to announce Sergey Nuyanzin as a
> new Flink Committer.
>
> > Sergey started contributing small improvements to the project in 2018.
> Over t
Thank you all!
The voting is closed now.
I've posted results [1].
[1] https://lists.apache.org/thread/mx3qd5qgyjtqk66p6sv639g777lm0jc6
Thanks,
Alexey
On Wed, Jul 3, 2024 at 6:39 PM Yuepeng Pan wrote:
> +1 (non-binding)
>
> Best regards,
>
> Yuepeng Pan
>
>
>
PRs will be prepared. Thank you everyone who participated!
All the best,
Alexey
[1] https://lists.apache.org/thread/2ycws2zplcyd1k25pn1ljmxvg5lgd8r2
[2]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-456%3A+CompiledPlan+support+for+Batch+Execution+Mode
epted if 3 binding votes (from active committers according to
the Flink bylaws [3]) are gathered by the community.
Thanks,
Alexey
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-456%3A+CompiledPlan+support+for+Batch+Execution+Mode
[2] https://lists.apache.org/t
Hey all, starting a vote in 24 hours. Unless there are more points to
discuss.
Thanks,
Alexey
On Mon, Jun 17, 2024 at 8:28 AM Alexey Leonov-Vendrovskiy <
vendrov...@gmail.com> wrote:
> Done. There was some accidental removal during editing.
>
> Thanks,
> Alexey
>
> O
Done. There was some accidental removal during editing.
Thanks,
Alexey
On Mon, Jun 17, 2024 at 5:23 AM Jim Hughes
wrote:
> Hi Alexey,
>
> Looks reasonable. As a note, I think this sentence is missing some words:
>
> "Due to batch queries nature, we do not expect the
Thanks Timo and Jim! Added a few sentences to the FLIP to cover your points.
-Alexey
On Mon, Jun 10, 2024 at 11:23 PM Timo Walther wrote:
> Hi Alexey,
>
> thanks for proposing this FLIP. It is a nice continuation of the vision
> we had for CompiledPlan when writing and implement
window of 1yr+ would allow deprecation of older
batch exec nodes, though I don't see this as a frequent event.
-Alexey
On Mon, May 13, 2024 at 1:52 PM Jim Hughes
wrote:
> Hi Alexey,
>
> After some thought, I have a question about deprecations:
>
> 3. Can we remove old version
Hey Paul,
Yes, no interchangeability. Just a wire-through for more uniformity.
Thanks,
Alexey
On Tue, May 7, 2024 at 2:10 AM Paul Lam wrote:
> Hi Alexey,
>
> Thanks a lot for bringing up the discussion. I’m big +1 for the FLIP.
>
> I suppose the goal doesn’t involve the interc
Hi everyone,
PTAL at the proposed FLIP-456: CompiledPlan support for Batch Execution
Mode. It is pretty self-describing.
Any thoughts are welcome!
Thanks,
Alexey
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-456%3A+CompiledPlan+support+for+Batch+Execution+Mode
.
Alexey Leonov-Vendrovskiy created FLINK-35241:
-
Summary: Support SQL FLOOR and CEIL functions with SECOND and
MINUTE for TIMESTAMP_TLZ
Key: FLINK-35241
URL: https://issues.apache.org/jira/browse/FLINK
that explicitly does unusual things.
Regards,
-Alexey
On Wed, Feb 14, 2024 at 12:27 AM Piotr Nowojski
wrote:
> Hi!
>
> Interesting catch. I think the current master branch behaviour is broken.
> The chance to lose some records on `endInput`
> is simply a critical bug. The li
, the only difference with
the change would be that in similar setups it would wait on any buffer size
> 0. It makes behavior consistent for results of any non-zero size.
Let me know your thoughts.
Thanks,
Alexey
Thanks for starting the vote!
Do you mind adding a link from the FLIP to this thread?
Thanks,
Alexey
On Thu, Jan 4, 2024 at 6:48 PM Feng Jin wrote:
> Hi everyone
>
> Thanks for all the feedback about the FLIP-387: Support named parameters
> for functions and call procedures [1] [
# problem_3.py
# call to .where() after .map() with pandas type function
# also resets column names
# and doesn't really filter values
import pandas as pd
t_env = TableEnvironment.create(EnvironmentSettings.in_streaming_mode())
table = t_env.from_elements(
elements=[
(1, 'China'),
;data').json_value('$.name', DataTypes.STRING()).alias('name'),
)
@udf(
result_type=(
'Row'
),
)
def example_map(row: Row):
print('\n'*3, f'{row=}', '\n'*3)
# will print:
# row=Row(id=1, data='{"
example_map(row: Row):
print('\n'*3, f'{row=}', '\n'*3)
# will print:
# row=Row(f0=1, f1='{"name": "Flink"}')
# expected:
# row=Row(id=1, data='{"name": "Flink"}')
data = json.loads(row.
?
2. Is it the expected behavior?
3. How can we get around this?
Best regards, Alexey
e coverage in the
currently proposed FLIP, but rather as a way to describe the semantics of
system columns that those could be (but don't have to) introduced by any
operator.
Thanks,
Alexey
On Tue, Aug 22, 2023 at 2:18 PM Jing Ge wrote:
> Hi Timo,
>
> Your last suggestion sounds
approach, because it makes the
> system columns very accessible and more aligned across the catalogs.
>
> BTW, I second Alexey that systems columns should not be shown with
> DESCRIBE statements.
>
> WDYT? Thanks!
>
> Best,
> Paul Lam
>
> > 2023年7月31日 23:54，Jark
>
> `SELECT * FROM (SELECT $rowtime, * FROM t);`
> Am I right that it will show `$rowtime` in output ?
Yes, all explicitly selected columns become a part of the result (and
intermediate) schema, and hence propagate.
On Thu, Jul 27, 2023 at 2:40 PM Alexey Leonov-Vendrovskiy
this vendor-specific / or configurable via flag (if needed).
Regards,
Alexey
On Thu, Jul 27, 2023 at 3:27 AM Sergey Nuyanzin wrote:
> Hi Timo,
>
> Thanks for the FLIP.
> I also tend to think that Option 3 is better.
>
> I would be also interested in a question mentioned by Benc
If breaking savepoint compatibility will be eventually an option, I would
recommend to try to upgrade Flink's Scala even to *2.13*
Best regards,
Alexey
On Fri, Apr 28, 2023 at 10:22 AM Chesnay Schepler
wrote:
> We don't know yet. I wanted to run some more experiments to see if
er for Java API. If that Scala wrapper is not an
official part of Flink project, then it will be unsafe to use Scala at all.
Günter has mentioned about it in his reply as well.
Best regards,
Alexey
On Mon, Apr 17, 2023 at 9:27 AM Martijn Visser
wrote:
> Hi Alexey,
>
> > Taking into
propose my free time to maintain that. As per Roman, required work
to maintain the library is very simple.
Best regards,
Alexey
On Sun, Apr 16, 2023 at 11:46 AM David Morávek wrote:
> cc dev@f.a.o
>
> On Sun, Apr 16, 2023 at 11:42 AM David Morávek wrote:
>
>> Hi Alexey,
>&
se/FLINK-29751 (Migrate SQL Client Local
Mode to use sql gateway)
It currently shows as unassigned. Is this really the case and no one is
working on enabling the connection from SQL Client to SQL Gateway.
Is the gateway mode planned to be supported for SQL Client in 1.17?
Regards,
Alexey
On Thu, Oct 27,
ing jobs on behalf of the client.
Ideally it would be nice to introduce some interfaces in the SQL Gateway
that would allow implementing custom authentication and authorization.
Another question about persistent Gateway: did you have any specific
thoughts about it or some draft design?
Thanks,
Persistent Gateway.
How can the authentication part be addressed on the SQL Client side?
Regards,
-Alexey
On Wed, Oct 12, 2022 at 11:24 PM yuxia wrote:
> > In what Flink’s release the connection from SQL Client to the Gateway is
> expected to be added?
> Flink 1.17
>
> > “Auth
Hi all,
I’m Alexey from Confluent. This is my first email in this discussion list.
I’m rather new to Flink, and to local customs of communication. I want to
dive deeper and hopefully get more involved over time.
Currently I have a few questions around SQL Gateway and SQL Client.
Specifically I
Alexey Petrenko created FLINK-28652:
---
Summary: Amazon Linux 2 based Docker container for Flink
Key: FLINK-28652
URL: https://issues.apache.org/jira/browse/FLINK-28652
Project: Flink
Issue
contributing to FileSystemHAService, maybe
it will be useful to someone else until FLIP-144 will be available
Thanks,
Alexey
From: Yang Wang
Sent: Wednesday, September 16, 2020 8:25 PM
To: Alexey Trenikhun
Cc: dev; Flink User Mail List
Subject: Re: FileSystemHaServices and
, on restart from
where we should start to avoid collision with already generated numbers, to do
saw we calculate offset0 as max over union list state.
Alexey
From: Seth Wiesman
Sent: Wednesday, September 9, 2020 9:37:03 AM
To: dev
Cc: Aljoscha Krettek ; user
from failure even
VoidBlobStore. I also use StatefulSet instead of Deployment
Thanks,
Alexey
From: Yang Wang
Sent: Tuesday, September 1, 2020 1:58 AM
To: dev
Cc: Alexey Trenikhun ; Flink User Mail List
Subject: Re: FileSystemHaServices and BlobStore
Hi Alexey,
Gl
Alexey Trenikhin created FLINK-11523:
Summary: TestHarness should provide way to configure
TypeSerailizers for side output
Key: FLINK-11523
URL: https://issues.apache.org/jira/browse/FLINK-11523
Alexey Trenikhin created FLINK-10621:
Summary: BootstrapToolsTest.testConcurrentActorSystemCreation
hangs forever when running locally
Key: FLINK-10621
URL: https://issues.apache.org/jira/browse/FLINK-10621
Alexey Trenikhin created FLINK-10127:
Summary: Add TypeInformation and serializers for JDK7 Instant
Key: FLINK-10127
URL: https://issues.apache.org/jira/browse/FLINK-10127
Project: Flink
Alexey Tsitkin created FLINK-9472:
-
Summary: Maven archetype code has typo in documentation
Key: FLINK-9472
URL: https://issues.apache.org/jira/browse/FLINK-9472
Project: Flink
Issue Type
Hi
>> The voting time has passed and I'm happy to announce that we've
collected enough votes to release this RC as Flink 1.3.2.
Maybe 1.4.0, because 1.3.2 already exist =)
2017-12-12 13:58 GMT+04:00 Aljoscha Krettek :
> The voting time has passed and I'm happy to announce that we've collected
dency on netty-router
2) rebuild and repack netty-router 1.10 with new version on netty 4.1 (as
PoC I already did this work, and all work correctly, only small changes
required)
We already have custom akka build and build also netty-router under
discussion.
Thanks
Alexey Diomin
2017-06-08 0:13 G
first step and enable select sslengine
as second step, not all in one step.
> However, if we do the change at the beginning of the next release cycle,
we
> might have enough exposure time to verify whether things work or not.
We just start 1.4 iteration and have time for testing.
Thank,
A
did tests and all work correctly, small changes in
NettyBufferPool.java and ChunkedByteBuf.java is required (implement new
method which added to interface).
Thanks
Alexey Diomin
ithout any hesitation.
Thanks
Alexey Diomin
2017-01-16 16:36 GMT+04:00 Ufuk Celebi :
> On 16 January 2017 at 12:59:04, Paris Carbone (par...@kth.se) wrote:
> > > Though, when someone has started reviewing a PR and shows interest
> > it probably makes sense to finish doing
Alexey Diomin created FLINK-5497:
Summary: remove duplicated tests
Key: FLINK-5497
URL: https://issues.apache.org/jira/browse/FLINK-5497
Project: Flink
Issue Type: Improvement
Hi Ivan,
I think problem not only with CEP project.
Main contributors overloaded and simple fixes frequently are staying as PR
without merge.
You can see how amount of open PR increasing over time.
Thanks,
Alexey Diomin
2017-01-15 17:18 GMT+04:00 Ivan Mushketyk :
> Hi Dmitry,
>
e, Jan 10, 2017 at 3:29 PM, Aljoscha Krettek
> wrote:
>
>> Thanks for looking into this! I think we can put in the fix and remove one
>> of the tests, yes.
>>
>> @Robert What do you think? I think you initially added this test a loooong
>> while back.
>&g
terator to
allow immutable objects)
Aljoscha, can we remove one test and fix buildSide.next(record) to
buildSide.next(recordReuse) ?
P.S. I started review because we have a lot of failing test due to cpu time
limit
Thanks,
Alexey
longrunning applications print hours without date very
uninformative.
What do you think?
Thanks,
Alexey
2017-01-09 17:25 GMT+04:00 Till Rohrmann :
> Hi Alexey,
>
> this is a good proposal. Could you open a corresponding JIRA issue for this
> change?
>
> Cheers,
> Till
>
Alexey Diomin created FLINK-5431:
Summary: time format for akka status
Key: FLINK-5431
URL: https://issues.apache.org/jira/browse/FLINK-5431
Project: Flink
Issue Type: Improvement
Hi
Because flink use lazy evaluation and because inactivityCEP don't have any
output then you pattern not apply.
/
inactivityCEP.select(new PatternSelectFunction() {
@Override
public Object select(Map pattern) throws
Exception {
System.out.println(pattern);
return null;
}
});
/
>> What am I mis
e or maybe stay
only HH:mm:ss
Thanks, Alexey
Thanks
with if (translator == null || !applyCanTranslate(transform, node,
translator)) all working as expectected
Regards,
Alexey Diomin
2016-08-31 14:12 GMT+04:00 Aljoscha Krettek :
> Ah I see, an unbounded source, such as the Kafka source does not work in
> batch mode
ow)
2016-08-31 13:53 GMT+04:00 Demin Alexey :
> Hi
>
> If we can change code on translator != null then next line (
> applyStreamingTransform(transform, node, translator); ) will cause NPE
>
> It's main problem why I don't understand code:
>
> x = nul
te(transform, node, translator))
>
> With what program did you encounter an NPE, it seems to me that this should
> rarely happen, at least it doesn't happen in all the Beam runner tests.
>
> Cheers,
> Aljoscha
>
> On Wed, 31 Aug 2016 at 11:27 Demin Alexey wrote:
>
>
t in your code then you will cause NPE
Maybe Aljoscha Krettek could describe how this code must work?
Regards,
Alexey Diomin
Alexey Diomin created FLINK-4148:
Summary: incorrect calculation distance in QuadTree
Key: FLINK-4148
URL: https://issues.apache.org/jira/browse/FLINK-4148
Project: Flink
Issue Type: Bug
> > > > the
> > > > > > > > last release before 1.0.
> > > > > > > >
> > > > > > > > For 0.10 we most noticeably have the new Streaming API which
> > > comes
> > > > > > > > with an improved runtime including exactly-once sources and
> > > sinks.
> > > > > > > > Additionally, we have a new web interface with support for
> > > > > > > > live-monitoring. Not to mention the countless fixes and
> > > > improvements.
> > > > > > > >
> > > > > > > > I've been ransacking the JIRA issues to find out what issues
> we
> > > > have
> > > > > > > > to fix before we can release. I've put these issues on the
> 0.10
> > > > wiki
> > > > > > > > page:
> > > > https://cwiki.apache.org/confluence/display/FLINK/0.10+Release
> > > > > > > >
> > > > > > > > It would be great to fix all of these issues. However, I
> think
> > we
> > > > > need
> > > > > > > > to be pragmatic and pick the most pressing ones. Let's do
> that
> > on
> > > > the
> > > > > > > > wiki page on the "To Be Fixed" section.
> > > > > > > >
> > > > > > > > Cheers,
> > > > > > > > Max
> > > > > > > >
> > > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
>
--
*Regards*
*Alexey Sapozhnikov*
CTO& Co-Founder
Scalabillit Inc
Aba Even 10-C, Herzelia, Israel
M : +972-52-2363823
E : ale...@scalabill.it
W : http://www.scalabill.it
YT - https://youtu.be/9Rj309PTOFA
Map:http://mapta.gs/Scalabillit
Revolutionizing Proof-of-Concept
creation of pipelines for Java is more of a
+long
term project, but we should make it possible to manually create pipelines in
Java.
On Fri, Sep 18, 2015 at 11:15 AM, Till Rohrmann
wrote:
> Hi Alexey and Hanan,
>
> one of FlinkML’s feature is the flexible pipelining mechanism. It
> a
ve been
> already
> implemented in Flinks ml source code.
>
> Another option is using MultipleLinearRegression.fitMLR() method ,but I
> haven't found a way to pass the train dataset to it as a parameter or by
> setter.
>
> I'll be more than happy if you could guide me how to imple
wrote:
> Why are the external IPs not working? Any kind of exception you can share?
>
> On Sun, Aug 30, 2015 at 5:02 PM, Alexey Sapozhnikov
> wrote:
>
> > it will not help, since the internal IPs are changing in AWS from time to
> > time and you should use only Public IP, w
>
> On Sun, Aug 30, 2015 at 4:44 PM, Alexey Sapozhnikov
> wrote:
>
> > Fully understand.
> > 1.My suggestion is to drop Akka and take something else, since this issue
> > is really big
> > 2.Not hostname not the endpoint are not working, clarifying the VPC topi
side, we have been using Flink on Cloud Platforms GCE, Amazon,
> and it worked.
>
> Can you try to use the internal hostname, or the fully qualified external
> hostname?
>
>
> On Sun, Aug 30, 2015 at 4:23 PM, Alexey Sapozhnikov
> wrote:
>
> > Hi.
> > First off
mazon-Linux.html
> Can you easily activate a DNS server in the VPC?
>
> 0.0.0.0 is not supported because of some requirements of the Akka
> framework.
> But you should be able to use the host's IP address.
> Can you try that as well?
>
>
>
>
> On Sun, Aug 30, 2015
dress.java:928)
@
21,1
71%
On Sun, Aug 30, 2015 at 4:57 PM, Robert Metzger wrote:
> How is Flink crashing when you start it on the Linux machine in Amazon?
>
> Can you post the exception here?
>
> On Sun, Aug 30
;
> Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67)
> > > > > > > > at
> > > > > > > >
> > > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> akka.dispatch.Batch
Hello all.
Some clarification: locally everything works great.
However once we run our Flink on remote linux machine and try to run the
client program from our machine, using create remote environment- Flink
JobManager is raising this exception
On Thu, Aug 27, 2015 at 7:41 PM, Stephan Ewen wrote
Hello all.
Some clarification: locally everything works great.
However once we run our Flink on remote linux machine and try to run the
client program from our machine, using create remote environment- Flink
JobManager is raising this exception
On Thu, Aug 27, 2015 at 7:41 PM, Stephan Ewen wrote
66 matches
Mail list logo
