[GitHub] [flink] liyafan82 commented on a change in pull request #8689: [FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString

liyafan82 commented on a change in pull request #8689: [FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString URL: https://github.com/apache/flink/pull/8689#discussion_r294619334 ## File path:

[GitHub] [flink] liyafan82 commented on a change in pull request #8689: [FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString

liyafan82 commented on a change in pull request #8689: [FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString URL: https://github.com/apache/flink/pull/8689#discussion_r294618087 ## File path:

[GitHub] [flink] liyafan82 commented on a change in pull request #8689: [FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString

liyafan82 commented on a change in pull request #8689: [FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString URL: https://github.com/apache/flink/pull/8689#discussion_r294617538 ## File path:

[GitHub] [flink] liyafan82 commented on a change in pull request #8689: [FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString

liyafan82 commented on a change in pull request #8689: [FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString URL: https://github.com/apache/flink/pull/8689#discussion_r294617113 ## File path:

[GitHub] [flink] lirui-apache commented on issue #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables

lirui-apache commented on issue #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables URL: https://github.com/apache/flink/pull/8766#issuecomment-502949540 cc @xuefuz @bowenli86 @zjuwangg for review I don't think the CI build failure is related. Is there any way to rerun

[GitHub] [flink] flinkbot commented on issue #8773: [FLINK-12879][Table SQL / Runtime] Improve the performance of AbstractBinaryWriter

flinkbot commented on issue #8773: [FLINK-12879][Table SQL / Runtime] Improve the performance of AbstractBinaryWriter URL: https://github.com/apache/flink/pull/8773#issuecomment-502947557 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] bowenli86 commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

bowenli86 commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#discussion_r294610200 ## File path:

[jira] [Updated] (FLINK-12879) Improve the performance of AbstractBinaryWriter

[ https://issues.apache.org/jira/browse/FLINK-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12879: --- Labels: pull-request-available (was: ) > Improve the performance of AbstractBinaryWriter >

[GitHub] [flink] liyafan82 opened a new pull request #8773: [FLINK-12879][Table SQL / Runtime] Improve the performance of AbstractBinaryWriter

liyafan82 opened a new pull request #8773: [FLINK-12879][Table SQL / Runtime] Improve the performance of AbstractBinaryWriter URL: https://github.com/apache/flink/pull/8773 ## What is the purpose of the change Improve the performance of AbstractBinaryWriter by: 1. remove

[jira] [Created] (FLINK-12879) Improve the performance of AbstractBinaryWriter

Liya Fan created FLINK-12879: Summary: Improve the performance of AbstractBinaryWriter Key: FLINK-12879 URL: https://issues.apache.org/jira/browse/FLINK-12879 Project: Flink Issue Type:

[GitHub] [flink] bowenli86 commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

bowenli86 commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#discussion_r294608484 ## File path:

[GitHub] [flink] godfreyhe commented on issue #8772: [FLINK-12878] [travis] Move flink-table-planner-blink/flink-table-runtime-blink to separate profile

godfreyhe commented on issue #8772: [FLINK-12878] [travis] Move flink-table-planner-blink/flink-table-runtime-blink to separate profile URL: https://github.com/apache/flink/pull/8772#issuecomment-502941003 sure @KurtYoung , I have updated it

[GitHub] [flink] flinkbot commented on issue #8772: [FLINK-12878] [travis] Move flink-table-planner-blink/flink-table-runtime-blink to separate profile

flinkbot commented on issue #8772: [FLINK-12878] [travis] Move flink-table-planner-blink/flink-table-runtime-blink to separate profile URL: https://github.com/apache/flink/pull/8772#issuecomment-502937980 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Updated] (FLINK-12878) Add travis profile for flink-table-planner-blink/flink-table-runtime-blink

[ https://issues.apache.org/jira/browse/FLINK-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12878: --- Labels: pull-request-available (was: ) > Add travis profile for

[GitHub] [flink] godfreyhe opened a new pull request #8772: [FLINK-12878] [travis] Move flink-table-planner-blink/flink-table-runtime-blink to separate profile

godfreyhe opened a new pull request #8772: [FLINK-12878] [travis] Move flink-table-planner-blink/flink-table-runtime-blink to separate profile URL: https://github.com/apache/flink/pull/8772 ## What is the purpose of the change *Move

[jira] [Updated] (FLINK-12878) Add travis profile for flink-table-planner-blink/flink-table-runtime-blink

[ https://issues.apache.org/jira/browse/FLINK-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12878: --- Description: The flink-table-planner-blink module and flink-table-runtime-blink module take almost

[GitHub] [flink] klion26 commented on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint

klion26 commented on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint URL: https://github.com/apache/flink/pull/8617#issuecomment-502937509 @aljoscha thanks for the reply, will create a separate Jira issue to that. close and reopen the pr for trigger

[GitHub] [flink] JingsongLi commented on a change in pull request #8730: [FLINK-12834][table-planner-blink] Support CharType and BinaryType

JingsongLi commented on a change in pull request #8730: [FLINK-12834][table-planner-blink] Support CharType and BinaryType URL: https://github.com/apache/flink/pull/8730#discussion_r294602280 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#discussion_r294601901 ## File path:

[GitHub] [flink] klion26 closed pull request #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint

klion26 closed pull request #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint URL: https://github.com/apache/flink/pull/8617 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] klion26 opened a new pull request #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint

klion26 opened a new pull request #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint URL: https://github.com/apache/flink/pull/8617 ## What is the purpose of the change Inspired by the idea of

[GitHub] [flink] xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#discussion_r294601274 ## File path:

[GitHub] [flink] sunjincheng121 commented on issue #8732: [FLINK-12720][python] Add the Python Table API Sphinx docs

sunjincheng121 commented on issue #8732: [FLINK-12720][python] Add the Python Table API Sphinx docs URL: https://github.com/apache/flink/pull/8732#issuecomment-502936228 @dianfu Thanks for helping improve the PR! @HuangXingBo told me he is on the vacation cannot update the PR those days,

[GitHub] [flink] c4emmmm commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

c4e commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r294172904 ## File path:

[GitHub] [flink] c4emmmm commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

c4e commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r294592417 ## File path:

[GitHub] [flink] c4emmmm commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

c4e commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r294598652 ## File path:

[GitHub] [flink] c4emmmm commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

c4e commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r294217416 ## File path:

[GitHub] [flink] c4emmmm commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

c4e commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r294214676 ## File path:

[GitHub] [flink] c4emmmm commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

c4e commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r294221044 ## File path:

[GitHub] [flink] c4emmmm commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

c4e commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r294215696 ## File path:

[GitHub] [flink] c4emmmm commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

c4e commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r294218860 ## File path:

[jira] [Comment Edited] (FLINK-12865) State inconsistency between RM and TM on the slot status

[ https://issues.apache.org/jira/browse/FLINK-12865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866199#comment-16866199 ] Yun Gao edited comment on FLINK-12865 at 6/18/19 3:52 AM: -- [~till.rohrmann] Hi

[jira] [Commented] (FLINK-12865) State inconsistency between RM and TM on the slot status

[ https://issues.apache.org/jira/browse/FLINK-12865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866199#comment-16866199 ] Yun Gao commented on FLINK-12865: - [~till.rohrmann] Hi Till, thanks a lot for the explanation and sorry

[jira] [Created] (FLINK-12878) Add travis profile for flink-table-planner-blink/flink-table-runtime-blink

godfrey he created FLINK-12878: -- Summary: Add travis profile for flink-table-planner-blink/flink-table-runtime-blink Key: FLINK-12878 URL: https://issues.apache.org/jira/browse/FLINK-12878 Project:

[GitHub] [flink] shuai-xu commented on a change in pull request #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter

shuai-xu commented on a change in pull request #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter URL: https://github.com/apache/flink/pull/8688#discussion_r294597079 ## File path:

[GitHub] [flink] shuai-xu commented on a change in pull request #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter

shuai-xu commented on a change in pull request #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter URL: https://github.com/apache/flink/pull/8688#discussion_r294597095 ## File path:

[GitHub] [flink] xintongsong commented on issue #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

xintongsong commented on issue #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#issuecomment-502929821 @gaoyunhaii Thanks again for the review. Your comments are addressed.

[GitHub] [flink] ifndef-SleePy commented on issue #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph…

ifndef-SleePy commented on issue #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph… URL: https://github.com/apache/flink/pull/8658#issuecomment-502929514 Hi @aljoscha , it seems that there is something wrong with Travis building. I have filed a JIRA issue to

[GitHub] [flink] shuai-xu commented on a change in pull request #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter

shuai-xu commented on a change in pull request #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter URL: https://github.com/apache/flink/pull/8688#discussion_r294594096 ## File path:

[jira] [Commented] (FLINK-12872) WindowOperator may fail with UnsupportedOperationException when merging windows

[ https://issues.apache.org/jira/browse/FLINK-12872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866178#comment-16866178 ] Rong Rong commented on FLINK-12872: --- This might be a [related

[GitHub] [flink] shuai-xu commented on a change in pull request #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter

shuai-xu commented on a change in pull request #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter URL: https://github.com/apache/flink/pull/8688#discussion_r294590071 ## File path:

[GitHub] [flink] shuai-xu commented on a change in pull request #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter

shuai-xu commented on a change in pull request #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter URL: https://github.com/apache/flink/pull/8688#discussion_r294590090 ## File path:

[jira] [Created] (FLINK-12877) Unify catalog database implementations and remove CatalogDatabase interfaces

Bowen Li created FLINK-12877: Summary: Unify catalog database implementations and remove CatalogDatabase interfaces Key: FLINK-12877 URL: https://issues.apache.org/jira/browse/FLINK-12877 Project: Flink

[jira] [Commented] (FLINK-12841) Unify catalog meta-objects implementations and remove their interfaces

[ https://issues.apache.org/jira/browse/FLINK-12841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866163#comment-16866163 ] Bowen Li commented on FLINK-12841: -- [~jark] [~dawidwys] Thanks for your response. I will break the task

[GitHub] [flink] flinkbot commented on issue #8771: [FLINK-12778][table] Fix derive row type bug for table aggregate

flinkbot commented on issue #8771: [FLINK-12778][table] Fix derive row type bug for table aggregate URL: https://github.com/apache/flink/pull/8771#issuecomment-502921986 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-12778) Fix deriveTableAggRowType bug for non-composite types

[ https://issues.apache.org/jira/browse/FLINK-12778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12778: --- Labels: pull-request-available (was: ) > Fix deriveTableAggRowType bug for non-composite

[GitHub] [flink] hequn8128 opened a new pull request #8771: [FLINK-12778][table] Fix derive row type bug for table aggregate

hequn8128 opened a new pull request #8771: [FLINK-12778][table] Fix derive row type bug for table aggregate URL: https://github.com/apache/flink/pull/8771 ## What is the purpose of the change This pull request fix derives row type bug for table aggregate. Currently, we

[GitHub] [flink] tianchen92 commented on issue #8624: [FLINK-10932]Initial flink-kubernetes module with empty implementation

tianchen92 commented on issue #8624: [FLINK-10932]Initial flink-kubernetes module with empty implementation URL: https://github.com/apache/flink/pull/8624#issuecomment-502921125 Thanks a lot for your comments @wangyang0918 , updated this PR

[jira] [Updated] (FLINK-12866) Travis building failed due to cache dir missing

[ https://issues.apache.org/jira/browse/FLINK-12866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-12866: - Priority: Blocker (was: Minor) > Travis building failed due to cache dir missing >

[jira] [Updated] (FLINK-12866) Travis building failed due to cache dir missing

[ https://issues.apache.org/jira/browse/FLINK-12866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-12866: - Description: Here is the failure information. Cached flink dir /home/travis/flink_cache/37821/flink

[jira] [Updated] (FLINK-12866) Travis building failed due to cache dir missing

[ https://issues.apache.org/jira/browse/FLINK-12866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-12866: - Description: Here is the failure information. Cached flink dir /home/travis/flink_cache/37821/flink

[jira] [Updated] (FLINK-12866) Travis building failed due to cache dir missing

[ https://issues.apache.org/jira/browse/FLINK-12866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-12866: - Summary: Travis building failed due to cache dir missing (was: Connectors module failed on Travis

[GitHub] [flink] godfreyhe commented on a change in pull request #8764: [FLINK-12798][table-planner][table-api-java] Port TableEnvironment to table-api-java module

godfreyhe commented on a change in pull request #8764: [FLINK-12798][table-planner][table-api-java] Port TableEnvironment to table-api-java module URL: https://github.com/apache/flink/pull/8764#discussion_r294587812 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #8624: [FLINK-10932]Initial flink-kubernetes module with empty implementation

wangyang0918 commented on a change in pull request #8624: [FLINK-10932]Initial flink-kubernetes module with empty implementation URL: https://github.com/apache/flink/pull/8624#discussion_r294587564 ## File path: flink-kubernetes/pom.xml ## @@ -0,0 +1,139 @@ + + +

[GitHub] [flink] godfreyhe commented on a change in pull request #8707: [FLINK-12815] [table-planner-blink] Supports CatalogManager in blink planner

godfreyhe commented on a change in pull request #8707: [FLINK-12815] [table-planner-blink] Supports CatalogManager in blink planner URL: https://github.com/apache/flink/pull/8707#discussion_r294587431 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8707: [FLINK-12815] [table-planner-blink] Supports CatalogManager in blink planner

godfreyhe commented on a change in pull request #8707: [FLINK-12815] [table-planner-blink] Supports CatalogManager in blink planner URL: https://github.com/apache/flink/pull/8707#discussion_r294587149 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8707: [FLINK-12815] [table-planner-blink] Supports CatalogManager in blink planner

godfreyhe commented on a change in pull request #8707: [FLINK-12815] [table-planner-blink] Supports CatalogManager in blink planner URL: https://github.com/apache/flink/pull/8707#discussion_r294586956 ## File path:

[jira] [Commented] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866149#comment-16866149 ] Kurt Young commented on FLINK-11775: Does this jira still valid? [~lzljs3620320] > Introduce

[jira] [Commented] (FLINK-12865) State inconsistency between RM and TM on the slot status

[ https://issues.apache.org/jira/browse/FLINK-12865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866148#comment-16866148 ] Xiaogang Shi commented on FLINK-12865: -- [~till.rohrmann]You are right that there is no problem with

[GitHub] [flink] ifndef-SleePy opened a new pull request #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph…

ifndef-SleePy opened a new pull request #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph… URL: https://github.com/apache/flink/pull/8658 …Generator from StreamExecutionEnvironment ## What is the purpose of the change * Disentangle

[GitHub] [flink] ifndef-SleePy closed pull request #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph…

ifndef-SleePy closed pull request #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph… URL: https://github.com/apache/flink/pull/8658 This is an automated message from the Apache Git Service. To

[GitHub] [flink] wangyang0918 commented on a change in pull request #8624: [FLINK-10932]Initial flink-kubernetes module with empty implementation

wangyang0918 commented on a change in pull request #8624: [FLINK-10932]Initial flink-kubernetes module with empty implementation URL: https://github.com/apache/flink/pull/8624#discussion_r294584651 ## File path: flink-kubernetes/pom.xml ## @@ -0,0 +1,139 @@ + + +

[GitHub] [flink] wangyang0918 commented on a change in pull request #8624: [FLINK-10932]Initial flink-kubernetes module with empty implementation

wangyang0918 commented on a change in pull request #8624: [FLINK-10932]Initial flink-kubernetes module with empty implementation URL: https://github.com/apache/flink/pull/8624#discussion_r294584657 ## File path: flink-kubernetes/pom.xml ## @@ -0,0 +1,139 @@ + + +

[jira] [Created] (FLINK-12876) Adapt region failover NG for legacy scheduler

Zhu Zhu created FLINK-12876: --- Summary: Adapt region failover NG for legacy scheduler Key: FLINK-12876 URL: https://issues.apache.org/jira/browse/FLINK-12876 Project: Flink Issue Type: Sub-task

[GitHub] [flink] KurtYoung commented on a change in pull request #8758: [FLINK-12867] Add insert overwrite grammar as HIVE dialect

KurtYoung commented on a change in pull request #8758: [FLINK-12867] Add insert overwrite grammar as HIVE dialect URL: https://github.com/apache/flink/pull/8758#discussion_r294579742 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8758: [FLINK-12867] Add insert overwrite grammar as HIVE dialect

KurtYoung commented on a change in pull request #8758: [FLINK-12867] Add insert overwrite grammar as HIVE dialect URL: https://github.com/apache/flink/pull/8758#discussion_r294579855 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294574283 ## File path:

[GitHub] [flink] asfgit closed pull request #8755: [FLINK-12864][python][tests] Improves the Python Table API test cases performance

asfgit closed pull request #8755: [FLINK-12864][python][tests] Improves the Python Table API test cases performance URL: https://github.com/apache/flink/pull/8755 This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-12864) Improves the performance of Python Table API test cases

[ https://issues.apache.org/jira/browse/FLINK-12864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12864. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 

[GitHub] [flink] asfgit closed pull request #8664: [FLINK-12779][table] Avoid field conflicts when generate field names for non-composite Typeinformation

asfgit closed pull request #8664: [FLINK-12779][table] Avoid field conflicts when generate field names for non-composite Typeinformation URL: https://github.com/apache/flink/pull/8664 This is an automated message from the

[jira] [Closed] (FLINK-12779) Avoid field conflicts when generate field names for non-composite Typeinformation

[ https://issues.apache.org/jira/browse/FLINK-12779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12779. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294573416 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294573026 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294572899 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294572606 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294572553 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294572208 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294572062 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294571568 ## File path:

[GitHub] [flink] ifndef-SleePy opened a new pull request #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph…

ifndef-SleePy opened a new pull request #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph… URL: https://github.com/apache/flink/pull/8658 …Generator from StreamExecutionEnvironment ## What is the purpose of the change * Disentangle

[GitHub] [flink] ifndef-SleePy closed pull request #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph…

ifndef-SleePy closed pull request #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph… URL: https://github.com/apache/flink/pull/8658 This is an automated message from the Apache Git Service. To

[GitHub] [flink] ifndef-SleePy commented on issue #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph…

ifndef-SleePy commented on issue #8658: [FLINK-12686][runtime] Disentangle StreamGraph/StreamNode/StreamGraph… URL: https://github.com/apache/flink/pull/8658#issuecomment-502900338 Close and reopen to trigger Travis checking again.

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294568899 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294568899 ## File path:

[GitHub] [flink] sunjincheng121 commented on issue #8755: [FLINK-12864][python][tests] Improves the Python Table API test cases performance

sunjincheng121 commented on issue #8755: [FLINK-12864][python][tests] Improves the Python Table API test cases performance URL: https://github.com/apache/flink/pull/8755#issuecomment-502898051 +1 to merged. @flinkbot approve all

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294566905 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied.

gaoyunhaii commented on a change in pull request #8740: [FLINK-12763][runtime] Fail job immediately if tasks’ resource needs can not be satisfied. URL: https://github.com/apache/flink/pull/8740#discussion_r294566425 ## File path:

[GitHub] [flink] sunjincheng121 commented on issue #8664: [FLINK-12779][table] Avoid field conflicts when generate field names for non-composite Typeinformation

sunjincheng121 commented on issue #8664: [FLINK-12779][table] Avoid field conflicts when generate field names for non-composite Typeinformation URL: https://github.com/apache/flink/pull/8664#issuecomment-502894701 @flinkbot approve all +1 to merged

[GitHub] [flink] bowenli86 commented on issue #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF

bowenli86 commented on issue #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF URL: https://github.com/apache/flink/pull/8770#issuecomment-502889176 cc @JingsongLi @xuefuz @lirui-apache @zjuwangg This is an

[GitHub] [flink] flinkbot commented on issue #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF

flinkbot commented on issue #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF URL: https://github.com/apache/flink/pull/8770#issuecomment-502888469 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-12658) Integrate Flink with Hive GenericUDF

[ https://issues.apache.org/jira/browse/FLINK-12658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12658: --- Labels: pull-request-available (was: ) > Integrate Flink with Hive GenericUDF >

[GitHub] [flink] bowenli86 opened a new pull request #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF

bowenli86 opened a new pull request #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF URL: https://github.com/apache/flink/pull/8770 ## What is the purpose of the change This PR integrates Flink with Hive GenericUDF. Note this PR is based on

[jira] [Closed] (FLINK-12871) Wrong SSL setup examples in docs

[ https://issues.apache.org/jira/browse/FLINK-12871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-12871. --- Resolution: Fixed Fix Version/s: 1.8.1 1.9.0 1.7.3

[GitHub] [flink] alexeyt820 commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord

alexeyt820 commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord URL: https://github.com/apache/flink/pull/8535#issuecomment-502875880 I was thinking why it is one to one, maybe `serialize` should return list of `ProducerRecord`. Consider use case

[GitHub] [flink] bowenli86 commented on issue #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

bowenli86 commented on issue #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#issuecomment-502865153 cc @JingsongLi @xuefuz @lirui-apache @zjuwangg

[GitHub] [flink] flinkbot commented on issue #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

flinkbot commented on issue #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#issuecomment-502863998 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-12875) support converting input args of char, varchar, bytes, timestamp, date for Hive functions

[ https://issues.apache.org/jira/browse/FLINK-12875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12875: --- Labels: pull-request-available (was: ) > support converting input args of char, varchar,

[GitHub] [flink] bowenli86 opened a new pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

bowenli86 opened a new pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769 ## What is the purpose of the change This PR adds support for converting input

[jira] [Updated] (FLINK-12875) support converting input args of char, varchar, bytes, timestamp, date for Hive functions

[ https://issues.apache.org/jira/browse/FLINK-12875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12875: - Summary: support converting input args of char, varchar, bytes, timestamp, date for Hive functions

[jira] [Updated] (FLINK-12875) [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

[ https://issues.apache.org/jira/browse/FLINK-12875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12875: - Summary: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date

  1   2   3   4   >