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
Is
[
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 schema|https://gi
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
C
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-9625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9625:
Component/s: Table API & SQL
> Enrich the error information to user
>
[
https://issues.apache.org/jira/browse/FLINK-9625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9625:
Description:
When the fields too many, and the types do not match with it would cause the
below er
mingleizhang created FLINK-9625:
---
Summary: Enrich the error information to user
Key: FLINK-9625
URL: https://issues.apache.org/jira/browse/FLINK-9625
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9614:
Comment: was deleted
(was: I close this since we catch a throwable. stackoverflowerror is
acceptab
[
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
(
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reopened FLINK-9614:
-
> Improve the error message for Compiler#compile
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517679#comment-16517679
]
mingleizhang commented on FLINK-9614:
-
I close this since we catch a throwable. stack
[
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-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 updated FLINK-9614:
Description:
When the below sql has too long. Like
case when case when .
when host in
(
[
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
> ---
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: Improv
[
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 to
[
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 to
[
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 to
[
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 re
[
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 Bucketing
[
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 to
[
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 to
[
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:
Description: Currently,
> Add bucket ready notification mechanism for BucketingSink when checkpoin
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
Projec
[
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 se
[
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-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9606:
Component/s: Table API & SQL
> Support ParquetTableSource
> --
>
>
[
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-9607:
---
Summary: Support ParquetTableSink
Key: FLINK-9607
URL: https://issues.apache.org/jira/browse/FLINK-9607
Project: Flink
Issue Type: New Feature
Repo
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
Re
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
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-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: (was: mingleizhang)
> JobManager isolation in session mode
> -
[
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-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
threads
[
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 deployme
[
https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16492418#comment-16492418
]
mingleizhang commented on FLINK-9410:
-
Yes. [~sihuazhou] I would like to take over thi
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491990#comment-16491990
]
mingleizhang commented on FLINK-9185:
-
It seems we can not find Stephen Jason/Jeson in
[
https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16490142#comment-16490142
]
mingleizhang commented on FLINK-9429:
-
I will give a PR to fix this soon.
> Quickstar
[
https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488314#comment-16488314
]
mingleizhang commented on FLINK-9429:
-
Hi, [~till.rohrmann]. Have you build flink agai
[
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-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487436#comment-16487436
]
mingleizhang commented on FLINK-9411:
-
Thanks for your feedback, [~StephanEwen]. What
[
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 {{AvroKeyValueS
[
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
> --
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-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 seria
[
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-9284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9284:
---
Assignee: Triones Deng
> Update CLI page
> ---
>
> Key: FLINK-928
[
https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453379#comment-16453379
]
mingleizhang commented on FLINK-9259:
-
I would not think it is a bug since {{SourceFun
[
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
org.apache.flink.api.
[
https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9231:
Description: This allows sockets to be bound even if there are sockets from
a previous application t
[
https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16450111#comment-16450111
]
mingleizhang edited comment on FLINK-9231 at 4/24/18 3:51 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16450111#comment-16450111
]
mingleizhang commented on FLINK-9231:
-
Hi, [~triones] I think you can push a PR first.
[
https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449911#comment-16449911
]
mingleizhang commented on FLINK-9231:
-
Come on [~triones]! :D
> Enable SO_REUSEADDR o
[
https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448027#comment-16448027
]
mingleizhang commented on FLINK-9239:
-
After thinking a little while, Only for you sai
[
https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448018#comment-16448018
]
mingleizhang commented on FLINK-9239:
-
Hi, [~twalthr] It is a good idea. How about usi
[
https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447998#comment-16447998
]
mingleizhang commented on FLINK-9239:
-
I would choose a {{WordCount}} as an example fo
[
https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9239:
---
Assignee: mingleizhang
> Reintroduce example program in quickstarts
> ---
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9185:
---
Assignee: (was: mingleizhang)
> Potential null dereference in
> PrioritizedOperatorSubta
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447543#comment-16447543
]
mingleizhang commented on FLINK-9185:
-
Hi, [~Stephen Jason], I unassigned now.
> Pote
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9236:
---
Assignee: mingleizhang
> Use Apache Parent POM 19
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang resolved FLINK-8335.
-
Resolution: Fixed
> Upgrade hbase connector dependency to 1.4.3
>
[
https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8999:
---
Assignee: mingleizhang
> Ensure the job has an operator with operator state.
> --
[
https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447058#comment-16447058
]
mingleizhang commented on FLINK-9193:
-
Do we plan to support write to ORC or Parquet f
[
https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9230:
Description:
https://api.travis-ci.org/v3/job/369380167/log.txt
{code:java}
Running org.apache.flink
mingleizhang created FLINK-9230:
---
Summary: WebFrontendITCase.testStopYarn is unstable
Key: FLINK-9230
URL: https://issues.apache.org/jira/browse/FLINK-9230
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16445640#comment-16445640
]
mingleizhang commented on FLINK-9185:
-
OKay. I can give this to you. You can push a PR
[
https://issues.apache.org/jira/browse/FLINK-9227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9227:
Component/s: Tests
> Add Bucketing e2e test script to run-nightly-tests.sh
> ---
[
https://issues.apache.org/jira/browse/FLINK-9227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9227:
Fix Version/s: 1.5.0
> Add Bucketing e2e test script to run-nightly-tests.sh
> -
mingleizhang created FLINK-9227:
---
Summary: Add Bucketing e2e test script to run-nightly-tests.sh
Key: FLINK-9227
URL: https://issues.apache.org/jira/browse/FLINK-9227
Project: Flink
Issue Type:
mingleizhang created FLINK-9226:
---
Summary: Add Bucketing e2e test script to run-nightly-tests.sh
Key: FLINK-9226
URL: https://issues.apache.org/jira/browse/FLINK-9226
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16445487#comment-16445487
]
mingleizhang commented on FLINK-9224:
-
Thanks [~twalthr]. :)
> Add Bucketing e2e tes
[
https://issues.apache.org/jira/browse/FLINK-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16445393#comment-16445393
]
mingleizhang commented on FLINK-9224:
-
[~twalthr] Should it put to {{run-nightly-tests
[
https://issues.apache.org/jira/browse/FLINK-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16445389#comment-16445389
]
mingleizhang commented on FLINK-9224:
-
Hi, [~twalthr] Could you take a look on this ji
mingleizhang created FLINK-9224:
---
Summary: Add Bucketing e2e test script to run-pre-commit-tests.sh
Key: FLINK-9224
URL: https://issues.apache.org/jira/browse/FLINK-9224
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-8646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16443821#comment-16443821
]
mingleizhang commented on FLINK-8646:
-
I dont know either. But I am watching
http://f
[
https://issues.apache.org/jira/browse/FLINK-8646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8646:
---
Assignee: mingleizhang
> Move docs directory to flink-docs
>
[
https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16441743#comment-16441743
]
mingleizhang edited comment on FLINK-9193 at 4/18/18 1:41 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16441743#comment-16441743
]
mingleizhang edited comment on FLINK-9193 at 4/18/18 1:40 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16441743#comment-16441743
]
mingleizhang commented on FLINK-9193:
-
I agree with [~twalthr] at this point. It would
[
https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16441734#comment-16441734
]
mingleizhang commented on FLINK-8661:
-
Sorry for later since my friend wants to get th
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8335:
Fix Version/s: 1.6.0
> Upgrade hbase connector dependency to 1.4.3
> ---
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8335:
Description:
hbase 1.4.3 has been released.
1.4.0 shows speed improvement over previous 1.x release
[
https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16440834#comment-16440834
]
mingleizhang commented on FLINK-8978:
-
Sounds like a HotSwap functionality. Interestin
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9185:
---
Assignee: mingleizhang
> Potential null dereference in
> PrioritizedOperatorSubtaskState#res
[
https://issues.apache.org/jira/browse/FLINK-9179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9179:
---
Assignee: mingleizhang
> Deduplicate WebOptions.PORT and RestOptions.REST_PORT
>
[
https://issues.apache.org/jira/browse/FLINK-9180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9180:
---
Assignee: mingleizhang
> Remove REST_ prefix from rest options
>
[
https://issues.apache.org/jira/browse/FLINK-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16438920#comment-16438920
]
mingleizhang commented on FLINK-9176:
-
I would re-introduce them into the surefire con
[
https://issues.apache.org/jira/browse/FLINK-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9176:
---
Assignee: mingleizhang
> Category annotations are unused
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-8993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8993:
---
Assignee: mingleizhang
> Add a test operator with keyed state that uses Kryo serializer
> (r
[
https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16433690#comment-16433690
]
mingleizhang commented on FLINK-9156:
-
Yes. We should make the CLI as the first choose
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16432430#comment-16432430
]
mingleizhang commented on FLINK-9087:
-
It seems that [~triones] does not have permissi
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8335:
Summary: Upgrade hbase connector dependency to 1.4.3 (was: Upgrade hbase
connector dependency to 1.
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16427834#comment-16427834
]
mingleizhang commented on FLINK-8335:
-
Thanks [~yuzhih...@gmail.com]. I will apply 1.4
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8335:
---
Assignee: mingleizhang
> Upgrade hbase connector dependency to 1.4.1
> --
1 - 100 of 524 matches
Mail list logo
