[jira] [Created] (FLINK-26367) Move sanity check in FlinkService#cancelJob to DefaultDeploymentValidator

2022-02-24 Thread Yang Wang (Jira)
Yang Wang created FLINK-26367: - Summary: Move sanity check in FlinkService#cancelJob to DefaultDeploymentValidator Key: FLINK-26367 URL: https://issues.apache.org/jira/browse/FLINK-26367 Project: Flink

[jira] [Created] (FLINK-26366) Support "insert directory"

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26366: Summary: Support "insert directory" Key: FLINK-26366 URL: https://issues.apache.org/jira/browse/FLINK-26366 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26365) improve hive udaf

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26365: Summary: improve hive udaf Key: FLINK-26365 URL: https://issues.apache.org/jira/browse/FLINK-26365 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-26364) Improve hive udtf

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26364: Summary: Improve hive udtf Key: FLINK-26364 URL: https://issues.apache.org/jira/browse/FLINK-26364 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-26363) Fail to use such expression like if(1= 1, 2, 3)

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26363: Summary: Fail to use such expression like if(1= 1, 2, 3) Key: FLINK-26363 URL: https://issues.apache.org/jira/browse/FLINK-26363 Project: Flink Issue Type: Sub-task

Re: jira

2022-02-24 Thread Yun Gao
Hi Simon, Thanks for your passion for contributing to the Flink community. You don't need a contributor permission to contribute your code to Flink. Find an open issue you are interested in at http://issues.apache.org/jira/browse/FLINK and comment with your ideas. It would be a good start for

Re: contributor

2022-02-24 Thread Yun Gao
Hi Mu, Thanks for your passion for contributing to the Flink community. You don't need a contributor permission to contribute your code to Flink. Find an open issue you are interested in at http://issues.apache.org/jira/browse/FLINK and comment with your ideas. It would be a good start for issues

Re: Re: [ANNOUNCE] Flink 1.15 Feature Freeze

2022-02-24 Thread Yun Gao
Hi Jing, Thanks for letting us know. I think it should be ok to merge this PR since the issue itself is a severe bug that would block the releasing, and the fix itself is not complex and is thus controllable. Best, Yun --Original Mail -- Sender:Jing Ge Send

[jira] [Created] (FLINK-26362) IndexOutOfBoundsException when subquery select all field from using hive dialect

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26362: Summary: IndexOutOfBoundsException when subquery select all field from using hive dialect Key: FLINK-26362 URL: https://issues.apache.org/jira/browse/FLINK-26362 Project:

[jira] [Created] (FLINK-26361) "Unexpected correlate variable $cor0" when using hive dialect to write a subquery

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26361: Summary: "Unexpected correlate variable $cor0" when using hive dialect to write a subquery Key: FLINK-26361 URL: https://issues.apache.org/jira/browse/FLINK-26361 Project:

[jira] [Created] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26360: Summary: [Umbrella] Improvement for Hive Query Syntax Compatibility Key: FLINK-26360 URL: https://issues.apache.org/jira/browse/FLINK-26360 Project: Flink Issue

possible bug in Statefun Golang SDK related to Context.Caller

2022-02-24 Thread Galen Warren
On the Context interface, Caller is defined like this: // Caller is the caller function instance's Address, if applicable. This is nil // if the message was sent to this function via an ingress. Caller() *Address ... so, in the event a function is invoked from an ingress, as opposed to from

[jira] [Created] (FLINK-26359) Aligning the retry mechanism for the repeatable cleanup and task restarts

2022-02-24 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26359: - Summary: Aligning the retry mechanism for the repeatable cleanup and task restarts Key: FLINK-26359 URL: https://issues.apache.org/jira/browse/FLINK-26359 Project:

[jira] [Created] (FLINK-26358) Operator maxParallelism is lost during chaining

2022-02-24 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-26358: --- Summary: Operator maxParallelism is lost during chaining Key: FLINK-26358 URL: https://issues.apache.org/jira/browse/FLINK-26358 Project: Flink Issue Type:

[jira] [Created] (FLINK-26357) add @PublicEvolving to AvroParquetRecordFormat

2022-02-24 Thread Jing Ge (Jira)
Jing Ge created FLINK-26357: --- Summary: add @PublicEvolving to AvroParquetRecordFormat Key: FLINK-26357 URL: https://issues.apache.org/jira/browse/FLINK-26357 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26356) Revisit the create of RestClusterClient

2022-02-24 Thread Aitozi (Jira)
Aitozi created FLINK-26356: -- Summary: Revisit the create of RestClusterClient Key: FLINK-26356 URL: https://issues.apache.org/jira/browse/FLINK-26356 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread zoucao (Jira)
zoucao created FLINK-26355: -- Summary: VarCharType was not be considered in HiveTableSqlFunction Key: FLINK-26355 URL: https://issues.apache.org/jira/browse/FLINK-26355 Project: Flink Issue Type:

[jira] [Created] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

2022-02-24 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-26354: Summary: "-restoreMode" should be "--restoreMode" and should have a shorthand Key: FLINK-26354 URL: https://issues.apache.org/jira/browse/FLINK-26354

Re: [ANNOUNCE] Flink 1.15 Feature Freeze

2022-02-24 Thread Jing Ge
Hi all, I'd like to ask if it is fine to merge this PR[1]. It is an extension of sink metrics that has been covered originally by FLIP-33 [2]. Such extension has been pointed out there: "*The following metric convention is not a complete list. More conventional metrics will be added over time.*"

[jira] [Created] (FLINK-26353) "flink stop --help" does not list "--type" option

2022-02-24 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-26353: Summary: "flink stop --help" does not list "--type" option Key: FLINK-26353 URL: https://issues.apache.org/jira/browse/FLINK-26353 Project: Flink

[jira] [Created] (FLINK-26352) Missing license header in WebUI source files

2022-02-24 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-26352: Summary: Missing license header in WebUI source files Key: FLINK-26352 URL: https://issues.apache.org/jira/browse/FLINK-26352 Project: Flink Issue

[jira] [Created] (FLINK-26351) After scaling a flink task running on k8s, the flink web ui graph always shows the parallelism of the first deployment.

2022-02-24 Thread qiunan (Jira)
qiunan created FLINK-26351: -- Summary: After scaling a flink task running on k8s, the flink web ui graph always shows the parallelism of the first deployment. Key: FLINK-26351 URL:

[jira] [Created] (FLINK-26350) Extend ConfigOptionBuilder in a way to allow a description for the default value

2022-02-24 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26350: - Summary: Extend ConfigOptionBuilder in a way to allow a description for the default value Key: FLINK-26350 URL: https://issues.apache.org/jira/browse/FLINK-26350

[jira] [Created] (FLINK-26349) AvroParquetReaders does not work with ReflectData

2022-02-24 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-26349: Summary: AvroParquetReaders does not work with ReflectData Key: FLINK-26349 URL: https://issues.apache.org/jira/browse/FLINK-26349 Project: Flink

contributor

2022-02-24 Thread ????
HiGuys, I want to contribute toApacheFlink. Wouldyou please give me the permissionasa contributor?MyJIRA IDism305343894.

[jira] [Created] (FLINK-26348) Maybe ChangelogNormalize should ignore unused columns when deduplicate

2022-02-24 Thread Kenyore (Jira)
Kenyore created FLINK-26348: --- Summary: Maybe ChangelogNormalize should ignore unused columns when deduplicate Key: FLINK-26348 URL: https://issues.apache.org/jira/browse/FLINK-26348 Project: Flink

[jira] [Created] (FLINK-26347) Should use Flink system Classloader (AppClassloader) when deserializing RPC message

2022-02-24 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-26347: --- Summary: Should use Flink system Classloader (AppClassloader) when deserializing RPC message Key: FLINK-26347 URL: https://issues.apache.org/jira/browse/FLINK-26347

[jira] [Created] (FLINK-26346) Add statistics collecting to sst files

2022-02-24 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-26346: --- Summary: Add statistics collecting to sst files Key: FLINK-26346 URL: https://issues.apache.org/jira/browse/FLINK-26346 Project: Flink Issue Type: Sub-task

jira

2022-02-24 Thread Simon Aries
Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is SimonAries.