[jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state

[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541073#comment-16541073 ] ASF GitHub Bot commented on FLINK-9514: --- Github user Aitozi commented on the issue:

[jira] [Created] (FLINK-9827) ResourceManager may receive outdate report of slots status from task manager

shuai.xu created FLINK-9827: --- Summary: ResourceManager may receive outdate report of slots status from task manager Key: FLINK-9827 URL: https://issues.apache.org/jira/browse/FLINK-9827 Project: Flink

[jira] [Updated] (FLINK-9817) Version not correctly bumped to 5.0

[ https://issues.apache.org/jira/browse/FLINK-9817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9817: -- Labels: pull-request-available (was: ) > Version not correctly bumped to 5.0 >

[GitHub] flink pull request #6300: [FLINK-9692][Kinesis Connector] Adaptive reads fro...

Github user tweise commented on a diff in the pull request: https://github.com/apache/flink/pull/6300#discussion_r201792650 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -224,10

[jira] [Commented] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540706#comment-16540706 ] ASF GitHub Bot commented on FLINK-9692: --- Github user tweise commented on a diff in the pull

[jira] [Commented] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540707#comment-16540707 ] ASF GitHub Bot commented on FLINK-9692: --- Github user tweise commented on a diff in the pull

[GitHub] flink pull request #6300: [FLINK-9692][Kinesis Connector] Adaptive reads fro...

Github user tweise commented on a diff in the pull request: https://github.com/apache/flink/pull/6300#discussion_r201793459 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -330,4

[jira] [Commented] (FLINK-9819) Create start up scripts for the StandaloneJobClusterEntryPoint

[ https://issues.apache.org/jira/browse/FLINK-9819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540777#comment-16540777 ] ASF GitHub Bot commented on FLINK-9819: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #6316: [FLINK-9819] Add startup scripts for standalone jo...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6316 [FLINK-9819] Add startup scripts for standalone job cluster entry point ## What is the purpose of the change Add startup shell scripts for the `StandaloneJobClusterEntryPoint`.

[jira] [Updated] (FLINK-9819) Create start up scripts for the StandaloneJobClusterEntryPoint

[ https://issues.apache.org/jira/browse/FLINK-9819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9819: -- Labels: pull-request-available (was: ) > Create start up scripts for the

[jira] [Created] (FLINK-9820) Let dynamic properties overwrite configuration settings in ClusterEntrypoint

Till Rohrmann created FLINK-9820: Summary: Let dynamic properties overwrite configuration settings in ClusterEntrypoint Key: FLINK-9820 URL: https://issues.apache.org/jira/browse/FLINK-9820 Project:

[GitHub] flink pull request #6317: [FLINK-9820] Forward dynamic properties to Flink c...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6317 [FLINK-9820] Forward dynamic properties to Flink configuration in ClusterEntrypoint ## What is the purpose of the change With this commit we can use dynamic properties to overwrite

[jira] [Commented] (FLINK-9820) Let dynamic properties overwrite configuration settings in ClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-9820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540801#comment-16540801 ] ASF GitHub Bot commented on FLINK-9820: --- GitHub user tillrohrmann opened a pull request:

[jira] [Updated] (FLINK-9820) Let dynamic properties overwrite configuration settings in ClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-9820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9820: -- Labels: pull-request-available (was: ) > Let dynamic properties overwrite configuration

[jira] [Updated] (FLINK-9823) Add Kubernetes deployment files for standalone job cluster

[ https://issues.apache.org/jira/browse/FLINK-9823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9823: -- Labels: pull-request-available (was: ) > Add Kubernetes deployment files for standalone job

[jira] [Commented] (FLINK-9823) Add Kubernetes deployment files for standalone job cluster

[ https://issues.apache.org/jira/browse/FLINK-9823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540869#comment-16540869 ] ASF GitHub Bot commented on FLINK-9823: --- GitHub user tillrohrmann opened a pull request:

[jira] [Assigned] (FLINK-9814) CsvTableSource lack of column warning

[ https://issues.apache.org/jira/browse/FLINK-9814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9814: --- Assignee: vinoyang > CsvTableSource lack of column warning > -

[jira] [Commented] (FLINK-9817) Version not correctly bumped to 5.0

[ https://issues.apache.org/jira/browse/FLINK-9817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540625#comment-16540625 ] ASF GitHub Bot commented on FLINK-9817: --- NicoK commented on issue #45: [FLINK-9817] update version

[jira] [Updated] (FLINK-9818) Add cluster component command line parser

[ https://issues.apache.org/jira/browse/FLINK-9818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9818: -- Labels: pull-request-available (was: ) > Add cluster component command line parser >

[jira] [Commented] (FLINK-9818) Add cluster component command line parser

[ https://issues.apache.org/jira/browse/FLINK-9818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540744#comment-16540744 ] ASF GitHub Bot commented on FLINK-9818: --- GitHub user tillrohrmann opened a pull request:

[jira] [Created] (FLINK-9821) Let dynamic properties overwrite configuration settings in TaskManagerRunner

Till Rohrmann created FLINK-9821: Summary: Let dynamic properties overwrite configuration settings in TaskManagerRunner Key: FLINK-9821 URL: https://issues.apache.org/jira/browse/FLINK-9821 Project:

[jira] [Commented] (FLINK-9822) Add Dockerfile for StandaloneJobClusterEntryPoint image

[ https://issues.apache.org/jira/browse/FLINK-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540863#comment-16540863 ] ASF GitHub Bot commented on FLINK-9822: --- GitHub user tillrohrmann opened a pull request:

[jira] [Updated] (FLINK-9822) Add Dockerfile for StandaloneJobClusterEntryPoint image

[ https://issues.apache.org/jira/browse/FLINK-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9822: -- Labels: pull-request-available (was: ) > Add Dockerfile for StandaloneJobClusterEntryPoint

[GitHub] flink pull request #6319: [FLINK-9822] Add Dockerfile for StandaloneJobClust...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6319 [FLINK-9822] Add Dockerfile for StandaloneJobClusterEntryPoint image ## What is the purpose of the change This commit adds a Dockerfile for a standalone job cluster image. The image

[GitHub] flink issue #6281: [FLINK-9750] Add new StreamingFileSink with ResumableWrit...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/6281 Hi @aljoscha and @StephanEwen . I have updated the PR, please have a look. ---

[jira] [Assigned] (FLINK-9488) Create common entry point for master and workers

[ https://issues.apache.org/jira/browse/FLINK-9488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9488: Assignee: Till Rohrmann > Create common entry point for master and workers >

[jira] [Created] (FLINK-9819) Create start up scripts for the StandaloneJobClusterEntryPoint

Till Rohrmann created FLINK-9819: Summary: Create start up scripts for the StandaloneJobClusterEntryPoint Key: FLINK-9819 URL: https://issues.apache.org/jira/browse/FLINK-9819 Project: Flink

[jira] [Created] (FLINK-9823) Add Kubernetes deployment files for standalone job cluster

Till Rohrmann created FLINK-9823: Summary: Add Kubernetes deployment files for standalone job cluster Key: FLINK-9823 URL: https://issues.apache.org/jira/browse/FLINK-9823 Project: Flink

[GitHub] flink pull request #6279: [FLINK-9706] Properly wait for termination of JobM...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6279 ---

[jira] [Commented] (FLINK-9706) DispatcherTest#testSubmittedJobGraphListener fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540886#comment-16540886 ] ASF GitHub Bot commented on FLINK-9706: --- Github user asfgit closed the pull request at:

[jira] [Created] (FLINK-9824) Support IPv6 literal

Ted Yu created FLINK-9824: - Summary: Support IPv6 literal Key: FLINK-9824 URL: https://issues.apache.org/jira/browse/FLINK-9824 Project: Flink Issue Type: Bug Reporter: Ted Yu

[jira] [Commented] (FLINK-9817) Version not correctly bumped to 5.0

[ https://issues.apache.org/jira/browse/FLINK-9817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540623#comment-16540623 ] ASF GitHub Bot commented on FLINK-9817: --- zentol commented on issue #45: [FLINK-9817] update version

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540695#comment-16540695 ] ASF GitHub Bot commented on FLINK-9792: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r201844991 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/LineBreakElement.java --- @@ -0,0 +1,40 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540708#comment-16540708 ] ASF GitHub Bot commented on FLINK-9692: --- Github user tweise commented on the issue:

[GitHub] flink issue #6300: [FLINK-9692][Kinesis Connector] Adaptive reads from Kines...

Github user tweise commented on the issue: https://github.com/apache/flink/pull/6300 @tzulitai can you please take a look - would be good if we can get this into v1.6.0 ---

[jira] [Commented] (FLINK-9735) Potential resource leak in RocksDBStateBackend#getDbOptions

[ https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540754#comment-16540754 ] Ted Yu commented on FLINK-9735: --- Short term, we should fix the leaked DBOptions instance. > Potential

[jira] [Updated] (FLINK-9675) Avoid FileInputStream/FileOutputStream

[ https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9675: -- Description: They rely on finalizers (before Java 11), which create unnecessary GC load. The alternatives,

[jira] [Commented] (FLINK-9821) Let dynamic properties overwrite configuration settings in TaskManagerRunner

[ https://issues.apache.org/jira/browse/FLINK-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540847#comment-16540847 ] ASF GitHub Bot commented on FLINK-9821: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #6318: [FLINK-9821] Forward dynamic properties to configu...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6318 [FLINK-9821] Forward dynamic properties to configuration in TaskManagerRunner ## What is the purpose of the change With this commit we can use dynamic properties to overwrite

[jira] [Updated] (FLINK-9821) Let dynamic properties overwrite configuration settings in TaskManagerRunner

[ https://issues.apache.org/jira/browse/FLINK-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9821: -- Labels: pull-request-available (was: ) > Let dynamic properties overwrite configuration

[jira] [Commented] (FLINK-9817) Version not correctly bumped to 5.0

[ https://issues.apache.org/jira/browse/FLINK-9817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540617#comment-16540617 ] ASF GitHub Bot commented on FLINK-9817: --- NicoK opened a new pull request #45: [FLINK-9817] update

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r201838689 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/LineBreakElement.java --- @@ -0,0 +1,40 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540662#comment-16540662 ] ASF GitHub Bot commented on FLINK-9792: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6320: [FLINK-9823] Add Kubernetes deployment ymls

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6320 [FLINK-9823] Add Kubernetes deployment ymls ## What is the purpose of the change The Kubernetes files contain a job-cluster service specification, a job specification for the

[jira] [Assigned] (FLINK-9806) Add a canonical link element to documentation HTML

[ https://issues.apache.org/jira/browse/FLINK-9806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9806: --- Assignee: vinoyang > Add a canonical link element to documentation HTML >

[jira] [Commented] (FLINK-9750) Create new StreamingFileSink that works on Flink's FileSystem abstraction

[ https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540654#comment-16540654 ] ASF GitHub Bot commented on FLINK-9750: --- Github user kl0u commented on the issue:

[jira] [Created] (FLINK-9818) Add cluster component command line parser

Till Rohrmann created FLINK-9818: Summary: Add cluster component command line parser Key: FLINK-9818 URL: https://issues.apache.org/jira/browse/FLINK-9818 Project: Flink Issue Type:

[GitHub] flink pull request #6315: [FLINK-9488] Add container entry point StandaloneJ...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6315 [FLINK-9488] Add container entry point StandaloneJobClusterEntryPoint ## What is the purpose of the change The StandaloneJobClusterEntryPoint is the basic entry point for containers.

[jira] [Updated] (FLINK-9488) Create common entry point for master and workers

[ https://issues.apache.org/jira/browse/FLINK-9488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9488: -- Labels: pull-request-available (was: ) > Create common entry point for master and workers >

[jira] [Commented] (FLINK-9488) Create common entry point for master and workers

[ https://issues.apache.org/jira/browse/FLINK-9488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540771#comment-16540771 ] ASF GitHub Bot commented on FLINK-9488: --- GitHub user tillrohrmann opened a pull request:

<    1   2   3   4