[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-25 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_r338933808 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-544414033 ## CI report: * decba8623c001e8bbe5dc797de2bc421b2e216ef : SUCCESS [Build](https://travis-c

[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-25 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-542593114 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[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-25 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_r338933006 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#issuecomment-536292278 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communi

[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-25 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-542593114 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[GitHub] [flink] flinkbot edited a comment on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module URL: https://github.com/apache/flink/pull/9884#issuecomment-541277981 ## CI report: * bbabed91379f6c9a9a9b10e8d4b4d0037a76af94 : FAILURE [Build](https://travis-ci.com/fli

[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-25 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_r338931696 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] Henvealf commented on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

2019-10-25 Thread GitBox
Henvealf commented on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#issuecomment-546249729 > Hi @Henvealf do you have time to update this? Sorry for not replying for a long time, I will update

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

2019-10-25 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: image-2019-10-25-16-05-37-336.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-25 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_r338931356 ## File path: flink-table/flink-table-planner-blink/src/mai

[jira] [Updated] (FLINK-14314) Allocate shared slot resources respecting the resources of all vertices in the group

2019-10-25 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14314: Description: With FLINK-14058, it is assumed that a shared slot should be large enough to be used by one

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540450322 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

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

2019-10-25 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: image-2019-10-25-15-57-26-129.png > google protobuf is not shaded > ---

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

2019-10-25 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: image-2019-10-25-15-57-08-031.png > google protobuf is not shaded > ---

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

2019-10-25 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-542055081 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the com

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

2019-10-25 Thread GitBox
JingsongLi 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_r338928023 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/

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

2019-10-25 Thread GitBox
GJL 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_r338927493 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/Testin

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

2019-10-25 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-542055081 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the com

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

2019-10-25 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-542055081 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the com

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

2019-10-25 Thread GitBox
GJL 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_r338926427 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/Defaul

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

2019-10-25 Thread GitBox
GJL 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_r338925769 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/Defaul

[GitHub] [flink] flinkbot edited a comment on issue #9937: [FLINK-14416][table] Add Module interface and ModuleManager

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9937: [FLINK-14416][table] Add Module interface and ModuleManager URL: https://github.com/apache/flink/pull/9937#issuecomment-543850869 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[GitHub] [flink] dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager

2019-10-25 Thread GitBox
dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager URL: https://github.com/apache/flink/pull/9937#discussion_r338922440 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnviro

[GitHub] [flink] dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager

2019-10-25 Thread GitBox
dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager URL: https://github.com/apache/flink/pull/9937#discussion_r338925343 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/module/ModuleMa

[GitHub] [flink] flinkbot edited a comment on issue #9937: [FLINK-14416][table] Add Module interface and ModuleManager

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9937: [FLINK-14416][table] Add Module interface and ModuleManager URL: https://github.com/apache/flink/pull/9937#issuecomment-543850869 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[GitHub] [flink] dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager

2019-10-25 Thread GitBox
dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager URL: https://github.com/apache/flink/pull/9937#discussion_r338925099 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/module/ModuleMa

[GitHub] [flink] dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager

2019-10-25 Thread GitBox
dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager URL: https://github.com/apache/flink/pull/9937#discussion_r338924795 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/module/ModuleMa

[GitHub] [flink] dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager

2019-10-25 Thread GitBox
dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager URL: https://github.com/apache/flink/pull/9937#discussion_r338924122 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnviro

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

2019-10-25 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 [Build](https://

[GitHub] [flink] dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager

2019-10-25 Thread GitBox
dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager URL: https://github.com/apache/flink/pull/9937#discussion_r338924299 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/module/ModuleMa

[GitHub] [flink] GJL commented on issue #8760: [FLINK-12869] Add yarn acls capability to flink containers

2019-10-25 Thread GitBox
GJL commented on issue #8760: [FLINK-12869] Add yarn acls capability to flink containers URL: https://github.com/apache/flink/pull/8760#issuecomment-546243040 @ashangit Can I get feedback on the comments I have left? I can finish the remaining work, if you do not have time to work on it.

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540450322 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #9955: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9955: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/9955#issuecomment-544487116 ## CI report: * d49b564de9cd861f415228388401c4dde188a52f : SUCCESS [Build](https

[jira] [Commented] (FLINK-10435) Client sporadically hangs after Ctrl + C

2019-10-25 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959514#comment-16959514 ] Gary Yao commented on FLINK-10435: -- If I recall correctly, one needs to Ctrl + C quickl

[jira] [Updated] (FLINK-14528) Add a constructor for FlinkKafkaProducer

2019-10-25 Thread Peng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng updated FLINK-14528: - Summary: Add a constructor for FlinkKafkaProducer (was: Add a Constructor for FlinkKafkaProducer) > Add a cons

[GitHub] [flink] flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-544414033 ## CI report: * decba8623c001e8bbe5dc797de2bc421b2e216ef : SUCCESS [Build](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #9937: [FLINK-14416][table] Add Module interface and ModuleManager

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9937: [FLINK-14416][table] Add Module interface and ModuleManager URL: https://github.com/apache/flink/pull/9937#issuecomment-543850869 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[jira] [Created] (FLINK-14528) Add a Constructor for FlinkKafkaProducer

2019-10-25 Thread Peng (Jira)
Peng created FLINK-14528: Summary: Add a Constructor for FlinkKafkaProducer Key: FLINK-14528 URL: https://issues.apache.org/jira/browse/FLINK-14528 Project: Flink Issue Type: Improvement Co

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

2019-10-25 Thread GitBox
JingsongLi 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_r338922755 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/

[GitHub] [flink] flinkbot edited a comment on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module URL: https://github.com/apache/flink/pull/9884#issuecomment-541276093 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to r

[GitHub] [flink] dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager

2019-10-25 Thread GitBox
dawidwys commented on a change in pull request #9937: [FLINK-14416][table] Add Module interface and ModuleManager URL: https://github.com/apache/flink/pull/9937#discussion_r338922440 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnviro

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

2019-10-25 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-546241252 Hi @twalthr , fixed comments, please take a look~ T

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : FAILURE

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

2019-10-25 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-545428245 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Commented] (FLINK-14525) buffer pool is destroyed

2019-10-25 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959508#comment-16959508 ] zhijiang commented on FLINK-14525: -- As [~wind_ljy] mentioned above, there exists some o

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338917127 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -32

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338912064 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/typeu

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338916249 ## File path: flink-python/pyflink/fn_execution/coder_impl.py ## @@

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338916042 ## File path: flink-python/pyflink/fn_execution/coder_impl.py ## @@

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338912624 ## File path: flink-python/pyflink/fn_execution/coders.py ## @@ -62,

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338911364 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/typeu

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338916287 ## File path: flink-python/pyflink/fn_execution/coder_impl.py ## @@

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338915147 ## File path: flink-python/pyflink/fn_execution/coders.py ## @@ -62,

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338912537 ## File path: flink-python/pyflink/fn_execution/coders.py ## @@ -62,

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338914835 ## File path: flink-python/pyflink/fn_execution/coders.py ## @@ -62,

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338913186 ## File path: flink-python/pyflink/fn_execution/coders.py ## @@ -25,

[GitHub] [flink] dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
dianfu commented on a change in pull request #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#discussion_r338917259 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -32

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

2019-10-25 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 [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-544398939 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communit

[GitHub] [flink] flinkbot edited a comment on issue #9955: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9955: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/9955#issuecomment-544476209 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help t

[GitHub] [flink] zhuzhurk commented on a change in pull request #9955: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

2019-10-25 Thread GitBox
zhuzhurk commented on a change in pull request #9955: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/9955#discussion_r338910226 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entry

<    1   2   3   4   5   6