[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506512 --- Diff: flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka08JsonTableSourceFactoryTest.java ---

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506494 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/SourceSink.java --- @@ -51,16 +51,10 @@ public void

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506661 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/exceptions.scala --- @@ -143,118 +143,82 @@ case class

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506861 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFactoryService.scala --- @@ -18,143 +18,358 @@

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

2018-07-13 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506769 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -163,80 +163,157 @@ public static void

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

2018-07-13 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506820 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -163,80 +163,157 @@ public static void

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

2018-07-13 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202505334 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -249,14 +326,40 @@ public static SSLContext

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

2018-07-13 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506868 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -163,80 +163,157 @@ public static void

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

2018-07-13 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506811 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -163,80 +163,157 @@ public static void

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

2018-07-13 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506709 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -163,80 +163,157 @@ public static void

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

2018-07-13 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506694 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -249,14 +326,40 @@ public static SSLContext

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

2018-07-13 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202505321 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/NettyClientServerSslTest.java --- @@ -160,6 +160,7 @@ private Configuration

[jira] [Closed] (FLINK-7087) Implement Flip-6 container entry point

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7087. Resolution: Fixed Fixed via 8f467c1e9727d5a86d38d0b49753c534a1a161da > Implement Flip-6 container

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

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9488. Resolution: Fixed Fixed via 8f467c1e9727d5a86d38d0b49753c534a1a161da > Create common entry point

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

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9819. Resolution: Fixed Fixed via 5a4bdf2c9fd1693ad3b90dbbd3bcb589ed15c101 > Create start up scripts

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

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9821. Resolution: Fixed Fixed via 740f2fbf2e65fa988c6a577989ccd8923729be45 > Let dynamic properties

[jira] [Assigned] (FLINK-7087) Implement Flip-6 container entry point

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7087: Assignee: Till Rohrmann > Implement Flip-6 container entry point >

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

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9818. Resolution: Fixed Fixed via ab9bd87e521d19db7c7d783268a3532d2e876a5d > Add cluster component

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

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9820. Resolution: Fixed Fixed via 2fbbf8ee662647c71581f5cd989226be820fed0f > Let dynamic properties

[jira] [Commented] (FLINK-9847) OneInputStreamTaskTest.testWatermarksNotForwardedWithinChainWhenIdle unstable

2018-07-13 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543957#comment-16543957 ] Congxian Qiu commented on FLINK-9847: - I just gotten the following error message as I run the test on

[jira] [Commented] (FLINK-9847) OneInputStreamTaskTest.testWatermarksNotForwardedWithinChainWhenIdle unstable

2018-07-13 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543965#comment-16543965 ] Congxian Qiu commented on FLINK-9847: - Could this be   {noformat} int

[jira] [Assigned] (FLINK-9849) Upgrade hbase version to 2.0.1 for hbase connector

2018-07-13 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei reassigned FLINK-9849: --- Assignee: zhangminglei > Upgrade hbase version to 2.0.1 for hbase connector >

[jira] [Commented] (FLINK-9325) generate the _meta file for checkpoint only when the writing is truly successful

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

[GitHub] flink issue #5982: [FLINK-9325][checkpoint]generate the meta file for checkp...

2018-07-13 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5982 @StephanEwen Thanks! Looking forward~ ---

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506193 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFactory.scala --- @@ -16,14 +16,14 @@ * limitations under

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506574 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalTableSourceUtil.scala --- @@ -44,32 +43,27 @@ object

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506625 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFormatFactory.scala --- @@ -16,42 +16,17 @@ * limitations

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506766 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFactoryService.scala --- @@ -18,143 +18,358 @@

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506740 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFactoryService.scala --- @@ -18,143 +18,358 @@

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202507057 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalTableSourceScan.scala --- @@ -52,12 +52,9 @@

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[jira] [Assigned] (FLINK-9762) CoreOptions.TMP_DIRS wrongly managed on Yarn

2018-07-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9762: --- Assignee: (was: vinoyang) > CoreOptions.TMP_DIRS wrongly managed on Yarn >

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

2018-07-13 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/6301 @jrthe42 Hi, thanks for your PR. From my side, I think use a connection pool to solve the connection problem is a better way. We don't need to keep the connections all the way. It wastes the

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

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

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506126 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java --- @@ -54,51 +56,105

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

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

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

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

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

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544052#comment-16544052 ] ASF GitHub Bot commented on FLINK-9821: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #6331: [FLINK-9701] [state] (follow up) Use StateTtlConfi...

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

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

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

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

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

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544056#comment-16544056 ] ASF GitHub Bot commented on FLINK-9143: --- Github user asfgit closed the pull request at:

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

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9823. Resolution: Fixed Fixed via 387a3bc198cfea016abd92953c7fce28e641cf67 > Add Kubernetes deployment

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

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544050#comment-16544050 ] ASF GitHub Bot commented on FLINK-9488: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9619. -- Resolution: Fixed Fix Version/s: (was: 1.5.2) Fixed via

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

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

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

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544055#comment-16544055 ] ASF GitHub Bot commented on FLINK-9822: --- Github user asfgit closed the pull request at:

[jira] [Updated] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9619: -- Labels: pull-request-available (was: ) > Always close the task manager connection when the

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

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

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

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544048#comment-16544048 ] ASF GitHub Bot commented on FLINK-9818: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544053#comment-16544053 ] ASF GitHub Bot commented on FLINK-9619: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #6283: [FLINK-9143] Use cluster strategy if none was set ...

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

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

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544051#comment-16544051 ] ASF GitHub Bot commented on FLINK-9820: --- Github user asfgit closed the pull request at:

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

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544046#comment-16544046 ] ASF GitHub Bot commented on FLINK-9823: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #6185: [FLINK-9619][YARN] Eagerly close the connection wi...

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

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

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

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

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544049#comment-16544049 ] ASF GitHub Bot commented on FLINK-9819: --- Github user asfgit closed the pull request at:

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

2018-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544054#comment-16544054 ] ASF GitHub Bot commented on FLINK-9701: --- Github user asfgit closed the pull request at:

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

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9822. Resolution: Fixed Fixed via 56e5381cb7aba01f1d7ecfa11e4be7f505a35baf > Add Dockerfile for

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

2018-07-13 Thread glaksh100
Github user glaksh100 commented on the issue: https://github.com/apache/flink/pull/6300 @StephanEwen I have run this on the following set up: ``` Number of shards on Kinesis stream: 384 Number of task slots: 384 / 192 / 96 Throughput achieved per shard (with adaptive

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

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506906 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFactoryService.scala --- @@ -18,143 +18,358 @@

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

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

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9701. -- Resolution: Fixed Fix Version/s: 1.6.0 Fixed via

[jira] [Resolved] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9143. -- Resolution: Fixed Fix Version/s: 1.6.0 Fixed via

[jira] [Assigned] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9143: Assignee: Dawid Wysakowicz (was: yuqi) > Restart strategy defined in flink-conf.yaml is

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

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-9701: -- > Activate TTL in state descriptors > - > > Key:

[jira] [Assigned] (FLINK-9844) PackagedProgram does not close URLClassLoader

2018-07-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9844: --- Assignee: vinoyang > PackagedProgram does not close URLClassLoader >

[GitHub] flink issue #6329: [FLINK-9841] Web UI only show partial taskmanager log

2018-07-13 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6329 @zentol yes, you are right, sorry about my expression. here we should not use try-with-resource, because the listener will close the file. And it seems try-with-resource close operation more faster

[jira] [Commented] (FLINK-9841) Web UI only show partial taskmanager log

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

[GitHub] flink pull request #6330: [FLINK-9499][rest] Support JSON request in JarHand...

2018-07-13 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/6330 [FLINK-9499][rest] Support JSON request in JarHandlers ## What is the purpose of the change With this PR it is now possible to configure the submission via the `JarRunHandler` with a JSON

[jira] [Commented] (FLINK-9499) Allow REST API for running a job to provide job configuration as body of POST request

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

[GitHub] flink pull request #6330: [FLINK-9499][rest] Support JSON request in JarHand...

2018-07-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6330#discussion_r202330424 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunRequestBody.java --- @@ -0,0 +1,109 @@ +/* + * Licensed

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

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

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

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

[jira] [Commented] (FLINK-9829) The wrapper classes be compared by symbol of '==' directly in BigDecSerializer.java

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

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

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

[jira] [Commented] (FLINK-9829) The wrapper classes be compared by symbol of '==' directly in BigDecSerializer.java

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

[GitHub] flink pull request #6321: [FLINK-9829] fix the wrapper classes be compared b...

2018-07-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6321#discussion_r202335561 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigDecSerializer.java --- @@ -69,17 +69,17 @@ public void serialize(BigDecimal

[jira] [Resolved] (FLINK-9703) Mesos does not expose TM Prometheus port

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9703. -- Resolution: Fixed Fix Version/s: 1.6.0 Fixed via

[jira] [Assigned] (FLINK-9006) Cluster test: Run general purpose job with failures with Yarn and per-job mode

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9006: Assignee: Gary Yao > Cluster test: Run general purpose job with failures with Yarn and

[jira] [Closed] (FLINK-9004) Cluster test: Run general purpose job with failures with Yarn session

2018-07-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9004. Resolution: Done Added via d58c8c05f0b86bdb74cb6e450848690e309011d6 > Cluster test: Run general

  1   2   3   4   5   >