[jira] [Created] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-02 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-10036: --- Summary: Flink's CSV output format is not consistent with the standard. Key: FLINK-10036 URL: https://issues.apache.org/jira/browse/FLINK-10036 Project: Flink

[jira] [Updated] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-02 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-10036: Description: h2. What's the problem Flink's CSV output format is not consistent with the

[jira] [Updated] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-02 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-10036: Description: h2. What's the problem Flink's CSV output format is not consistent with the

[jira] [Created] (FLINK-13198) Introduce TimeLength in configuration package

2019-07-10 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13198: --- Summary: Introduce TimeLength in configuration package Key: FLINK-13198 URL: https://issues.apache.org/jira/browse/FLINK-13198 Project: Flink Issue Type:

[jira] [Updated] (FLINK-13198) Introduce TimeInterval in configuration package

2019-07-11 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13198: Description: Similar with MemorySize in the configuration package, we also need to introduce a

[jira] [Updated] (FLINK-13198) Introduce TimeUtils with parsing method

2019-07-11 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13198: Description: We need a parse function to parse strings like "123ms", "321s", "12min" and such,

[jira] [Created] (FLINK-13236) Fix bug and improve performance in TopNBuffer

2019-07-11 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13236: --- Summary: Fix bug and improve performance in TopNBuffer Key: FLINK-13236 URL: https://issues.apache.org/jira/browse/FLINK-13236 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-13259) Typo in PojoComparator

2019-07-15 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-13259: --- Assignee: Caizhi Weng > Typo in PojoComparator > -- > >

[jira] [Commented] (FLINK-13261) Typo in ReOpenableHashTableITCase

2019-07-15 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884952#comment-16884952 ] Caizhi Weng commented on FLINK-13261: - I discover many other typos about accessor. Maybe it's better

[jira] [Assigned] (FLINK-13261) Typo in ReOpenableHashTableITCase

2019-07-15 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-13261: --- Assignee: Caizhi Weng > Typo in ReOpenableHashTableITCase >

[jira] [Updated] (FLINK-13259) Typos about "access"

2019-07-15 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13259: Description: Typo in PojoComparator, FieldAccessor, HashTableITCase, ReOpenableHashTableITCase, 

[jira] [Comment Edited] (FLINK-13261) Typo in ReOpenableHashTableITCase

2019-07-15 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884952#comment-16884952 ] Caizhi Weng edited comment on FLINK-13261 at 7/15/19 9:24 AM: -- I discover

[jira] [Created] (FLINK-13258) Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator

2019-07-15 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13258: --- Summary: Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator Key: FLINK-13258 URL: https://issues.apache.org/jira/browse/FLINK-13258 Project:

[jira] [Created] (FLINK-13490) Fix return null in JDBCUtils::getFieldFromResultSet

2019-07-29 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13490: --- Summary: Fix return null in JDBCUtils::getFieldFromResultSet Key: FLINK-13490 URL: https://issues.apache.org/jira/browse/FLINK-13490 Project: Flink Issue

[jira] [Created] (FLINK-13880) The behavior of JobExecutionResult.getAccumulatorResult does not match its java doc

2019-08-27 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-13880: --- Summary: The behavior of JobExecutionResult.getAccumulatorResult does not match its java doc Key: FLINK-13880 URL: https://issues.apache.org/jira/browse/FLINK-13880

[jira] [Updated] (FLINK-13438) Fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP support

2019-07-28 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13438: Attachment: 0001-hive.patch > Fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP support >

[jira] [Commented] (FLINK-13438) Fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP support

2019-07-28 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894837#comment-16894837 ] Caizhi Weng commented on FLINK-13438: - Hi [~lirui] [~jark] and [~lzljs3620320], sorry for the late

[jira] [Updated] (FLINK-13283) JDBC source/sink should respect the conversion class of DataType

2019-08-06 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13283: Labels: pull-request-available (was: ) > JDBC source/sink should respect the conversion class of

[jira] [Created] (FLINK-13322) Fix serializer snapshot recovery in BaseArray and BaseMap serializers.

2019-07-18 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13322: --- Summary: Fix serializer snapshot recovery in BaseArray and BaseMap serializers. Key: FLINK-13322 URL: https://issues.apache.org/jira/browse/FLINK-13322 Project: Flink

[jira] [Created] (FLINK-13323) Add tests for complex data formats (generic array, generic map, etc.)

2019-07-18 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13323: --- Summary: Add tests for complex data formats (generic array, generic map, etc.) Key: FLINK-13323 URL: https://issues.apache.org/jira/browse/FLINK-13323 Project: Flink

[jira] [Updated] (FLINK-13323) Add tests for complex data formats

2019-07-18 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13323: Summary: Add tests for complex data formats (was: Add tests for complex data formats (generic

[jira] [Updated] (FLINK-13322) Fix serializer snapshot recovery in BaseArray and BaseMap serializers.

2019-07-18 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13322: Component/s: Table SQL / Runtime > Fix serializer snapshot recovery in BaseArray and BaseMap

[jira] [Updated] (FLINK-13323) Add tests for complex data formats

2019-07-18 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13323: Component/s: Table SQL / Runtime > Add tests for complex data formats >

[jira] [Updated] (FLINK-13322) Fix serializer snapshot recovery in BaseArray and BaseMap serializers.

2019-07-18 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13322: Labels: pull-request-available (was: ) > Fix serializer snapshot recovery in BaseArray and

[jira] [Updated] (FLINK-13323) Add tests for complex data formats

2019-07-18 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13323: Labels: pull-request-available (was: ) > Add tests for complex data formats >

[jira] [Created] (FLINK-13304) Fix implementation of getString and getBinary method in NestedRow

2019-07-17 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13304: --- Summary: Fix implementation of getString and getBinary method in NestedRow Key: FLINK-13304 URL: https://issues.apache.org/jira/browse/FLINK-13304 Project: Flink

[jira] [Created] (FLINK-13410) Csv input format does not support LocalDate

2019-07-24 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13410: --- Summary: Csv input format does not support LocalDate Key: FLINK-13410 URL: https://issues.apache.org/jira/browse/FLINK-13410 Project: Flink Issue Type: Test

[jira] [Updated] (FLINK-13410) Csv input format does not support LocalDate

2019-07-24 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13410: Issue Type: Bug (was: Test) > Csv input format does not support LocalDate >

[jira] [Commented] (FLINK-13410) Csv input format does not support LocalDate

2019-07-24 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892381#comment-16892381 ] Caizhi Weng commented on FLINK-13410: - They are sort of related because they are the same type of

[jira] [Updated] (FLINK-13410) Csv input format does not support LocalDate

2019-07-24 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13410: Issue Type: Sub-task (was: Bug) Parent: FLINK-13285 > Csv input format does not support

[jira] [Created] (FLINK-13438) Fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP support

2019-07-26 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13438: --- Summary: Fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP support Key: FLINK-13438 URL: https://issues.apache.org/jira/browse/FLINK-13438 Project: Flink

[jira] [Created] (FLINK-13348) Table schema is modified when pushing projection to table source

2019-07-22 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-13348: --- Summary: Table schema is modified when pushing projection to table source Key: FLINK-13348 URL: https://issues.apache.org/jira/browse/FLINK-13348 Project: Flink

[jira] [Updated] (FLINK-13348) Table schema is modified when pushing projection to table source

2019-07-22 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13348: Issue Type: Sub-task (was: Test) Parent: FLINK-13285 > Table schema is modified when

[jira] [Updated] (FLINK-13348) ProjectableTableSource is not supported by blink-planner correctly

2019-07-22 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13348: Summary: ProjectableTableSource is not supported by blink-planner correctly (was: Table schema

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

2019-11-15 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974941#comment-16974941 ] Caizhi Weng commented on FLINK-13943: - Hi dear Flink community, I would like to try on this

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

2019-11-18 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976354#comment-16976354 ] Caizhi Weng commented on FLINK-13943: - Hi dear Flink community. My ideas for this improvement are as

[jira] [Comment Edited] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

2019-11-18 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976354#comment-16976354 ] Caizhi Weng edited comment on FLINK-13943 at 11/18/19 8:33 AM: --- Hi dear

[jira] [Commented] (FLINK-14625) Eliminate cross join in multi join to reduce cost

2019-11-12 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973011#comment-16973011 ] Caizhi Weng commented on FLINK-14625: - Hi dear Flink community! I would like to implement this

[jira] [Created] (FLINK-14960) Dependency shading of table modules test fails on Travis

2019-11-26 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-14960: --- Summary: Dependency shading of table modules test fails on Travis Key: FLINK-14960 URL: https://issues.apache.org/jira/browse/FLINK-14960 Project: Flink Issue

[jira] [Updated] (FLINK-14960) Dependency shading of table modules test fails on Travis

2019-11-26 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14960: Labels: test-stability (was: ) > Dependency shading of table modules test fails on Travis >

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

2019-11-24 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981257#comment-16981257 ] Caizhi Weng commented on FLINK-13943: - Thanks for all the feedbacks. I'm going to go with Aljoscha's

[jira] [Commented] (FLINK-14989) Improve efficiency by bitwise operation.

2019-11-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984718#comment-16984718 ] Caizhi Weng commented on FLINK-14989: - Hi Ziqiang, Thanks for the JIRA. Which part are you going

[jira] [Created] (FLINK-14348) YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a fails to delete files

2019-10-08 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-14348: --- Summary: YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a fails to delete files Key: FLINK-14348 URL: https://issues.apache.org/jira/browse/FLINK-14348

[jira] [Updated] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

2019-10-08 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14347: Issue Type: Test (was: Bug) > YARNSessionFIFOITCase.checkForProhibitedLogContents found a log

[jira] [Updated] (FLINK-14348) YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a fails to delete files

2019-10-08 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14348: Issue Type: Test (was: Bug) > YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a fails to

[jira] [Created] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

2019-10-08 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-14347: --- Summary: YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string Key: FLINK-14347 URL: https://issues.apache.org/jira/browse/FLINK-14347

[jira] [Issue Comment Deleted] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-25 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14807: Comment: was deleted (was: Thanks for the comment [~godfreyhe]. I'll list more details about my

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-25 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033373#comment-17033373 ] Caizhi Weng edited comment on FLINK-14807 at 2/26/20 3:51 AM: -- Hi dear

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-25 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033373#comment-17033373 ] Caizhi Weng edited comment on FLINK-14807 at 2/26/20 3:55 AM: -- Hi dear

[jira] [Updated] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-25 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14807: Attachment: (was: table-collect.png) > Add Table#collect api for fetching data to client >

[jira] [Updated] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-25 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14807: Attachment: table-collect.png > Add Table#collect api for fetching data to client >

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-25 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033373#comment-17033373 ] Caizhi Weng edited comment on FLINK-14807 at 2/26/20 4:01 AM: -- Hi dear

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-05 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051891#comment-17051891 ] Caizhi Weng commented on FLINK-14807: - Hi dear Flink community! I've implemented a POC of my

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-05 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051891#comment-17051891 ] Caizhi Weng edited comment on FLINK-14807 at 3/5/20, 8:34 AM: -- Hi dear

[jira] [Updated] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-05 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14807: Attachment: table-collect-draft.patch > Add Table#collect api for fetching data to client >

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-06 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053298#comment-17053298 ] Caizhi Weng edited comment on FLINK-14807 at 3/6/20, 10:56 AM: --- Hi

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-06 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053298#comment-17053298 ] Caizhi Weng commented on FLINK-14807: - Hi [~sewen], Thanks for the reply. I think we might need to

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-24 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044034#comment-17044034 ] Caizhi Weng commented on FLINK-14807: - Thanks for the comment [~godfreyhe]. I'll list more details

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-25 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044034#comment-17044034 ] Caizhi Weng edited comment on FLINK-14807 at 2/25/20 10:24 AM: --- Thanks for

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-02 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049884#comment-17049884 ] Caizhi Weng commented on FLINK-14807: - Hi dear Flink community, After some implementation and

[jira] [Created] (FLINK-15987) SELECT 1.0e0 / 0.0e0 throws NumberFormatException

2020-02-10 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-15987: --- Summary: SELECT 1.0e0 / 0.0e0 throws NumberFormatException Key: FLINK-15987 URL: https://issues.apache.org/jira/browse/FLINK-15987 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033373#comment-17033373 ] Caizhi Weng commented on FLINK-14807: - Hi dear Flink community, I'm digging this up because I have

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033373#comment-17033373 ] Caizhi Weng edited comment on FLINK-14807 at 2/10/20 5:01 AM: -- Hi dear

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033373#comment-17033373 ] Caizhi Weng edited comment on FLINK-14807 at 2/10/20 6:08 AM: -- Hi dear

[jira] [Updated] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14807: Attachment: table-collect.png > Add Table#collect api for fetching data to client >

[jira] [Commented] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014210#comment-17014210 ] Caizhi Weng commented on FLINK-15066: - >From the perspective of a new user, especially a user from

[jira] [Updated] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-15570: Description: Currently we only support inserting into empty csv tables. It would be nice for a

[jira] [Created] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-15570: --- Summary: Support inserting into non-empty csv tables Key: FLINK-15570 URL: https://issues.apache.org/jira/browse/FLINK-15570 Project: Flink Issue Type:

[jira] [Closed] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-15570. --- Resolution: Duplicate > Support inserting into non-empty csv tables >

[jira] [Updated] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-15570: Priority: Major (was: Minor) > Support inserting into non-empty csv tables >

[jira] [Updated] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-15570: Description: Currently we only support inserting into empty csv tables. It would be nice for a

[jira] [Updated] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-15570: Labels: Usability (was: ) > Support inserting into non-empty csv tables >

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056695#comment-17056695 ] Caizhi Weng commented on FLINK-14807: - Hi dear Flink community. After a long offline discussion

[jira] [Commented] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

2020-03-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057605#comment-17057605 ] Caizhi Weng commented on FLINK-15290: - Hi [~lzljs3620320], I also agree that hive source configs

[jira] [Created] (FLINK-16543) Support setting schedule mode by config for Blink planner in batch mode

2020-03-11 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-16543: --- Summary: Support setting schedule mode by config for Blink planner in batch mode Key: FLINK-16543 URL: https://issues.apache.org/jira/browse/FLINK-16543 Project: Flink

[jira] [Updated] (FLINK-16541) Document of table.exec.shuffle-mode is incorrect

2020-03-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-16541: Description: Document of table.exec.shuffle-mode is incorrect. Currently the document states

[jira] [Created] (FLINK-16541) Document of table.exec.shuffle-mode is incorrect

2020-03-11 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-16541: --- Summary: Document of table.exec.shuffle-mode is incorrect Key: FLINK-16541 URL: https://issues.apache.org/jira/browse/FLINK-16541 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-08 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054621#comment-17054621 ] Caizhi Weng commented on FLINK-14807: - Hi [~sewen] What I'm worrying about is not the stress on the

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-12 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058366#comment-17058366 ] Caizhi Weng commented on FLINK-14807: - Hi [~sewen] Our current implementation (through

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-16 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060077#comment-17060077 ] Caizhi Weng edited comment on FLINK-14807 at 3/16/20, 9:54 AM: --- Hi

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-16 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060077#comment-17060077 ] Caizhi Weng commented on FLINK-14807: - Hi [~sewen] The client receives the data through REST calls

[jira] [Updated] (FLINK-17081) Batch test classes in Blink planner does not extend TestLogger

2020-04-10 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-17081: Labels: pull-request-available (was: ) > Batch test classes in Blink planner does not extend

[jira] [Created] (FLINK-17081) Batch test classes in Blink planner does not extend TestLogger

2020-04-10 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-17081: --- Summary: Batch test classes in Blink planner does not extend TestLogger Key: FLINK-17081 URL: https://issues.apache.org/jira/browse/FLINK-17081 Project: Flink

[jira] [Updated] (FLINK-17083) Restrict users of accumulators not to return null in Accumulator#getLocalValue

2020-04-10 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-17083: Description: [This discussion|https://issues.apache.org/jira/browse/FLINK-13880] raises a

[jira] [Commented] (FLINK-13880) The behavior of JobExecutionResult.getAccumulatorResult does not match its java doc

2020-04-10 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080356#comment-17080356 ] Caizhi Weng commented on FLINK-13880: - [~gjy] thanks for raising this problem. As this problem is

[jira] [Created] (FLINK-17080) Utils.CollectHelper is possible to throw NPE if the sink is up but not initialized when the job fails

2020-04-10 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-17080: --- Summary: Utils.CollectHelper is possible to throw NPE if the sink is up but not initialized when the job fails Key: FLINK-17080 URL:

[jira] [Updated] (FLINK-17083) Restrict users of accumulators not to return null in Accumulator#getLocalValue

2020-04-10 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-17083: Description: [This discussion|https://issues.apache.org/jira/browse/FLINK-13880] raises a

[jira] [Created] (FLINK-17083) Restrict users of accumulators not to return null in Accumulator#getLocalValue

2020-04-10 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-17083: --- Summary: Restrict users of accumulators not to return null in Accumulator#getLocalValue Key: FLINK-17083 URL: https://issues.apache.org/jira/browse/FLINK-17083

[jira] [Updated] (FLINK-17080) Utils.CollectHelper is possible to throw NPE if the sink is up but not initialized when the job fails

2020-04-10 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-17080: Labels: pull-request-available (was: ) > Utils.CollectHelper is possible to throw NPE if the

[jira] [Updated] (FLINK-13880) The behavior of JobExecutionResult.getAccumulatorResult does not match its java doc

2020-04-10 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13880: Affects Version/s: 1.11.0 > The behavior of JobExecutionResult.getAccumulatorResult does not

[jira] [Updated] (FLINK-13880) The behavior of JobExecutionResult.getAccumulatorResult does not match its java doc

2020-04-10 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13880: Component/s: (was: Runtime / Coordination) API / Core > The behavior of

[jira] [Updated] (FLINK-13880) The behavior of JobExecutionResult.getAccumulatorResult does not match its java doc

2020-04-10 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13880: Priority: Major (was: Minor) > The behavior of JobExecutionResult.getAccumulatorResult does not

[jira] [Comment Edited] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

2020-04-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079109#comment-17079109 ] Caizhi Weng edited comment on FLINK-16636 at 4/9/20, 9:40 AM: -- [~ykt836]

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

2020-04-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079109#comment-17079109 ] Caizhi Weng commented on FLINK-16636: - [~ykt836] NPE is caused by

[jira] [Updated] (FLINK-17023) The format checking of extractExecutionParams in config.sh is incorrect

2020-04-16 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-17023: Description: In FLINK-15727 {{BashJavaUtils}} now returns multiple lines of results to avoid

[jira] [Created] (FLINK-17197) ContinuousFileReaderOperator might shade the real exception when processing records

2020-04-16 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-17197: --- Summary: ContinuousFileReaderOperator might shade the real exception when processing records Key: FLINK-17197 URL: https://issues.apache.org/jira/browse/FLINK-17197

[jira] [Created] (FLINK-17045) If multiple views are based on tables not defined in the yaml config file, dropping one of the views will throw exception

2020-04-08 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-17045: --- Summary: If multiple views are based on tables not defined in the yaml config file, dropping one of the views will throw exception Key: FLINK-17045 URL:

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

2020-04-20 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088308#comment-17088308 ] Caizhi Weng commented on FLINK-16636: - Hi [~rmetzger] thanks for reporting. Is the heap dump

[jira] [Comment Edited] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

2020-04-21 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088308#comment-17088308 ] Caizhi Weng edited comment on FLINK-16636 at 4/21/20, 6:06 AM: --- Hi

[jira] [Comment Edited] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

2020-04-20 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088308#comment-17088308 ] Caizhi Weng edited comment on FLINK-16636 at 4/21/20, 5:58 AM: --- Hi

  1   2   3   4   5   6   7   8   >