[jira] [Updated] (FLINK-11421) Providing more compilation options for code-generated operators

2019-01-27 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-11421: - Labels: pull-request-available (was: ) > Providing more compilation options for code-generated

[jira] [Commented] (FLINK-10725) Support for Java 11 (LTS)

2019-04-03 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16809487#comment-16809487 ] Liya Fan commented on FLINK-10725: -- Is anyone looking at this issue? > Support for Java 11 (LTS) >

[jira] [Commented] (FLINK-12102) FlinkILoopTest fails on Java 9

2019-04-03 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16809493#comment-16809493 ] Liya Fan commented on FLINK-12102: -- Does Java 11 also have this problem? > FlinkILoopTest fails on

[jira] [Commented] (FLINK-3273) Remove Scala dependency from flink-streaming-java

2019-04-03 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16809495#comment-16809495 ] Liya Fan commented on FLINK-3273: - Hi [~mxm], would you please help explain what you mean by "add a Scala

[jira] [Commented] (FLINK-3273) Remove Scala dependency from flink-streaming-java

2019-04-04 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16809581#comment-16809581 ] Liya Fan commented on FLINK-3273: - Hi [~dawidwys], thank you so much for your feedback. So what is the

[jira] [Commented] (FLINK-3273) Remove Scala dependency from flink-streaming-java

2019-04-04 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16809672#comment-16809672 ] Liya Fan commented on FLINK-3273: - Hi [~mxm], thanks a lot for the detailed explanation. To resolve this

[jira] [Commented] (FLINK-3273) Remove Scala dependency from flink-streaming-java

2019-04-04 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16809692#comment-16809692 ] Liya Fan commented on FLINK-3273: - [~dawidwys] I see. This issue can only be resolved with large

[jira] [Commented] (FLINK-4859) Clearly Separate Responsibilities of StreamOperator and StreamTask

2019-04-07 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812032#comment-16812032 ] Liya Fan commented on FLINK-4859: - Hi [~aljoscha], would you please give more descriptions about this

[jira] [Commented] (FLINK-10684) Improve the CSV reading process

2019-04-07 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812036#comment-16812036 ] Liya Fan commented on FLINK-10684: -- In my opinion, it may be reasonable not to print invalid lines,

[jira] [Commented] (FLINK-11964) Avoid hash collision of partition and bucket in HybridHashTable in Blink SQL

2019-04-07 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812085#comment-16812085 ] Liya Fan commented on FLINK-11964: -- Hi [~lzljs3620320], this is a good point, because the selection of

[jira] [Commented] (FLINK-4785) Flink string parser doesn't handle string fields containing two consecutive double quotes

2019-04-07 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812098#comment-16812098 ] Liya Fan commented on FLINK-4785: - Hi [~f.pompermaier], it seems the url is no longer valid. Does this

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

2019-02-20 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772937#comment-16772937 ] Liya Fan commented on FLINK-11421: -- [~ykt836] Closed. Thanks for the reminder. > Add compilation

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

2019-02-19 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772585#comment-16772585 ] Liya Fan commented on FLINK-11421: -- Hi Kurt Young, thank you so much for your attention. I understand

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

2019-02-20 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772760#comment-16772760 ] Liya Fan commented on FLINK-11421: -- [~ykt836] I see. Thanks a lot for the comments. I will work on this

[jira] [Created] (FLINK-11421) Providing more compilation options for code-generated operators

2019-01-23 Thread Liya Fan (JIRA)
Liya Fan created FLINK-11421: Summary: Providing more compilation options for code-generated operators Key: FLINK-11421 URL: https://issues.apache.org/jira/browse/FLINK-11421 Project: Flink

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

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

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

[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=16815009#comment-16815009 ] Liya Fan commented on FLINK-10929: -- We have imported Arrow in our efforts to vectorize Blink batch

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

2019-04-09 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-10929: - Attachment: image-2019-04-10-13-43-08-107.png > Add support for Apache Arrow >

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

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

[jira] [Commented] (FLINK-11831) Separate CodeGeneratorContext for different generation targets

2019-04-09 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813998#comment-16813998 ] Liya Fan commented on FLINK-11831: -- Hi [~ykt836], thank you for opening this issue. I think this is a

[jira] [Commented] (FLINK-5428) Decrease restart delay in RecoveryITCase

2019-04-09 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814037#comment-16814037 ] Liya Fan commented on FLINK-5428: - Now this UT can be finished in 3s, so this issue can be closed. >

[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

[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=16814075#comment-16814075 ] Liya Fan commented on FLINK-10391: -- The current implementation already uses 

[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=16815155#comment-16815155 ] Liya Fan commented on FLINK-10929: -- Hi [~yanghua], thank you so much for your feedback. Below is an

[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=16815361#comment-16815361 ] Liya Fan commented on FLINK-12162: -- Hi [~dawidwys], thanks for your comments. This problem is triggered

[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=16815155#comment-16815155 ] Liya Fan edited comment on FLINK-10929 at 4/11/19 7:45 AM: --- Hi [~yanghua],

[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

[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=16815264#comment-16815264 ] Liya Fan commented on FLINK-10929: -- Hi [~fhueske], thank you for your kind reply. I agree with most

[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=16815229#comment-16815229 ] Liya Fan commented on FLINK-12162: -- Hi [~dawidwys], thanks a lot for your kind reminder. I checked the

[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

[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=16814230#comment-16814230 ] Liya Fan commented on FLINK-12153: -- According to the error message, your hadoop is outdated.  Please

[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=16814248#comment-16814248 ] Liya Fan commented on FLINK-11799: -- Hi Jason, thanks for opening this issue. For problem 1), I don't

[jira] [Commented] (FLINK-4785) Flink string parser doesn't handle string fields containing two consecutive double quotes

2019-04-08 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812955#comment-16812955 ] Liya Fan commented on FLINK-4785: - [~f.pompermaier] Thanks for the information. I can also access it now.

[jira] [Commented] (FLINK-10725) Support for Java 11 (LTS)

2019-04-08 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812950#comment-16812950 ] Liya Fan commented on FLINK-10725: -- [~aljoscha] Thanks a lot for the information.  [~Zentol] If there

[jira] [Assigned] (FLINK-12102) FlinkILoopTest fails on Java 9

2019-04-09 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12102: Assignee: Liya Fan > FlinkILoopTest fails on Java 9 > -- > >

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

2019-04-15 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:

[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

[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=16817620#comment-16817620 ] Liya Fan commented on FLINK-12187: -- [~bd2019us], thanks for opening this issue. Could you please give

[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=16818567#comment-16818567 ] Liya Fan commented on FLINK-12204: -- [~hequn8128], thanks for your fast response. Please go ahead and

[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=16818499#comment-16818499 ] Liya Fan commented on FLINK-12204: -- I vote for this issue, because it helps debugging. If no one else

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

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

[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=16819706#comment-16819706 ] Liya Fan commented on FLINK-12189: -- To make the PR easier to understand to review, I have split the

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

[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

[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=16848865#comment-16848865 ] Liya Fan commented on FLINK-12620: -- [~mikekap] Thank you for finding this problem. Would you please

[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=16849567#comment-16849567 ] Liya Fan commented on FLINK-12620: -- [~mikekap], thanks for providing additional details.  I don't

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

[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=16854154#comment-16854154 ] Liya Fan commented on FLINK-12701: -- Hi [~josh.bradt], thanks for reporting this problem. This seems a

[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

[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=16850307#comment-16850307 ] Liya Fan commented on FLINK-12620: -- [~mikekap], thanks for the clarification. Would you please give

[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] [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-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-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] [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] [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:

[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=16861775#comment-16861775 ] Liya Fan commented on FLINK-12811: -- I tried two different versions of JDK1.8, but could not reproduce

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

[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=16868251#comment-16868251 ] Liya Fan commented on FLINK-12886: -- [~ykt836] [~lzljs3620320], two ideas to resolve the performance

[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=16868500#comment-16868500 ] Liya Fan commented on FLINK-12886: -- [~ykt836], thanks a lot for your feedback. If we chose option 2, I

[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=16868505#comment-16868505 ] Liya Fan commented on FLINK-12886: -- [~lzljs3620320], thanks for your feedback and suggestion. The

[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=16867398#comment-16867398 ] Liya Fan commented on FLINK-12886: -- Hi [~lzljs3620320], thanks for your comments. Please see my

[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=16867424#comment-16867424 ] Liya Fan commented on FLINK-12886: -- [~ykt836] Thanks a lot for the article. I will take a look. >

[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=16869126#comment-16869126 ] Liya Fan commented on FLINK-12886: -- [~ykt836], [~lzljs3620320] Another advantage I can think of is

[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=16869126#comment-16869126 ] Liya Fan edited comment on FLINK-12886 at 6/21/19 3:27 AM: --- [~ykt836],

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

2019-06-21 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:

[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

[jira] [Assigned] (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: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-22 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] [Assigned] (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:all-tabpanel ] Liya Fan reassigned FLINK-12319: Assignee: Liya Fan > StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer >

[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=16845566#comment-16845566 ] Liya Fan commented on FLINK-12319: -- Hi [~mpf], thank you for your feedback. I am looking at this issue.

[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=16845757#comment-16845757 ] Liya Fan commented on FLINK-12319: -- [~mpf] The problem has been fixed by our

[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

[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=16846381#comment-16846381 ] Liya Fan commented on FLINK-12586: -- Hi [~shinhira_kazunori], thanks for finding this problem. I have

[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=16846399#comment-16846399 ] Liya Fan commented on FLINK-12593: -- Hi [~jark], thank you so much for sharing the good news and the

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

[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] [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=16826677#comment-16826677 ] Liya Fan edited comment on FLINK-10929 at 4/30/19 3:01 AM: --- Hi [Stephan

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

[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=16821637#comment-16821637 ] Liya Fan commented on FLINK-12259: -- [~quan], thanks a lot for the comments. [~gauravtiwari89], I have

[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=16833664#comment-16833664 ] Liya Fan commented on FLINK-11421: -- Hi [~lzljs3620320], thanks a lot for your information. Can I

[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=16833687#comment-16833687 ] Liya Fan commented on FLINK-11421: -- [~lzljs3620320] Thanks a lot for your confirm. >> I think we

[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

[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] [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:

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

[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

[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

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

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

[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=16822827#comment-16822827 ] Liya Fan commented on FLINK-12279: -- Hi [~Wosinsan], thanks for opening this isssue. Would you please

[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=16823638#comment-16823638 ] Liya Fan commented on FLINK-12115: -- I vote for this issue, because it enhances the portability of

[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=16825624#comment-16825624 ] Liya Fan commented on FLINK-12319: -- Hi [~mpf], thank you for opening this issue. It seems like a bug

  1   2   >