[jira] [Created] (FLINK-19686) Cast question for data | time

2020-10-16 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-19686: - Summary: Cast question for data | time Key: FLINK-19686 URL: https://issues.apache.org/jira/browse/FLINK-19686 Project: Flink Issue Type: Wish Component

Re: Re: [VOTE] Add Translation Specification for Stateful Functions

2020-10-16 Thread Shawn Huang
Hi, Congxian. Thanks for your contribution. I noticed that in wiki, the link format is still like "{{ site.baseurl }}/.../xxx.html". But the "{% link %}" tag is recommended now [1]. So is it necessary to update this in wiki? It seems some translators haven't noticed this. [1] http://apache-flink-m

Re: IllegalStateException from incompatible state type - better exception type?

2020-10-16 Thread Kim, Hwanju
Thanks Gordon. If its semantic is not (yet) clearly defined, I think we can make it a bit more clear. Incrementally, I think any exception that's more specific than general Java exception (e.g., IllegalStateException) would be at least making information better, where or not there is clearly se

[jira] [Created] (FLINK-19685) When use HBase-Connector lookupFunction, 8 hours less to query `DATE`,`TIME`,`TIMESTAMP` data

2020-10-16 Thread CaoZhen (Jira)
CaoZhen created FLINK-19685: --- Summary: When use HBase-Connector lookupFunction, 8 hours less to query `DATE`,`TIME`,`TIMESTAMP` data Key: FLINK-19685 URL: https://issues.apache.org/jira/browse/FLINK-19685

Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image

2020-10-16 Thread Till Rohrmann
+1 for making it configurable in the same Docker image. Cheers, Till On Fri, Oct 16, 2020 at 12:56 PM Chesnay Schepler wrote: > If it is possible to support both allocators in a single image then we > should definitely go with that option. > > On 10/16/2020 12:21 PM, Yun Tang wrote: > > Thanks

[jira] [Created] (FLINK-19684) The Jdbc-connector's 'lookup.max-retries' option implementation is different from the meaning

2020-10-16 Thread CaoZhen (Jira)
CaoZhen created FLINK-19684: --- Summary: The Jdbc-connector's 'lookup.max-retries' option implementation is different from the meaning Key: FLINK-19684 URL: https://issues.apache.org/jira/browse/FLINK-19684

Re: Re: [VOTE] Add Translation Specification for Stateful Functions

2020-10-16 Thread Congxian Qiu
FYI, I've added the Specification for Stateful Functions to the existing wiki[1] [1] https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications Best, Congxian Congxian Qiu 于2020年10月15日周四 下午8:33写道: > Hi all > Thanks everyone for the voting. > > The voting time f

Re: [DISCUSS] Remove flink-connector-filesystem module.

2020-10-16 Thread Chesnay Schepler
@Seth: Earlier in this discussion it was said that the BucketingSink would not be usable in 1.12 . On 10/16/2020 4:25 PM, Seth Wiesman wrote: +1 It has been deprecated for some time and the StreamingFileSink has stabalized with a large number of formats and features. Plus, the bucketing sink o

Re: [DISCUSS] Remove flink-connector-filesystem module.

2020-10-16 Thread Seth Wiesman
+1 It has been deprecated for some time and the StreamingFileSink has stabalized with a large number of formats and features. Plus, the bucketing sink only implements a small number of stable interfaces[1]. I would expect users to continue to use the bucketing sink from the 1.11 release with futur

[jira] [Created] (FLINK-19683) Actively timeout aligned checkpoints on the output

2020-10-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-19683: -- Summary: Actively timeout aligned checkpoints on the output Key: FLINK-19683 URL: https://issues.apache.org/jira/browse/FLINK-19683 Project: Flink Issue

[jira] [Created] (FLINK-19682) Actively timeout checkpoint barriers on the inputs

2020-10-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-19682: -- Summary: Actively timeout checkpoint barriers on the inputs Key: FLINK-19682 URL: https://issues.apache.org/jira/browse/FLINK-19682 Project: Flink Issue

[jira] [Created] (FLINK-19681) Passively timeout alignment on the inputs

2020-10-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-19681: -- Summary: Passively timeout alignment on the inputs Key: FLINK-19681 URL: https://issues.apache.org/jira/browse/FLINK-19681 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-19680) Add CheckpointBarrierAnnouncement priority message

2020-10-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-19680: -- Summary: Add CheckpointBarrierAnnouncement priority message Key: FLINK-19680 URL: https://issues.apache.org/jira/browse/FLINK-19680 Project: Flink Issue

[jira] [Created] (FLINK-19679) Deduplicate code between CheckpointBarrierUnaligner and CheckpointBarrierAligner

2020-10-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-19679: -- Summary: Deduplicate code between CheckpointBarrierUnaligner and CheckpointBarrierAligner Key: FLINK-19679 URL: https://issues.apache.org/jira/browse/FLINK-19679

[jira] [Created] (FLINK-19678) tableEnv.getConfig.setNullCheck(false) seems to break group by

2020-10-16 Thread Ion Alberdi (Jira)
Ion Alberdi created FLINK-19678: --- Summary: tableEnv.getConfig.setNullCheck(false) seems to break group by Key: FLINK-19678 URL: https://issues.apache.org/jira/browse/FLINK-19678 Project: Flink

[jira] [Created] (FLINK-19677) TaskManager takes abnormally long time to register with JobManager on Kubernetes

2020-10-16 Thread Weike Dong (Jira)
Weike Dong created FLINK-19677: -- Summary: TaskManager takes abnormally long time to register with JobManager on Kubernetes Key: FLINK-19677 URL: https://issues.apache.org/jira/browse/FLINK-19677 Project:

Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image

2020-10-16 Thread Chesnay Schepler
If it is possible to support both allocators in a single image then we should definitely go with that option. On 10/16/2020 12:21 PM, Yun Tang wrote: Thanks for Yang's suggestion. I think this could be a better choice. We could install jemalloc and only enable it in LD_PRELOAD when user pass s

[jira] [Created] (FLINK-19676) java package name error in docs

2020-10-16 Thread leiqiang (Jira)
leiqiang created FLINK-19676: Summary: java package name error in docs Key: FLINK-19676 URL: https://issues.apache.org/jira/browse/FLINK-19676 Project: Flink Issue Type: Bug Components:

Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image

2020-10-16 Thread Yun Tang
Thanks for Yang's suggestion. I think this could be a better choice. We could install jemalloc and only enable it in LD_PRELOAD when user pass specific configuration for docker-entrypoint.sh. By doing so, we could avoid to create another docker image tags and also offer ability to reduce memory f

[jira] [Created] (FLINK-19675) The plan of is incorrect when Calc contains WHERE clause, composite fields access and Python UDF at the same time

2020-10-16 Thread Dian Fu (Jira)
Dian Fu created FLINK-19675: --- Summary: The plan of is incorrect when Calc contains WHERE clause, composite fields access and Python UDF at the same time Key: FLINK-19675 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-19674) Translate "Docker" of "Clusters & Depolyment" page into Chinese

2020-10-16 Thread Shubin Ruan (Jira)
Shubin Ruan created FLINK-19674: --- Summary: Translate "Docker" of "Clusters & Depolyment" page into Chinese Key: FLINK-19674 URL: https://issues.apache.org/jira/browse/FLINK-19674 Project: Flink

[jira] [Created] (FLINK-19673) Translate "Standalone Cluster" of "Clusters & Depolyment" page into Chinese

2020-10-16 Thread Xiao Huang (Jira)
Xiao Huang created FLINK-19673: -- Summary: Translate "Standalone Cluster" of "Clusters & Depolyment" page into Chinese Key: FLINK-19673 URL: https://issues.apache.org/jira/browse/FLINK-19673 Project: Flin

[jira] [Created] (FLINK-19672) Merge kafka-connector-base into flink-connector-kafka

2020-10-16 Thread Timo Walther (Jira)
Timo Walther created FLINK-19672: Summary: Merge kafka-connector-base into flink-connector-kafka Key: FLINK-19672 URL: https://issues.apache.org/jira/browse/FLINK-19672 Project: Flink Issue T

[jira] [Created] (FLINK-19671) Update EditorConfig file to be useful

2020-10-16 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-19671: Summary: Update EditorConfig file to be useful Key: FLINK-19671 URL: https://issues.apache.org/jira/browse/FLINK-19671 Project: Flink Issue Type: Imp

Re: [DISCUSS] FLIP-148: Introduce Sort-Merge Based Blocking Shuffle to Flink

2020-10-16 Thread Till Rohrmann
Thanks for sharing the preliminary numbers with us Yingjie. The numbers look quite impressive :-) Cheers, Till On Thu, Oct 15, 2020 at 5:25 PM Yingjie Cao wrote: > Hi Till, > > Thanks for your reply and comments. > > You are right, the proposed sort-merge based shuffle is an extension of the >

[jira] [Created] (FLINK-19670) Create view error

2020-10-16 Thread simenliuxing (Jira)
simenliuxing created FLINK-19670: Summary: Create view error Key: FLINK-19670 URL: https://issues.apache.org/jira/browse/FLINK-19670 Project: Flink Issue Type: Bug Components: Table