[jira] [Assigned] (FLINK-13310) Remove shade-plugin configuration in hive-connector

2019-07-17 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-13310: -- Assignee: Ji Liu > Remove shade-plugin configuration in hive-connector >

[jira] [Commented] (FLINK-13147) Duplicated code in 'if' conditional statement

2019-07-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880277#comment-16880277 ] Ji Liu commented on FLINK-13147: [~q977734161] Thanks for reporting this issue, I provided a PR to fix

[jira] [Assigned] (FLINK-13147) Duplicated code in 'if' conditional statement

2019-07-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-13147: -- Assignee: Ji Liu > Duplicated code in 'if' conditional statement >

[jira] [Updated] (FLINK-13054) [Java] Support compact fixed-width vectors

2019-07-02 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu updated FLINK-13054: --- Description: was: In shuffle stage of some applications, FixedWitdhVectors may have very little

[jira] [Closed] (FLINK-13054) [Java] Support compact fixed-width vectors

2019-07-02 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu closed FLINK-13054. -- Resolution: Invalid > [Java] Support compact fixed-width vectors > --

[jira] [Created] (FLINK-13054) [Java] Support compact fixed-width vectors

2019-07-02 Thread Ji Liu (JIRA)
Ji Liu created FLINK-13054: -- Summary: [Java] Support compact fixed-width vectors Key: FLINK-13054 URL: https://issues.apache.org/jira/browse/FLINK-13054 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-12825) Remove deprecation from BatchTableSource/Sink

2019-06-13 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-12825: -- Assignee: (was: Ji Liu) > Remove deprecation from BatchTableSource/Sink >

[jira] [Assigned] (FLINK-12825) Remove deprecation from BatchTableSource/Sink

2019-06-13 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-12825: -- Assignee: Ji Liu > Remove deprecation from BatchTableSource/Sink >

[jira] [Created] (FLINK-12631) Check if proper JAR file in JobWithJars

2019-05-27 Thread Ji Liu (JIRA)
Ji Liu created FLINK-12631: -- Summary: Check if proper JAR file in JobWithJars Key: FLINK-12631 URL: https://issues.apache.org/jira/browse/FLINK-12631 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

2019-04-29 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-10446: -- Assignee: (was: Ji Liu) > Use the "guava beta checker" plugin to keep off of @Beta API >

[jira] [Assigned] (FLINK-12145) Host config in flink-web is incorrect

2019-04-29 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-12145: -- Assignee: (was: Ji Liu) > Host config in flink-web is incorrect >

[jira] [Assigned] (FLINK-12349) invalid

2019-04-29 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-12349: -- Assignee: (was: Ji Liu) > invalid > --- > > Key: FLINK-12349 >

[jira] [Updated] (FLINK-12349) invalid

2019-04-27 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu updated FLINK-12349: --- Summary: invalid (was: [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount) >

[jira] [Updated] (FLINK-12349) [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount

2019-04-27 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu updated FLINK-12349: --- Description: (was: Now in _BaseValueVector#getValidityBufferSizeFromCount_ and 

[jira] [Closed] (FLINK-12349) [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount

2019-04-27 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu closed FLINK-12349. -- Resolution: Invalid > [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount >

[jira] [Created] (FLINK-12349) [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount

2019-04-27 Thread Ji Liu (JIRA)
Ji Liu created FLINK-12349: -- Summary: [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount Key: FLINK-12349 URL: https://issues.apache.org/jira/browse/FLINK-12349 Project: Flink

[jira] [Created] (FLINK-12293) Fix some comment typos in flink-streaming-java.

2019-04-22 Thread Ji Liu (JIRA)
Ji Liu created FLINK-12293: -- Summary: Fix some comment typos in flink-streaming-java. Key: FLINK-12293 URL: https://issues.apache.org/jira/browse/FLINK-12293 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

2019-04-22 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-10446: -- Assignee: Ji Liu > Use the "guava beta checker" plugin to keep off of @Beta API >

[jira] [Assigned] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

2019-04-22 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-10446: -- Assignee: (was: Ji Liu) > Use the "guava beta checker" plugin to keep off of @Beta API >

[jira] [Assigned] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

2019-04-22 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-10446: -- Assignee: Ji Liu > Use the "guava beta checker" plugin to keep off of @Beta API >

[jira] [Commented] (FLINK-9904) Allow users to control MaxDirectMemorySize

2019-04-18 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16821633#comment-16821633 ] Ji Liu commented on FLINK-9904: --- [~hroongta] ok, then I will fix this. thanks! > Allow users to control

[jira] [Assigned] (FLINK-9904) Allow users to control MaxDirectMemorySize

2019-04-18 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-9904: - Assignee: Ji Liu > Allow users to control MaxDirectMemorySize >

[jira] [Commented] (FLINK-10441) Don't log warning when creating upload directory

2019-04-18 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16821630#comment-16821630 ] Ji Liu commented on FLINK-10441: [~uce] Hi, thanks for opening this issue, I have submitted a PR: 

[jira] [Assigned] (FLINK-10441) Don't log warning when creating upload directory

2019-04-18 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-10441: -- Assignee: Ji Liu > Don't log warning when creating upload directory >

[jira] [Commented] (FLINK-9904) Allow users to control MaxDirectMemorySize

2019-04-17 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820720#comment-16820720 ] Ji Liu commented on FLINK-9904: --- Hi [~hroongta] are you still working on this issue? If not, i would like

[jira] [Commented] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants

2019-04-15 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818509#comment-16818509 ] Ji Liu commented on FLINK-3991: --- [~Zentol] Alright, thanks for replying. > Remove deprecated configuration

[jira] [Assigned] (FLINK-9542) ExEnv#registerCachedFile should accept Path

2019-04-15 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-9542: - Assignee: Ji Liu > ExEnv#registerCachedFile should accept Path >

[jira] [Commented] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

2019-04-12 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816047#comment-16816047 ] Ji Liu commented on FLINK-11619: [~yuqi] Thanks for replying. You mean you will continue to work on

[jira] [Commented] (FLINK-9542) ExEnv#registerCachedFile should accept Path

2019-04-11 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815362#comment-16815362 ] Ji Liu commented on FLINK-9542: --- [~Zentol] Is this issue still open? I quickly looked into the code and it

[jira] [Comment Edited] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

2019-04-11 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814217#comment-16814217 ] Ji Liu edited comment on FLINK-11619 at 4/11/19 7:13 AM: - +1, the default

[jira] [Commented] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

2019-04-11 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815135#comment-16815135 ] Ji Liu commented on FLINK-11619: hi, [~yuqi] if you have no opinion, I would like to prepare a PR to

[jira] [Commented] (FLINK-3685) Logical error in code for DateSerializer deserialize with reuse

2019-04-10 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814379#comment-16814379 ] Ji Liu commented on FLINK-3685: --- Since this problem is fixed in

[jira] [Commented] (FLINK-9385) Operators with two inputs should show "Records Received" in Web UI separately, rather than added together

2019-04-10 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814361#comment-16814361 ] Ji Liu commented on FLINK-9385: --- Hi [~joshlemer], thanks for opening this issue, but I think one could calc

[jira] [Comment Edited] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

2019-04-10 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814217#comment-16814217 ] Ji Liu edited comment on FLINK-11619 at 4/10/19 9:03 AM: - The default

[jira] [Commented] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

2019-04-10 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814217#comment-16814217 ] Ji Liu commented on FLINK-11619: In default _ScheduleMod_e of _JobGraph_ is LAZY_FROM_SOURCES, but when 

[jira] [Closed] (FLINK-12145) Host config in flink-web is incorrect

2019-04-10 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu closed FLINK-12145. -- Resolution: Won't Do > Host config in flink-web is incorrect > - > >

[jira] [Commented] (FLINK-12145) Host config in flink-web is incorrect

2019-04-10 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814202#comment-16814202 ] Ji Liu commented on FLINK-12145: ok, I have closed this issue. > Host config in flink-web is incorrect

[jira] [Commented] (FLINK-11799) KryoSerializer/OperatorChain ignores copy failure resulting in NullPointerException

2019-04-10 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814188#comment-16814188 ] Ji Liu commented on FLINK-11799: Agree, it's necessary to print error log when copy fails and now it

[jira] [Commented] (FLINK-12118) Documentation in left navigation is not in step with its content

2019-04-10 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814102#comment-16814102 ] Ji Liu commented on FLINK-12118: This is because the release branch for 1.8 was already cut. Therefore

[jira] [Commented] (FLINK-7916) Remove NetworkStackThroughputITCase

2019-04-09 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814021#comment-16814021 ] Ji Liu commented on FLINK-7916: --- [~till.rohrmann] Absolutely, in the long run it's a better solution to

[jira] [Commented] (FLINK-12145) Host config in flink-web is incorrect

2019-04-09 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813986#comment-16813986 ] Ji Liu commented on FLINK-12145: [~fhueske] alright, I raised this issue just because 0.0.0.0:4000 can't

[jira] [Commented] (FLINK-12145) Host config in flink-web is incorrect

2019-04-09 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813268#comment-16813268 ] Ji Liu commented on FLINK-12145: cc @[~fhueske] > Host config in flink-web is incorrect >

[jira] [Created] (FLINK-12145) Host config in flink-web is incorrect

2019-04-09 Thread Ji Liu (JIRA)
Ji Liu created FLINK-12145: -- Summary: Host config in flink-web is incorrect Key: FLINK-12145 URL: https://issues.apache.org/jira/browse/FLINK-12145 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-12128) There is a typo on the website

2019-04-09 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813242#comment-16813242 ] Ji Liu commented on FLINK-12128: [~fhueske] If nobody is working on this, I would like to provide a

[jira] [Comment Edited] (FLINK-12128) There is a typo on the website

2019-04-09 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813242#comment-16813242 ] Ji Liu edited comment on FLINK-12128 at 4/9/19 10:32 AM: - [~fhueske]

[jira] [Assigned] (FLINK-12125) Add OVH to poweredby.zh.md and index.zh.md

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-12125: -- Assignee: Ji Liu > Add OVH to poweredby.zh.md and index.zh.md >

[jira] [Commented] (FLINK-12125) Add OVH to poweredby.zh.md and index.zh.md

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813003#comment-16813003 ] Ji Liu commented on FLINK-12125: Hi [~fhueske] Is there anyone work on this? if not, I would like to

[jira] [Assigned] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-3991: - Assignee: Ji Liu > Remove deprecated configuration keys from ConfigConstants >

[jira] [Assigned] (FLINK-9787) Change ExecutionConfig#getGlobalJobParameters to return an instance of GlobalJobParameters instead of null if no custom globalJobParameters are set yet

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-9787: - Assignee: Ji Liu > Change ExecutionConfig#getGlobalJobParameters to return an instance of >

[jira] [Assigned] (FLINK-7916) Remove NetworkStackThroughputITCase

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-7916: - Assignee: Ji Liu > Remove NetworkStackThroughputITCase > --- > >

[jira] [Assigned] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-10437: -- Assignee: Ji Liu > Some of keys under withDeprecatedKeys aren't marked as @depreacted >

[jira] [Comment Edited] (FLINK-7916) Remove NetworkStackThroughputITCase

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812155#comment-16812155 ] Ji Liu edited comment on FLINK-7916 at 4/8/19 10:40 AM: Agree, I think move these

[jira] [Comment Edited] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812271#comment-16812271 ] Ji Liu edited comment on FLINK-10437 at 4/8/19 10:12 AM: - I have checked usages

[jira] [Comment Edited] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812271#comment-16812271 ] Ji Liu edited comment on FLINK-10437 at 4/8/19 9:34 AM: [~Tison] I have checked

[jira] [Commented] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812271#comment-16812271 ] Ji Liu commented on FLINK-10437: [~Tison] I have checked usages of _ConfigOption.withDeparecatedKeys_