Re: [VOTE] FLIP-105: Support to Interpret and Emit Changelog in Flink SQL

2020-04-13 Thread Jark Wu
+1 (binding) Best, Jark On Sun, 12 Apr 2020 at 09:24, Benchao Li wrote: > +1 (non-binding) > > Jark Wu 于2020年4月11日周六 上午11:31写道: > > > Hi all, > > > > I would like to start the vote for FLIP-105 [1], which is discussed and > > reached a consensus in the discussion thread [2]. > > > > The vote

[jira] [Created] (FLINK-17127) Make pod creating retry interval configurable

2020-04-13 Thread Yang Wang (Jira)
Yang Wang created FLINK-17127: - Summary: Make pod creating retry interval configurable Key: FLINK-17127 URL: https://issues.apache.org/jira/browse/FLINK-17127 Project: Flink Issue Type: New

[jira] [Created] (FLINK-17126) Correct the execution behavior of BatchTableEnvironment

2020-04-13 Thread godfrey he (Jira)
godfrey he created FLINK-17126: -- Summary: Correct the execution behavior of BatchTableEnvironment Key: FLINK-17126 URL: https://issues.apache.org/jira/browse/FLINK-17126 Project: Flink Issue

[jira] [Created] (FLINK-17125) Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17125: Summary: Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users Key: FLINK-17125 URL: https://issues.apache.org/jira/browse/FLINK-17125

[jira] [Created] (FLINK-17124) The PyFlink Job runs into infinite loop if the UDF file imports job code.

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17124: Summary: The PyFlink Job runs into infinite loop if the UDF file imports job code. Key: FLINK-17124 URL: https://issues.apache.org/jira/browse/FLINK-17124 Project:

[VOTE] FLIP-123: DDL and DML compatibility for Hive connector

2020-04-13 Thread Rui Li
Hi all, I'd like to start the vote for FLIP-123[1], which has been discussed in thread[2]. The vote will be open for 72h, until April 16 2020 01:00 PM UTC, unless there's an objection. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-123%3A+DDL+and+DML+compatibility+for+Hive+connector

[jira] [Created] (FLINK-17123) flink-sql-connector-elasticsearch版本与 es 版本不对应

2020-04-13 Thread longxibendi (Jira)
longxibendi created FLINK-17123: --- Summary: flink-sql-connector-elasticsearch版本与 es 版本不对应 Key: FLINK-17123 URL: https://issues.apache.org/jira/browse/FLINK-17123 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17122) Support InputSelectable and BoundedMultiInput operators with checkpointing

2020-04-13 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-17122: -- Summary: Support InputSelectable and BoundedMultiInput operators with checkpointing Key: FLINK-17122 URL: https://issues.apache.org/jira/browse/FLINK-17122

[jira] [Created] (FLINK-17121) Adds Pipeline of Building Wheel Packages in Azure CI

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17121: Summary: Adds Pipeline of Building Wheel Packages in Azure CI Key: FLINK-17121 URL: https://issues.apache.org/jira/browse/FLINK-17121 Project: Flink Issue

[jira] [Created] (FLINK-17120) Support Cython Optimizing Python Operations

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17120: Summary: Support Cython Optimizing Python Operations Key: FLINK-17120 URL: https://issues.apache.org/jira/browse/FLINK-17120 Project: Flink Issue Type:

[jira] [Created] (FLINK-17119) Support Composite DataTypes in Cython

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17119: Summary: Support Composite DataTypes in Cython Key: FLINK-17119 URL: https://issues.apache.org/jira/browse/FLINK-17119 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17118) Support Primitive DataTypes in Cython

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17118: Summary: Support Primitive DataTypes in Cython Key: FLINK-17118 URL: https://issues.apache.org/jira/browse/FLINK-17118 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17117) There are an useless cast operation for sql on blink when generate code

2020-04-13 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-17117: - Summary: There are an useless cast operation for sql on blink when generate code Key: FLINK-17117 URL: https://issues.apache.org/jira/browse/FLINK-17117 Project: Flink

Re: apply contributor

2020-04-13 Thread Benchao Li
Hi 牧桦, Welcome to the community! Currently, we don't need to apply a contributor permission to contribute, contributors has no authority to assign issues. You can create an issue and ask a committer to assign it to you. 郭牧桦 <18534455...@163.com> 于2020年4月13日周一 下午5:33写道: > Hi Guys, > > I want to

[jira] [Created] (FLINK-17116) support UsernamePasswordCredentials for elasticsearch sink via SQL DDL

2020-04-13 Thread Kai Chen (Jira)
Kai Chen created FLINK-17116: Summary: support UsernamePasswordCredentials for elasticsearch sink via SQL DDL Key: FLINK-17116 URL: https://issues.apache.org/jira/browse/FLINK-17116 Project: Flink

Re: [DISCUSS] FLIP-123: DDL and DML compatibility for Hive connector

2020-04-13 Thread Rui Li
Thanks Jingsong for the explanation and it makes sense. I have updated the FLIP. Let me know if that reflects what you have in mind. On Mon, Apr 13, 2020 at 4:52 PM Jingsong Li wrote: > Hi, > > I didn't mean to unify parser for Flink SQL and Hive SQL. > I mean we should not put hive things to

apply contributor

2020-04-13 Thread 郭牧桦
Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is doushabao. | | 郭牧桦 | | 18534455...@163.com | 签名由网易邮箱大师定制

Re: [DISCUSS] FLIP-123: DDL and DML compatibility for Hive connector

2020-04-13 Thread Jingsong Li
Hi, I didn't mean to unify parser for Flink SQL and Hive SQL. I mean we should not put hive things to planner. Because planner have set conformance. So the parser already know the dialect things. A simple way is implement a Flink SqlParserImplFactory with conformance. We can limit dialect things

Re: [DISCUSS] Generating java code?

2020-04-13 Thread Niels Basjes
Hi, On Mon, Apr 13, 2020 at 8:30 AM Yang Wang wrote: > Although the latter option is more stable, > i think it is not acceptable for all the developers to execute `mvn > generate-sources` first. Otherwise, the Flink project is just broken and could not run tests, Flink > jobs in IDE. > > It is

[jira] [Created] (FLINK-17115) Support Cython Optimizing Python User Defined Function(FLIP-121)

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17115: Summary: Support Cython Optimizing Python User Defined Function(FLIP-121) Key: FLINK-17115 URL: https://issues.apache.org/jira/browse/FLINK-17115 Project: Flink

[jira] [Created] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

2020-04-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-17114: - Summary: When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail. Key: FLINK-17114 URL:

[jira] [Created] (FLINK-17113) Refactor view support in SQL Client

2020-04-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17113: Summary: Refactor view support in SQL Client Key: FLINK-17113 URL: https://issues.apache.org/jira/browse/FLINK-17113 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17112) Support DESCRIBE VIEW view_name in Flink SQL

2020-04-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17112: Summary: Support DESCRIBE VIEW view_name in Flink SQL Key: FLINK-17112 URL: https://issues.apache.org/jira/browse/FLINK-17112 Project: Flink Issue Type:

[jira] [Created] (FLINK-17111) Support SHOW VIEWS in Flink SQL

2020-04-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17111: Summary: Support SHOW VIEWS in Flink SQL Key: FLINK-17111 URL: https://issues.apache.org/jira/browse/FLINK-17111 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17110) Make StreamExecutionEnvironment#configure also affects configuration

2020-04-13 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-17110: --- Summary: Make StreamExecutionEnvironment#configure also affects configuration Key: FLINK-17110 URL: https://issues.apache.org/jira/browse/FLINK-17110 Project: Flink

[RESULT][VOTE] FLIP-121: Support Cython Optimizing Python User Defined Function

2020-04-13 Thread Xingbo Huang
Hi all, The voting time for FLIP-121[1] has passed. I'm closing the vote now. There 3 + 1votes, 3 of which are binding: - Dian (binding) - Jincheng (binding) - Hequn (binding) There are no disapproving votes. Thus, FLIP-121 has been accepted. Thanks a lot for everyone for joining this

[jira] [Created] (FLINK-17109) FlinkPipelineTranslationUtil#getJobGraph doesn't consider Jars and Classpaths in configuration.

2020-04-13 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-17109: --- Summary: FlinkPipelineTranslationUtil#getJobGraph doesn't consider Jars and Classpaths in configuration. Key: FLINK-17109 URL: https://issues.apache.org/jira/browse/FLINK-17109

Re: [VOTE] FLIP-121: Support Cython Optimizing Python User Defined Function

2020-04-13 Thread Xingbo Huang
Hi all, Thanks a lot for the discussion and votes. I will summarize the result in a separate email. Best, Xingbo Hequn Cheng 于2020年4月13日周一 下午3:12写道: > +1 (binding) > > Best, > Hequn > > On Mon, Apr 13, 2020 at 1:50 PM jincheng sun > wrote: > > > +1(binding) > > > > Best, > > Jincheng > > > >

Re: [VOTE] FLIP-121: Support Cython Optimizing Python User Defined Function

2020-04-13 Thread Hequn Cheng
+1 (binding) Best, Hequn On Mon, Apr 13, 2020 at 1:50 PM jincheng sun wrote: > +1(binding) > > Best, > Jincheng > > > > Dian Fu 于2020年4月8日周三 上午9:59写道: > > > +1 (binding) > > > > > 在 2020年4月8日,上午9:53,Xingbo Huang 写道: > > > > > > Hi all, > > > I would like to start the vote for FLIP-121[1],

[RESULT][VOTE] FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame

2020-04-13 Thread Dian Fu
Hi all, The voting time for FLIP-120[1] has passed. I'm closing the vote now. There are 5 +1 votes, 3 of which are binding: - Jincheng (binding) - Hequn (binding) - Dian Fu (binding) - Xingbo Huang (non-binding) - Jeff (non-binding) There are no disapproving votes and thus FLIP-120 has been

[jira] [Created] (FLINK-17108) Exception: Cannot determine simple type name "com"

2020-04-13 Thread xiemeilong (Jira)
xiemeilong created FLINK-17108: -- Summary: Exception: Cannot determine simple type name "com" Key: FLINK-17108 URL: https://issues.apache.org/jira/browse/FLINK-17108 Project: Flink Issue Type:

Re: [VOTE] FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame

2020-04-13 Thread Dian Fu
Hi all, Thanks a lot for the discussion and votes. I'll summarize the voting results in a separate email. Regards, Dian > 在 2020年4月13日,下午2:40,Dian Fu 写道: > > +1 (binding) > > Regards, > Dian > >> 在 2020年4月13日,下午1:31,Hequn Cheng 写道: >> >> +1 (binding) >> >> Best, >> Hequn >> >> On Mon,

Re: [VOTE] FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame

2020-04-13 Thread Dian Fu
+1 (binding) Regards, Dian > 在 2020年4月13日,下午1:31,Hequn Cheng 写道: > > +1 (binding) > > Best, > Hequn > > On Mon, Apr 13, 2020 at 1:28 PM Jeff Zhang wrote: > >> +1 >> >> >> jincheng sun 于2020年4月13日周一 下午1:24写道: >> >>> +1(binding) >>> >>> Best, >>> Jincheng >>> >>> >>> >>> Xingbo Huang

[jira] [Created] (FLINK-17107) CheckpointCoordinatorConfiguration#isExactlyOnce() is inconsistent with StreamConfig#getCheckpointMode()

2020-04-13 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-17107: --- Summary: CheckpointCoordinatorConfiguration#isExactlyOnce() is inconsistent with StreamConfig#getCheckpointMode() Key: FLINK-17107 URL:

Re: [DISCUSS] Generating java code?

2020-04-13 Thread Yang Wang
Hi Niels, Thanks a lot for starting this discussion. Although the latter option is more stable, i think it is not acceptable for all the developers to execute `mvn generate-sources` first. Otherwise, the Flink project is just broken and could not run tests, Flink jobs in IDE. So i think the

[jira] [Created] (FLINK-17106) Support create/drop view in Flink SQL

2020-04-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17106: Summary: Support create/drop view in Flink SQL Key: FLINK-17106 URL: https://issues.apache.org/jira/browse/FLINK-17106 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17105) FLIP-71: E2E viewsupport

2020-04-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17105: Summary: FLIP-71: E2E viewsupport Key: FLINK-17105 URL: https://issues.apache.org/jira/browse/FLINK-17105 Project: Flink Issue Type: New Feature