Hi all,
I recently encountered a question while reading the Flink code.
In my understanding, `RunAsync` and `CallAsync` are classes for local
invocations to `AkkaRpcActor`, and should only be used locally.
However, `CallAsync` implements `Serializable`, but `RunAsync` not. And
`AkkaRpcActor`
+1
- checked announcement blog post
- packaged the project (skipped test cases)
- Started an empty cluster locally and submitted wordcount example job
Best,
Vino
Dian Fu 于2019年2月19日周二 下午2:42写道：
> +1
>
> - compiled from source
> - check the signature and hash
> - started standalone cluster
+1
- compiled from source
- check the signature and hash
- started standalone cluster and tried a WordCount example.
Regards,
Dian
> 在 2019年2月16日，下午5:28，Hequn Cheng 写道：
>
> Great job! Thanks jincheng for your efforts on the RC1 of Flink 1.6.4!
>
> +1 (non-binding)
>
> I have checked the
Benchao Li created FLINK-11655:
--
Summary: runnable field should be transient in RunAsync from RPC
messages
Key: FLINK-11655
URL: https://issues.apache.org/jira/browse/FLINK-11655
Project: Flink
thank you for the quick response.
On Mon, Feb 18, 2019 at 8:58 PM Jürgen Kreileder (JIRA)
wrote:
> Jürgen Kreileder created FLINK-11654:
>
>
> Summary: ProducerFencedExceptions from Kafka in EXACTLY_ONCE
> mode due to identical transactional
Jürgen Kreileder created FLINK-11654:
Summary: ProducerFencedExceptions from Kafka in EXACTLY_ONCE mode
due to identical transactional IDs in multiple jobs
Key: FLINK-11654
URL:
Seth Wiesman created FLINK-11653:
Summary: Add configuration to enforce custom UID's on datastream
Key: FLINK-11653
URL: https://issues.apache.org/jira/browse/FLINK-11653
Project: Flink
Hi Aleksandr,
Welcome to the Flink community!
I've given you contributor permissions for Jira.
Best, Fabian
Am Mo., 18. Feb. 2019 um 16:18 Uhr schrieb Александр :
> Hi, everyone. Could you give me corresponding rights? Jira name: Salatich
>
> Best regards,
> Aleksandr Salatich
>
Hi Stephan,
Thanks for summarizing the work into a roadmap. It really helps
users to understand where Flink will forward to. The entire outline looks
good to me. If appropriate, I would recommend to add another two attracting
categories in the roadmap.
*Flink ML Enhancement*
- Refactor ML
Hi, everyone. Could you give me corresponding rights? Jira name: Salatich
Best regards,
Aleksandr Salatich
Thanks Jark!
I think we definitely need a Translation Specification and Glossary and
like the idea of maintinaing it in wiki.
Regarding the CC-BY-SA license of the Mozilla document, it seems that we
copy the content but not modify it [1].
So, maybe we have to come up with something like that our
I added "Runtime / Configuration" to the proposal:
https://cwiki.apache.org/confluence/display/FLINK/Proposal+for+new+JIRA+Components
Since this discussion has been open for 10 days, I assume we have reached
consensus here. I will soon start renaming components.
On Wed, Feb 13, 2019 at 10:51 AM
TisonKun created FLINK-11652:
Summary: Remove legacy JobClient
Key: FLINK-11652
URL: https://issues.apache.org/jira/browse/FLINK-11652
Project: Flink
Issue Type: Sub-task
Components:
Hey,
I was able to build the commit on a clean Ubuntu 18.04 Docker image. I ran
the following commands:
$ docker run -it ubuntu /bin/bash
% apt-get update
% apt-get install maven openjdk-8-jdk git
% git clone git clone https://github.com/apache/flink.git
% cd flink
% git checkout
Hi Ramya,
LIMIT is supported for batch SQL but requires an ORDER BY clause to be
deterministic.
For example
SELECT a, b, c FROM Abc ORDER BY a DESC LIMIT 5
is a supported query.
If you are only interested in the top-k values (and not the values of the
other attributes) you can also implement a
Thanks Stephan for the proposal and a big +1 to this!
I also think it's a good idea to add a link of discussion/FLIP/JIRA to each
item as Zhijiang mentioned above.
This would be a great help for keeping track of progress and joining in the
discussion easily.
Best,
Jark
On Fri, 15 Feb 2019 at
Gary Yao created FLINK-11651:
Summary: Upgrade Jepsen to 0.1.11 in flink-jepsen
Key: FLINK-11651
URL: https://issues.apache.org/jira/browse/FLINK-11651
Project: Flink
Issue Type: Improvement
That's great.
Awesome, thanks a lot Gordon!
I've asked Infra to add you as a moderator:
https://issues.apache.org/jira/browse/INFRA-17865
On Wed, Feb 13, 2019 at 11:15 AM Tzu-Li (Gordon) Tai
wrote:
> Hi Robert,
>
> I'll be willing to help with moderating the user-zh@ list.
>
> Cheers,
> Gordon
>
> On Wed,
Till Rohrmann created FLINK-11650:
-
Summary: Remove legacy FlinkResourceManager
Key: FLINK-11650
URL: https://issues.apache.org/jira/browse/FLINK-11650
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-11649:
-
Summary: Remove legacy JobInfo
Key: FLINK-11649
URL: https://issues.apache.org/jira/browse/FLINK-11649
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-11648:
-
Summary: Remove MemoryArchivist
Key: FLINK-11648
URL: https://issues.apache.org/jira/browse/FLINK-11648
Project: Flink
Issue Type: Sub-task
Sergey Starokozhev created FLINK-11647:
--
Summary: Use message headers in flink kafka connectors
Key: FLINK-11647
URL: https://issues.apache.org/jira/browse/FLINK-11647
Project: Flink
Thanks!
Robert Metzger 于2019年2月18日周一 下午4:48写道：
> Hey,
> I gave you contributor permissions. Thanks a lot for helping with the
> translation effort!
>
> On Mon, Feb 18, 2019 at 7:13 AM 陈利飞 wrote:
>
> > My jira account is: hustclf
> >
> > 陈利飞 于2019年2月18日周一 下午2:08写道：
> >
> > > Hi, all:
> > > I
Hi Padarn,
This is the jira issue: https://issues.apache.org/jira/browse/FLINK-11187
and the fix, as you can see, was first included in version 1.7.2.
Cheers,
Kostas
On Mon, Feb 18, 2019 at 3:49 AM Padarn Wilson
wrote:
> Hi Addison, Kostas, Steffan,
>
> I am also encountering this exact
zhijiang created FLINK-11646:
Summary: Remove legacy MockRecordWriter
Key: FLINK-11646
URL: https://issues.apache.org/jira/browse/FLINK-11646
Project: Flink
Issue Type: Test
Hi Robert,
Regarding FLINK-10776 - Update migration tests for Flink 1.7:
There's still one last test class that needs to be migrated (progress
reflected in the list of subtasks of FLINK-10776), and we definitely should
still fix that before releasing 1.8.0 to ensure backwards compatibility of
Till Rohrmann created FLINK-11645:
-
Summary: Remove legacy JobManager
Key: FLINK-11645
URL: https://issues.apache.org/jira/browse/FLINK-11645
Project: Flink
Issue Type: Sub-task
Hey,
I gave you contributor permissions. Thanks a lot for helping with the
translation effort!
On Mon, Feb 18, 2019 at 7:13 AM 陈利飞 wrote:
> My jira account is: hustclf
>
> 陈利飞 于2019年2月18日周一 下午2:08写道：
>
> > Hi, all:
> > I am applying for flink contributor permission, I want to help to
> >
Thank you Gordon!
Help spread the word here:
https://twitter.com/ApacheFlink/status/1097416946688102401
On Mon, Feb 18, 2019 at 7:41 AM Dian Fu wrote:
> Great job. It's great to have a more stable 1.7 release available. Thanks
> @Gordon for making it happen.
>
> Regards,
> Dian
>
> 在
I'm not involved enough with the development to say whether end of this
week is a realistic deadline.
But I see that it makes sense to release 1.8 soon, if it is blocking the
Table API refactoring.
There are 5 blockers assigned to the 1.8.0 release:
thinktothings created FLINK-11644:
-
Summary: Exception in thread "main"
org.apache.flink.client.program.ProgramInvocationException: Could not retrieve
the execution result.
Key: FLINK-11644
URL:
32 matches
Mail list logo
