[jira] [Created] (FLINK-22062) Add "Data Sources" (FLIP-27 sources overview page) page from 1.12x to master

Robert Metzger created FLINK-22062: -- Summary: Add "Data Sources" (FLIP-27 sources overview page) page from 1.12x to master Key: FLINK-22062 URL: https://issues.apache.org/jira/browse/FLINK-22062 Proj

[jira] [Created] (FLINK-22061) The DEFAULT_NON_SPLITTABLE_FILE_ENUMERATOR defined in FileSource should points to NonSplittingRecursiveEnumerator

Dian Fu created FLINK-22061: --- Summary: The DEFAULT_NON_SPLITTABLE_FILE_ENUMERATOR defined in FileSource should points to NonSplittingRecursiveEnumerator Key: FLINK-22061 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-22060) Move null handling from ErrorInfo into Task.notifyFinalState

Matthias created FLINK-22060: Summary: Move null handling from ErrorInfo into Task.notifyFinalState Key: FLINK-22060 URL: https://issues.apache.org/jira/browse/FLINK-22060 Project: Flink Issue T

[jira] [Created] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

xiaogang zhou created FLINK-22059: - Summary: add a new option is rocksdb statebackend to enable job threads setting Key: FLINK-22059 URL: https://issues.apache.org/jira/browse/FLINK-22059 Project: Fli

[jira] [Created] (FLINK-22058) Support FLIP-27 based NumberSequenceSource connector in PyFlink DataStream API

Dian Fu created FLINK-22058: --- Summary: Support FLIP-27 based NumberSequenceSource connector in PyFlink DataStream API Key: FLINK-22058 URL: https://issues.apache.org/jira/browse/FLINK-22058 Project: Flink

[jira] [Created] (FLINK-22057) Flink client submitting Flink job remotely to Flink cluster through Loadbalancer rest service

Bhagi created FLINK-22057: - Summary: Flink client submitting Flink job remotely to Flink cluster through Loadbalancer rest service Key: FLINK-22057 URL: https://issues.apache.org/jira/browse/FLINK-22057 Proje

[jira] [Created] (FLINK-22056) FlinkKafkaProducerITCase failed because of "producer leak".

Guowei Ma created FLINK-22056: - Summary: FlinkKafkaProducerITCase failed because of "producer leak". Key: FLINK-22056 URL: https://issues.apache.org/jira/browse/FLINK-22056 Project: Flink Issue

[jira] [Created] (FLINK-22055) RPC main thread executor may schedule commands with wrong time unit of delay

Xintong Song created FLINK-22055: Summary: RPC main thread executor may schedule commands with wrong time unit of delay Key: FLINK-22055 URL: https://issues.apache.org/jira/browse/FLINK-22055 Project:

[jira] [Created] (FLINK-22054) Using a shared watcher for ConfigMap watching

Yi Tang created FLINK-22054: --- Summary: Using a shared watcher for ConfigMap watching Key: FLINK-22054 URL: https://issues.apache.org/jira/browse/FLINK-22054 Project: Flink Issue Type: Improvement

[GitHub] [flink-ml] lindong28 commented on pull request #2: [FLINK-22013] Add Github Actions to flink-ml for every push and pull request

lindong28 commented on pull request #2: URL: https://github.com/apache/flink-ml/pull/2#issuecomment-810706284 @becketqin Could you review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink-ml] lindong28 opened a new pull request #2: [FLINK-22013] Add Github Actions to flink-ml for every push and pull request

lindong28 opened a new pull request #2: URL: https://github.com/apache/flink-ml/pull/2 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, ple

Re: Flink job cannot find recover path after using entropy injection for s3 file systems

link fix pr here https://github.com/apache/flink/pull/15442 we might need someone help review and merge meanwhile. -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

[jira] [Created] (FLINK-22053) Recovery of a completed split in NumberSequenceSource causes fatal exception.

Arvid Heise created FLINK-22053: --- Summary: Recovery of a completed split in NumberSequenceSource causes fatal exception. Key: FLINK-22053 URL: https://issues.apache.org/jira/browse/FLINK-22053 Project:

[jira] [Created] (FLINK-22052) Add FLIP-142 changes to PyFlink

Seth Wiesman created FLINK-22052: Summary: Add FLIP-142 changes to PyFlink Key: FLINK-22052 URL: https://issues.apache.org/jira/browse/FLINK-22052 Project: Flink Issue Type: Sub-task

Re: flink 1.11 class loading question

Hi Till, We did some investigation and found this memory usage point to rocksdbstatebackend running on managed memory. So far we have seen this bug in rocksdbstatebackend on managed memory. we followed suggestion [1] and disabled managed memory management so far not seeing issue. I felt this mi

Re: Glob support on file access

Hi, FYI: I just submitted the small PR to support this: https://github.com/apache/flink/pull/15436 Best Etienne On 29/03/2021 20:05, Arvid Heise wrote: Hi Etienne, In general, any small PR on this subject is very welcome. I don't think that the community as a whole will invest much into Fi

[jira] [Created] (FLINK-22051) Better document the distinction between stop-with-savepoint and stop-with-savepoint-with-drain

Till Rohrmann created FLINK-22051: - Summary: Better document the distinction between stop-with-savepoint and stop-with-savepoint-with-drain Key: FLINK-22051 URL: https://issues.apache.org/jira/browse/FLINK-22051

[jira] [Created] (FLINK-22050) Failed to release input gate (IllegalReferenceCountException)

Roman Khachatryan created FLINK-22050: - Summary: Failed to release input gate (IllegalReferenceCountException) Key: FLINK-22050 URL: https://issues.apache.org/jira/browse/FLINK-22050 Project: Flin

[jira] [Created] (FLINK-22049) Simplify calculating the starting index of the local key-group range in InternalTimerServiceImpl constructor.

ZhangWei created FLINK-22049: Summary: Simplify calculating the starting index of the local key-group range in InternalTimerServiceImpl constructor. Key: FLINK-22049 URL: https://issues.apache.org/jira/browse/FLINK-22

[jira] [Created] (FLINK-22048) Remove unnecessary akka.transport.* configuration options

Till Rohrmann created FLINK-22048: - Summary: Remove unnecessary akka.transport.* configuration options Key: FLINK-22048 URL: https://issues.apache.org/jira/browse/FLINK-22048 Project: Flink I

[jira] [Created] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

hayden zhou created FLINK-22047: --- Summary: Could not find FLINSHED Flink job and can't submit job Key: FLINK-22047 URL: https://issues.apache.org/jira/browse/FLINK-22047 Project: Flink Issue T

[jira] [Created] (FLINK-22046) org.apache.flink.cep.nfa.State#toString() may has a abnormal format

shiqihao created FLINK-22046: Summary: org.apache.flink.cep.nfa.State#toString() may has a abnormal format Key: FLINK-22046 URL: https://issues.apache.org/jira/browse/FLINK-22046 Project: Flink

[jira] [Created] (FLINK-22045) Set log level for shaded zookeeper logger

Matthias created FLINK-22045: Summary: Set log level for shaded zookeeper logger Key: FLINK-22045 URL: https://issues.apache.org/jira/browse/FLINK-22045 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-22044) running job from Flink client(cli) from outside Flink jobmanager pod

Bhagi created FLINK-22044: - Summary: running job from Flink client(cli) from outside Flink jobmanager pod Key: FLINK-22044 URL: https://issues.apache.org/jira/browse/FLINK-22044 Project: Flink Issu

[jira] [Created] (FLINK-22043) Introduce thrift format to (de)serialize thrift message only with table

jinfeng created FLINK-22043: --- Summary: Introduce thrift format to (de)serialize thrift message only with table Key: FLINK-22043 URL: https://issues.apache.org/jira/browse/FLINK-22043 Project: Flink

Re: [DISCUSS] Releasing Stateful Functions 3.0.0

@Konstantin Knauf Yes, we'll make sure that migration docs are added before finalizing the release. I've proceeded to create RC1 for StateFun 3.0.0. Voting is happening on a separate thread. On Tue, Mar 30, 2021 at 3:06 AM Robert Metzger wrote: > Wow, the feature list sounds really exciting! >

[VOTE] Apache Flink Stateful Functions 3.0.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 3.0.0 of Apache Flink Stateful Functions, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Testing Guideline** You can find here [1] a page in the projec

[jira] [Created] (FLINK-22042) Fix reading bigint(20) UNSIGNED type field cannot be cast

jingzi created FLINK-22042: -- Summary: Fix reading bigint(20) UNSIGNED type field cannot be cast Key: FLINK-22042 URL: https://issues.apache.org/jira/browse/FLINK-22042 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-22041) Configure DataStreamAllroundTest via Configuration instead of ParameterTool

Till Rohrmann created FLINK-22041: - Summary: Configure DataStreamAllroundTest via Configuration instead of ParameterTool Key: FLINK-22041 URL: https://issues.apache.org/jira/browse/FLINK-22041 Project

Re: Glob support on file access

Hi Arvid, Thanks for your answer. Yes I know that DataSet API is to be deprecated. But still it is a small PR (2 lines of production code) so I guess we could merge it for users that still use DataSet API for batch. @Timo can I assign you as reviewer on the PR ? Best Etienne On 29/03/2021

[jira] [Created] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

Robert Metzger created FLINK-22040: -- Summary: Maven: Entry has not been leased from this pool / fix for e2e tests Key: FLINK-22040 URL: https://issues.apache.org/jira/browse/FLINK-22040 Project: Flin

[jira] [Created] (FLINK-22039) Add Javadocs to StateFun's new Java SDK

Tzu-Li (Gordon) Tai created FLINK-22039: --- Summary: Add Javadocs to StateFun's new Java SDK Key: FLINK-22039 URL: https://issues.apache.org/jira/browse/FLINK-22039 Project: Flink Issue T

[jira] [Created] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN

Andy created FLINK-22038: Summary: Update TopN node to be without rowNumber if rowNumber field is projected out after TopN Key: FLINK-22038 URL: https://issues.apache.org/jira/browse/FLINK-22038 Project: Flin

[jira] [Created] (FLINK-22037) Remove the redundant blocking queue from DeployingTasksBenchmarkBase

Zhilong Hong created FLINK-22037: Summary: Remove the redundant blocking queue from DeployingTasksBenchmarkBase Key: FLINK-22037 URL: https://issues.apache.org/jira/browse/FLINK-22037 Project: Flink

[jira] [Created] (FLINK-22036) Document Jira Bot in Flink Confluence

Konstantin Knauf created FLINK-22036: Summary: Document Jira Bot in Flink Confluence Key: FLINK-22036 URL: https://issues.apache.org/jira/browse/FLINK-22036 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-22034) Add Rule 1

Konstantin Knauf created FLINK-22034: Summary: Add Rule 1 Key: FLINK-22034 URL: https://issues.apache.org/jira/browse/FLINK-22034 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-22035) Run Jira Bot periodically with Github Actions

Konstantin Knauf created FLINK-22035: Summary: Run Jira Bot periodically with Github Actions Key: FLINK-22035 URL: https://issues.apache.org/jira/browse/FLINK-22035 Project: Flink Issue T

[jira] [Created] (FLINK-22033) Add Rule 2

Konstantin Knauf created FLINK-22033: Summary: Add Rule 2 Key: FLINK-22033 URL: https://issues.apache.org/jira/browse/FLINK-22033 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-22032) Implement Rule 3 First (Simplest Rule)

Konstantin Knauf created FLINK-22032: Summary: Implement Rule 3 First (Simplest Rule) Key: FLINK-22032 URL: https://issues.apache.org/jira/browse/FLINK-22032 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-22031) Create Jira Account for Jira Bot

Konstantin Knauf created FLINK-22031: Summary: Create Jira Account for Jira Bot Key: FLINK-22031 URL: https://issues.apache.org/jira/browse/FLINK-22031 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22030) Add Technical Debt Issue Type

Konstantin Knauf created FLINK-22030: Summary: Add Technical Debt Issue Type Key: FLINK-22030 URL: https://issues.apache.org/jira/browse/FLINK-22030 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22029) Remove "Task", "Wish" and "Test" Issue Types

Konstantin Knauf created FLINK-22029: Summary: Remove "Task", "Wish" and "Test" Issue Types Key: FLINK-22029 URL: https://issues.apache.org/jira/browse/FLINK-22029 Project: Flink Issue Ty

[jira] [Created] (FLINK-22028) Remove "Trivial" Ticket Priority

Konstantin Knauf created FLINK-22028: Summary: Remove "Trivial" Ticket Priority Key: FLINK-22028 URL: https://issues.apache.org/jira/browse/FLINK-22028 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22027) Create separate repository for Jira Bot

Konstantin Knauf created FLINK-22027: Summary: Create separate repository for Jira Bot Key: FLINK-22027 URL: https://issues.apache.org/jira/browse/FLINK-22027 Project: Flink Issue Type: S

[jira] [Created] (FLINK-22026) Improved Jira Process & Bot

Konstantin Knauf created FLINK-22026: Summary: Improved Jira Process & Bot Key: FLINK-22026 URL: https://issues.apache.org/jira/browse/FLINK-22026 Project: Flink Issue Type: Improvement