Re: [DISCUSS] FLIP-33: Standardize connector metrics

In any case, we probably have to make some change to the existing MetricGroup interface. We can discuss that in this thread as well. On Thu, Mar 21, 2019 at 1:13 PM Becket Qin wrote: > A few updates to the thread. I uploaded a patch[1] as a complete example > of how users can use the metrics in

Re: [DISCUSS] FLIP-33: Standardize connector metrics

A few updates to the thread. I uploaded a patch[1] as a complete example of how users can use the metrics in the future. Some thoughts below after taking a look at the AbstractMetricGroup and its subclasses. This patch intends to provide convenience for Flink connector implementations to follow

Re: [DISCUSS] Improve the flinkbot

Hi all, In the past discussion of Supporting Chinese Documentation for Apache Flink[1], we reach a consensus to add a documentation check item to the flinkbot review process. I propose the idea here to get some more feedbacks about this. The new item we want to add is: ``` ### 6. Are English

Re: [DISCUSS] Introduction of a Table API Java Expression DSL

Hi Timo, I'm +1 on the proposal. I like the idea to provide a Java DSL which is more friendly than string-based approach in programming. My concern is if/when we can drop the string-based expression parser. If it takes a very long time, we have to paid more development cost on the three Table

Re: [DISCUSS] Reorganizing Table-related Jira components some more

+1 to Kurt's proposal which removes the "API" prefix and add a table's operator component. In the other hand, I think it's worth to distinguish Blink SQL issues and Flink SQL issues via the component name. Currently, it's hard to distinguish. How about: Table SQL / API Table SQL / Client Table

Re: [DISCUSS] Reorganizing Table-related Jira components some more

Hi Aljoscha, +1 to further separate table-relate jira components, but I would prefer to move "Runtime / Operators" to a dedicated "Table SQL / Operators". There is one concern about the "classic planner" and "new planner", the naming will be inaccurate after blink merge done and we deprecated

Re: [DISCUSS] Reorganizing Table-related Jira components some more

+1 to restructure the Jira components. How about: Table / API Table / Client Table / Classic Planner (or Legacy Planner) Table / New Planner Regards, Shaoxuan On Thu, Mar 21, 2019 at 12:39 AM Aljoscha Krettek wrote: > Hi, > > First of all, I hope I cc’ed all the relevant people. Sorry if I

Re: [PROGRESS UPDATE] [DISCUSS] Flink-Hive Integration and Catalogs

Thanks, Shaoxuan! I've sent a Chinese version to user-zh at the same time yesterday. >From feedbacks we received so far, supporting multiple older hive versions is definitely one of our focuses next. *More feedbacks are welcome from our community!* On Tue, Mar 19, 2019 at 8:44 PM Shaoxuan Wang

Contributor permission application

Hi guys, Could you please give me contributor permissions for Flink project? Here my Jira id: artsem.semianenka Best regards, Artsem

[jira] [Created] (FLINK-11986) Add micro benchmark for state operations

Yu Li created FLINK-11986: - Summary: Add micro benchmark for state operations Key: FLINK-11986 URL: https://issues.apache.org/jira/browse/FLINK-11986 Project: Flink Issue Type: Improvement

[DISCUSS] Reorganizing Table-related Jira components some more

Hi, First of all, I hope I cc’ed all the relevant people. Sorry if I forgot anyone. I would like to restructure the Table/SQL-related Jira components a bit more to better reflect the current state of components. Right now we have: * API / Table SQL: this is just a wild collection of

Fw: Contributor permission application

Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is yutaochina. 2019-03-20 博彦科技股份有限公司 --上海泓智信息科技有限公司 地址：上海市长宁区天山路8号402室 邮编：200336 手机：15501079221 邮箱：hdxg1101300...@163.com，yuta...@beyondsoft.com 发件人："hdxg1101300123"

contributor permission apply

Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is jianlong miao.

[jira] [Created] (FLINK-11985) Remove ignored command line parameter from yarn_setup.md

Guowei Ma created FLINK-11985: - Summary: Remove ignored command line parameter from yarn_setup.md Key: FLINK-11985 URL: https://issues.apache.org/jira/browse/FLINK-11985 Project: Flink Issue

Re: contributor permission application

Done. On 20.03.2019 13:35, shaomeng wang wrote: Hi there, I want to be a Flink contributor. Would you please give me the contributor permission? My JIRA ID is shaomeng.wang Thanks, Shaomeng Wang

Re: contributor permission application

Done. On 20.03.2019 13:26, Xu Yang wrote: Hi there, I want to be a Flink contributor. Would you please give me the contributor permission? My JIRA ID is xuyang1706 Thanks, Xu

Re: contributor permission application

Done. On 20.03.2019 14:03, Meng Wang wrote: Hi there, I want to be a Flink contributor. Could you please give me contributor permissions? My jira id is: wangm92. --- Best, Matt Wang Original Message Sender:shaomeng wangshaomengwan...@gmail.com Recipient:dev...@flink.apache.org

Re: contributor permission apply

Done. On 20.03.2019 12:25, ?? wrote: Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is robot_lgw.

contributor permission application

Hi there, I want to be a Flink contributor. Could you please give me contributor permissions? My jira id is: wangm92. --- Best, Matt Wang Original Message Sender:shaomeng wangshaomengwan...@gmail.com Recipient:dev...@flink.apache.org Date:Wednesday, Mar 20, 2019 20:35 Subject:contributor

[jira] [Created] (FLINK-11984) StreamingFileSink docs do not mention S3 savepoint caveats.

Kostas Kloudas created FLINK-11984: -- Summary: StreamingFileSink docs do not mention S3 savepoint caveats. Key: FLINK-11984 URL: https://issues.apache.org/jira/browse/FLINK-11984 Project: Flink

contributor permission application

Hi there, I want to be a Flink contributor. Would you please give me the contributor permission? My JIRA ID is shaomeng.wang Thanks, Shaomeng Wang

contributor permission application

Hi there, I want to be a Flink contributor. Would you please give me the contributor permission? My JIRA ID is xuyang1706 Thanks, Xu

[jira] [Created] (FLINK-11983) Refactor resolved aggregation reference expressions in blink

Jingsong Lee created FLINK-11983: Summary: Refactor resolved aggregation reference expressions in blink Key: FLINK-11983 URL: https://issues.apache.org/jira/browse/FLINK-11983 Project: Flink

[jira] [Created] (FLINK-11982) org.apache.flink.table.api.NoMatchingTableFactoryException

pingle wang created FLINK-11982: --- Summary: org.apache.flink.table.api.NoMatchingTableFactoryException Key: FLINK-11982 URL: https://issues.apache.org/jira/browse/FLINK-11982 Project: Flink

[jira] [Created] (FLINK-11981) Introduce ProjectionCodeGenerator and HashCodeGenerator for BaseRow

Jingsong Lee created FLINK-11981: Summary: Introduce ProjectionCodeGenerator and HashCodeGenerator for BaseRow Key: FLINK-11981 URL: https://issues.apache.org/jira/browse/FLINK-11981 Project: Flink

[jira] [Created] (FLINK-11980) Improve efficiency of iterating KeySelectionListener on notification

Stefan Richter created FLINK-11980: -- Summary: Improve efficiency of iterating KeySelectionListener on notification Key: FLINK-11980 URL: https://issues.apache.org/jira/browse/FLINK-11980 Project:

contributor permission apply

Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is robot_lgw.

Re: apply for contributor permission

Done. On 20.03.2019 10:10, Xintong Song wrote: Hi, Could someone kindly give me the contributor permission? JIRA account: xintongsong Thank you~ Xintong Song

[REMINDER] Flink Forward San Francisco in a few days

Hi everyone, *Flink Forward San Francisco 2019 will take place in a few days on April 1st and 2nd.* If you haven't done so already and are planning to attend, you should register soon at: -> https://sf-2019.flink-forward.org/register Don't forget to use the 25% discount code *MailingList* for

[jira] [Created] (FLINK-11978) Enable vectorized Python UDF with Pandas api

Yurui Zhou created FLINK-11978: -- Summary: Enable vectorized Python UDF with Pandas api Key: FLINK-11978 URL: https://issues.apache.org/jira/browse/FLINK-11978 Project: Flink Issue Type:

apply for contributor permission

Hi, Could someone kindly give me the contributor permission? JIRA account: xintongsong Thank you~ Xintong Song

Re: flink jira contributor permission

Hi, Welcome to the Flink community. I've given you contributor permissions for Jira. Best, Fabian Am Mi., 20. März 2019 um 07:11 Uhr schrieb 陶然(楚澄) < chucheng...@alibaba-inc.com>: > Hi, > > I want to contribute to Apache Flink. > Would you please give me the contributor permission? > My JIRA

[jira] [Created] (FLINK-11979) Using Apache Arrow as the serialization format between Java runtime and Python worker

Yurui Zhou created FLINK-11979: -- Summary: Using Apache Arrow as the serialization format between Java runtime and Python worker Key: FLINK-11979 URL: https://issues.apache.org/jira/browse/FLINK-11979

[jira] [Created] (FLINK-11977) Enable PyFlink to interact with Pandas

Yurui Zhou created FLINK-11977: -- Summary: Enable PyFlink to interact with Pandas Key: FLINK-11977 URL: https://issues.apache.org/jira/browse/FLINK-11977 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11976) PyFlink vectorized python udf with Pandas support

Yurui Zhou created FLINK-11976: -- Summary: PyFlink vectorized python udf with Pandas support Key: FLINK-11976 URL: https://issues.apache.org/jira/browse/FLINK-11976 Project: Flink Issue Type:

[jira] [Created] (FLINK-11975) Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)'

Jing Zhang created FLINK-11975: -- Summary: Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)' Key: FLINK-11975 URL: https://issues.apache.org/jira/browse/FLINK-11975 Project:

[jira] [Created] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen

Jingsong Lee created FLINK-11974: Summary: Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen Key: FLINK-11974 URL: https://issues.apache.org/jira/browse/FLINK-11974

[jira] [Created] (FLINK-11973) computeSelfCost method should not return null to avoid NPE

godfrey he created FLINK-11973: -- Summary: computeSelfCost method should not return null to avoid NPE Key: FLINK-11973 URL: https://issues.apache.org/jira/browse/FLINK-11973 Project: Flink Issue

flink jira contributor permission

Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is lemonjing. Thanks.

[jira] [Created] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error

sunjincheng created FLINK-11972: --- Summary: Fix `Command: start_kubernetes_if_not_ruunning failed` error Key: FLINK-11972 URL: https://issues.apache.org/jira/browse/FLINK-11972 Project: Flink