[
https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153064#comment-16153064
]
mingleizhang commented on FLINK-7573:
-
I want to reach an agreement on this issue before start working
[
https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-7573:
Description:
Currently, all connectors as far as I have known that merely support the TCP
[
https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-7573:
Description:
Currently, all connectors as far as I have known that merely support the TCP
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-3829:
---
Assignee: mingleizhang
> flink-java
> --
>
> Key: FLINK-3829
>
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178461#comment-16178461
]
mingleizhang commented on FLINK-3829:
-
[~yew1eb] I was not pointing to this jira. You know what jira
[
https://issues.apache.org/jira/browse/FLINK-6444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178428#comment-16178428
]
mingleizhang commented on FLINK-6444:
-
Hey, [~yew1eb]. I think you can just use reflections do it in a
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178437#comment-16178437
]
mingleizhang commented on FLINK-3829:
-
Hey, [~yew1eb] You can assign it to yourself now as I find you
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-3829:
---
Assignee: (was: mingleizhang)
> flink-java
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178126#comment-16178126
]
mingleizhang commented on FLINK-3986:
-
I would like to work on this. Just not sure which way we choose
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-3829:
Description:
{noformat}
[WARNING] Used undeclared dependencies found:
[WARNING]
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178152#comment-16178152
]
mingleizhang commented on FLINK-3829:
-
Hey, [~till.rohrmann] One thing that I should mention it, most
[
https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-3986:
Description: The readFileStream(String filePath, long intervalMillis,
WatchType watchType) has to
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178484#comment-16178484
]
mingleizhang commented on FLINK-3829:
-
Hey,[~yew1eb] I am also a newbie. So, that is WHY I am angry.
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178493#comment-16178493
]
mingleizhang commented on FLINK-3829:
-
[~yew1eb] Me to. You are very welcome ~
> flink-java
>
[
https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-7573:
Description: Currently, all connectors as far as I have known that merely
support the TCP transport
mingleizhang created FLINK-7573:
---
Summary: Introduce Http protocol connector for Elasticsearch2
Key: FLINK-7573
URL: https://issues.apache.org/jira/browse/FLINK-7573
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264159#comment-16264159
]
mingleizhang commented on FLINK-7472:
-
Is it still a valid one ?
> Release task managers gracefully
>
[
https://issues.apache.org/jira/browse/FLINK-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-7967:
---
Assignee: mingleizhang
> Deprecate Hadoop specific Flink configuration options
>
[
https://issues.apache.org/jira/browse/FLINK-8192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16278030#comment-16278030
]
mingleizhang commented on FLINK-8192:
-
[~tzulitai] I would create a subtask of Elasticsearch if you
mingleizhang created FLINK-8199:
---
Summary: Annotation for Elasticsearch connector
Key: FLINK-8199
URL: https://issues.apache.org/jira/browse/FLINK-8199
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-8192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16278179#comment-16278179
]
mingleizhang commented on FLINK-8192:
-
Okay. Thanks [~tzulitai]
> Properly annotate APIs of all Flink
[
https://issues.apache.org/jira/browse/FLINK-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8199:
Affects Version/s: (was: 1.5.0)
> Annotation for Elasticsearch connector
>
[
https://issues.apache.org/jira/browse/FLINK-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8199:
---
Assignee: mingleizhang
> Annotation for Elasticsearch connector
>
mingleizhang created FLINK-8276:
---
Summary: Annotation for Kafka connector
Key: FLINK-8276
URL: https://issues.apache.org/jira/browse/FLINK-8276
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16238862#comment-16238862
]
mingleizhang commented on FLINK-7967:
-
Hi, [~till.rohrmann] I have a question. Do we need to tell the
[
https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8999:
---
Assignee: (was: mingleizhang)
> Ensure the job has an operator with operator state.
>
[
https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9008:
Comment: was deleted
(was: Hi, [~till.rohrmann] I would like to confirm one stuff with you here for
[
https://issues.apache.org/jira/browse/FLINK-8993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8993:
---
Assignee: (was: mingleizhang)
> Add a test operator with keyed state that uses Kryo
mingleizhang created FLINK-9411:
---
Summary: Support parquet rolling sink writer
Key: FLINK-9411
URL: https://issues.apache.org/jira/browse/FLINK-9411
Project: Flink
Issue Type: New Feature
mingleizhang created FLINK-9407:
---
Summary: Support orc rolling sink writer
Key: FLINK-9407
URL: https://issues.apache.org/jira/browse/FLINK-9407
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9411:
Component/s: filesystem-connector
> Support parquet rolling sink writer
>
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9407:
Description: Currently, we only support {{StringWriter}},
{{SequenceFileWriter}} and
[
https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488314#comment-16488314
]
mingleizhang commented on FLINK-9429:
-
Hi, [~till.rohrmann]. Have you build flink again ? I tested on
[
https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490142#comment-16490142
]
mingleizhang commented on FLINK-9429:
-
I will give a PR to fix this soon.
> Quickstart E2E not
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487436#comment-16487436
]
mingleizhang commented on FLINK-9411:
-
Thanks for your feedback, [~StephanEwen]. What you mean is that
[
https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9429:
---
Assignee: mingleizhang
> Quickstart E2E not working locally
>
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9236:
---
Assignee: Stephen Jason (was: mingleizhang)
> Use Apache Parent POM 19
>
[
https://issues.apache.org/jira/browse/FLINK-9537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9537:
---
Assignee: mingleizhang
> JobManager isolation in session mode
>
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Issue Type: New Feature (was: Improvement)
> Add bucket ready notification mechanism for
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want
mingleizhang created FLINK-9609:
---
Summary: Add bucket ready notification mechanism for BucketingSink
when checkpoint complete
Key: FLINK-9609
URL: https://issues.apache.org/jira/browse/FLINK-9609
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description: Currently,
> Add bucket ready notification mechanism for BucketingSink when
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description: Currently, BucketingSink only can {{notifyCheckpointComplete}}
(was: Currently, )
>
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Summary: Add bucket ready mechanism for BucketingSink when checkpoint
complete (was: Add bucket
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want
mingleizhang created FLINK-9605:
---
Summary: Support KafkaProtoBufTableSink
Key: FLINK-9605
URL: https://issues.apache.org/jira/browse/FLINK-9605
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9606:
---
Assignee: (was: mingleizhang)
> Support ParquetTableSource
> --
mingleizhang created FLINK-9606:
---
Summary: Support ParquetTableSource
Key: FLINK-9606
URL: https://issues.apache.org/jira/browse/FLINK-9606
Project: Flink
Issue Type: New Feature
mingleizhang created FLINK-9607:
---
Summary: Support ParquetTableSink
Key: FLINK-9607
URL: https://issues.apache.org/jira/browse/FLINK-9607
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9606:
Component/s: Table API & SQL
> Support ParquetTableSource
> --
>
>
mingleizhang created FLINK-9604:
---
Summary: Support KafkaProtoBufTableSource
Key: FLINK-9604
URL: https://issues.apache.org/jira/browse/FLINK-9604
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-9604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9604:
Description:
Protocol buffers are a language-neutral, platform-neutral extensible mechanism
for
[
https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9607:
---
Assignee: (was: mingleizhang)
> Support ParquetTableSink
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang resolved FLINK-9614.
-
Resolution: Not A Problem
> Improve the error message for Compiler#compile
>
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang closed FLINK-9614.
---
> Improve the error message for Compiler#compile
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9537:
---
Assignee: (was: mingleizhang)
> JobManager isolation in session mode
>
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16491990#comment-16491990
]
mingleizhang commented on FLINK-9185:
-
It seems we can not find Stephen Jason/Jeson in naming list.
>
[
https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9413:
---
Assignee: mingleizhang
> Tasks can fail with PartitionNotFoundException if consumer
[
https://issues.apache.org/jira/browse/FLINK-8886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8886:
Description:
Flink's TaskManager executes tasks from different jobs within the same JVM as
[
https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492418#comment-16492418
]
mingleizhang commented on FLINK-9410:
-
Yes. [~sihuazhou] I would like to take over this. And thank you
mingleizhang created FLINK-9650:
---
Summary: Support Protocol Buffers formats
Key: FLINK-9650
URL: https://issues.apache.org/jira/browse/FLINK-9650
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9650:
Description: We need to generate a \{{TypeInformation}} from a standard
[Protobuf
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9614:
Affects Version/s: 1.5.0
> Improve the error message for Compiler#compile
>
mingleizhang created FLINK-9651:
---
Summary: Add a Kafka table source factory with Protobuf format
support
Key: FLINK-9651
URL: https://issues.apache.org/jira/browse/FLINK-9651
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9614:
Description:
When the below sql has too long. Like
case when case when .
when host in
mingleizhang created FLINK-9614:
---
Summary: Improve the error message for Compiler#compile
Key: FLINK-9614
URL: https://issues.apache.org/jira/browse/FLINK-9614
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9614:
Component/s: Table API & SQL
> Improve the error message for Compiler#compile
>
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517679#comment-16517679
]
mingleizhang commented on FLINK-9614:
-
I close this since we catch a throwable. stackoverflowerror is
[
https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9259:
Description:
The exception stack is as follows:
{code:java}
//Code placeholder
[
https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16453379#comment-16453379
]
mingleizhang commented on FLINK-9259:
-
I would not think it is a bug since {{SourceFunction}} has
[
https://issues.apache.org/jira/browse/FLINK-9284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9284:
---
Assignee: Triones Deng
> Update CLI page
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16340755#comment-16340755
]
mingleizhang commented on FLINK-8357:
-
Thanks [~mingmxu]. I will take a look.
> enable rolling in
[
https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8357:
---
Assignee: mingleizhang
> enable rolling in default log settings
>
[
https://issues.apache.org/jira/browse/FLINK-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16341194#comment-16341194
]
mingleizhang commented on FLINK-7095:
-
I will use Commons CLI as it's tool that implements this
[
https://issues.apache.org/jira/browse/FLINK-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16326024#comment-16326024
]
mingleizhang commented on FLINK-8433:
-
I will take into this issue soon.
> Update code example for
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16344368#comment-16344368
]
mingleizhang commented on FLINK-4084:
-
Yea.
> Add configDir parameter to CliFrontend and flink shell
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342087#comment-16342087
]
mingleizhang commented on FLINK-4084:
-
What is the status of this jira ?
> Add configDir parameter to
[
https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16343323#comment-16343323
]
mingleizhang commented on FLINK-6160:
-
I found all components such as {{TaskExecutor}}, {{JobMaster}}
[
https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8357:
Fix Version/s: 1.5.0
> enable rolling in default log settings
>
[
https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347928#comment-16347928
]
mingleizhang commented on FLINK-6160:
-
Thanks [~till.rohrmann] I will take a look on what you said.
>
[
https://issues.apache.org/jira/browse/FLINK-8599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356361#comment-16356361
]
mingleizhang commented on FLINK-8599:
-
Thanks for reporting this [~ChengzhiZhao]. I think it can be an
[
https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355036#comment-16355036
]
mingleizhang commented on FLINK-8572:
-
[~LaiAng] You can try another browser to see whether it works.
[
https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355032#comment-16355032
]
mingleizhang commented on FLINK-8572:
-
Hi, [~LaiAng] Change the subject to English. And what you
[
https://issues.apache.org/jira/browse/FLINK-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360533#comment-16360533
]
mingleizhang commented on FLINK-8625:
-
Thanks [~pnowojski] We can improve the performance and reduce
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361742#comment-16361742
]
mingleizhang commented on FLINK-8335:
-
Thanks [~yuzhih...@gmail.com] I will take a look on this when
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361750#comment-16361750
]
mingleizhang commented on FLINK-8335:
-
OKay. Thanks ~ :)
> Upgrade hbase connector dependency to
[
https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359833#comment-16359833
]
mingleizhang commented on FLINK-8212:
-
Hi, [~till.rohrmann] I have a question. If we do not use
[
https://issues.apache.org/jira/browse/FLINK-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359733#comment-16359733
]
mingleizhang commented on FLINK-6161:
-
Hi, [~zjwang] Are you still working on this ?
> Retry
[
https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359861#comment-16359861
]
mingleizhang commented on FLINK-8212:
-
I can directly move those methods to {{TaskManagerServices}}
[
https://issues.apache.org/jira/browse/FLINK-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359208#comment-16359208
]
mingleizhang commented on FLINK-8423:
-
Hi, [~Zentol] Does this NPE will make the jvm died ?
>
[
https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363685#comment-16363685
]
mingleizhang commented on FLINK-8212:
-
Thanks [~till.rohrmann] I will correct the code again.
> Pull
[
https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8212:
---
Assignee: mingleizhang
> Pull EnvironmentInformation out of TaskManagerServices
>
[
https://issues.apache.org/jira/browse/FLINK-8573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8573:
---
Assignee: mingleizhang
> Print JobID for failed jobs
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359303#comment-16359303
]
mingleizhang commented on FLINK-8623:
-
{\{getLocalHost()}} returns the actual IP of one of our network
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359289#comment-16359289
]
mingleizhang commented on FLINK-8623:
-
Hi, [~till.rohrmann] The expected address is 127.0.1.1, but the
[
https://issues.apache.org/jira/browse/FLINK-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358322#comment-16358322
]
mingleizhang commented on FLINK-8423:
-
I will fix this issue.
> OperatorChain#pushToOperator catch
[
https://issues.apache.org/jira/browse/FLINK-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8423:
---
Assignee: mingleizhang
> OperatorChain#pushToOperator catch block may fail with NPE
>
301 - 400 of 523 matches
Mail list logo
