Ying Z created FLINK-35502:
--
Summary: compress the checkpoint metadata ZK/ETCD HA Services
Key: FLINK-35502
URL: https://issues.apache.org/jira/browse/FLINK-35502
Project: Flink
Issue Type
Ying Lin created FLINK-27697:
Summary: Restoring from a checkpoint will start duplicated
application when mixing use streaming sinks and sql sinks in code.
Key: FLINK-27697
URL: https://issues.apache.org/jira/browse
YING HOU created FLINK-23304:
Summary: More detail information in sql validate exception
Key: FLINK-23304
URL: https://issues.apache.org/jira/browse/FLINK-23304
Project: Flink
Issue Type
ying zhang created FLINK-22205:
--
Summary: Does it support gpu coding in flink?
Key: FLINK-22205
URL: https://issues.apache.org/jira/browse/FLINK-22205
Project: Flink
Issue Type: Task
ying zhang created FLINK-22204:
--
Summary: Does it support rate-limiting in flink 1.12?
Key: FLINK-22204
URL: https://issues.apache.org/jira/browse/FLINK-22204
Project: Flink
Issue Type: Bug
ying zhang created FLINK-22086:
--
Summary: Read hive
Key: FLINK-22086
URL: https://issues.apache.org/jira/browse/FLINK-22086
Project: Flink
Issue Type: Bug
Reporter: ying zhang
ying zhang created FLINK-22009:
--
Summary: when data type is map,we cannot union
Key: FLINK-22009
URL: https://issues.apache.org/jira/browse/FLINK-22009
Project: Flink
Issue Type: Bug
ying zhang created FLINK-21683:
--
Summary: java.lang.ClassCastException:
org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to
org.apache.orc.Reader
Key: FLINK-21683
URL: https://issues.apache.org/jira
ying zhang created FLINK-21682:
--
Summary: java.lang.ClassCastException:
org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to
org.apache.orc.Reader
Key: FLINK-21682
URL: https://issues.apache.org/jira
ying zhang created FLINK-21681:
--
Summary: java.lang.ClassCastException:
org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to
org.apache.orc.Reader
Key: FLINK-21681
URL: https://issues.apache.org/jira
Ying Z created FLINK-19244:
--
Summary: CsvRowDataDeserializationSchema throws cast exception :
Row length mismatch.
Key: FLINK-19244
URL: https://issues.apache.org/jira/browse/FLINK-19244
Project: Flink
Ying Z created FLINK-18782:
--
Summary: How to retain the column'name when convert a Table to
DataStream
Key: FLINK-18782
URL: https://issues.apache.org/jira/browse/FLINK-18782
Project: Flink
Ying Z created FLINK-15719:
--
Summary: Exceptions when using scala types directly with the State
Process API
Key: FLINK-15719
URL: https://issues.apache.org/jira/browse/FLINK-15719
Project: Flink
Ying Xu created FLINK-15476:
---
Summary: Update StreamingFileSink documentation -- bulk encoded
writer now supports customized checkpoint policy
Key: FLINK-15476
URL: https://issues.apache.org/jira/browse/FLINK-15476
Ying Xu created FLINK-15301:
---
Summary: Flink Kinesis AsyncRecordEmitter needs to handle
unchecked exception gracefully
Key: FLINK-15301
URL: https://issues.apache.org/jira/browse/FLINK-15301
Project: Flink
YING HOU created FLINK-14508:
Summary: google protobuf is not shaded
Key: FLINK-14508
URL: https://issues.apache.org/jira/browse/FLINK-14508
Project: Flink
Issue Type: Bug
Components
Ying Xu created FLINK-14039:
---
Summary: Flink Kinesis consumer: configurable per-shard
consumption rate when running in adaptive mode
Key: FLINK-14039
URL: https://issues.apache.org/jira/browse/FLINK-14039
Congratulations Kostas!
On Fri, Sep 6, 2019 at 11:21 PM Gary Yao wrote:
> Congratulations Klou!
>
> On Sat, Sep 7, 2019 at 6:21 AM Thomas Weise wrote:
>
> > Congratulations!
> >
> >
> > On Fri, Sep 6, 2019 at 9:22 AM zhijiang > .invalid>
> > wrote:
> >
> > > Congratulations Klou!
> > >
> > > B
a high-level example. In practice, our app is more
complex, with a much larger number of protobuf classes. Messages may be
added/deleted across different versions of the Flink app.
On Wed, Aug 7, 2019 at 11:23 AM Yun Tang wrote:
> Hi Ying
>
> What version of Flink are you using and please
Hi Flink community:
Our Flink application sends different types of protobuf messages
on-the-wire. Since protobuf cannot be handled by Flink type serializer, we
had to register custom Kyro serializer:
env.getConfig().*registerTypeWithKryoSerializer*(MyProtoClass1.class,
ProtobufSerializer.class);
Hi Kostas:
For simplicity FLINK-13027
<https://issues.apache.org/jira/browse/FLINK-13027> has been assigned to my
current user ID. I will contribute using that ID.
Will circulate with the community once we have initial success with this
new rolling policy !
Thank you again.
-
Ying
Dear Flink community:
Per an earlier discussion thread, I created FLINK-13027 and would like to
contribute to it.
Is it possible to grant me the Contributor access?
*yxu-apache
<https://issues.apache.org/jira/secure/ViewProfile.jspa?name=yxu-apache>*
Thanks in advance.
-
Ying
PS:
d you mind granting me the contributor access for the following account
? This way I can assign the JIRA to myself.
*yxu-apache
<https://issues.apache.org/jira/secure/ViewProfile.jspa?name=yxu-apache>*
Many thanks!
<http://www.lyft.com/>
-
Ying
On Fri, Jun 28, 2019 at 2:23
an happy to contribute if there's no other plan to address this
issue.
Thanks again.
-
Bests
Ying
On Tue, Jun 25, 2019 at 2:24 AM Kostas Kloudas wrote:
> Hi Ying,
>
> You are right! If it is either on checkpoint or on size, then this is
> doable even with the current state o
Ying Xu created FLINK-13027:
---
Summary: StreamingFileSink bulk-encoded writer supports file
rolling upon customized events
Key: FLINK-13027
URL: https://issues.apache.org/jira/browse/FLINK-13027
Project
ing()
<https://github.com/apache/flink/blob/3702029f45b7034b767e2b7eb01601c7f76ab35e/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Bucket.java#L275>.
Not sure if I miss anything there.
-
Ying
On Mon, Jun 24, 2019 at 2:01 AM Kostas Kloudas
rantee.
Any advises on whether the above idea makes sense? Or perhaps there are
pitfalls that one might pay attention when introducing such rolling policy.
Thanks a lot!
-
Ying
Ying Xu created FLINK-10358:
---
Summary: Flink kinesis connector could throw NPE during
getRecords() call
Key: FLINK-10358
URL: https://issues.apache.org/jira/browse/FLINK-10358
Project: Flink
+1 on separating out the logic relevant to Kinesalite. Kinesalite is likely
used in testing environment a lot.
On Thu, Sep 13, 2018 at 1:52 AM, Евгений Юшин
wrote:
> Hi there
>
> Flink Kinesis consumer checks shards id for a particular pattern:
> "^shardId-\\d{12}"
>
> https://github.com/apache
Thank you so much Fabian!
Will update status in the JIRA.
-
Ying
On Tue, Jul 31, 2018 at 1:37 AM, Fabian Hueske wrote:
> Done!
>
> Thank you :-)
>
> 2018-07-31 6:41 GMT+02:00 Ying Xu :
>
> > Thanks Fabian and Thomas.
> >
> > Please assign FLINK-4582 to
Thanks Fabian and Thomas.
Please assign FLINK-4582 to the following username:
*yxu-apache
<https://issues.apache.org/jira/secure/ViewProfile.jspa?name=yxu-apache>*
If needed I can get a ICLA or CCLA whichever is proper.
*Ying Xu*
Software Engineer
510.368.1252 <+15103681252>
granted with a contributor role?
Many thanks in advance.
*Ying Xu*
Software Engineer
510.368.1252 <+15103681252>
[image: Lyft] <http://www.lyft.com/>
On Fri, Jul 6, 2018 at 6:23 PM, Ying Xu wrote:
> Hi Gordon:
>
> Cool. Thanks for the thumb-up!
>
> We will include
Hi Gordon:
Cool. Thanks for the thumb-up!
We will include some test cases around the behavior of re-sharding. If
needed we can double check the behavior with AWS, and see if additional
changes are needed. Will keep you posted.
-
Ying
On Wed, Jul 4, 2018 at 7:22 PM, Tzu-Li (Gordon) Tai
wrote
HI Gordon:
We are starting to implement some of the primitives along this path. Please
let us know if you have any suggestions.
Thanks!
On Fri, Jun 29, 2018 at 12:31 AM, Ying Xu wrote:
> Hi Gordon:
>
> Really appreciate the reply.
>
> Yes our plan is to build the connecto
me e.g,
FlinkDynamoStreamConsumer.
At best this could simply work. But we would like to hear if there are
other situations to take care of. In particular, I am wondering
what's the *"resharding
behavior"* mentioned in FLINK-4582.
Thanks a lot!
-
Ying
On Wed, Jun 27, 2018 at 10:43 PM
Thanks Fabian for the suggestion.
*Ying Xu*
Software Engineer
510.368.1252 <+15103681252>
[image: Lyft] <http://www.lyft.com/>
On Wed, Jun 27, 2018 at 2:01 AM, Fabian Hueske wrote:
> Hi Ying,
>
> I'm not aware of any effort for this issue.
> You could check wit
y much.
-
Ying
37 matches
Mail list logo
