[GitHub] [flink] flinkbot commented on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

2019-12-08 Thread GitBox
flinkbot commented on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#issuecomment-563110907 ## CI report: * bef118a977b3aa635fc748260d07b0d5079b2c0e : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959 ## CI report: * 2e942aa60f0807a6a41fd0483237d8b571fdca1f : PENDING

[GitHub] [flink] flinkbot commented on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog

2019-12-08 Thread GitBox
flinkbot commented on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog URL: https://github.com/apache/flink/pull/10493#issuecomment-563111006 ## CI report: * a79225d75a53240951a4378380ff2aac457c1278 :

[jira] [Updated] (FLINK-15139) misc end to end test failed on 'SQL Client end-to-end test (Old planner)'

2019-12-08 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15139: -- Priority: Critical (was: Major) > misc end to end test failed on 'SQL Client end-to-end test (Old planner)'

[GitHub] [flink] flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#issuecomment-562648066 ## CI report: * 9802f136dd38c6ba22752a7761e644b7bd05e99d

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : SUCCESS

[GitHub] [flink] carp84 commented on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject

2019-12-08 Thread GitBox
carp84 commented on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject URL: https://github.com/apache/flink/pull/10300#issuecomment-563107225 @StephanEwen Thanks for the comments and suggestions! Codes updated accordingly and already got a green build

[jira] [Commented] (FLINK-15141) Using decimal type in a sink table, the result returns a not match ValidationException

2019-12-08 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991210#comment-16991210 ] xiaojin.wy commented on FLINK-15141: [~ykt836] can you please assign someone to check it? > Using

[jira] [Updated] (FLINK-15141) Using decimal type in a sink table, the result returns a not match ValidationException

2019-12-08 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-15141: --- Description: The planner what I used is blink. *The source table is:* CREATE TABLE `aggtest` (

[jira] [Commented] (FLINK-15141) Using decimal type in a sink table, the result returns a not match ValidationException

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991209#comment-16991209 ] Jingsong Lee commented on FLINK-15141: -- Hi [~xiaojin.wy], is this duplicated with 

[GitHub] [flink] flinkbot commented on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog

2019-12-08 Thread GitBox
flinkbot commented on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog URL: https://github.com/apache/flink/pull/10493#issuecomment-563104281 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-15061) create/alter table/databases properties should be case sensitive stored in catalog

2019-12-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15061: --- Labels: pull-request-available (was: ) > create/alter table/databases properties should be

[GitHub] [flink] zjuwangg commented on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog

2019-12-08 Thread GitBox
zjuwangg commented on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog URL: https://github.com/apache/flink/pull/10493#issuecomment-563103554 cc @xuefuz @bowenli86 @KurtYoung to have a review.

[jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

2019-12-08 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-12692: -- Fix Version/s: (was: 1.10.0) 1.11.0 Sorry but we have to postpone the work to 1.11.0

[GitHub] [flink] zjuwangg opened a new pull request #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog

2019-12-08 Thread GitBox
zjuwangg opened a new pull request #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog URL: https://github.com/apache/flink/pull/10493 ## What is the purpose of the change *Now in the class `SqlToOperationConverter`,

[jira] [Commented] (FLINK-11911) KafkaTopicPartition is not a valid POJO

2019-12-08 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991204#comment-16991204 ] Yu Li commented on FLINK-11911: --- {quote} The essential change this requires in the serialization stack is

[jira] [Created] (FLINK-15141) Using decimal type in a sink table, the result returns a not match ValidationException

2019-12-08 Thread xiaojin.wy (Jira)
xiaojin.wy created FLINK-15141: -- Summary: Using decimal type in a sink table, the result returns a not match ValidationException Key: FLINK-15141 URL: https://issues.apache.org/jira/browse/FLINK-15141

[GitHub] [flink] flinkbot edited a comment on issue #10490: [FLINK-15136][docs] Update the Chinese version of Working with State

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10490: [FLINK-15136][docs] Update the Chinese version of Working with State URL: https://github.com/apache/flink/pull/10490#issuecomment-563052850 ## CI report: * a2fdaa407c0cf02efee89f2c65912445ee3d34e1 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#issuecomment-562648066 ## CI report: * 9802f136dd38c6ba22752a7761e644b7bd05e99d

[jira] [Updated] (FLINK-13197) support querying Hive's view in Flink

2019-12-08 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13197: --- Issue Type: Test (was: Improvement) > support querying Hive's view in Flink >

[jira] [Updated] (FLINK-13197) Verify querying Hive's view in Flink

2019-12-08 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13197: --- Summary: Verify querying Hive's view in Flink (was: support querying Hive's view in Flink) > Verify

[GitHub] [flink] flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#issuecomment-560368141 ## CI report: * ebaf14134fb520e1e66c7788139fb619e8fb2be0 : SUCCESS

[jira] [Assigned] (FLINK-15109) InternalTimerServiceImpl references restored state after use, taking up resources unnecessarily

2019-12-08 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-15109: Assignee: Roman Khachatryan > InternalTimerServiceImpl references restored state after use,

[jira] [Resolved] (FLINK-15109) InternalTimerServiceImpl references restored state after use, taking up resources unnecessarily

2019-12-08 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang resolved FLINK-15109. -- Resolution: Fixed Fixed in master: 59ac51814c46d790f1ae030e1a199bddf00a8b01 >

[jira] [Updated] (FLINK-15109) InternalTimerServiceImpl references restored state after use, taking up resources unnecessarily

2019-12-08 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-15109: - Fix Version/s: 1.10.0 > InternalTimerServiceImpl references restored state after use, taking up >

[GitHub] [flink] zhijiangW merged pull request #10465: [FLINK-15109][runtime] null out restored state ref in InternalTimerServiceImpl after use

2019-12-08 Thread GitBox
zhijiangW merged pull request #10465: [FLINK-15109][runtime] null out restored state ref in InternalTimerServiceImpl after use URL: https://github.com/apache/flink/pull/10465 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

2019-12-08 Thread GitBox
flinkbot commented on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#issuecomment-563096144 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Updated] (FLINK-15140) Shuffle data compression does not work with BroadcastRecordWriter.

2019-12-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15140: --- Labels: pull-request-available (was: ) > Shuffle data compression does not work with

[GitHub] [flink] wsry opened a new pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

2019-12-08 Thread GitBox
wsry opened a new pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492 1. Disable data compression for operators which use broadcast partitioner in pipelined mode. 2. Not

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

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13410: - Fix Version/s: (was: 1.10.0) > Csv input format does not support LocalDate >

[jira] [Commented] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner

2019-12-08 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991193#comment-16991193 ] godfrey he commented on FLINK-15123: I'd like to take this ticket > remove uniqueKeys from

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

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991194#comment-16991194 ] Jingsong Lee commented on FLINK-13410: -- Now, Csv source / sink will type informations, so them

[jira] [Commented] (FLINK-15097) flink can not use user specified hdfs conf when submitting app in client node

2019-12-08 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991192#comment-16991192 ] Congxian Qiu(klion26) commented on FLINK-15097: --- If these two are truly the same, could we

[jira] [Comment Edited] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-12-08 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991190#comment-16991190 ] Guowei Ma edited comment on FLINK-13993 at 12/9/19 7:01 AM: [~tison] Sorry

[jira] [Commented] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-12-08 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991190#comment-16991190 ] Guowei Ma commented on FLINK-13993: --- [~tison] Sorry for the late reply.  I think your method could

[jira] [Updated] (FLINK-11135) Refactor Hadoop config loading in HadoopUtils

2019-12-08 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-11135: - Affects Version/s: 1.10.0 1.8.2 1.9.1 > Refactor Hadoop

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

2019-12-08 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: - Fix Version/s: (was: 1.10.0) > Implement LimitableTableSource for FileSystemTableFactory >

[jira] [Closed] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-12-08 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-13993. - Resolution: Fixed > Using FlinkUserCodeClassLoaders to load the user class in the perjob mode >

[jira] [Assigned] (FLINK-15081) Translate "Concepts & Common API" page of Table API into Chinese

2019-12-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15081: --- Assignee: Steve OU > Translate "Concepts & Common API" page of Table API into Chinese >

[jira] [Commented] (FLINK-15081) Translate "Concepts & Common API" page of Table API into Chinese

2019-12-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991187#comment-16991187 ] Jark Wu commented on FLINK-15081: - Hi [~ousheobin], I assigned this ticket to you. Feel free to open

[GitHub] [flink] flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959 ## CI report: * 2e942aa60f0807a6a41fd0483237d8b571fdca1f : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10489: [FLINK-15134][client] Delete temporary files created in YarnClusterDescriptor

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10489: [FLINK-15134][client] Delete temporary files created in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10489#issuecomment-563036443 ## CI report: * bd0bc5261acfb555944947c0151f54c5eb806e1a : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#issuecomment-560368141 ## CI report: * ebaf14134fb520e1e66c7788139fb619e8fb2be0 : SUCCESS

[jira] [Comment Edited] (FLINK-15081) Translate "Concepts & Common API" page of Table API into Chinese

2019-12-08 Thread Steve OU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991182#comment-16991182 ] Steve OU edited comment on FLINK-15081 at 12/9/19 6:45 AM: --- [~jark] Hi Jark. I

[jira] [Commented] (FLINK-15081) Translate "Concepts & Common API" page of Table API into Chinese

2019-12-08 Thread Steve OU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991182#comment-16991182 ] Steve OU commented on FLINK-15081: -- [~jark] Hi Jark. I did not open the PR now. Actually it is the

[GitHub] [flink] flinkbot edited a comment on issue #9289: [FLINK-13390] Clarify the exact meaning of state size when executing incremental checkpoint

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #9289: [FLINK-13390] Clarify the exact meaning of state size when executing incremental checkpoint URL: https://github.com/apache/flink/pull/9289#issuecomment-516734686 ## CI report: * a31d65fb01f4d6d8952f0eab8def4f379cd1051a : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject URL: https://github.com/apache/flink/pull/10300#issuecomment-557891612 ## CI report: * dae41b86e4710d0c83d3f764e6196513db26a2c8 : FAILURE

[jira] [Comment Edited] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

2019-12-08 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991179#comment-16991179 ] Congxian Qiu(klion26) edited comment on FLINK-15105 at 12/9/19 6:38 AM:

[GitHub] [flink] danny0405 commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-08 Thread GitBox
danny0405 commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#discussion_r355282741 ## File path:

[jira] [Commented] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

2019-12-08 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991179#comment-16991179 ] Congxian Qiu(klion26) commented on FLINK-15105: --- The test complete checkpoint successfully

[jira] [Closed] (FLINK-12308) Support python language in Flink Table API

2019-12-08 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12308. --- Resolution: Fixed > Support python language in Flink Table API >

[GitHub] [flink] flinkbot commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-08 Thread GitBox
flinkbot commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959 ## CI report: * 2e942aa60f0807a6a41fd0483237d8b571fdca1f : UNKNOWN Bot commands The

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

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14258: - Fix Version/s: (was: 1.10.0) > Integrate hive to FileSystemTableFactory >

[GitHub] [flink] lirui-apache commented on a change in pull request #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

2019-12-08 Thread GitBox
lirui-apache commented on a change in pull request #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#discussion_r355279701 ## File path:

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

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14257: - Fix Version/s: (was: 1.10.0) > Integrate csv to FileSystemTableFactory >

[jira] [Commented] (FLINK-13056) Optimize region failover performance on calculating vertices to restart

2019-12-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991173#comment-16991173 ] Zhu Zhu commented on FLINK-13056: - postpone this improvement to 1.11. > Optimize region failover

[GitHub] [flink] flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569 ## CI report: * 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 : CANCELED

[jira] [Updated] (FLINK-13056) Optimize region failover performance on calculating vertices to restart

2019-12-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-13056: Fix Version/s: (was: 1.10.0) 1.11.0 > Optimize region failover performance on

[jira] [Updated] (FLINK-14266) Introduce RowCsvInputFormat to new CSV module

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14266: - Fix Version/s: (was: 1.10.0) > Introduce RowCsvInputFormat to new CSV module >

[jira] [Closed] (FLINK-13285) Check connectors runnable in blink runner

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-13285. Resolution: Fixed > Check connectors runnable in blink runner >

[jira] [Updated] (FLINK-14267) Introduce RowCsvOutputFormat to new CSV module

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14267: - Fix Version/s: (was: 1.10.0) > Introduce RowCsvOutputFormat to new CSV module >

[jira] [Commented] (FLINK-15081) Translate "Concepts & Common API" page of Table API into Chinese

2019-12-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991169#comment-16991169 ] Jark Wu commented on FLINK-15081: - [~ousheobin], did you open a pull request? > Translate "Concepts &

[jira] [Commented] (FLINK-14951) State TTL backend end-to-end test fail when taskManager has multiple slot

2019-12-08 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991170#comment-16991170 ] Yangze Guo commented on FLINK-14951: [~azagrebin] Hi, andrey. I notice the fix version of this issue

[jira] [Updated] (FLINK-13438) Hive source/sink/udx should respect the conversion class of DataType

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13438: - Parent: (was: FLINK-13285) Issue Type: Bug (was: Sub-task) > Hive source/sink/udx

[GitHub] [flink] flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#issuecomment-560368141 ## CI report: * ebaf14134fb520e1e66c7788139fb619e8fb2be0 : SUCCESS

[GitHub] [flink] KurtYoung commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-08 Thread GitBox
KurtYoung commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#discussion_r355277953 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject URL: https://github.com/apache/flink/pull/10300#issuecomment-557891612 ## CI report: * dae41b86e4710d0c83d3f764e6196513db26a2c8 : FAILURE

[GitHub] [flink] leonardBang commented on a change in pull request #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-08 Thread GitBox
leonardBang commented on a change in pull request #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#discussion_r355276918 ## File path:

[GitHub] [flink] leonardBang commented on a change in pull request #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-08 Thread GitBox
leonardBang commented on a change in pull request #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#discussion_r355276947 ## File path:

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

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-13283. -- Resolution: Fixed > JDBC source/sink should respect the conversion class of DataType >

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

2019-12-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991166#comment-16991166 ] Jingsong Lee commented on FLINK-13283: -- Fixed in https://issues.apache.org/jira/browse/FLINK-14645

[jira] [Commented] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

2019-12-08 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991163#comment-16991163 ] Yu Li commented on FLINK-13993: --- [~maguowei] Since all sub-tasks have been completed, I guess we could

[GitHub] [flink] JingsongLi commented on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

2019-12-08 Thread GitBox
JingsongLi commented on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#issuecomment-563077831 LGTM, only left minor comment. This is an

[GitHub] [flink] JingsongLi commented on a change in pull request #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

2019-12-08 Thread GitBox
JingsongLi commented on a change in pull request #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#discussion_r355274831 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

2019-12-08 Thread GitBox
lirui-apache commented on a change in pull request #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#discussion_r355273794 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10462: [FLINK-15031][runtime] Calculate required shuffle memory before allocating slots if resources are specified

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10462: [FLINK-15031][runtime] Calculate required shuffle memory before allocating slots if resources are specified URL: https://github.com/apache/flink/pull/10462#issuecomment-562542464 ## CI report: * 708583f6acbff12da90bc28269d924433c446e32

[GitHub] [flink] flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436#issuecomment-562103759 ## CI report: * 3441142c77315169ce7a3b48d4d59e710c1016c2 : CANCELED

[jira] [Updated] (FLINK-15136) Update the Chinese version of "Working with state"

2019-12-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15136: Issue Type: Improvement (was: Bug) > Update the Chinese version of "Working with state" >

[jira] [Updated] (FLINK-15136) Update the Chinese version of "Working with state"

2019-12-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15136: Parent: (was: FLINK-11526) Issue Type: Bug (was: Sub-task) > Update the Chinese version of

[GitHub] [flink] flinkbot commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-08 Thread GitBox
flinkbot commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563073936 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-15093) StreamExecutionEnvironment does not clear transformations when executing

2019-12-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15093: --- Labels: pull-request-available (was: ) > StreamExecutionEnvironment does not clear

[GitHub] [flink] danny0405 opened a new pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-08 Thread GitBox
danny0405 opened a new pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491 …ar transformations when executing ## What is the purpose of the change Add internal interface

[GitHub] [flink] XuQianJin-Stars commented on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time

2019-12-08 Thread GitBox
XuQianJin-Stars commented on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time URL: https://github.com/apache/flink/pull/8746#issuecomment-563072805 hi @walterddr Thank you very much for this PR.

[jira] [Updated] (FLINK-15139) misc end to end test failed on 'SQL Client end-to-end test (Old planner)'

2019-12-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15139: Affects Version/s: (was: 2.0.0) 1.10.0 > misc end to end test failed on 'SQL

[jira] [Updated] (FLINK-15139) misc end to end test failed on 'SQL Client end-to-end test (Old planner)'

2019-12-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15139: Fix Version/s: (was: 2.0.0) 1.10.0 > misc end to end test failed on 'SQL Client

[GitHub] [flink] flinkbot edited a comment on issue #10479: [FLINK-14992][client] Add job listener to execution environments

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10479: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10479#issuecomment-562851491 ## CI report: * a5903c83403e4628cdb00e85ab5860be9ebaadc4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#issuecomment-562648066 ## CI report: * 9802f136dd38c6ba22752a7761e644b7bd05e99d

[GitHub] [flink] flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436#issuecomment-562103759 ## CI report: * 3441142c77315169ce7a3b48d4d59e710c1016c2 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : SUCCESS

[jira] [Updated] (FLINK-15140) Shuffle data compression does not work with BroadcastRecordWriter.

2019-12-08 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-15140: Description: I tested the newest code of master branch last weekend with more test cases.

[GitHub] [flink] flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#issuecomment-560368141 ## CI report: * ebaf14134fb520e1e66c7788139fb619e8fb2be0 : SUCCESS

[jira] [Created] (FLINK-15140) Shuffle data compression does not work with BroadcastRecordWriter.

2019-12-08 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-15140: --- Summary: Shuffle data compression does not work with BroadcastRecordWriter. Key: FLINK-15140 URL: https://issues.apache.org/jira/browse/FLINK-15140 Project: Flink

[jira] [Assigned] (FLINK-15131) Add Source API classes

2019-12-08 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-15131: Assignee: Jiangjie Qin > Add Source API classes > -- > >

[GitHub] [flink] KurtYoung commented on a change in pull request #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

2019-12-08 Thread GitBox
KurtYoung commented on a change in pull request #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#discussion_r355264664 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#issuecomment-562648066 ## CI report: * 9802f136dd38c6ba22752a7761e644b7bd05e99d

[GitHub] [flink] flinkbot edited a comment on issue #10479: [FLINK-14992][client] Add job listener to execution environments

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10479: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10479#issuecomment-562851491 ## CI report: * a5903c83403e4628cdb00e85ab5860be9ebaadc4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#issuecomment-560368141 ## CI report: * ebaf14134fb520e1e66c7788139fb619e8fb2be0 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #7314: [FLINK-11135][YARN] Refactor Hadoop config loading in HadoopUtils

2019-12-08 Thread GitBox
flinkbot edited a comment on issue #7314: [FLINK-11135][YARN] Refactor Hadoop config loading in HadoopUtils URL: https://github.com/apache/flink/pull/7314#issuecomment-563040815 ## CI report: * 2b4f99077d6d27409c625bf6ee303e527153d0e3 : SUCCESS

[GitHub] [flink] xuyang1706 commented on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-12-08 Thread GitBox
xuyang1706 commented on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-563058981 > Thanks for the contribution @xuyang1706 . I think overall the diff looks good to me. Just have some questions regarding the

  1   2   3   4   5   >