[jira] [Created] (FLINK-9651) Add a Kafka table source factory with Protobuf format support

2018-06-23 Thread mingleizhang (JIRA)
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

[jira] [Updated] (FLINK-9650) Support Protocol Buffers formats

2018-06-23 Thread mingleizhang (JIRA)
[ 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

[jira] [Created] (FLINK-9650) Support Protocol Buffers formats

2018-06-23 Thread mingleizhang (JIRA)
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

[jira] [Updated] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-23 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Updated] (FLINK-9625) Enrich the error information to user

2018-06-20 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Updated] (FLINK-9625) Enrich the error information to user

2018-06-20 Thread mingleizhang (JIRA)
[ 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

[jira] [Created] (FLINK-9625) Enrich the error information to user

2018-06-20 Thread mingleizhang (JIRA)
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

[jira] [Issue Comment Deleted] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-20 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-20 Thread mingleizhang (JIRA)
[ 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

[jira] [Reopened] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-20 Thread mingleizhang (JIRA)
[ 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 > -- >

[jira] [Commented] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
[ 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

[jira] [Closed] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
[ 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 > -- > >

[jira] [Resolved] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Updated] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Created] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
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:

[jira] [Updated] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

2018-06-18 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

2018-06-18 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

2018-06-18 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

2018-06-18 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete

2018-06-18 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete

2018-06-18 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete

2018-06-18 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete

2018-06-18 Thread mingleizhang (JIRA)
[ 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, ) >

[jira] [Updated] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete

2018-06-18 Thread mingleizhang (JIRA)
[ 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

[jira] [Created] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete

2018-06-18 Thread mingleizhang (JIRA)
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

[jira] [Updated] (FLINK-9604) Support KafkaProtoBufTableSource

2018-06-17 Thread mingleizhang (JIRA)
[ 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

[jira] [Assigned] (FLINK-9607) Support ParquetTableSink

2018-06-17 Thread mingleizhang (JIRA)
[ 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 > > >

[jira] [Updated] (FLINK-9606) Support ParquetTableSource

2018-06-17 Thread mingleizhang (JIRA)
[ 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 > -- > >

[jira] [Assigned] (FLINK-9606) Support ParquetTableSource

2018-06-17 Thread mingleizhang (JIRA)
[ 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 > --

[jira] [Created] (FLINK-9607) Support ParquetTableSink

2018-06-17 Thread mingleizhang (JIRA)
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

[jira] [Created] (FLINK-9606) Support ParquetTableSource

2018-06-17 Thread mingleizhang (JIRA)
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

[jira] [Created] (FLINK-9605) Support KafkaProtoBufTableSink

2018-06-17 Thread mingleizhang (JIRA)
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

[jira] [Created] (FLINK-9604) Support KafkaProtoBufTableSource

2018-06-17 Thread mingleizhang (JIRA)
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

[jira] [Assigned] (FLINK-9236) Use Apache Parent POM 19

2018-06-11 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Assigned] (FLINK-9537) JobManager isolation in session mode

2018-06-09 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Assigned] (FLINK-9537) JobManager isolation in session mode

2018-06-08 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Updated] (FLINK-8886) Job isolation via scheduling in shared cluster

2018-06-06 Thread mingleizhang (JIRA)
[ 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

[jira] [Assigned] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long

2018-05-30 Thread mingleizhang (JIRA)
[ 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

[jira] [Commented] (FLINK-9410) Replace NMClient with NMClientAsync in YarnResourceManager

2018-05-28 Thread mingleizhang (JIRA)
[ 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

[jira] [Commented] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

2018-05-27 Thread mingleizhang (JIRA)
[ 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. >

[jira] [Commented] (FLINK-9429) Quickstart E2E not working locally

2018-05-24 Thread mingleizhang (JIRA)
[ 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

[jira] [Commented] (FLINK-9429) Quickstart E2E not working locally

2018-05-23 Thread mingleizhang (JIRA)
[ 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

[jira] [Assigned] (FLINK-9429) Quickstart E2E not working locally

2018-05-23 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Commented] (FLINK-9411) Support parquet rolling sink writer

2018-05-23 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9407) Support orc rolling sink writer

2018-05-23 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9411) Support parquet rolling sink writer

2018-05-22 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Created] (FLINK-9411) Support parquet rolling sink writer

2018-05-22 Thread mingleizhang (JIRA)
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

[jira] [Created] (FLINK-9407) Support orc rolling sink writer

2018-05-22 Thread mingleizhang (JIRA)
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

[jira] [Issue Comment Deleted] (FLINK-9008) End-to-end test: Quickstarts

2018-05-14 Thread mingleizhang (JIRA)
[ 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

[jira] [Assigned] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom)

2018-05-09 Thread mingleizhang (JIRA)
[ 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

[jira] [Assigned] (FLINK-8999) Ensure the job has an operator with operator state.

2018-05-07 Thread mingleizhang (JIRA)
[ 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. >

[jira] [Assigned] (FLINK-9284) Update CLI page

2018-05-03 Thread mingleizhang (JIRA)
[ 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:

[jira] [Commented] (FLINK-9259) The implementation of the SourceFunction is not serializable.

2018-04-25 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9259) The implementation of the SourceFunction is not serializable.

2018-04-25 Thread mingleizhang (JIRA)
[ 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

[jira] [Updated] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-04-24 Thread mingleizhang (JIRA)
[ 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

[jira] [Comment Edited] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-04-24 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450111#comment-16450111 ] mingleizhang edited comment on FLINK-9231 at 4/24/18 3:51 PM: -- Hi, [~triones]

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-04-24 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450111#comment-16450111 ] mingleizhang commented on FLINK-9231: - Hi, [~triones] I think you can push a PR first. Would not

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-04-24 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449911#comment-16449911 ] mingleizhang commented on FLINK-9231: - Come on [~triones]! :D > Enable SO_REUSEADDR on listen sockets

[jira] [Commented] (FLINK-9239) Reintroduce example program in quickstarts

2018-04-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16448027#comment-16448027 ] mingleizhang commented on FLINK-9239: - After thinking a little while, Only for you said : Such example

[jira] [Commented] (FLINK-9239) Reintroduce example program in quickstarts

2018-04-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16448018#comment-16448018 ] mingleizhang commented on FLINK-9239: - Hi, [~twalthr] It is a good idea. How about using an operator

[jira] [Commented] (FLINK-9239) Reintroduce example program in quickstarts

2018-04-23 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447998#comment-16447998 ] mingleizhang commented on FLINK-9239: - I would choose a {{WordCount}} as an example for new user if

[jira] [Assigned] (FLINK-9239) Reintroduce example program in quickstarts

2018-04-23 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Assigned] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

2018-04-22 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Commented] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

2018-04-22 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447543#comment-16447543 ] mingleizhang commented on FLINK-9185: - Hi, [~Stephen Jason], I unassigned now. > Potential null

[jira] [Assigned] (FLINK-9236) Use Apache Parent POM 19

2018-04-22 Thread mingleizhang (JIRA)
[ 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 > > >

[jira] [Resolved] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

2018-04-22 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Assigned] (FLINK-8999) Ensure the job has an operator with operator state.

2018-04-21 Thread mingleizhang (JIRA)
[ 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. >

[jira] [Commented] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

2018-04-21 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447058#comment-16447058 ] mingleizhang commented on FLINK-9193: - Do we plan to support write to ORC or Parquet format in future

[jira] [Updated] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

2018-04-20 Thread mingleizhang (JIRA)
[ 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

[jira] [Created] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

2018-04-20 Thread mingleizhang (JIRA)
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:

[jira] [Commented] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

2018-04-20 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16445640#comment-16445640 ] mingleizhang commented on FLINK-9185: - OKay. I can give this to you. You can push a PR to here. >

[jira] [Updated] (FLINK-9227) Add Bucketing e2e test script to run-nightly-tests.sh

2018-04-20 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Updated] (FLINK-9227) Add Bucketing e2e test script to run-nightly-tests.sh

2018-04-20 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Created] (FLINK-9227) Add Bucketing e2e test script to run-nightly-tests.sh

2018-04-20 Thread mingleizhang (JIRA)
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

[jira] [Created] (FLINK-9226) Add Bucketing e2e test script to run-nightly-tests.sh

2018-04-20 Thread mingleizhang (JIRA)
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

[jira] [Commented] (FLINK-9224) Add Bucketing e2e test script to run-pre-commit-tests.sh

2018-04-20 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16445487#comment-16445487 ] mingleizhang commented on FLINK-9224: - Thanks [~twalthr]. :) > Add Bucketing e2e test script to

[jira] [Commented] (FLINK-9224) Add Bucketing e2e test script to run-pre-commit-tests.sh

2018-04-20 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16445393#comment-16445393 ] mingleizhang commented on FLINK-9224: - [~twalthr] Should it put to {{run-nightly-tests.sh}} ? > Add

[jira] [Commented] (FLINK-9224) Add Bucketing e2e test script to run-pre-commit-tests.sh

2018-04-20 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16445389#comment-16445389 ] mingleizhang commented on FLINK-9224: - Hi, [~twalthr] Could you take a look on this jira ? Thank you.

[jira] [Created] (FLINK-9224) Add Bucketing e2e test script to run-pre-commit-tests.sh

2018-04-20 Thread mingleizhang (JIRA)
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

[jira] [Commented] (FLINK-8646) Move docs directory to flink-docs

2018-04-19 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443821#comment-16443821 ] mingleizhang commented on FLINK-8646: - I dont know either. But I am watching

[jira] [Assigned] (FLINK-8646) Move docs directory to flink-docs

2018-04-19 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Comment Edited] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

2018-04-17 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441743#comment-16441743 ] mingleizhang edited comment on FLINK-9193 at 4/18/18 1:41 AM: -- I agree with

[jira] [Comment Edited] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

2018-04-17 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441743#comment-16441743 ] mingleizhang edited comment on FLINK-9193 at 4/18/18 1:40 AM: -- I agree with

[jira] [Commented] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

2018-04-17 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441743#comment-16441743 ] mingleizhang commented on FLINK-9193: - I agree with [~twalthr] at this point. It would be better

[jira] [Commented] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap()

2018-04-17 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441734#comment-16441734 ] mingleizhang commented on FLINK-8661: - Sorry for later since my friend wants to get this ticket. But I

[jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

2018-04-17 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

2018-04-17 Thread mingleizhang (JIRA)
[ 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

[jira] [Commented] (FLINK-8978) End-to-end test: Job upgrade

2018-04-17 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440834#comment-16440834 ] mingleizhang commented on FLINK-8978: - Sounds like a HotSwap functionality. Interesting. > End-to-end

[jira] [Assigned] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

2018-04-16 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Assigned] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT

2018-04-16 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Assigned] (FLINK-9180) Remove REST_ prefix from rest options

2018-04-16 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Commented] (FLINK-9176) Category annotations are unused

2018-04-15 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438920#comment-16438920 ] mingleizhang commented on FLINK-9176: - I would re-introduce them into the surefire configuration. >

[jira] [Assigned] (FLINK-9176) Category annotations are unused

2018-04-15 Thread mingleizhang (JIRA)
[ 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 > --- >

[jira] [Assigned] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom)

2018-04-15 Thread mingleizhang (JIRA)
[ 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 >

[jira] [Commented] (FLINK-9156) CLI does not respect -m,--jobmanager option

2018-04-11 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433690#comment-16433690 ] mingleizhang commented on FLINK-9156: - Yes. We should make the CLI as the first choose, can not use

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

2018-04-10 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432430#comment-16432430 ] mingleizhang commented on FLINK-9087: - It seems that [~triones] does not have permission to perform

[jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

2018-04-05 Thread mingleizhang (JIRA)
[ 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

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.1

2018-04-05 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427834#comment-16427834 ] mingleizhang commented on FLINK-8335: - Thanks [~yuzhih...@gmail.com]. I will apply 1.4.3 this to here

[jira] [Assigned] (FLINK-8335) Upgrade hbase connector dependency to 1.4.1

2018-04-05 Thread mingleizhang (JIRA)
[ 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   2   3   4   5   6   >