[jira] [Updated] (FLINK-9779) Remove SlotRequest timeout

2018-07-11 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-9779: --- Description: As is involved in FLINK-8643 and  FLINK-8653, we use external timeout to replace internal timeout of

[jira] [Commented] (FLINK-9649) TaskManagers are not scheduled on Mesos

2018-07-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541160#comment-16541160 ] Gary Yao commented on FLINK-9649: - [~lishim] You are right. Thanks for following up. > TaskManagers are

[jira] [Assigned] (FLINK-9828) Resource manager should recover slot resource status after failover

2018-07-11 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuai.xu reassigned FLINK-9828: --- Assignee: shuai.xu > Resource manager should recover slot resource status after failover >

[jira] [Commented] (FLINK-9807) Improve EventTimeWindowCheckpointITCase with parameterized

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541135#comment-16541135 ] ASF GitHub Bot commented on FLINK-9807: --- Github user yanghua commented on a diff in the pull

[jira] [Commented] (FLINK-9807) Improve EventTimeWindowCheckpointITCase with parameterized

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541136#comment-16541136 ] ASF GitHub Bot commented on FLINK-9807: --- Github user yanghua commented on a diff in the pull

[jira] [Commented] (FLINK-9807) Improve EventTimeWindowCheckpointITCase with parameterized

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541138#comment-16541138 ] ASF GitHub Bot commented on FLINK-9807: --- Github user yanghua commented on a diff in the pull

[jira] [Commented] (FLINK-9807) Improve EventTimeWindowCheckpointITCase with parameterized

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541137#comment-16541137 ] ASF GitHub Bot commented on FLINK-9807: --- Github user yanghua commented on a diff in the pull

[GitHub] flink pull request #6305: [FLINK-9807][tests] Optimize EventTimeWindowCheckp...

2018-07-11 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6305#discussion_r201907959 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java --- @@ -871,19 +892,40 @@ public

[GitHub] flink pull request #6305: [FLINK-9807][tests] Optimize EventTimeWindowCheckp...

2018-07-11 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6305#discussion_r201908022 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java --- @@ -871,19 +892,40 @@ public

[GitHub] flink pull request #6305: [FLINK-9807][tests] Optimize EventTimeWindowCheckp...

2018-07-11 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6305#discussion_r201908226 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/LocalRecoveryITCase.java --- @@ -25,35 +25,46 @@ import org.junit.Rule;

[GitHub] flink pull request #6305: [FLINK-9807][tests] Optimize EventTimeWindowCheckp...

2018-07-11 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6305#discussion_r201908082 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java --- @@ -871,19 +892,40 @@ public

[jira] [Created] (FLINK-9828) Resource manager should recover slot resource status after failover

2018-07-11 Thread shuai.xu (JIRA)
shuai.xu created FLINK-9828: --- Summary: Resource manager should recover slot resource status after failover Key: FLINK-9828 URL: https://issues.apache.org/jira/browse/FLINK-9828 Project: Flink

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

2018-07-11 Thread shuai.xu (JIRA)
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] [Created] (FLINK-9826) Implement FLIP-6 YARN Resource Manager for SESSION mode

2018-07-11 Thread shuai.xu (JIRA)
shuai.xu created FLINK-9826: --- Summary: Implement FLIP-6 YARN Resource Manager for SESSION mode Key: FLINK-9826 URL: https://issues.apache.org/jira/browse/FLINK-9826 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-11 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541084#comment-16541084 ] Rong Rong commented on FLINK-9294: -- hmm. nvm. I think I messed up with scala/java implicit conversion. I

[jira] [Assigned] (FLINK-9825) Upgrade checkstyle version to 8.6

2018-07-11 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei reassigned FLINK-9825: --- Assignee: zhangminglei > Upgrade checkstyle version to 8.6 >

[jira] [Created] (FLINK-9825) Upgrade checkstyle version to 8.6

2018-07-11 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9825: - Summary: Upgrade checkstyle version to 8.6 Key: FLINK-9825 URL: https://issues.apache.org/jira/browse/FLINK-9825 Project: Flink Issue Type: Improvement

[GitHub] flink issue #6301: [FLINK-9794] [jdbc] JDBCOutputFormat does not consider id...

2018-07-11 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6301 @sihuazhou is right and reviewed, +1 from my side ---

[jira] [Commented] (FLINK-9794) JDBCOutputFormat does not consider idle connection and multithreads synchronization

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541077#comment-16541077 ] ASF GitHub Bot commented on FLINK-9794: --- Github user yanghua commented on the issue:

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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:

[GitHub] flink issue #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrappers

2018-07-11 Thread Aitozi
Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/6186 Hi, after read the whole implementation, i found that the state is expired when it is accessed, When there is the dirty data store to state and never be queried, how does it can be expired. Or is

[jira] [Commented] (FLINK-9794) JDBCOutputFormat does not consider idle connection and multithreads synchronization

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541068#comment-16541068 ] ASF GitHub Bot commented on FLINK-9794: --- Github user jrthe42 commented on the issue:

[GitHub] flink issue #6301: [FLINK-9794] [jdbc] JDBCOutputFormat does not consider id...

2018-07-11 Thread jrthe42
Github user jrthe42 commented on the issue: https://github.com/apache/flink/pull/6301 Hi @sihuazhou , I am not familiar with the checkpoint mechanism of Flink, and I check the source code again. Although the ```RichSinkFunction#invoke()``` and

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541061#comment-16541061 ] ASF GitHub Bot commented on FLINK-9514: --- Github user Aitozi commented on a diff in the pull

[GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp...

2018-07-11 Thread Aitozi
Github user Aitozi commented on a diff in the pull request: https://github.com/apache/flink/pull/6186#discussion_r201895445 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlListState.java --- @@ -0,0 +1,171 @@ +/* + * Licensed to the Apache

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

2018-07-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9824: --- Assignee: vinoyang > Support IPv6 literal > > > Key:

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

2018-07-11 Thread Ted Yu (JIRA)
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] [Assigned] (FLINK-9814) CsvTableSource lack of column warning

2018-07-11 Thread vinoyang (JIRA)
[ 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] [Assigned] (FLINK-9806) Add a canonical link element to documentation HTML

2018-07-11 Thread vinoyang (JIRA)
[ 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] [Resolved] (FLINK-9439) DispatcherTest#testJobRecovery dead locks

2018-07-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9439. -- Resolution: Fixed Fixed via 1.6.0: 3c4e59a7f78deeaccf41022e92699e1ef7510cc3 1.5.2:

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

2018-07-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9706. -- Resolution: Fixed Fixed via 1.6.0: 3c4e59a7f78deeaccf41022e92699e1ef7510cc3 1.5.2:

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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:

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

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

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540875#comment-16540875 ] ASF GitHub Bot commented on FLINK-9706: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink issue #6279: [FLINK-9706] Properly wait for termination of JobManagerR...

2018-07-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/6279 Thanks for the review @GJL. Merging this PR. ---

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

2018-07-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6279#discussion_r201869163 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -536,7 +540,25 @@ private JobManagerRunner

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540877#comment-16540877 ] ASF GitHub Bot commented on FLINK-9706: --- Github user tillrohrmann commented on the issue:

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-07-11 Thread tillrohrmann
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] [Created] (FLINK-9823) Add Kubernetes deployment files for standalone job cluster

2018-07-11 Thread Till Rohrmann (JIRA)
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

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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...

2018-07-11 Thread tillrohrmann
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

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

2018-07-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9822: Summary: Add Dockerfile for StandaloneJobClusterEntryPoint image Key: FLINK-9822 URL: https://issues.apache.org/jira/browse/FLINK-9822 Project: Flink Issue

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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

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

2018-07-11 Thread tillrohrmann
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] [Created] (FLINK-9821) Let dynamic properties overwrite configuration settings in TaskManagerRunner

2018-07-11 Thread Till Rohrmann (JIRA)
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-9820) Let dynamic properties overwrite configuration settings in ClusterEntrypoint

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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

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

2018-07-11 Thread tillrohrmann
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] [Created] (FLINK-9820) Let dynamic properties overwrite configuration settings in ClusterEntrypoint

2018-07-11 Thread Till Rohrmann (JIRA)
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:

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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...

2018-07-11 Thread tillrohrmann
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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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-9819) Create start up scripts for the StandaloneJobClusterEntryPoint

2018-07-11 Thread Till Rohrmann (JIRA)
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] [Assigned] (FLINK-9488) Create common entry point for master and workers

2018-07-11 Thread Till Rohrmann (JIRA)
[ 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] [Updated] (FLINK-9675) Avoid FileInputStream/FileOutputStream

2018-07-11 Thread Ted Yu (JIRA)
[ 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-9488) Create common entry point for master and workers

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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 >

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

2018-07-11 Thread tillrohrmann
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] [Commented] (FLINK-9735) Potential resource leak in RocksDBStateBackend#getDbOptions

2018-07-11 Thread Ted Yu (JIRA)
[ 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-9818) Add cluster component command line parser

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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:

[GitHub] flink pull request #6314: [FLINK-9818] Add cluster component command line pa...

2018-07-11 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6314 [FLINK-9818] Add cluster component command line parser ## What is the purpose of the change The cluster component command line parser is responsible for parsing the common command

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

2018-07-11 Thread Till Rohrmann (JIRA)
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:

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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...

2018-07-11 Thread tweise
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 ---

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

2018-07-11 Thread tweise
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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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

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

2018-07-11 Thread tweise
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-9792) Cannot add html tags in options description

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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...

2018-07-11 Thread dawidwys
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-9792) Cannot add html tags in options description

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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 #6312: [FLINK-9792] Added custom Description class for Co...

2018-07-11 Thread zentol
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-9750) Create new StreamingFileSink that works on Flink's FileSystem abstraction

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-07-11 Thread kl0u
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] [Commented] (FLINK-9817) Version not correctly bumped to 5.0

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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] [Commented] (FLINK-9817) Version not correctly bumped to 5.0

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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-9817) Version not correctly bumped to 5.0

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ 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 >

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

2018-07-11 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9817: -- Summary: Version not correctly bumped to 5.0 Key: FLINK-9817 URL: https://issues.apache.org/jira/browse/FLINK-9817 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7789) Add handler for Async IO operator timeouts

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540611#comment-16540611 ] ASF GitHub Bot commented on FLINK-7789: --- Github user pranjal0811 commented on the issue:

[GitHub] flink issue #6091: [FLINK-7789][DataStream API] Add handler for Async IO ope...

2018-07-11 Thread pranjal0811
Github user pranjal0811 commented on the issue: https://github.com/apache/flink/pull/6091 Hi Team, Would this feature be included in the Flink 1.5.1 version? Cheers, Pranjal ---

[jira] [Commented] (FLINK-7789) Add handler for Async IO operator timeouts

2018-07-11 Thread Pranjal Shrivastava (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540607#comment-16540607 ] Pranjal Shrivastava commented on FLINK-7789: Hi Team, Is there any chances that this feature

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540595#comment-16540595 ] 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...

2018-07-11 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r201819026 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/ListElement.java --- @@ -0,0 +1,60 @@ +/* + * Licensed to the Apache

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

2018-07-11 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r201819059 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/BlockElement.java --- @@ -0,0 +1,33 @@ +/* + * Licensed to the

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

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

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

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540594#comment-16540594 ] 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...

2018-07-11 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r201818972 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/Formatter.java --- @@ -0,0 +1,48 @@ +/* + * Licensed to the Apache

[jira] [Updated] (FLINK-9701) Activate TTL in state descriptors

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9701: -- Labels: pull-request-available (was: ) > Activate TTL in state descriptors >

[jira] [Commented] (FLINK-9701) Activate TTL in state descriptors

2018-07-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540571#comment-16540571 ] ASF GitHub Bot commented on FLINK-9701: --- GitHub user azagrebin opened a pull request:

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

2018-07-11 Thread azagrebin
GitHub user azagrebin opened a pull request: https://github.com/apache/flink/pull/6313 [FLINK-9701] Add TTL in state descriptors ## What is the purpose of the change This PR activates TTL feature in state descriptors. ## Brief change log - add method

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

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

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

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

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

2018-07-11 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r201806215 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/BlockElement.java --- @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache

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

2018-07-11 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r201805835 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/ListElement.java --- @@ -0,0 +1,60 @@ +/* + * Licensed to the Apache

  1   2   3   4   >