[jira] [Commented] (FLINK-15538) Separate decimal implementations into separate sub-classes

2020-01-09 Thread Liya Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012394#comment-17012394 ] Liya Fan commented on FLINK-15538: -- [~ykt836] Good point. Admittedly, a virtual funct

[jira] [Created] (FLINK-15538) Separate decimal implementations into separate sub-classes

2020-01-09 Thread Liya Fan (Jira)
Liya Fan created FLINK-15538: Summary: Separate decimal implementations into separate sub-classes Key: FLINK-15538 URL: https://issues.apache.org/jira/browse/FLINK-15538 Project: Flink Issue Type

[jira] [Created] (FLINK-14731) LogicalWatermarkAssigner should use specified trait set when doing copy

2019-11-12 Thread Liya Fan (Jira)
Liya Fan created FLINK-14731: Summary: LogicalWatermarkAssigner should use specified trait set when doing copy Key: FLINK-14731 URL: https://issues.apache.org/jira/browse/FLINK-14731 Project: Flink

[jira] [Commented] (FLINK-13221) Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-21 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889884#comment-16889884 ] Liya Fan commented on FLINK-13221: -- [~ykt836]. Sure. Thanks a lot. > Blink planner sho

[jira] [Assigned] (FLINK-13221) Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

2019-07-11 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-13221: Assignee: Liya Fan > Blink planner should set ScheduleMode to > LAZY_FROM_SOURCES_WITH_BATCH_SLO

[jira] [Created] (FLINK-13200) Improve the generated code for if statements

2019-07-10 Thread Liya Fan (JIRA)
Liya Fan created FLINK-13200: Summary: Improve the generated code for if statements Key: FLINK-13200 URL: https://issues.apache.org/jira/browse/FLINK-13200 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-13108) Remove duplicated type cast in generated code

2019-07-04 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13108: - Description: There are duplicated cast operations in the generated code. For example, to run org.apache

[jira] [Updated] (FLINK-13108) Remove duplicated type cast in generated code

2019-07-04 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13108: - Description: There are duplicated cast operations in the generated code. For example, to run org.apache

[jira] [Updated] (FLINK-13108) Remove duplicated type cast in generated code

2019-07-04 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13108: - Description: There are duplicated cast operations in the generated code. For example, to run org.apache

[jira] [Created] (FLINK-13108) Remove duplicated type cast in generated code

2019-07-04 Thread Liya Fan (JIRA)
Liya Fan created FLINK-13108: Summary: Remove duplicated type cast in generated code Key: FLINK-13108 URL: https://issues.apache.org/jira/browse/FLINK-13108 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-13058) Avoid memory copy for the trimming operations of BinaryString

2019-07-02 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13058: - Description: For trimming operations of BinaryString (trim, trimLeft, trimRight), if the trimmed string

[jira] [Created] (FLINK-13058) Avoid memory copy for the trimming operations of BinaryString

2019-07-02 Thread Liya Fan (JIRA)
Liya Fan created FLINK-13058: Summary: Avoid memory copy for the trimming operations of BinaryString Key: FLINK-13058 URL: https://issues.apache.org/jira/browse/FLINK-13058 Project: Flink Issue

[jira] [Updated] (FLINK-13053) Vectorization Support in Flink

2019-07-02 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13053: - Description: Vectorization is a popular technique in SQL engines today. Compared with traditional row-b

[jira] [Updated] (FLINK-13053) Vectorization Support in Flink

2019-07-02 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13053: - Description: Vectorization is a popular technique in SQL engines today. Compared with traditional row-b

[jira] [Created] (FLINK-13053) Vectorization Support in Flink

2019-07-02 Thread Liya Fan (JIRA)
Liya Fan created FLINK-13053: Summary: Vectorization Support in Flink Key: FLINK-13053 URL: https://issues.apache.org/jira/browse/FLINK-13053 Project: Flink Issue Type: New Feature Comp

[jira] [Created] (FLINK-13043) Fix the bug of parsing Dewey number from string

2019-07-01 Thread Liya Fan (JIRA)
Liya Fan created FLINK-13043: Summary: Fix the bug of parsing Dewey number from string Key: FLINK-13043 URL: https://issues.apache.org/jira/browse/FLINK-13043 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-12628) Check test failure if partition has no consumers in Execution.getPartitionMaxParallelism

2019-07-01 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12628: Assignee: Liya Fan > Check test failure if partition has no consumers in > Execution.getPartitio

[jira] [Created] (FLINK-12922) Remove method parameter from OperatorCodeGenerator

2019-06-20 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12922: Summary: Remove method parameter from OperatorCodeGenerator Key: FLINK-12922 URL: https://issues.apache.org/jira/browse/FLINK-12922 Project: Flink Issue Type: Improv

[jira] [Comment Edited] (FLINK-12886) Support container memory segment

2019-06-20 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869126#comment-16869126 ] Liya Fan edited comment on FLINK-12886 at 6/21/19 3:27 AM: --- [~

[jira] [Commented] (FLINK-12886) Support container memory segment

2019-06-20 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869126#comment-16869126 ] Liya Fan commented on FLINK-12886: -- [~ykt836], [~lzljs3620320] Another advantage I can

[jira] [Commented] (FLINK-12886) Support container memory segment

2019-06-20 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16868505#comment-16868505 ] Liya Fan commented on FLINK-12886: -- [~lzljs3620320], thanks for your feedback and sugge

[jira] [Commented] (FLINK-12886) Support container memory segment

2019-06-20 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16868500#comment-16868500 ] Liya Fan commented on FLINK-12886: -- [~ykt836], thanks a lot for your feedback. If we c

[jira] [Commented] (FLINK-12886) Support container memory segment

2019-06-19 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16868251#comment-16868251 ] Liya Fan commented on FLINK-12886: -- [~ykt836] [~lzljs3620320], two ideas to resolve the

[jira] [Created] (FLINK-12900) Refactor the class hierarchy for BinaryFormat

2019-06-19 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12900: Summary: Refactor the class hierarchy for BinaryFormat Key: FLINK-12900 URL: https://issues.apache.org/jira/browse/FLINK-12900 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-12886) Support container memory segment

2019-06-19 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867424#comment-16867424 ] Liya Fan commented on FLINK-12886: -- [~ykt836] Thanks a lot for the article. I will take

[jira] [Commented] (FLINK-12886) Support container memory segment

2019-06-19 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867398#comment-16867398 ] Liya Fan commented on FLINK-12886: -- Hi [~lzljs3620320], thanks for your comments. Pleas

[jira] [Created] (FLINK-12886) Support container memory segment

2019-06-18 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12886: Summary: Support container memory segment Key: FLINK-12886 URL: https://issues.apache.org/jira/browse/FLINK-12886 Project: Flink Issue Type: New Feature Co

[jira] [Created] (FLINK-12879) Improve the performance of AbstractBinaryWriter

2019-06-17 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12879: Summary: Improve the performance of AbstractBinaryWriter Key: FLINK-12879 URL: https://issues.apache.org/jira/browse/FLINK-12879 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-12811) flink-table-planner-blink compile error

2019-06-11 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861775#comment-16861775 ] Liya Fan commented on FLINK-12811: -- I tried two different versions of JDK1.8, but could

[jira] [Updated] (FLINK-12750) Gettting Started - Docker Playground - Interactive SQL Playground

2019-06-05 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12750: - Component/s: Documentation > Gettting Started - Docker Playground - Interactive SQL Playground > ---

[jira] [Updated] (FLINK-12749) Getting Started - Docker Playgrounds - Flink Cluster Playground

2019-06-05 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12749: - Component/s: Documentation > Getting Started - Docker Playgrounds - Flink Cluster Playground > -

[jira] [Updated] (FLINK-12746) Getting Started - Project Setup and DataStream Example Walkthrough

2019-06-05 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12746: - Component/s: Documentation > Getting Started - Project Setup and DataStream Example Walkthrough > --

[jira] [Updated] (FLINK-12748) Getting Started - Flink Overview

2019-06-05 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12748: - Component/s: Documentation > Getting Started - Flink Overview > > >

[jira] [Updated] (FLINK-12747) Getting Started - Table API Example Walkthrough

2019-06-05 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12747: - Component/s: Documentation > Getting Started - Table API Example Walkthrough > -

[jira] [Created] (FLINK-12730) Combine BitSet implementations in flink-runtime

2019-06-04 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12730: Summary: Combine BitSet implementations in flink-runtime Key: FLINK-12730 URL: https://issues.apache.org/jira/browse/FLINK-12730 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-12687) ByteHashSet is always in dense mode

2019-06-03 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12687: - Component/s: (was: Runtime / Operators) Table SQL / Runtime > ByteHashSet is always

[jira] [Commented] (FLINK-12701) Column name alias causes exception when used with where and group-by

2019-06-02 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16854154#comment-16854154 ] Liya Fan commented on FLINK-12701: -- Hi [~josh.bradt], thanks for reporting this problem

[jira] [Created] (FLINK-12687) ByteHashSet is always in dense mode

2019-05-30 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12687: Summary: ByteHashSet is always in dense mode Key: FLINK-12687 URL: https://issues.apache.org/jira/browse/FLINK-12687 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-12620) Deadlock in task deserialization

2019-05-28 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850307#comment-16850307 ] Liya Fan commented on FLINK-12620: -- [~mikekap], thanks for the clarification. Would yo

[jira] [Commented] (FLINK-12620) Deadlock in task deserialization

2019-05-28 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849567#comment-16849567 ] Liya Fan commented on FLINK-12620: -- [~mikekap], thanks for providing additional details

[jira] [Commented] (FLINK-12620) Deadlock in task deserialization

2019-05-27 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848865#comment-16848865 ] Liya Fan commented on FLINK-12620: -- [~mikekap] Thank you for finding this problem. Wou

[jira] [Commented] (FLINK-12593) Revise the document for CEP

2019-05-22 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846399#comment-16846399 ] Liya Fan commented on FLINK-12593: -- Hi [~jark], thank you so much for sharing the good

[jira] [Commented] (FLINK-12586) Stderr and stdout are reversed in OptimizerPlanEnvironment

2019-05-22 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846381#comment-16846381 ] Liya Fan commented on FLINK-12586: -- Hi [~shinhira_kazunori], thanks for finding this pr

[jira] [Created] (FLINK-12593) Revise the document for CEP

2019-05-22 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12593: Summary: Revise the document for CEP Key: FLINK-12593 URL: https://issues.apache.org/jira/browse/FLINK-12593 Project: Flink Issue Type: Improvement Compone

[jira] [Commented] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-05-22 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845757#comment-16845757 ] Liya Fan commented on FLINK-12319: -- [~mpf] The problem has been fixed by our [PR|[http

[jira] [Assigned] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-05-21 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12319: Assignee: Liya Fan > StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer > --

[jira] [Assigned] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-05-21 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12319: Assignee: (was: Liya Fan) > StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer > ---

[jira] [Commented] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-05-21 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845566#comment-16845566 ] Liya Fan commented on FLINK-12319: -- Hi [~mpf], thank you for your feedback. I am lookin

[jira] [Assigned] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-05-21 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12319: Assignee: Liya Fan > StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer > --

[jira] [Updated] (FLINK-12335) Remove useless code in SegmentsUtil

2019-05-21 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12335: - Summary: Remove useless code in SegmentsUtil (was: Improvement the performance of class SegmentsUtil)

[jira] [Updated] (FLINK-12553) Fix a bug in SqlDateTimeUtils#parseToTimeMillis

2019-05-20 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12553: - Description: If parameter "1999-12-31 12:34:56.123" is used, it should return 123. But it returns 1230 n

[jira] [Created] (FLINK-12553) Fix a bug in SqlDateTimeUtils#parseToTimeMillis

2019-05-20 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12553: Summary: Fix a bug in SqlDateTimeUtils#parseToTimeMillis Key: FLINK-12553 URL: https://issues.apache.org/jira/browse/FLINK-12553 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler

2019-05-06 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833687#comment-16833687 ] Liya Fan commented on FLINK-11421: -- [~lzljs3620320] Thanks a lot for your confirm. >>

[jira] [Commented] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler

2019-05-06 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833664#comment-16833664 ] Liya Fan commented on FLINK-11421: -- Hi [~lzljs3620320], thanks a lot for your informati

[jira] [Comment Edited] (FLINK-10929) Add support for Apache Arrow

2019-04-29 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826677#comment-16826677 ] Liya Fan edited comment on FLINK-10929 at 4/30/19 3:01 AM: --- Hi

[jira] [Created] (FLINK-12361) Remove useless expression from runtime scheduler

2019-04-28 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12361: Summary: Remove useless expression from runtime scheduler Key: FLINK-12361 URL: https://issues.apache.org/jira/browse/FLINK-12361 Project: Flink Issue Type: Improvem

[jira] [Assigned] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-04-27 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12348: Assignee: Liya Fan > Use TableConfig in api module to replace TableConfig in blink-planner module

[jira] [Assigned] (FLINK-12347) flink-table-runtime-blink is missing scala suffix

2019-04-27 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12347: Assignee: Liya Fan > flink-table-runtime-blink is missing scala suffix >

[jira] [Updated] (FLINK-12335) Improvement the performance of class SegmentsUtil

2019-04-26 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12335: - Description: Improve the performance of class SegmentsUtil: To evaluate the offset, an integer is bitan

[jira] [Updated] (FLINK-12335) Improvement the performance of class SegmentsUtil

2019-04-26 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12335: - Description: Improve the performance of class SegmentsUtil from two points: 1. In method allocateReuseB

[jira] [Created] (FLINK-12335) Improvement the performance of class SegmentsUtil

2019-04-26 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12335: Summary: Improvement the performance of class SegmentsUtil Key: FLINK-12335 URL: https://issues.apache.org/jira/browse/FLINK-12335 Project: Flink Issue Type: Improve

[jira] [Commented] (FLINK-10929) Add support for Apache Arrow

2019-04-25 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826677#comment-16826677 ] Liya Fan commented on FLINK-10929: -- Hi [Stephan Ewen|https://issues.apache.org/jira/se

[jira] [Commented] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-04-25 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826610#comment-16826610 ] Liya Fan commented on FLINK-12319: -- Hi [~mpf], thanks again for the additional informat

[jira] [Commented] (FLINK-12334) change to MockStreamTask breaks OneInputStreamOperatorTestHarness

2019-04-25 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826606#comment-16826606 ] Liya Fan commented on FLINK-12334: -- Hi [~cre...@gmail.com], thanks for opening this iss

[jira] [Commented] (FLINK-12319) StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer

2019-04-24 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825624#comment-16825624 ] Liya Fan commented on FLINK-12319: -- Hi [~mpf], thank you for opening this issue. It se

[jira] [Commented] (FLINK-12115) Add support in Flink to persist state in Azure's blob store

2019-04-22 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823638#comment-16823638 ] Liya Fan commented on FLINK-12115: -- I vote for this issue, because it enhances the port

[jira] [Created] (FLINK-12290) Fix the misleading exception message in SharedSlot class

2019-04-22 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12290: Summary: Fix the misleading exception message in SharedSlot class Key: FLINK-12290 URL: https://issues.apache.org/jira/browse/FLINK-12290 Project: Flink Issue Type:

[jira] [Created] (FLINK-12289) Fix bugs and typos in Memory manager

2019-04-22 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12289: Summary: Fix bugs and typos in Memory manager Key: FLINK-12289 URL: https://issues.apache.org/jira/browse/FLINK-12289 Project: Flink Issue Type: Bug Compon

[jira] [Commented] (FLINK-12259) Improve debuggability of method invocation failures in OptimizerPlanEnvironment

2019-04-22 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823035#comment-16823035 ] Liya Fan commented on FLINK-12259: -- Hi [~gauravtiwari89], I see. Replied :) Thank you.

[jira] [Commented] (FLINK-12279) Create source to allow streaming data from websocket.

2019-04-21 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16822827#comment-16822827 ] Liya Fan commented on FLINK-12279: -- Hi [~Wosinsan], thanks for opening this isssue. Wou

[jira] [Commented] (FLINK-12259) Improve debuggability of method invocation failures in OptimizerPlanEnvironment

2019-04-18 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821637#comment-16821637 ] Liya Fan commented on FLINK-12259: -- [~quan], thanks a lot for the comments. [~gauravtiw

[jira] [Assigned] (FLINK-12259) Improve debuggability of method invocation failures in OptimizerPlanEnvironment

2019-04-18 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12259: Assignee: Liya Fan > Improve debuggability of method invocation failures in > OptimizerPlanEnvir

[jira] [Commented] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph

2019-04-17 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820763#comment-16820763 ] Liya Fan commented on FLINK-12246: -- Thanks for opening this issue. I do not see this is

[jira] [Updated] (FLINK-12223) HeapMemorySegment.getArray should return null after being freed

2019-04-17 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12223: - Description: According to the JavaDoc, HeapMemorySegment.getArray should return null after free is calle

[jira] [Created] (FLINK-12223) HeapMemorySegment.getArray should return null after being freed

2019-04-17 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12223: Summary: HeapMemorySegment.getArray should return null after being freed Key: FLINK-12223 URL: https://issues.apache.org/jira/browse/FLINK-12223 Project: Flink Issu

[jira] [Commented] (FLINK-12189) Fix bugs and typos in memory management related code

2019-04-16 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819706#comment-16819706 ] Liya Fan commented on FLINK-12189: -- To make the PR easier to understand to review, I ha

[jira] [Created] (FLINK-12216) Respect the number of bytes from input parameters in HybridMemorySegment

2019-04-16 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12216: Summary: Respect the number of bytes from input parameters in HybridMemorySegment Key: FLINK-12216 URL: https://issues.apache.org/jira/browse/FLINK-12216 Project: Flink

[jira] [Created] (FLINK-12210) Fix a bug in AbstractPagedInputView.readLine

2019-04-16 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12210: Summary: Fix a bug in AbstractPagedInputView.readLine Key: FLINK-12210 URL: https://issues.apache.org/jira/browse/FLINK-12210 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-12189) Fix bugs and typos in memory management related code

2019-04-15 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12189: - Priority: Critical (was: Major) > Fix bugs and typos in memory management related code > --

[jira] [Commented] (FLINK-12204) Improve JDBCOutputFormat ClassCastException

2019-04-15 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818567#comment-16818567 ] Liya Fan commented on FLINK-12204: -- [~hequn8128], thanks for your fast response. Please

[jira] [Commented] (FLINK-12204) Improve JDBCOutputFormat ClassCastException

2019-04-15 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818499#comment-16818499 ] Liya Fan commented on FLINK-12204: -- I vote for this issue, because it helps debugging.

[jira] [Commented] (FLINK-12187) wrap FileWriter with BufferedWriter for better performance

2019-04-15 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817620#comment-16817620 ] Liya Fan commented on FLINK-12187: -- [~bd2019us], thanks for opening this issue. Could y

[jira] [Updated] (FLINK-12189) Fix bugs and typos in memory management related code

2019-04-15 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12189: - Summary: Fix bugs and typos in memory management related code (was: Fix bugs and typos in memory manage

[jira] [Created] (FLINK-12189) Fix bugs and typos in memory management related classes

2019-04-14 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12189: Summary: Fix bugs and typos in memory management related classes Key: FLINK-12189 URL: https://issues.apache.org/jira/browse/FLINK-12189 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-12162) Build error in flink-table-planner

2019-04-11 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815361#comment-16815361 ] Liya Fan commented on FLINK-12162: -- Hi [~dawidwys], thanks for your comments. This prob

[jira] [Commented] (FLINK-10929) Add support for Apache Arrow

2019-04-11 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815264#comment-16815264 ] Liya Fan commented on FLINK-10929: -- Hi [~fhueske], thank you for your kind reply. I agr

[jira] [Commented] (FLINK-12162) Build error in flink-table-planner

2019-04-11 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815229#comment-16815229 ] Liya Fan commented on FLINK-12162: -- Hi [~dawidwys], thanks a lot for your kind reminder

[jira] [Updated] (FLINK-12162) Build error in flink-table-planner

2019-04-11 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-12162: - Description: There is a build error in project flink-table-planner: [ERROR] Failed to execute goal org

[jira] [Created] (FLINK-12162) Build error in flink-table-planner

2019-04-11 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12162: Summary: Build error in flink-table-planner Key: FLINK-12162 URL: https://issues.apache.org/jira/browse/FLINK-12162 Project: Flink Issue Type: Bug Componen

[jira] [Comment Edited] (FLINK-10929) Add support for Apache Arrow

2019-04-11 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815155#comment-16815155 ] Liya Fan edited comment on FLINK-10929 at 4/11/19 7:45 AM: --- Hi

[jira] [Commented] (FLINK-10929) Add support for Apache Arrow

2019-04-11 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815155#comment-16815155 ] Liya Fan commented on FLINK-10929: -- Hi [~yanghua], thank you so much for your feedback.

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

2019-04-10 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815127#comment-16815127 ] Liya Fan commented on FLINK-11799: -- Hi [~longtimer], thanks a lot for your feedback. I

[jira] [Commented] (FLINK-10929) Add support for Apache Arrow

2019-04-10 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815009#comment-16815009 ] Liya Fan commented on FLINK-10929: -- We have imported Arrow in our efforts to vectorize

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

2019-04-10 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-11799: Assignee: Liya Fan > KryoSerializer/OperatorChain ignores copy failure resulting in > NullPointe

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

2019-04-10 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814396#comment-16814396 ] Liya Fan commented on FLINK-3685: - Hi [~bowen.zheng], thank you for opening this issue. T

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

2019-04-10 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814248#comment-16814248 ] Liya Fan commented on FLINK-11799: -- Hi Jason, thanks for opening this issue. For proble

[jira] [Commented] (FLINK-12153) 提交flink job到flink环境下报错

2019-04-10 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814230#comment-16814230 ] Liya Fan commented on FLINK-12153: -- According to the error message, your hadoop is outd

[jira] [Commented] (FLINK-10130) How to define two hdfs name-node IPs in flink-conf.yaml file

2019-04-09 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814097#comment-16814097 ] Liya Fan commented on FLINK-10130: -- [~Paul Lin] is right. HDFS name service solves the

[jira] [Updated] (FLINK-10391) MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils

2019-04-09 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-10391: - Attachment: image-2019-04-10-13-54-13-788.png > MillisOfDay is used in place of instant for LocalTime ct

[jira] [Commented] (FLINK-10391) MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils

2019-04-09 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814075#comment-16814075 ] Liya Fan commented on FLINK-10391: -- The current implementation already uses  org.joda.t

  1   2   >