[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938252#comment-16938252 ] Jingsong Lee commented on FLINK-13740: -- For #1, I mean BinaryGeneric still extends BinaryFormat and

[jira] [Updated] (FLINK-14254) Introduce BatchFileSystemSink

2019-09-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14254: - Summary: Introduce BatchFileSystemSink (was: Introduce FileSystemOutputFormat) > Introduce

[jira] [Created] (FLINK-14255) Introduce StreamingFileSystemSink

2019-09-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14255: Summary: Introduce StreamingFileSystemSink Key: FLINK-14255 URL: https://issues.apache.org/jira/browse/FLINK-14255 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-14254) Introduce BatchFileSystemSink

2019-09-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14254: - Description: Introduce BatchFileSystemSink to support all table file system connector with

[jira] [Updated] (FLINK-14249) Rework table partition support

2019-09-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14249: - Description: A partition is a division of a logical database or its constituent elements into

[jira] [Created] (FLINK-14257) Integrate csv to FileSystemTableFactory

2019-09-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14257: Summary: Integrate csv to FileSystemTableFactory Key: FLINK-14257 URL: https://issues.apache.org/jira/browse/FLINK-14257 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14258) Integrate hive to FileSystemTableFactory

2019-09-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14258: Summary: Integrate hive to FileSystemTableFactory Key: FLINK-14258 URL: https://issues.apache.org/jira/browse/FLINK-14258 Project: Flink Issue Type:

[jira] [Created] (FLINK-14256) Introduce FileSystemTableFactory

2019-09-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14256: Summary: Introduce FileSystemTableFactory Key: FLINK-14256 URL: https://issues.apache.org/jira/browse/FLINK-14256 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14253) Add hash distribution and sort grouping only when dynamic partition insert

2019-09-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14253: Summary: Add hash distribution and sort grouping only when dynamic partition insert Key: FLINK-14253 URL: https://issues.apache.org/jira/browse/FLINK-14253 Project:

[jira] [Created] (FLINK-14254) Introduce FileSystemOutputFormat

2019-09-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14254: Summary: Introduce FileSystemOutputFormat Key: FLINK-14254 URL: https://issues.apache.org/jira/browse/FLINK-14254 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-12263) Remove SINGLE_VALUE aggregate function from physical plan

2019-09-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-12263. Resolution: Invalid > Remove SINGLE_VALUE aggregate function from physical plan >

[jira] [Closed] (FLINK-11490) Add an initial Blink SQL batch runtime

2019-09-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-11490. Resolution: Fixed > Add an initial Blink SQL batch runtime >

[jira] [Commented] (FLINK-12263) Remove SINGLE_VALUE aggregate function from physical plan

2019-09-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939104#comment-16939104 ] Jingsong Lee commented on FLINK-12263: -- SINGLE_VALUE is useful for "select * from A where a =

[jira] [Commented] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails

2019-09-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936860#comment-16936860 ] Jingsong Lee commented on FLINK-14173: -- Hi [~BenoitParis] , the different semantics is:

[jira] [Created] (FLINK-14249) Rework table partition support

2019-09-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14249: Summary: Rework table partition support Key: FLINK-14249 URL: https://issues.apache.org/jira/browse/FLINK-14249 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938201#comment-16938201 ] Jingsong Lee commented on FLINK-13740: -- Yes, A thorough solution is BinaryGeneric should never

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938206#comment-16938206 ] Jingsong Lee commented on FLINK-13740: -- 1.Let BinaryGeneric not extends LazyBinaryFormat 2.All

[jira] [Commented] (FLINK-14080) Support precision of TimestampType

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938237#comment-16938237 ] Jingsong Lee commented on FLINK-14080: -- [~jark] Can you assign this ticket to [~docete] ? >

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938238#comment-16938238 ] Jingsong Lee commented on FLINK-13740: -- Let me clear the solutions: 1.Let BinaryGeneric not

[jira] [Created] (FLINK-13089) Implement batch nested loop join in blink

2019-07-03 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-13089: Summary: Implement batch nested loop join in blink Key: FLINK-13089 URL: https://issues.apache.org/jira/browse/FLINK-13089 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-13089) Implement batch nested loop join in blink

2019-07-03 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13089: - Description: Nested loop join has two advantages: 1.Nested loop join is quicker when build row

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962935#comment-16962935 ] Jingsong Lee commented on FLINK-13740: -- Hi [~jark], Have we reached an agreement? Can you assign

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962940#comment-16962940 ] Jingsong Lee commented on FLINK-13702: -- BinaryLazyFormat is designed for single threaded context.

[jira] [Commented] (FLINK-14488) Update python table API with temporary objects methods

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962795#comment-16962795 ] Jingsong Lee commented on FLINK-14488: -- I think `createTempFunction` in TableEnvironment need wait

[jira] [Updated] (FLINK-13869) Hive functions can not work in blink planner stream mode

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13869: - Environment: (was: method call stack:

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962943#comment-16962943 ] Jingsong Lee commented on FLINK-13702: -- I think this Jira is not production bug, it is a test bug.

[jira] [Updated] (FLINK-13869) Hive functions can not work in blink planner stream mode

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13869: - Description: In flink, specifying the StreamTableEnvironment through the EnvironmentSetting

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962929#comment-16962929 ] Jingsong Lee commented on FLINK-13702: -- Thanks [~dwysakowicz], nice analysis, you are right.

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962929#comment-16962929 ] Jingsong Lee edited comment on FLINK-13702 at 10/30/19 11:06 AM: - Thanks

[jira] [Created] (FLINK-14595) Move flink-orc to flink-formats from flink-connectors

2019-11-03 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14595: Summary: Move flink-orc to flink-formats from flink-connectors Key: FLINK-14595 URL: https://issues.apache.org/jira/browse/FLINK-14595 Project: Flink Issue

[jira] [Commented] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

2019-11-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971408#comment-16971408 ] Jingsong Lee commented on FLINK-14676: -- Hi [~jark], the parallelism of StreamTableSource need be

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962952#comment-16962952 ] Jingsong Lee commented on FLINK-13740: -- Hi [~dwysakowicz] , are you interested in fixing it? We all

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-11-01 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964605#comment-16964605 ] Jingsong Lee edited comment on FLINK-13702 at 11/1/19 6:31 AM: ---

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-11-01 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964662#comment-16964662 ] Jingsong Lee commented on FLINK-13702: -- Hi [~dwysakowicz] [~jark], Let me summarize the current

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964605#comment-16964605 ] Jingsong Lee commented on FLINK-13702: -- [~dwysakowicz] yes, it depends on our CodeGen or runtime

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964605#comment-16964605 ] Jingsong Lee edited comment on FLINK-13702 at 11/1/19 5:21 AM: ---

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963600#comment-16963600 ] Jingsong Lee commented on FLINK-13702: -- Thanks [~jark] 's input. It's true that there are multiple

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963600#comment-16963600 ] Jingsong Lee edited comment on FLINK-13702 at 10/31/19 3:25 AM: Thanks

[jira] [Updated] (FLINK-14735) Improve batch schedule check input consumable performance

2019-11-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14735: - Summary: Improve batch schedule check input consumable performance (was: Improve batch

[jira] [Commented] (FLINK-14735) Improve batch schedule check input consumable performance

2019-11-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973091#comment-16973091 ] Jingsong Lee commented on FLINK-14735: -- CC: [~zhuzh] [~GJL] [~trohrmann] > Improve batch schedule

[jira] [Created] (FLINK-14735) Improve batch schedule performance

2019-11-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14735: Summary: Improve batch schedule performance Key: FLINK-14735 URL: https://issues.apache.org/jira/browse/FLINK-14735 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-14722) Optimize mapred.HadoopInputSplit to not serialize conf when split is not configurable

2019-11-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973098#comment-16973098 ] Jingsong Lee commented on FLINK-14722: -- [~ykt836] [~jark] Can you assign this ticket to me? >

[jira] [Created] (FLINK-14743) Optimize BaseRowSerializer to use Projection instead of switch

2019-11-13 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14743: Summary: Optimize BaseRowSerializer to use Projection instead of switch Key: FLINK-14743 URL: https://issues.apache.org/jira/browse/FLINK-14743 Project: Flink

[jira] [Commented] (FLINK-14808) ClientUtils set thread ClassLoader that is different from the user cl of PackagedProgram

2019-11-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974917#comment-16974917 ] Jingsong Lee commented on FLINK-14808: -- CC: [~kkl0u] [~aljoscha] [~tison] > ClientUtils set thread

[jira] [Commented] (FLINK-14800) Introduce parallelism inference for HiveSource

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974853#comment-16974853 ] Jingsong Lee commented on FLINK-14800: -- PR: [https://github.com/apache/flink/pull/10210] >

[jira] [Commented] (FLINK-14063) Operators use fractions to decide how many managed memory to allocate

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974870#comment-16974870 ] Jingsong Lee commented on FLINK-14063: -- [~ykt836] Can you assign this ticket to me? > Operators

[jira] [Created] (FLINK-14802) Multi vectorized read version support for hive orc read

2019-11-14 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14802: Summary: Multi vectorized read version support for hive orc read Key: FLINK-14802 URL: https://issues.apache.org/jira/browse/FLINK-14802 Project: Flink

[jira] [Created] (FLINK-14808) ClientUtils set thread ClassLoader that is different from the user cl of PackagedProgram

2019-11-15 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14808: Summary: ClientUtils set thread ClassLoader that is different from the user cl of PackagedProgram Key: FLINK-14808 URL: https://issues.apache.org/jira/browse/FLINK-14808

[jira] [Commented] (FLINK-14808) ClientUtils set thread ClassLoader that is different from the user cl of PackagedProgram

2019-11-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976226#comment-16976226 ] Jingsong Lee commented on FLINK-14808: -- [~kkl0u] Yes, please assign to me. > ClientUtils set

[jira] [Commented] (FLINK-14722) Optimize mapred.HadoopInputSplit to not serialize conf when split is not configurable

2019-11-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972307#comment-16972307 ] Jingsong Lee commented on FLINK-14722: -- It defines writeObject and readObject for java

[jira] [Updated] (FLINK-14721) HiveTableSource should implement LimitableTableSource interface

2019-11-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14721: - Parent: FLINK-14133 Issue Type: Sub-task (was: Improvement) > HiveTableSource should

[jira] [Created] (FLINK-14722) Optimize mapred.HadoopInputSplit to not serialize conf when split is not configurable

2019-11-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14722: Summary: Optimize mapred.HadoopInputSplit to not serialize conf when split is not configurable Key: FLINK-14722 URL: https://issues.apache.org/jira/browse/FLINK-14722

[jira] [Commented] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

2019-11-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972052#comment-16972052 ] Jingsong Lee commented on FLINK-14676: -- Let me give more background: 1. our goal of 1.10  is to be

[jira] [Updated] (FLINK-14710) Decide column nullability according to Hive constraints

2019-11-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14710: - Parent: FLINK-14133 Issue Type: Sub-task (was: Improvement) > Decide column

[jira] [Updated] (FLINK-14722) Optimize mapred.HadoopInputSplit to not serialize conf when split is not configurable

2019-11-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14722: - Parent: FLINK-14133 Issue Type: Sub-task (was: Improvement) > Optimize

[jira] [Updated] (FLINK-14656) blink planner should also fetch catalog statistics for permanent CatalogTableImpl

2019-11-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14656: - Parent: FLINK-14133 Issue Type: Sub-task (was: Bug) > blink planner should also fetch

[jira] [Updated] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

2019-11-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14676: - Parent: FLINK-14133 Issue Type: Sub-task (was: New Feature) > Introduce parallelism

[jira] [Commented] (FLINK-14735) Improve batch schedule check input consumable performance

2019-11-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975119#comment-16975119 ] Jingsong Lee commented on FLINK-14735: -- Thanks [~sewen] for spotting, got it, "heartbeat.timeout"

[jira] [Commented] (FLINK-14808) ClientUtils set thread ClassLoader that is different from the user cl of PackagedProgram

2019-11-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975570#comment-16975570 ] Jingsong Lee commented on FLINK-14808: -- Thanks [~kkl0u] > ClientUtils set thread ClassLoader that

[jira] [Commented] (FLINK-14808) ClientUtils set thread ClassLoader that is different from the user cl of PackagedProgram

2019-11-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975571#comment-16975571 ] Jingsong Lee commented on FLINK-14808: -- [~kkl0u] Do you think we should add a test to cover this

[jira] [Updated] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14676: - Fix Version/s: (was: 1.10.0) > Introduce parallelism inference for InputFormatTableSource >

[jira] [Updated] (FLINK-14133) Improve batch sql and hive integrate performance milestone-1

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14133: - Summary: Improve batch sql and hive integrate performance milestone-1 (was: Improve batch sql

[jira] [Updated] (FLINK-14676) Introduce parallelism inference for source

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14676: - Summary: Introduce parallelism inference for source (was: Introduce parallelism inference for

[jira] [Created] (FLINK-14799) Improve batch sql and hive integrate performance milestone-2

2019-11-14 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14799: Summary: Improve batch sql and hive integrate performance milestone-2 Key: FLINK-14799 URL: https://issues.apache.org/jira/browse/FLINK-14799 Project: Flink

[jira] [Created] (FLINK-14800) Introduce parallelism inference for HiveSource

2019-11-14 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14800: Summary: Introduce parallelism inference for HiveSource Key: FLINK-14800 URL: https://issues.apache.org/jira/browse/FLINK-14800 Project: Flink Issue Type:

[jira] [Updated] (FLINK-14676) Introduce parallelism inference for source

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14676: - Parent: (was: FLINK-14133) Issue Type: Improvement (was: Sub-task) > Introduce

[jira] [Updated] (FLINK-14676) Introduce parallelism inference for source

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14676: - Parent: FLINK-14799 Issue Type: Sub-task (was: New Feature) > Introduce parallelism

[jira] [Updated] (FLINK-14676) Introduce parallelism inference for source

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14676: - Issue Type: New Feature (was: Improvement) > Introduce parallelism inference for source >

[jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14148: - Parent: (was: FLINK-14133) Issue Type: Improvement (was: Sub-task) > Investigate

[jira] [Updated] (FLINK-14515) Implement LimitableTableSource for FileSystemTableFactory

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14515: - Parent: FLINK-14799 Issue Type: Sub-task (was: New Feature) > Implement

[jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14148: - Parent: FLINK-14799 Issue Type: Sub-task (was: Improvement) > Investigate pushing

[jira] [Updated] (FLINK-14515) Implement LimitableTableSource for FileSystemTableFactory

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14515: - Parent: (was: FLINK-14133) Issue Type: New Feature (was: Sub-task) > Implement

[jira] [Updated] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11899: - Parent: (was: FLINK-14133) Issue Type: Improvement (was: Sub-task) > Introduce

[jira] [Updated] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11899: - Parent: FLINK-14799 Issue Type: Sub-task (was: Improvement) > Introduce vectorized

[jira] [Updated] (FLINK-14133) Improve batch sql and hive integrate performance milestone-1

2019-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14133: - Fix Version/s: 1.10.0 > Improve batch sql and hive integrate performance milestone-1 >

[jira] [Commented] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-11-04 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966632#comment-16966632 ] Jingsong Lee commented on FLINK-14243: -- Hi [~jackylau] Can you share the code of GetJsonObject?  I

[jira] [Comment Edited] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-11-04 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966632#comment-16966632 ] Jingsong Lee edited comment on FLINK-14243 at 11/4/19 12:39 PM: Hi

[jira] [Commented] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time

2019-11-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970070#comment-16970070 ] Jingsong Lee commented on FLINK-14674: -- Hi [~Leonard Xu] Will hang forever? Can you show the stack?

[jira] [Commented] (FLINK-14662) Distinguish unknown table stats and zero

2019-11-07 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969748#comment-16969748 ] Jingsong Lee commented on FLINK-14662: -- I think we have already used -1 to UNKNOWN: {code:java}

[jira] [Created] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

2019-11-08 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14676: Summary: Introduce parallelism inference for InputFormatTableSource Key: FLINK-14676 URL: https://issues.apache.org/jira/browse/FLINK-14676 Project: Flink

[jira] [Updated] (FLINK-14848) BaseRowSerializer.toBinaryRow wrongly process null for non-compact decimal

2019-11-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14848: - Summary: BaseRowSerializer.toBinaryRow wrongly process null for non-compact decimal (was:

[jira] [Updated] (FLINK-14872) Potential deadlock for task reading from blocking ResultPartition.

2019-11-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14872: - Priority: Blocker (was: Major) > Potential deadlock for task reading from blocking

[jira] [Created] (FLINK-15049) Compile bug when hash join with timestamp type key

2019-12-03 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-15049: Summary: Compile bug when hash join with timestamp type key Key: FLINK-15049 URL: https://issues.apache.org/jira/browse/FLINK-15049 Project: Flink Issue

[jira] [Created] (FLINK-15050) DataFormatConverters will fail when timestamp type precision more than 3

2019-12-03 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-15050: Summary: DataFormatConverters will fail when timestamp type precision more than 3 Key: FLINK-15050 URL: https://issues.apache.org/jira/browse/FLINK-15050 Project:

[jira] [Commented] (FLINK-14063) Operators use fractions to decide how many managed memory to allocate

2019-12-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986783#comment-16986783 ] Jingsong Lee commented on FLINK-14063: -- Hi [~chesnay], PR ready now. [~ykt836] will review it. >

[jira] [Created] (FLINK-15035) Introduce unknown memory setting to table in blink planner

2019-12-03 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-15035: Summary: Introduce unknown memory setting to table in blink planner Key: FLINK-15035 URL: https://issues.apache.org/jira/browse/FLINK-15035 Project: Flink

[jira] [Updated] (FLINK-14860) Provide a new InputSplitAssigner that consider page cache utilization ratio

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14860: - Parent: FLINK-14799 Issue Type: Sub-task (was: New Feature) > Provide a new

[jira] [Updated] (FLINK-14860) Provide a new InputSplitAssigner that consider page cache utilization ratio

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14860: - Parent: (was: FLINK-14133) Issue Type: New Feature (was: Sub-task) > Provide a new

[jira] [Closed] (FLINK-5832) Support for simple hive UDF

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-5832. --- Resolution: Fixed > Support for simple hive UDF > --- > >

[jira] [Closed] (FLINK-5834) Support for Hive User-defined Table-generating Function (UDTF)

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-5834. --- Resolution: Fixed > Support for Hive User-defined Table-generating Function (UDTF) >

[jira] [Closed] (FLINK-5833) Support for Hive GenericUDF

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-5833. --- Resolution: Fixed > Support for Hive GenericUDF > --- > >

[jira] [Commented] (FLINK-14063) Operators use fractions to decide how many managed memory to allocate

2019-12-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986839#comment-16986839 ] Jingsong Lee commented on FLINK-14063: -- Hang up this ticket until FLINK-15023 done. > Operators

[jira] [Commented] (FLINK-5833) Support for Hive GenericUDF

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986545#comment-16986545 ] Jingsong Lee commented on FLINK-5833: - Hi [~fhueske]  [~miaoever] because we have supported it in

[jira] [Commented] (FLINK-5832) Support for simple hive UDF

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986544#comment-16986544 ] Jingsong Lee commented on FLINK-5832: - Hi [~miaoever] [~twalthr] [~xuefu] , because we have supported

[jira] [Commented] (FLINK-10556) Integration with Apache Hive

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986552#comment-16986552 ] Jingsong Lee commented on FLINK-10556: -- Hi [~xuefuz] [~phoenixjiangnan], we have already done many

[jira] [Commented] (FLINK-10719) Add user documentation for Flink-Hive integration

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986551#comment-16986551 ] Jingsong Lee commented on FLINK-10719: -- Hi [~phoenixjiangnan], We already have documents related to

[jira] [Closed] (FLINK-10556) Integration with Apache Hive

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-10556. Resolution: Fixed > Integration with Apache Hive > > >

[jira] [Commented] (FLINK-14517) Handle escape characters for partition path

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986646#comment-16986646 ] Jingsong Lee commented on FLINK-14517: -- Yes, it is. > Handle escape characters for partition path

[jira] [Closed] (FLINK-14517) Handle escape characters for partition path

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-14517. Resolution: Fixed > Handle escape characters for partition path >

[jira] [Updated] (FLINK-15003) Improve hive test performance

2019-12-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15003: - Summary: Improve hive test performance (was: Use embedded mode to improve hive test

<    1   2   3   4   5   6   7   8   9   10   >