Congratulations Yu, well deserved!
Best,
Jingsong
On Wed, Jun 17, 2020 at 1:42 PM Yuan Mei wrote:
> Congrats, Yu!
>
> GXGX & well deserved!!
>
> Best Regards,
>
> Yuan
>
> On Wed, Jun 17, 2020 at 9:15 AM jincheng sun
> wrote:
>
>> Hi all,
>>
>> On behalf of the Flink PMC, I'm happy to announce
Congrats, Yu!
GXGX & well deserved!!
Best Regards,
Yuan
On Wed, Jun 17, 2020 at 9:15 AM jincheng sun
wrote:
> Hi all,
>
> On behalf of the Flink PMC, I'm happy to announce that Yu Li is now
> part of the Apache Flink Project Management Committee (PMC).
>
> Yu Li has been very active on Flink'
Congratulations Yu!
Rui Li 于2020年6月17日周三 下午1:15写道：
> Congratulations!
>
> On Wed, Jun 17, 2020 at 11:58 AM Xingbo Huang wrote:
>
> > Congratulations Yu! Well deserved
> >
> > Best,
> > Xingbo
> >
> > Peter Huang 于2020年6月17日周三 上午11:51写道：
> >
> > > Congratulations Yu!
> > >
> > > On Tue, Jun 16,
Congratulations!
On Wed, Jun 17, 2020 at 11:58 AM Xingbo Huang wrote:
> Congratulations Yu! Well deserved
>
> Best,
> Xingbo
>
> Peter Huang 于2020年6月17日周三 上午11:51写道：
>
> > Congratulations Yu!
> >
> > On Tue, Jun 16, 2020 at 8:31 PM Dan Zou wrote:
> >
> > > Congratulations Yu!
> > >
> > > Best,
Piotr Nowojski created FLINK-18341:
--
Summary: Building Flink Walkthrough Table Java 0.1 COMPILATION
ERROR
Key: FLINK-18341
URL: https://issues.apache.org/jira/browse/FLINK-18341
Project: Flink
Why compile JobGraph yourself? This is really an internal API and may cause
problems.
Could you try to use `flink run` command [1] to submit your user jar
instead?
Btw, what's your Flink version? If you are using Flink 1.10.0, could you
try to use 1.10.1?
Best,
Jark
On Wed, 17 Jun 2020 at 12:41,
(forwarding this to user@ as it is more suited to be located there)
Hi Sunil,
With remote functions (using the Python SDK), messages sent to / from them
must be Protobuf messages.
This is a requirement since remote functions can be written in any
language, and we use Protobuf as a means for cross
Tzu-Li (Gordon) Tai created FLINK-18340:
---
Summary: Support directly providing bytes instead of a Protobuf
messages when writing to Kafka / Kinesis with the Python SDK
Key: FLINK-18340
URL: https://issues.apa
Thanks for the reply,
Here is the simple java program that re-produce the problem:
1. code for the application:
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
I second Jark's comment. We need a CI mechanism to ensure this.
Best,
Yangze Guo
On Wed, Jun 17, 2020 at 11:45 AM Jark Wu wrote:
>
> Hi everyone,
>
> Before going to use {% link %} and adding a CI to force using link tag, I
> suggest adding a CI profile to check broken links first.
>
> The backg
Congratulations Yu! Well deserved
Best,
Xingbo
Peter Huang 于2020年6月17日周三 上午11:51写道：
> Congratulations Yu!
>
> On Tue, Jun 16, 2020 at 8:31 PM Dan Zou wrote:
>
> > Congratulations Yu!
> >
> > Best,
> > Dan Zou
> >
> > > 2020年6月17日 上午11:28，Jeff Zhang 写道：
> > >
> > > Congratulations Yu ！
> > >
>
Congratulations Yu!
On Tue, Jun 16, 2020 at 8:31 PM Dan Zou wrote:
> Congratulations Yu!
>
> Best,
> Dan Zou
>
> > 2020年6月17日 上午11:28，Jeff Zhang 写道：
> >
> > Congratulations Yu ！
> >
> > Yun Gao 于2020年6月17日周三 上午11:26写道：
> >
> >> Congratulations Yu!
> >>
> >> Best,
> >> Yun
> >>
> >> ---
Hi everyone,
Before going to use {% link %} and adding a CI to force using link tag, I
suggest adding a CI profile to check broken links first.
The background is that, recently, I noticed that many contributors are
beginning to use link tags, but forget to link ".zh.md" instead of ".md" in
Chines
Congratulations Yu!
Best,
Dan Zou
> 2020年6月17日 上午11:28，Jeff Zhang 写道：
>
> Congratulations Yu ！
>
> Yun Gao 于2020年6月17日周三 上午11:26写道：
>
>> Congratulations Yu!
>>
>> Best,
>> Yun
>>
>> --
>> Sender:Zhijiang
>> Date:2020/06/17 11:
Congratulations Yu ！
Yun Gao 于2020年6月17日周三 上午11:26写道：
> Congratulations Yu!
>
> Best,
> Yun
>
> --
> Sender:Zhijiang
> Date:2020/06/17 11:18:35
> Recipient:Dian Fu; dev
> Cc:Haibo Sun; user; user-zh<
> user...@flink.apache.org>
> Th
Congratulations Yu!
Best,
Yun
--
Sender:Zhijiang
Date:2020/06/17 11:18:35
Recipient:Dian Fu; dev
Cc:Haibo Sun; user;
user-zh
Theme:Re: [ANNOUNCE] Yu Li is now part of the Flink PMC
Congratulations Yu! Well deserved!
Best,
Zhijian
Congratulations Yu! Well deserved!
Best,
Zhijiang
--
From:Dian Fu
Send Time:2020年6月17日(星期三) 10:48
To:dev
Cc:Haibo Sun ; user ; user-zh
Subject:Re: [ANNOUNCE] Yu Li is now part of the Flink PMC
Congrats Yu!
Regards,
Dian
> 在 2
hehuiyuan created FLINK-18339:
-
Summary: ValidationException exception that field typeinformation
in TableSchema and in TableSource return type for blink
Key: FLINK-18339
URL: https://issues.apache.org/jira/browse/FL
Congrats Yu!
Regards,
Dian
> 在 2020年6月17日，上午10:35，Jark Wu 写道：
>
> Congratulations Yu! Well deserved!
>
> Best,
> Jark
>
> On Wed, 17 Jun 2020 at 10:18, Haibo Sun wrote:
>
>> Congratulations Yu!
>>
>> Best,
>> Haibo
>>
>>
>> At 2020-06-17 09:15:02, "jincheng sun" wrote:
>>> Hi all,
>>>
Congratulations Yu!
Jark Wu 于2020年6月17日周三 上午10:36写道：
> Congratulations Yu! Well deserved!
>
> Best,
> Jark
>
> On Wed, 17 Jun 2020 at 10:18, Haibo Sun wrote:
>
> > Congratulations Yu!
> >
> > Best,
> > Haibo
> >
> >
> > At 2020-06-17 09:15:02, "jincheng sun" wrote:
> > >Hi all,
> > >
> > >On b
Congratulations Yu!
Best,
Forward
Jark Wu 于2020年6月17日周三 上午10:36写道：
> Congratulations Yu! Well deserved!
>
> Best,
> Jark
>
> On Wed, 17 Jun 2020 at 10:18, Haibo Sun wrote:
>
> > Congratulations Yu!
> >
> > Best,
> > Haibo
> >
> >
> > At 2020-06-17 09:15:02, "jincheng sun" wrote:
> > >Hi all
Hi,
Which Flink version are you using? Are you using SQL CLI? Could you share
your table/sql program?
We did fix some classloading problems around SQL CLI, e.g. FLINK-18302
Best,
Jark
On Wed, 17 Jun 2020 at 10:31, 杜斌 wrote:
> add the full stack trace here:
>
>
> Caused by:
>
> org.apache.flink
Congratulations Yu! Well deserved!
Best,
Jark
On Wed, 17 Jun 2020 at 10:18, Haibo Sun wrote:
> Congratulations Yu!
>
> Best,
> Haibo
>
>
> At 2020-06-17 09:15:02, "jincheng sun" wrote:
> >Hi all,
> >
> >On behalf of the Flink PMC, I'm happy to announce that Yu Li is now
> >part of the Apache F
add the full stack trace here:
Caused by:
org.apache.flink.shaded.guava18.com.google.common.util.concurrent.UncheckedExecutionException:
org.apache.flink.api.common.InvalidProgramException: Table program cannot
be compiled. This is a bug. Please file an issue.
at
org.apache.flink.shaded.guava18.c
Hi,
Need help on this issue, here is what Flink reported when I enable the
checkpoint setting of the StreamExecutionEnvironment:
/* 1 */
/* 2 */ public class SourceConversion$1 extends
org.apache.flink.table.runtime.operators.AbstractProcessStreamOperator
/* 3 */ implements
org.apach
Congratulations Yu!
Best,
Haibo
At 2020-06-17 09:15:02, "jincheng sun" wrote:
>Hi all,
>
>On behalf of the Flink PMC, I'm happy to announce that Yu Li is now
>part of the Apache Flink Project Management Committee (PMC).
>
>Yu Li has been very active on Flink's Statebackend component, working
Congratulations Yu !
Best,
Leonard Xu
> 在 2020年6月17日，09:50，Yangze Guo 写道：
>
> Congrats, Yu!
> Best,
> Yangze Guo
>
> On Wed, Jun 17, 2020 at 9:35 AM Xintong Song wrote:
>>
>> Congratulations Yu, well deserved~!
>>
>> Thank you~
>>
>> Xintong Song
>>
>>
>>
>> On Wed, Jun 17, 2020 at 9:15
Congrats, Yu!
Best,
Yangze Guo
On Wed, Jun 17, 2020 at 9:35 AM Xintong Song wrote:
>
> Congratulations Yu, well deserved~!
>
> Thank you~
>
> Xintong Song
>
>
>
> On Wed, Jun 17, 2020 at 9:15 AM jincheng sun wrote:
>>
>> Hi all,
>>
>> On behalf of the Flink PMC, I'm happy to announce that Yu Li
Congratulations Yu, well deserved~!
Thank you~
Xintong Song
On Wed, Jun 17, 2020 at 9:15 AM jincheng sun
wrote:
> Hi all,
>
> On behalf of the Flink PMC, I'm happy to announce that Yu Li is now
> part of the Apache Flink Project Management Committee (PMC).
>
> Yu Li has been very active on F
Hi all,
On behalf of the Flink PMC, I'm happy to announce that Yu Li is now
part of the Apache Flink Project Management Committee (PMC).
Yu Li has been very active on Flink's Statebackend component, working on
various improvements, for example the RocksDB memory management for 1.10.
and keeps che
checking to see if this is possible currently.
Read json data from kafka topic => process using statefun => write out to kafka
in json format.
I could have a separate process to read the source json data convert to
protobuf into another kafka topic but it sounds in-efficient.
e.g.
Read json dat
Chesnay Schepler created FLINK-18338:
Summary: RocksDB tests crash the JVM on CI
Key: FLINK-18338
URL: https://issues.apache.org/jira/browse/FLINK-18338
Project: Flink
Issue Type: Bug
godfrey he created FLINK-18337:
--
Summary: Introduce TableResult#await method to wait data ready
Key: FLINK-18337
URL: https://issues.apache.org/jira/browse/FLINK-18337
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-18336:
-
Summary: CheckpointFailureManager forgets failed checkpoints after
a successful one
Key: FLINK-18336
URL: https://issues.apache.org/jira/browse/FLINK-18336
Piotr Nowojski created FLINK-18335:
--
Summary:
NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs
Key: FLINK-18335
URL: https://issues.apache.org/jira/browse/FLINK-18335
Project: Fli
Chesnay Schepler created FLINK-18334:
Summary: Exclude .dumpstream files that only contain
JAVA_TOOL_OPTIONS logging
Key: FLINK-18334
URL: https://issues.apache.org/jira/browse/FLINK-18334
Project
Jark Wu created FLINK-18333:
---
Summary: UnsignedTypeConversionITCase failed caused by MariaDB4j
"Asked to waitFor Program"
Key: FLINK-18333
URL: https://issues.apache.org/jira/browse/FLINK-18333
Project: Fli
tartarus created FLINK-18332:
Summary: Add error message to precondition in
KeyGroupPartitionedPriorityQueue
Key: FLINK-18332
URL: https://issues.apache.org/jira/browse/FLINK-18332
Project: Flink
Chesnay Schepler created FLINK-18331:
Summary: Hive NOTICE issues
Key: FLINK-18331
URL: https://issues.apache.org/jira/browse/FLINK-18331
Project: Flink
Issue Type: Bug
Componen
Chesnay Schepler created FLINK-18330:
Summary: Python NOTICE issues
Key: FLINK-18330
URL: https://issues.apache.org/jira/browse/FLINK-18330
Project: Flink
Issue Type: Bug
Compon
Chesnay Schepler created FLINK-18329:
Summary: Runtime NOTICE issues
Key: FLINK-18329
URL: https://issues.apache.org/jira/browse/FLINK-18329
Project: Flink
Issue Type: Bug
Compo
Chesnay Schepler created FLINK-18327:
Summary: ML NOTICE issues
Key: FLINK-18327
URL: https://issues.apache.org/jira/browse/FLINK-18327
Project: Flink
Issue Type: Bug
Components
Chesnay Schepler created FLINK-18328:
Summary: Blink planner NOTICE issues
Key: FLINK-18328
URL: https://issues.apache.org/jira/browse/FLINK-18328
Project: Flink
Issue Type: Bug
Chesnay Schepler created FLINK-18326:
Summary: Kubernetes NOTICE issues
Key: FLINK-18326
URL: https://issues.apache.org/jira/browse/FLINK-18326
Project: Flink
Issue Type: Bug
Co
Jiatao Tao created FLINK-18325:
--
Summary: SqlMapTypeNameSpec#unparse may throw NPE
Key: FLINK-18325
URL: https://issues.apache.org/jira/browse/FLINK-18325
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-18324:
Summary: Translate updated data type and function page into Chinese
Key: FLINK-18324
URL: https://issues.apache.org/jira/browse/FLINK-18324
Project: Flink
Is
Jiangjie Qin created FLINK-18323:
Summary: Implement a Kafka Source based on new Source API
Key: FLINK-18323
URL: https://issues.apache.org/jira/browse/FLINK-18323
Project: Flink
Issue Type:
Jiangjie Qin created FLINK-18322:
Summary: Fix unstable ExecutorNotifierTest#testExceptionInHandler.
Key: FLINK-18322
URL: https://issues.apache.org/jira/browse/FLINK-18322
Project: Flink
Iss
Robert Metzger created FLINK-18321:
--
Summary: AbstractCloseableRegistryTest.testClose unstable
Key: FLINK-18321
URL: https://issues.apache.org/jira/browse/FLINK-18321
Project: Flink
Issue Ty
Jingsong Lee created FLINK-18320:
Summary: flink-sql-connector-hive modules should merge hive-exec
dependencies
Key: FLINK-18320
URL: https://issues.apache.org/jira/browse/FLINK-18320
Project: Flink
Jingsong Lee created FLINK-18319:
Summary: Lack LICENSE.protobuf in flink-sql-orc
Key: FLINK-18319
URL: https://issues.apache.org/jira/browse/FLINK-18319
Project: Flink
Issue Type: Bug
Dimitris Vogiatzidakis created FLINK-18318:
--
Summary: Flink ML
Key: FLINK-18318
URL: https://issues.apache.org/jira/browse/FLINK-18318
Project: Flink
Issue Type: Task
Compo
Thanks for reporting this issue Lucent. One way to solve it would be to
reintroduce the RedirectHandler and allow the user to choose between
forwarding to the leader as it is right now in Flink 1.10 and using
redirects as it was the case in the past. If I remember correctly, then
redirects also had
Piotr Nowojski created FLINK-18317:
--
Summary: Verify dependencies licencses in Flink 1.11
Key: FLINK-18317
URL: https://issues.apache.org/jira/browse/FLINK-18317
Project: Flink
Issue Type: S
Hi, Vivin!
Thanks for your interest in participating in Google Season of Docs (GSoD)
and contributing to Apache Flink! We're glad that you enjoyed working with
Flink before, and that it motivated you to now apply to GSoD.
Regarding what you can work on, there are no strict requirements since
ther
55 matches
Mail list logo
