[jira] [Assigned] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

2018-10-18 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-10531: -- Assignee: Renjie Liu > State TTL RocksDb backend end-to-end test failed on Travis >

[jira] [Assigned] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

2018-08-14 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-8953: - Assignee: (was: Renjie Liu) > Resolve unresolved field references in FieldComputer

[jira] [Created] (FLINK-10101) Mesos web ui url is missing.

2018-08-08 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-10101: -- Summary: Mesos web ui url is missing. Key: FLINK-10101 URL: https://issues.apache.org/jira/browse/FLINK-10101 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9720) Introduce ResourceTag class for tag support in scheduling

2018-08-05 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu updated FLINK-9720: -- Fix Version/s: (was: 1.6.0) 1.7.0 > Introduce ResourceTag class for tag support

[jira] [Updated] (FLINK-9662) Task manager isolation for jobs

2018-08-05 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu updated FLINK-9662: -- Fix Version/s: (was: 1.6.0) 1.7.0 > Task manager isolation for jobs >

[jira] [Assigned] (FLINK-9948) JSON format does not convert timestamps correctly

2018-07-31 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-9948: - Assignee: (was: Renjie Liu) > JSON format does not convert timestamps correctly >

[jira] [Assigned] (FLINK-9948) JSON format does not convert timestamps correctly

2018-07-31 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-9948: - Assignee: Renjie Liu > JSON format does not convert timestamps correctly >

[jira] [Assigned] (FLINK-9740) Support group windows over intervals of months

2018-07-31 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-9740: - Assignee: Renjie Liu > Support group windows over intervals of months >

[jira] [Assigned] (FLINK-8865) Add CLI query code completion in SQL Client

2018-07-31 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-8865: - Assignee: (was: Renjie Liu) > Add CLI query code completion in SQL Client >

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-07-29 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561101#comment-16561101 ] Renjie Liu commented on FLINK-9936: --- [~gjy] I'm working on this and I've already made an internal

[jira] [Closed] (FLINK-7470) Acquire RM leadership before registering with Mesos

2018-07-26 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu closed FLINK-7470. - Resolution: Duplicate > Acquire RM leadership before registering with Mesos >

[jira] [Created] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-07-24 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9936: - Summary: Mesos resource manager unable to connect to master after failover Key: FLINK-9936 URL: https://issues.apache.org/jira/browse/FLINK-9936 Project: Flink

[jira] [Closed] (FLINK-9726) Enable job task manager isolation use tag support

2018-07-23 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu closed FLINK-9726. - Resolution: Duplicate Duplicated > Enable job task manager isolation use tag support >

[jira] [Closed] (FLINK-9096) flip 6 allocates different resources for different jobs

2018-07-23 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu closed FLINK-9096. - Resolution: Duplicate Duplication of 5131 > flip 6 allocates different resources for different jobs >

[jira] [Assigned] (FLINK-8865) Add CLI query code completion in SQL Client

2018-07-23 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-8865: - Assignee: Renjie Liu > Add CLI query code completion in SQL Client >

[jira] [Commented] (FLINK-8858) Add support for INSERT INTO in SQL Client

2018-07-05 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533453#comment-16533453 ] Renjie Liu commented on FLINK-8858: --- Hi [~twalthr] That's ok since currently I have no time for that.

[jira] [Closed] (FLINK-9671) Add configuration to enable task manager isolation.

2018-07-03 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu closed FLINK-9671. - Resolution: Won't Fix > Add configuration to enable task manager isolation. >

[jira] [Created] (FLINK-9727) Allow user to pass resource tag expression in command line

2018-07-03 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9727: - Summary: Allow user to pass resource tag expression in command line Key: FLINK-9727 URL: https://issues.apache.org/jira/browse/FLINK-9727 Project: Flink Issue

[jira] [Created] (FLINK-9726) Enable job task manager isolation use tag support

2018-07-03 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9726: - Summary: Enable job task manager isolation use tag support Key: FLINK-9726 URL: https://issues.apache.org/jira/browse/FLINK-9726 Project: Flink Issue Type: New

[jira] [Created] (FLINK-9725) Add tag support to standalone cluster manager.

2018-07-03 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9725: - Summary: Add tag support to standalone cluster manager. Key: FLINK-9725 URL: https://issues.apache.org/jira/browse/FLINK-9725 Project: Flink Issue Type: New

[jira] [Created] (FLINK-9724) Add tag support to yarn resource manager

2018-07-03 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9724: - Summary: Add tag support to yarn resource manager Key: FLINK-9724 URL: https://issues.apache.org/jira/browse/FLINK-9724 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9723) Add tags support to mesos resource manager

2018-07-03 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9723: - Summary: Add tags support to mesos resource manager Key: FLINK-9723 URL: https://issues.apache.org/jira/browse/FLINK-9723 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9722) Add resource tag predicate into slot manager

2018-07-03 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9722: - Summary: Add resource tag predicate into slot manager Key: FLINK-9722 URL: https://issues.apache.org/jira/browse/FLINK-9722 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9721) Introduce ResourceTagExpression class

2018-07-03 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9721: - Summary: Introduce ResourceTagExpression class Key: FLINK-9721 URL: https://issues.apache.org/jira/browse/FLINK-9721 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9720) Introduce ResourceTag class for tag support in scheduling

2018-07-03 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9720: - Summary: Introduce ResourceTag class for tag support in scheduling Key: FLINK-9720 URL: https://issues.apache.org/jira/browse/FLINK-9720 Project: Flink Issue

[jira] [Created] (FLINK-9719) Mesos should use hostname as default jobmanager.rpc.address

2018-07-03 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9719: - Summary: Mesos should use hostname as default jobmanager.rpc.address Key: FLINK-9719 URL: https://issues.apache.org/jira/browse/FLINK-9719 Project: Flink Issue

[jira] [Closed] (FLINK-9670) Introduce slot manager factory

2018-07-01 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu closed FLINK-9670. - Resolution: Invalid > Introduce slot manager factory > -- > >

[jira] [Closed] (FLINK-9669) Introduce task manager assignment store

2018-07-01 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu closed FLINK-9669. - Resolution: Invalid > Introduce task manager assignment store > ---

[jira] [Commented] (FLINK-9662) Task manager isolation for jobs

2018-06-29 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527474#comment-16527474 ] Renjie Liu commented on FLINK-9662: --- [~till.rohrmann] [~elevy] According to our discussion above, I've

[jira] [Commented] (FLINK-9662) Task manager isolation for jobs

2018-06-28 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526247#comment-16526247 ] Renjie Liu commented on FLINK-9662: --- Would it be better if we reuse the existing job id field in

[jira] [Commented] (FLINK-9662) Task manager isolation for jobs

2018-06-27 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525864#comment-16525864 ] Renjie Liu commented on FLINK-9662: --- [~till.rohrmann] [~elevy] [~gzm55] I think it's quite tricky to

[jira] [Updated] (FLINK-9662) Task manager isolation for jobs

2018-06-27 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu updated FLINK-9662: -- Attachment: job isolation sequence.jpg > Task manager isolation for jobs >

[jira] [Created] (FLINK-9671) Add configuration to enable task manager isolation.

2018-06-27 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9671: - Summary: Add configuration to enable task manager isolation. Key: FLINK-9671 URL: https://issues.apache.org/jira/browse/FLINK-9671 Project: Flink Issue Type: New

[jira] [Created] (FLINK-9670) Introduce slot manager factory

2018-06-27 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9670: - Summary: Introduce slot manager factory Key: FLINK-9670 URL: https://issues.apache.org/jira/browse/FLINK-9670 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9669) Introduce task manager assignment store

2018-06-27 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9669: - Summary: Introduce task manager assignment store Key: FLINK-9669 URL: https://issues.apache.org/jira/browse/FLINK-9669 Project: Flink Issue Type: New Feature

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

2018-06-26 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523444#comment-16523444 ] Renjie Liu commented on FLINK-8886: --- [~till.rohrmann], [~elevy], [~mingleizhang] I've created an 

[jira] [Updated] (FLINK-9663) Allow jobs to be scheduled to hosts that meet requirements.

2018-06-26 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu updated FLINK-9663: -- Summary: Allow jobs to be scheduled to hosts that meet requirements. (was: Allow jobs to be scheduled

[jira] [Created] (FLINK-9663) Allow jobs to be scheduled to task managers with special tags

2018-06-26 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9663: - Summary: Allow jobs to be scheduled to task managers with special tags Key: FLINK-9663 URL: https://issues.apache.org/jira/browse/FLINK-9663 Project: Flink Issue

[jira] [Created] (FLINK-9662) Task manager isolation for jobs

2018-06-26 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9662: - Summary: Task manager isolation for jobs Key: FLINK-9662 URL: https://issues.apache.org/jira/browse/FLINK-9662 Project: Flink Issue Type: New Feature

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

2018-06-06 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-8886: - Assignee: Renjie Liu > Job isolation via scheduling in shared cluster >

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

2018-06-06 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502997#comment-16502997 ] Renjie Liu commented on FLINK-8886: --- I think there are two parts of this issue: # Task manager

[jira] [Assigned] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

2018-04-03 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-8953: - Assignee: Renjie Liu > Resolve unresolved field references in FieldComputer expressions >

[jira] [Created] (FLINK-9117) Disable artifact download in mesos container environment.

2018-03-30 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9117: - Summary: Disable artifact download in mesos container environment. Key: FLINK-9117 URL: https://issues.apache.org/jira/browse/FLINK-9117 Project: Flink Issue

[jira] [Closed] (FLINK-9077) flip6 cluster framework doesn't work on mesos

2018-03-28 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu closed FLINK-9077. - Resolution: Not A Problem It has been proven that this is caused by my mistake. When starting

[jira] [Updated] (FLINK-9077) flip6 cluster framework doesn't work on mesos

2018-03-27 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu updated FLINK-9077: -- Priority: Blocker (was: Major) > flip6 cluster framework doesn't work on mesos >

[jira] [Created] (FLINK-9096) flip 6 allocates different resources for different jobs

2018-03-27 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9096: - Summary: flip 6 allocates different resources for different jobs Key: FLINK-9096 URL: https://issues.apache.org/jira/browse/FLINK-9096 Project: Flink Issue Type:

[jira] [Updated] (FLINK-9077) flip6 cluster framework doesn't work on mesos

2018-03-26 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu updated FLINK-9077: -- Description: I'm testing flip6 on mesos, and the following is my config:  

[jira] [Created] (FLINK-9077) flip6 cluster framework doesn't work on mesos

2018-03-26 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9077: - Summary: flip6 cluster framework doesn't work on mesos Key: FLINK-9077 URL: https://issues.apache.org/jira/browse/FLINK-9077 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9077) flip6 cluster framework doesn't work on mesos

2018-03-26 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu updated FLINK-9077: -- Attachment: flink-liurj-mesos-appmaster-qt9ss.prod.mediav.com.log > flip6 cluster framework doesn't

[jira] [Commented] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

2018-03-15 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401391#comment-16401391 ] Renjie Liu commented on FLINK-8953: --- Hi, Tim: I want to look into this, could you assign this to me? >

[jira] [Commented] (FLINK-8852) SQL Client does not work with new FLIP-6 mode

2018-03-14 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399891#comment-16399891 ] Renjie Liu commented on FLINK-8852: --- Hi, [~twalthr]: I would like to look into this, could you assign

[jira] [Created] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState

2018-03-12 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-8919: - Summary: Add KeyedProcessFunctionWIthCleanupState Key: FLINK-8919 URL: https://issues.apache.org/jira/browse/FLINK-8919 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8858) SQL Client to submit long running query in file

2018-03-05 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-8858: - Summary: SQL Client to submit long running query in file Key: FLINK-8858 URL: https://issues.apache.org/jira/browse/FLINK-8858 Project: Flink Issue Type: New

[jira] [Assigned] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

2018-03-02 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-6968: - Assignee: Renjie Liu > Store streaming, updating tables with unique key in queryable state >

[jira] [Commented] (FLINK-6131) Add side inputs for DataStream API

2017-06-06 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038420#comment-16038420 ] Renjie Liu commented on FLINK-6131: --- Hi, we are facing the same issues and want to solve it with

[jira] [Created] (FLINK-5445) flink kafka consumer should support rate control

2017-01-11 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-5445: - Summary: flink kafka consumer should support rate control Key: FLINK-5445 URL: https://issues.apache.org/jira/browse/FLINK-5445 Project: Flink Issue Type: Bug