Unsubscribe me
#/**本邮件及其附件含有小米公司的保密信息，仅限于发送给上面地址中列出的个人或群组。禁止任何其他人以任何形式使用（包括但不限于全部或部分地泄露、复制、或散发）本邮件中的信息。如果您错收了本邮件，请您立即电话或邮件通知发件人并删除本邮件！
This e-mail and its attachments contain confidential information from XIAOMI,
which is intended only for the person or entity whose address is listed above.
Unsubscribe me
Jiangjie Qin created FLINK-12425:
Summary: Implement RPCs to allow clients release result partitions
in a Flink cluster.
Key: FLINK-12425
URL: https://issues.apache.org/jira/browse/FLINK-12425
Project
godfrey he created FLINK-12424:
--
Summary: Supports dag (multiple-sinks query) optimization
Key: FLINK-12424
URL: https://issues.apache.org/jira/browse/FLINK-12424
Project: Flink
Issue Type: New
Armstrong Nova created FLINK-12423:
--
Summary: Add Timer metric type for flink-metrics module
Key: FLINK-12423
URL: https://issues.apache.org/jira/browse/FLINK-12423
Project: Flink
Issue Type
Jeff Zhang created FLINK-12422:
--
Summary: Remove IN_TESTS for make test code and production code
consistent
Key: FLINK-12422
URL: https://issues.apache.org/jira/browse/FLINK-12422
Project: Flink
Jark Wu created FLINK-12421:
---
Summary: Synchronize the latest documentation changes into Chinese
documents
Key: FLINK-12421
URL: https://issues.apache.org/jira/browse/FLINK-12421
Project: Flink
Is
Ruidong Li created FLINK-12420:
--
Summary: Add support of cache/invalidateCache for TableAPI
Key: FLINK-12420
URL: https://issues.apache.org/jira/browse/FLINK-12420
Project: Flink
Issue Type: Sub
Ruidong Li created FLINK-12419:
--
Summary: Add support for consuming BLOCKING_PERSISTENT
ResultPartition
Key: FLINK-12419
URL: https://issues.apache.org/jira/browse/FLINK-12419
Project: Flink
Is
Thanks for following up promptly and sharing the feedback @shaoxuan.
Yes I share the same view with you on the convergence of these 2 FLIPs
eventually. I also have some questions regarding the API as well as the
possible convergence challenges (especially current Co-processor approach
vs. FLIP-39'
Bowen Li created FLINK-12418:
Summary: Add input/output format and SerDeLib information for Hive
tables in HiveCatalogUtil#createHiveTable
Key: FLINK-12418
URL: https://issues.apache.org/jira/browse/FLINK-12418
Hi All,
Sounds interesting. I submitted a talk about using Flink for machine learning.
However, I would also be happy to gain some community feedback if the topic is
to the right interest of the community.
In short, we use flink to train machine learning models and to then use the
same model
Bowen Li created FLINK-12417:
Summary: Merge ReadableCatalog and ReadableWritableCatalog
Key: FLINK-12417
URL: https://issues.apache.org/jira/browse/FLINK-12417
Project: Flink
Issue Type: Sub-tas
Slava D created FLINK-12416:
---
Summary: Docker build script fails on symlink creation ln -s
Key: FLINK-12416
URL: https://issues.apache.org/jira/browse/FLINK-12416
Project: Flink
Issue Type: Bug
Thanks for reporting this issue Quan. I've pulled in Andrey who developed
this feature and might shed some light on the problem.
Cheers,
Till
On Mon, May 6, 2019 at 11:04 AM Congxian Qiu wrote:
> Hi Quan
> Is the problem still there when running on 1.8? If there is still a
> problem when using
I think this is a good idea Jark. Putting the last update date on the
roadmap would also force us to regularly update it.
Cheers,
Till
On Mon, May 6, 2019 at 4:14 AM Jark Wu wrote:
> Hi,
>
> One suggestion for the roadmap:
>
> Shall we add a `latest-update-time` to the top of Roadmap page? So t
+1 for the release
Cheers,
Till
On Sun, May 5, 2019 at 9:03 AM jincheng sun
wrote:
> Thanks for your approval @Chesnay Schepler
> @Bowen Li @Tzu-Li
> (Gordon) Tai !
>
> And thanks for adding more release necessity context @Chesnay Schepler
> .
>
> I'll prepare the RC as soon as possible.
>
> A
Hi Quan,
Currently namespace is only useful in WindowOperator (see
WindowOperator.java), and for other places, VoidNamespace is used as the
placeholder.
: )
On Mon, May 6, 2019 at 9:36 PM Shi Quan wrote:
> Hi,
>
> Few documentation mention “namespace” when talking about state. What’s the
> mea
Hi,
Few documentation mention “namespace” when talking about state. What’s the
meaning of this properties and how to use it ?
Best
Quan Shi
Armstrong Nova created FLINK-12415:
--
Summary: Translate "History Server" doc into Chinese
Key: FLINK-12415
URL: https://issues.apache.org/jira/browse/FLINK-12415
Project: Flink
Issue Type: S
Gary Yao created FLINK-12414:
Summary: Implement ExecutionGraph to SchedulingTopology Adapter
Key: FLINK-12414
URL: https://issues.apache.org/jira/browse/FLINK-12414
Project: Flink
Issue Type: Su
Gary Yao created FLINK-12413:
Summary: Implement ExecutionFailureHandler
Key: FLINK-12413
URL: https://issues.apache.org/jira/browse/FLINK-12413
Project: Flink
Issue Type: Sub-task
Comp
YangFei created FLINK-12412:
---
Summary: Allow ListTypeInfo used for java.util.List and
MapTypeInfo used for java.util.Map
Key: FLINK-12412
URL: https://issues.apache.org/jira/browse/FLINK-12412
Project: Flin
Thanks for the feedback, Rong and Flavio.
@Rong Rong
> There's another thread regarding a close to merge FLIP-23 implementation
> [1]. I agree this might still be early stage to talk about productionizing
> and model-serving. But I would be nice to keep the design/implementation
in
> mind that: ea
Thanks Rong, really appreciate review.
See some answers below
Boris Lublinsky
FDP Architect
boris.lublin...@lightbend.com
https://www.lightbend.com/
> On May 5, 2019, at 7:52 PM, Rong Rong wrote:
>
> Hi Robert, Boris,
>
> Sorry for the late reply. I took some time to look at the implementatio
I read byte data from Kafka. I use a class ProtoSchema
implemented DeserializationSchema
to get the actual java class. My question is that how can I transfer the
byte data to Row just by ProtoSchema? What if the data structure is nested?
Thank you.
Hi Quan
Is the problem still there when running on 1.8? If there is still a problem
when using 1.8, could you please share a minimal reproduce demo. Thanks
Best, Congxian
On May 6, 2019, 14:44 +0800, Shi Quan , wrote:
> Hi,
> Recently we encounter with IllegalArgumentException when using state w
Thanks for announcing the Call for Presentations here!
Since the deadline is approaching, I wanted to bump up this thread to
remind everybody to submit talks!
Please reach out to me or Fabian directly if you have any questions or if
you need any support!
On Thu, Apr 11, 2019 at 3:47 PM Fabian H
Dawid Wysakowicz created FLINK-12411:
Summary: Fix failling e2e test test_streaming_sql.sh
Key: FLINK-12411
URL: https://issues.apache.org/jira/browse/FLINK-12411
Project: Flink
Issue Typ
29 matches
Mail list logo
