[GitHub] [flink] danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338392894 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338391937 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338390788 ## File path:

[GitHub] [flink] JingsongLi commented on issue #9803: [FLINK-14265][table-planner-blink] Don't use ContinuousFileReaderOperator to support multiple paths

2019-10-23 Thread GitBox
JingsongLi commented on issue #9803: [FLINK-14265][table-planner-blink] Don't use ContinuousFileReaderOperator to support multiple paths URL: https://github.com/apache/flink/pull/9803#issuecomment-545755404 > ``` > * NOTES ON CHECKPOINTING: In the case of a {@link

[GitHub] [flink] wangxlong commented on a change in pull request #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner

2019-10-23 Thread GitBox
wangxlong commented on a change in pull request #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner URL: https://github.com/apache/flink/pull/9916#discussion_r338389183 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9948: [FLINK-14451][runtime] Refactor FailoverTopology to extend base topology

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9948: [FLINK-14451][runtime] Refactor FailoverTopology to extend base topology URL: https://github.com/apache/flink/pull/9948#discussion_r338388819 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338387696 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542617499 ## CI report: * f20e67a260971f17d77c7ecc7c55b04136e432c5 : SUCCESS

[GitHub] [flink] wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338386955 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9980: [WIP][FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9980: [WIP][FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/9980#issuecomment-545692886 ## CI report: * 413eea83e59307f0709a9d4e055dcd9015c846d5 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#issuecomment-539878774 ## CI report: * c8bf66050c865904c402bdc9c079a6e4de1a064c : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-545444286 ## CI report: * 89d33a5aeefd6934261cc185c306c2e55b6c8ad2 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#issuecomment-57625 ## CI report: * b23539ddc208cdfe371759a4ba3ef7d7dc3b : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542617499 ## CI report: * f20e67a260971f17d77c7ecc7c55b04136e432c5 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage.

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage. URL: https://github.com/apache/flink/pull/9894#issuecomment-541559889 ## CI report: * 89595e0af27e0ae61f0fcd956ec422f203a3ab95 : CANCELED

[GitHub] [flink] JingsongLi commented on issue #9803: [FLINK-14265][table-planner-blink] Don't use ContinuousFileReaderOperator to support multiple paths

2019-10-23 Thread GitBox
JingsongLi commented on issue #9803: [FLINK-14265][table-planner-blink] Don't use ContinuousFileReaderOperator to support multiple paths URL: https://github.com/apache/flink/pull/9803#issuecomment-545736961 ``` * NOTES ON CHECKPOINTING: In the case of a {@link FileInputFormat},

[GitHub] [flink] flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#issuecomment-57625 ## CI report: * b23539ddc208cdfe371759a4ba3ef7d7dc3b : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542617499 ## CI report: * f20e67a260971f17d77c7ecc7c55b04136e432c5 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#issuecomment-542062879 ## CI report: * efdb2ad3942939590bbb0203ab04bae5fec634a9 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#issuecomment-539878774 ## CI report: * c8bf66050c865904c402bdc9c079a6e4de1a064c : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS

[GitHub] [flink] Mrart commented on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

2019-10-23 Thread GitBox
Mrart commented on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-545732095 > Nearly there ;) thks This is an automated

[GitHub] [flink] danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338371878 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338371293 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338371293 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338371293 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338371293 ## File path:

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

2019-10-23 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14515: Summary: Implement LimitableTableSource for FileSystemTableFactory Key: FLINK-14515 URL: https://issues.apache.org/jira/browse/FLINK-14515 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9981: [FLINK-13195][sql-client] Add create table support for SqlClient

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9981: [FLINK-13195][sql-client] Add create table support for SqlClient URL: https://github.com/apache/flink/pull/9981#issuecomment-545714180 ## CI report: * 52a10e0283f21047ac18d6668b71cfa4f6fc21a9 : FAILURE

[GitHub] [flink] wangxlong commented on a change in pull request #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner

2019-10-23 Thread GitBox
wangxlong commented on a change in pull request #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner URL: https://github.com/apache/flink/pull/9916#discussion_r338371307 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9980: [WIP][FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9980: [WIP][FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/9980#issuecomment-545692886 ## CI report: * 413eea83e59307f0709a9d4e055dcd9015c846d5 : FAILURE

[GitHub] [flink] bowenli86 commented on issue #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

2019-10-23 Thread GitBox
bowenli86 commented on issue #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927#issuecomment-545731315 LGTM! Merging This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-545444286 ## CI report: * 89d33a5aeefd6934261cc185c306c2e55b6c8ad2 : FAILURE

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338371293 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage.

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage. URL: https://github.com/apache/flink/pull/9894#issuecomment-541559889 ## CI report: * 89595e0af27e0ae61f0fcd956ec422f203a3ab95 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#issuecomment-539878774 ## CI report: * c8bf66050c865904c402bdc9c079a6e4de1a064c : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS

[GitHub] [flink] JingsongLi commented on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

2019-10-23 Thread GitBox
JingsongLi commented on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-545728276 > Thanks for your PR. I leave some comments. > btw: the last 3 commit's have wrong

[GitHub] [flink] jinglining commented on a change in pull request #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

2019-10-23 Thread GitBox
jinglining commented on a change in pull request #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#discussion_r338368266 ## File path:

[jira] [Assigned] (FLINK-14270) new web ui should display more than 4 metrics

2019-10-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14270: --- Assignee: Yadong Xie > new web ui should display more than 4 metrics >

[GitHub] [flink] guoweiM commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-23 Thread GitBox
guoweiM commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r338367848 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

2019-10-23 Thread GitBox
JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338367399 ## File path:

[GitHub] [flink] jinglining commented on a change in pull request #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

2019-10-23 Thread GitBox
jinglining commented on a change in pull request #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#discussion_r338367329 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

2019-10-23 Thread GitBox
JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338367203 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

2019-10-23 Thread GitBox
JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338366730 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-545444286 ## CI report: * 89d33a5aeefd6934261cc185c306c2e55b6c8ad2 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9980: [WIP][FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9980: [WIP][FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/9980#issuecomment-545692886 ## CI report: * 413eea83e59307f0709a9d4e055dcd9015c846d5 : FAILURE

[jira] [Updated] (FLINK-14508) google protobuf is not shaded

2019-10-23 Thread YING HOU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YING HOU updated FLINK-14508: - Attachment: (was: image-2019-10-23-18-07-27-188.png) > google protobuf is not shaded >

[GitHub] [flink] JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

2019-10-23 Thread GitBox
JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338366580 ## File path:

[jira] [Updated] (FLINK-14508) google protobuf is not shaded

2019-10-23 Thread YING HOU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YING HOU updated FLINK-14508: - Attachment: (was: pom.xml) > google protobuf is not shaded > -- > >

[jira] [Updated] (FLINK-14508) google protobuf is not shaded

2019-10-23 Thread YING HOU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YING HOU updated FLINK-14508: - Description: I try to use phoenix in my flink project. When I use

[GitHub] [flink] flinkbot edited a comment on issue #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#issuecomment-542062879 ## CI report: * efdb2ad3942939590bbb0203ab04bae5fec634a9 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage.

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage. URL: https://github.com/apache/flink/pull/9894#issuecomment-541559889 ## CI report: * 89595e0af27e0ae61f0fcd956ec422f203a3ab95 : CANCELED

[GitHub] [flink] wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338364936 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#issuecomment-539878774 ## CI report: * c8bf66050c865904c402bdc9c079a6e4de1a064c : FAILURE

[GitHub] [flink] wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338364552 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS

[GitHub] [flink] wuchong commented on a change in pull request #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner

2019-10-23 Thread GitBox
wuchong commented on a change in pull request #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner URL: https://github.com/apache/flink/pull/9916#discussion_r338363743 ## File path:

[GitHub] [flink] xuyang1706 commented on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

2019-10-23 Thread GitBox
xuyang1706 commented on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-545722380 > Hi @xuyang1706 @becketqin Thanks for the discussion and sorry for the late response. This PR currently seems

[GitHub] [flink] wuchong commented on a change in pull request #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner

2019-10-23 Thread GitBox
wuchong commented on a change in pull request #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner URL: https://github.com/apache/flink/pull/9916#discussion_r338355369 ## File path:

[GitHub] [flink] JingsongLi commented on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module

2019-10-23 Thread GitBox
JingsongLi commented on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module URL: https://github.com/apache/flink/pull/9884#issuecomment-545721995 > Btw did you have a look at #4660. Isn't this issue a duplicate? The differences are: - This PR is in

[jira] [Commented] (FLINK-14514) Improve interface of FunctionContext#getJobParameter

2019-10-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16958478#comment-16958478 ] Jark Wu commented on FLINK-14514: - cc [~twalthr] [~aljoscha] > Improve interface of

[jira] [Updated] (FLINK-14514) Improve interface of FunctionContext#getJobParameter

2019-10-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14514: Description: Currentlly, {{FunctionContext#getJobParameter}} gets the key-values from env's

[GitHub] [flink] danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338363402 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338363242 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338363168 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

2019-10-23 Thread GitBox
danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338362915 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

2019-10-23 Thread GitBox
xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r338362984 ## File path:

[jira] [Updated] (FLINK-13513) Add the Mapper and related classes for later algorithm implementations.

2019-10-23 Thread Xu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Yang updated FLINK-13513: Description: Define the abstract classes for the single-thread executor for Row type data. * Add the

[GitHub] [flink] godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-23 Thread GitBox
godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r338360645 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-23 Thread GitBox
godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r338359693 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-23 Thread GitBox
godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r338361636 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-23 Thread GitBox
godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r338362044 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-23 Thread GitBox
godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r338355400 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-23 Thread GitBox
godfreyhe commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r338362335 ## File path:

[jira] [Updated] (FLINK-13513) Add the Mapper and related classes for later algorithm implementations.

2019-10-23 Thread Xu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Yang updated FLINK-13513: Summary: Add the Mapper and related classes for later algorithm implementations. (was: Add the

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338177737 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9981: [FLINK-13195][sql-client] Add create table support for SqlClient

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9981: [FLINK-13195][sql-client] Add create table support for SqlClient URL: https://github.com/apache/flink/pull/9981#issuecomment-545714180 ## CI report: * 52a10e0283f21047ac18d6668b71cfa4f6fc21a9 : PENDING

[GitHub] [flink] JingsongLi commented on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module

2019-10-23 Thread GitBox
JingsongLi commented on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module URL: https://github.com/apache/flink/pull/9884#issuecomment-545719375 > Thanks @JingsongLi for the PR. I added an initial set of comments. It would be great if we could further reduce

[GitHub] [flink] flinkbot edited a comment on issue #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#issuecomment-542062879 ## CI report: * efdb2ad3942939590bbb0203ab04bae5fec634a9 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

2019-10-23 Thread GitBox
flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#issuecomment-539878774 ## CI report: * c8bf66050c865904c402bdc9c079a6e4de1a064c : FAILURE

[jira] [Created] (FLINK-14514) Improve interface of FunctionContext#getJobParameter

2019-10-23 Thread Jark Wu (Jira)
Jark Wu created FLINK-14514: --- Summary: Improve interface of FunctionContext#getJobParameter Key: FLINK-14514 URL: https://issues.apache.org/jira/browse/FLINK-14514 Project: Flink Issue Type:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338177737 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338179104 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338172474 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338191388 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-23 Thread GitBox
zhuzhurk commented on a change in pull request #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#discussion_r338176523 ## File path:

[GitHub] [flink] flinkbot commented on issue #9981: [FLINK-13195][sql-client] Add create table support for SqlClient

2019-10-23 Thread GitBox
flinkbot commented on issue #9981: [FLINK-13195][sql-client] Add create table support for SqlClient URL: https://github.com/apache/flink/pull/9981#issuecomment-545714180 ## CI report: * 52a10e0283f21047ac18d6668b71cfa4f6fc21a9 : UNKNOWN Bot commands The @flinkbot

[jira] [Commented] (FLINK-14513) Implement listPartitionsByFilter to HiveCatalog

2019-10-23 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16958469#comment-16958469 ] Terry Wang commented on FLINK-14513: Feel free to assign this task to me :) > Implement

[jira] [Updated] (FLINK-14512) Introduce listPartitionsByFilter to Catalog

2019-10-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14512: - Fix Version/s: 1.10.0 > Introduce listPartitionsByFilter to Catalog >

[jira] [Created] (FLINK-14513) Implement listPartitionsByFilter to HiveCatalog

2019-10-23 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14513: Summary: Implement listPartitionsByFilter to HiveCatalog Key: FLINK-14513 URL: https://issues.apache.org/jira/browse/FLINK-14513 Project: Flink Issue Type:

[jira] [Created] (FLINK-14512) Introduce listPartitionsByFilter to Catalog

2019-10-23 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14512: Summary: Introduce listPartitionsByFilter to Catalog Key: FLINK-14512 URL: https://issues.apache.org/jira/browse/FLINK-14512 Project: Flink Issue Type:

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

2019-10-23 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] [Commented] (FLINK-14511) Checking YARN queues should add "root" prefix

2019-10-23 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16958466#comment-16958466 ] Yang Wang commented on FLINK-14511: --- Hi [~Dillon.], thanks for this issue. I think we need more

[GitHub] [flink] KurtYoung commented on issue #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki…

2019-10-23 Thread GitBox
KurtYoung commented on issue #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki… URL: https://github.com/apache/flink/pull/9966#issuecomment-545711523 @liuyongvs There are some compilation errors, please fix it first.

[jira] [Commented] (FLINK-14499) MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

2019-10-23 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16958461#comment-16958461 ] Zili Chen commented on FLINK-14499: --- Thanks for your attention [~AT-Fieldless]. I've assigned the

[jira] [Assigned] (FLINK-14499) MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

2019-10-23 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-14499: - Assignee: AT-Fieldless > MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull >

[GitHub] [flink] liuyongvs commented on issue #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki…

2019-10-23 Thread GitBox
liuyongvs commented on issue #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki… URL: https://github.com/apache/flink/pull/9966#issuecomment-545707154 > Your base branch seems to be wrong, please use latest master branch and create a fix

  1   2   3   4   5   6   >