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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-13147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880277#comment-16880277 ] Ji Liu commented on FLINK-13147: [~q977734161] Thanks for reporting this issue, I provid

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

[ 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

[ 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 non-n

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

[ 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

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

[ 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

[ 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

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

[ 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

[ 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

[ 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

[ 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) > inv

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

[ 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  _BitVectorHelper#getVali

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

[ 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

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.

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

[ 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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-9904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821633#comment-16821633 ] Ji Liu commented on FLINK-9904: --- [~hroongta] ok, then I will fix this. thanks! > Allow use

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821630#comment-16821630 ] Ji Liu commented on FLINK-10441: [~uce] Hi, thanks for opening this issue, I have submit

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-9904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820720#comment-16820720 ] Ji Liu commented on FLINK-9904: --- Hi [~hroongta] are you still working on this issue? If not

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

[ https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818509#comment-16818509 ] Ji Liu commented on FLINK-3991: --- [~Zentol] Alright, thanks for replying. > Remove deprecat

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16816047#comment-16816047 ] Ji Liu commented on FLINK-11619: [~yuqi] Thanks for replying. You mean you will continue

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

[ https://issues.apache.org/jira/browse/FLINK-9542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815362#comment-16815362 ] Ji Liu commented on FLINK-9542: --- [~Zentol] Is this issue still open? I quickly looked into

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

[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814217#comment-16814217 ] Ji Liu edited comment on FLINK-11619 at 4/11/19 7:13 AM: - +1, th

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

[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815135#comment-16815135 ] Ji Liu commented on FLINK-11619: hi, [~yuqi] if you have no opinion, I would like to pre

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

[ https://issues.apache.org/jira/browse/FLINK-3685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814379#comment-16814379 ] Ji Liu commented on FLINK-3685: --- Since this problem is fixed in [FLINK-3856|https://issues

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

[ https://issues.apache.org/jira/browse/FLINK-9385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814361#comment-16814361 ] Ji Liu commented on FLINK-9385: --- Hi [~joshlemer], thanks for opening this issue, but I thin

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

[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814217#comment-16814217 ] Ji Liu edited comment on FLINK-11619 at 4/10/19 9:03 AM: - The de

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

[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814217#comment-16814217 ] Ji Liu commented on FLINK-11619: In default _ScheduleMod_e of _JobGraph_ is LAZY_FROM_SO

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-12145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814202#comment-16814202 ] Ji Liu commented on FLINK-12145: ok, I have closed this issue. > Host config in flink-w

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

[ https://issues.apache.org/jira/browse/FLINK-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814188#comment-16814188 ] Ji Liu commented on FLINK-11799: Agree, it's necessary to print error log when copy fail

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

[ https://issues.apache.org/jira/browse/FLINK-12118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814102#comment-16814102 ] Ji Liu commented on FLINK-12118: This is because the release branch for 1.8 was already

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-12145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813986#comment-16813986 ] Ji Liu commented on FLINK-12145: [~fhueske] alright, I raised this issue just because 0.

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

[ https://issues.apache.org/jira/browse/FLINK-12145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

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 Reporte

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

[ https://issues.apache.org/jira/browse/FLINK-12128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813242#comment-16813242 ] Ji Liu commented on FLINK-12128: [~fhueske] If nobody is working on this, I would like t

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

[ https://issues.apache.org/jira/browse/FLINK-12128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813242#comment-16813242 ] Ji Liu edited comment on FLINK-12128 at 4/9/19 10:32 AM: - [~fhue

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-12125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813003#comment-16813003 ] Ji Liu commented on FLINK-12125: Hi [~fhueske] Is there anyone work on this? if not, I w

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

[ 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

[ 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 > GlobalJobPa

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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812155#comment-16812155 ] Ji Liu edited comment on FLINK-7916 at 4/8/19 10:40 AM: Agree, I

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

[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812271#comment-16812271 ] Ji Liu edited comment on FLINK-10437 at 4/8/19 10:12 AM: - I have

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

[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812271#comment-16812271 ] Ji Liu edited comment on FLINK-10437 at 4/8/19 9:34 AM: [~Tison]

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

[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812271#comment-16812271 ] Ji Liu commented on FLINK-10437: [~Tison] I have checked usages of _ConfigOption.withDep