[
https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu updated FLINK-15476:
Priority: Minor (was: Major)
> Update StreamingFileSink documentation -- bulk encoded writer now
[
https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032198#comment-17032198
]
Ying Xu commented on FLINK-15476:
-
Thanks for asking [~kkl0u] . I was busy with a few other work items.
[
https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17017522#comment-17017522
]
Ying Xu commented on FLINK-15476:
-
HI [~kkl0u] is it OK to pursue this Jira based on [the
[
https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu updated FLINK-15476:
Component/s: Documentation
Description:
Per FLINK-13027, {{StreamingFileSink}}'s bulk encoded writer
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
[
https://issues.apache.org/jira/browse/FLINK-15301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998418#comment-16998418
]
Ying Xu edited comment on FLINK-15301 at 12/17/19 5:45 PM:
---
Example stacktrace
[
https://issues.apache.org/jira/browse/FLINK-15301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998418#comment-16998418
]
Ying Xu commented on FLINK-15301:
-
Example stacktrace
{code:java}
05:39:32.393 INFO
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 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
[
https://issues.apache.org/jira/browse/FLINK-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919902#comment-16919902
]
Ying Xu commented on FLINK-13864:
-
HI [~kkl0u] , this is Ying and I have been working with [~kailashhd]
[
https://issues.apache.org/jira/browse/FLINK-13027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu reassigned FLINK-13027:
---
Assignee: Ying Xu
> StreamingFileSink bulk-encoded writer supports file rolling upon customized
>
[
https://issues.apache.org/jira/browse/FLINK-13027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu reassigned FLINK-13027:
---
Assignee: (was: Ying Xu)
> StreamingFileSink bulk-encoded writer supports file rolling upon
[
https://issues.apache.org/jira/browse/FLINK-13027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu reassigned FLINK-13027:
---
Assignee: Ying Xu
> StreamingFileSink bulk-encoded writer supports file rolling upon customized
>
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:
[
https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16760284#comment-16760284
]
Ying Xu commented on FLINK-4582:
Thanks [~tinder-dthomson] . Internally we use the *new ObjectMapper()*
[
https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16671216#comment-16671216
]
Ying Xu commented on FLINK-4582:
[~tinder-dthomson] Posted the PR here:
[
https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667569#comment-16667569
]
Ying Xu commented on FLINK-4582:
Thanks [~tinder-dthomson] for the detailed comments. Yes that's
[
https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665527#comment-16665527
]
Ying Xu commented on FLINK-4582:
Hi [~tinder-dthomson] thanks for raising this issue up. And sorry for
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622739#comment-16622739
]
Ying Xu commented on FLINK-10358:
-
[PR 6708|https://github.com/apache/flink/pull/6708] is merged
>
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu closed FLINK-10358.
---
Resolution: Fixed
> Flink kinesis connector could throw NPE during getRecords() call
>
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu reassigned FLINK-10358:
---
Assignee: Ying Xu
> Flink kinesis connector could throw NPE during getRecords() call
>
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu updated FLINK-10358:
Description:
When extending the flink kinesis connector to consume from a dynamodb stream,
it was found
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu updated FLINK-10358:
Description:
When extending the flink kinesis connector to consume from a dynamodb stream,
it was found
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu updated FLINK-10358:
Description:
When extending the flink kinesis connector to consume from a dynamodb stream,
it was found
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu updated FLINK-10358:
Description:
When extending the flink kinesis connector to consume from a dynamodb stream,
it was found
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
[
https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16560327#comment-16560327
]
Ying Xu commented on FLINK-4582:
[~tzulitai] Just an update, we are very close to have a working
[
https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525650#comment-16525650
]
Ying Xu commented on FLINK-4582:
Hi:
[~tzulitai] [~mingdaoy]
I'm following up on this JIRA as we
28 matches
Mail list logo
