[jira] [Commented] (FLINK-7391) Normalize release entries

2018-07-16 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546102#comment-16546102 ] Dawid Wysakowicz commented on FLINK-7391: - Hi [~nssalian], If there is no assigne

[jira] [Assigned] (FLINK-7391) Normalize release entries

2018-07-16 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-7391: --- Assignee: Neelesh Srinivas Salian > Normalize release entries >

[jira] [Commented] (FLINK-9868) Expose channel id to ProcessFunction

2018-07-16 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546079#comment-16546079 ] Kostas Kloudas commented on FLINK-9868: --- Hi [~yanghua]! From the discussion you pos

[jira] [Comment Edited] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-07-16 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546071#comment-16546071 ] buptljy edited comment on FLINK-6895 at 7/17/18 6:10 AM: - [~twalt

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-07-16 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546071#comment-16546071 ] buptljy commented on FLINK-6895: [~twalthr] I think we can use "isOperandLiteral" functio

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546069#comment-16546069 ] ASF GitHub Bot commented on FLINK-6895: --- Github user buptljy commented on the issue

[jira] [Updated] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6895: -- Labels: pull-request-available (was: ) > Add STR_TO_DATE supported in SQL > --

[GitHub] flink issue #5628: [FLINK-6895][table]Add STR_TO_DATE supported in SQL

2018-07-16 Thread buptljy
Github user buptljy commented on the issue: https://github.com/apache/flink/pull/5628 @twalthr Sorry for late reply here. This can be closed now, and I'll submit another PR this week. I've posted my solution in FLINK-6895, we can have a discussion there. ---

[jira] [Commented] (FLINK-7391) Normalize release entries

2018-07-16 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546060#comment-16546060 ] Neelesh Srinivas Salian commented on FLINK-7391: [~Zentol], is anyone wor

[jira] [Comment Edited] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-07-16 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546057#comment-16546057 ] Neelesh Srinivas Salian edited comment on FLINK-6895 at 7/17/18 5:50 AM: --

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-07-16 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546057#comment-16546057 ] Neelesh Srinivas Salian commented on FLINK-6895: [~fhueske] [~twalthr] is

[jira] [Assigned] (FLINK-9862) Update end-to-end test to use RocksDB backed timers

2018-07-16 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-9862: -- Assignee: Tzu-Li (Gordon) Tai > Update end-to-end test to use RocksDB backed t

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

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546036#comment-16546036 ] ASF GitHub Bot commented on FLINK-9829: --- Github user lamber-ken closed the pull req

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

2018-07-16 Thread lamber-ken
Github user lamber-ken closed the pull request at: https://github.com/apache/flink/pull/6321 ---

[jira] [Commented] (FLINK-9866) Allow passing program arguments to StandaloneJobCluster

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

[GitHub] flink pull request #6344: [FLINK-9866] Allow passing command line arguments ...

2018-07-16 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6344#discussion_r202895544 --- Diff: flink-container/kubernetes/README.md --- @@ -17,6 +17,7 @@ The files contain the following variables: - `${FLINK_IMAGE_NAME}`: Name of th

[jira] [Commented] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546030#comment-16546030 ] ASF GitHub Bot commented on FLINK-9869: --- Github user tison1 commented on the issue:

[GitHub] flink issue #6345: [FLINK-9869] Send PartitionInfo in batch to Improve perfo...

2018-07-16 Thread tison1
Github user tison1 commented on the issue: https://github.com/apache/flink/pull/6345 cc @tillrohrmann @fhueske ---

[jira] [Assigned] (FLINK-9868) Expose channel id to ProcessFunction

2018-07-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9868: --- Assignee: vinoyang > Expose channel id to ProcessFunction > > >

[jira] [Updated] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9869: -- Labels: pull-request-available (was: ) > Send PartitionInfo in batch to Improve perfornance >

[jira] [Commented] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance

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

[GitHub] flink pull request #6345: [FLINK-9869] Send PartitionInfo in batch to Improv...

2018-07-16 Thread tison1
GitHub user tison1 opened a pull request: https://github.com/apache/flink/pull/6345 [FLINK-9869] Send PartitionInfo in batch to Improve perfornance ## What is the purpose of the change Current we send partition info as soon as one arrive. we could `cachePartitionInfo` and t

[jira] [Created] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance

2018-07-16 Thread JIRA
陈梓立 created FLINK-9869: -- Summary: Send PartitionInfo in batch to Improve perfornance Key: FLINK-9869 URL: https://issues.apache.org/jira/browse/FLINK-9869 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-9868) Expose channel id to ProcessFunction

2018-07-16 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-9868: --- Description: Currently, channel id has not been exposed from {{StreamInputProcessor}} to the {{Proces

[jira] [Created] (FLINK-9868) Expose channel id to ProcessFunction

2018-07-16 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-9868: -- Summary: Expose channel id to ProcessFunction Key: FLINK-9868 URL: https://issues.apache.org/jira/browse/FLINK-9868 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-9859) Distinguish TM akka config with JM config

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545885#comment-16545885 ] ASF GitHub Bot commented on FLINK-9859: --- Github user tison1 commented on the issue:

[GitHub] flink issue #6339: [FLINK-9859][Runtime] Distinguish TM akka config with JM ...

2018-07-16 Thread tison1
Github user tison1 commented on the issue: https://github.com/apache/flink/pull/6339 cc @zentol @tzulitai ---

[jira] [Created] (FLINK-9867) Extend release notes for Flink 1.6

2018-07-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9867: Summary: Extend release notes for Flink 1.6 Key: FLINK-9867 URL: https://issues.apache.org/jira/browse/FLINK-9867 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9489) Checkpoint timers as part of managed keyed state instead of raw keyed state

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

[GitHub] flink pull request #6333: [FLINK-9489] Checkpoint timers as part of managed ...

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

[jira] [Resolved] (FLINK-9489) Checkpoint timers as part of managed keyed state instead of raw keyed state

2018-07-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9489. -- Resolution: Done Done via dbddf00b75032c20df6e7aef26814da392347194 > Checkpoint timers as part

[jira] [Resolved] (FLINK-9490) Provide backwards compatibility for timer state of Flink 1.5

2018-07-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9490. -- Resolution: Done Done via dbddf00b75032c20df6e7aef26814da392347194 > Provide backwards compati

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

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

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

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

[jira] [Updated] (FLINK-9866) Allow passing program arguments to StandaloneJobCluster

2018-07-16 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-9866: Component/s: Distributed Coordination > Allow passing program arguments to StandaloneJobClu

[jira] [Commented] (FLINK-6997) SavepointITCase fails in master branch sometimes

2018-07-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545624#comment-16545624 ] Chesnay Schepler commented on FLINK-6997: - Tried reproducing this locally but fai

[jira] [Updated] (FLINK-9866) Allow passing program arguments to StandaloneJobCluster

2018-07-16 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-9866: Fix Version/s: 1.6.0 > Allow passing program arguments to StandaloneJobCluster > --

[jira] [Updated] (FLINK-9815) YARNSessionCapacitySchedulerITCase flaky

2018-07-16 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-9815: Priority: Blocker (was: Major) > YARNSessionCapacitySchedulerITCase flaky > --

[jira] [Updated] (FLINK-9815) YARNSessionCapacitySchedulerITCase flaky

2018-07-16 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-9815: Fix Version/s: 1.6.0 > YARNSessionCapacitySchedulerITCase flaky > -

[jira] [Commented] (FLINK-9815) YARNSessionCapacitySchedulerITCase flaky

2018-07-16 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545619#comment-16545619 ] Dawid Wysakowicz commented on FLINK-9815: - Another failure: https://api.travis-ci

[jira] [Updated] (FLINK-9866) Allow passing program arguments to StandaloneJobCluster

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9866: -- Labels: pull-request-available (was: ) > Allow passing program arguments to StandaloneJobClust

[jira] [Commented] (FLINK-9866) Allow passing program arguments to StandaloneJobCluster

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

[GitHub] flink pull request #6344: [FLINK-9866] Allow passing command line arguments ...

2018-07-16 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/6344 [FLINK-9866] Allow passing command line arguments to standalone job ## What is the purpose of the change Allow passing program arguments to standalone job ## Brief change log

[jira] [Created] (FLINK-9866) Allow passing program arguments to StandaloneJobCluster

2018-07-16 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-9866: --- Summary: Allow passing program arguments to StandaloneJobCluster Key: FLINK-9866 URL: https://issues.apache.org/jira/browse/FLINK-9866 Project: Flink I

[jira] [Closed] (FLINK-9839) End-to-end test: Streaming job with SSL

2018-07-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9839. --- Resolution: Fixed Fix Version/s: 1.5.2 master: e2e090b1a105f9bd20b6e6d0d354fefd5ab0fce

[jira] [Closed] (FLINK-9842) Job submission fails via CLI with SSL enabled

2018-07-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9842. --- Resolution: Fixed master: 0a5aebb0149d3660e549446a3d46df34ef1fb4d2 1.5: 44e5cb6671e637a9ea617

[jira] [Closed] (FLINK-9380) Failing end-to-end tests should not clean up logs

2018-07-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9380. --- Resolution: Fixed master: 053614ff2fad2847ba7e7c801a706eb06bed 1.5: dfc8d15841a86ec7d3b9c

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

2018-07-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545495#comment-16545495 ] Nico Kruber edited comment on FLINK-9860 at 7/16/18 5:04 PM: -

[jira] [Commented] (FLINK-9860) Netty resource leak on receiver side

2018-07-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545495#comment-16545495 ] Nico Kruber commented on FLINK-9860: oh, with our shaded netty version, I actually ne

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

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545487#comment-16545487 ] ASF GitHub Bot commented on FLINK-9762: --- Github user JTaky commented on a diff in t

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

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545489#comment-16545489 ] ASF GitHub Bot commented on FLINK-9762: --- Github user JTaky commented on a diff in t

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

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545488#comment-16545488 ] ASF GitHub Bot commented on FLINK-9762: --- Github user JTaky commented on a diff in t

[GitHub] flink pull request #6284: [FLINK-9762] CoreOptions.TMP_DIRS ('io.tmp.dirs') ...

2018-07-16 Thread JTaky
Github user JTaky commented on a diff in the pull request: https://github.com/apache/flink/pull/6284#discussion_r202756696 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -473,8 +474,13 @@ private ContainerLaunchContext createTaskExecutorLa

[GitHub] flink pull request #6284: [FLINK-9762] CoreOptions.TMP_DIRS ('io.tmp.dirs') ...

2018-07-16 Thread JTaky
Github user JTaky commented on a diff in the pull request: https://github.com/apache/flink/pull/6284#discussion_r202756519 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java --- @@ -181,12 +181,17 @@ * The config parameter defining the direc

[GitHub] flink pull request #6284: [FLINK-9762] CoreOptions.TMP_DIRS ('io.tmp.dirs') ...

2018-07-16 Thread JTaky
Github user JTaky commented on a diff in the pull request: https://github.com/apache/flink/pull/6284#discussion_r202756536 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java --- @@ -250,6 +250,10 @@ public static Configuration gene

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

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545481#comment-16545481 ] ASF GitHub Bot commented on FLINK-9762: --- Github user JTaky commented on a diff in t

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

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545480#comment-16545480 ] ASF GitHub Bot commented on FLINK-9762: --- Github user JTaky commented on a diff in t

[GitHub] flink pull request #6284: [FLINK-9762] CoreOptions.TMP_DIRS ('io.tmp.dirs') ...

2018-07-16 Thread JTaky
Github user JTaky commented on a diff in the pull request: https://github.com/apache/flink/pull/6284#discussion_r202755913 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -473,8 +474,13 @@ private ContainerLaunchContext createTaskExecutorLa

[GitHub] flink pull request #6284: [FLINK-9762] CoreOptions.TMP_DIRS ('io.tmp.dirs') ...

2018-07-16 Thread JTaky
Github user JTaky commented on a diff in the pull request: https://github.com/apache/flink/pull/6284#discussion_r202755897 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -473,8 +474,13 @@ private ContainerLaunchContext createTaskExecutorLa

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

2018-07-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545457#comment-16545457 ] Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:46 PM: -

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

2018-07-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545457#comment-16545457 ] Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:38 PM: -

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

2018-07-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545457#comment-16545457 ] Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:37 PM: -

[jira] [Commented] (FLINK-9860) Netty resource leak on receiver side

2018-07-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545457#comment-16545457 ] Nico Kruber commented on FLINK-9860: The e2e test that was running when the leak occu

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

2018-07-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545457#comment-16545457 ] Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:36 PM: -

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

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

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-16 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/6343 [FLINK-9852] [table] Expose descriptor-based sink creation ## What is the purpose of the change This commit exposes the new unified sink creation through the table environments and the exte

[jira] [Updated] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9852: -- Labels: pull-request-available (was: ) > Expose descriptor-based sink creation in table enviro

[jira] [Assigned] (FLINK-9863) Add a built-in ingestion time TS extractor

2018-07-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9863: --- Assignee: vinoyang > Add a built-in ingestion time TS extractor > --

[jira] [Assigned] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

2018-07-16 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-9598: --- Assignee: Yun Tang > [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when >

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[GitHub] flink issue #6266: [FLINK-9682] Add setDescription to execution environment ...

2018-07-16 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6266 @zentol can you review this PR? so that I can start the part 2 of the task as soon as possible. thanks. ---

[jira] [Commented] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

2018-07-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545352#comment-16545352 ] vinoyang commented on FLINK-9598: - [~yunta] I agree with you. I will release the assignee

[jira] [Assigned] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

2018-07-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9598: --- Assignee: (was: vinoyang) > [Checkpoints] The config Minimum Pause Between Checkpoints doesn't w

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545324#comment-16545324 ] ASF GitHub Bot commented on FLINK-9013: --- Github user NicoK commented on a diff in t

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545325#comment-16545325 ] ASF GitHub Bot commented on FLINK-9013: --- Github user NicoK commented on a diff in t

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545323#comment-16545323 ] ASF GitHub Bot commented on FLINK-9013: --- Github user NicoK commented on a diff in t

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545326#comment-16545326 ] ASF GitHub Bot commented on FLINK-9013: --- Github user NicoK commented on a diff in t

[GitHub] flink pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores...

2018-07-16 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/6294#discussion_r202720821 --- Diff: docs/ops/deployment/yarn_setup.md --- @@ -132,7 +132,7 @@ Stop the YARN session by stopping the unix process (using CTRL+C) or by entering

[GitHub] flink pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores...

2018-07-16 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/6294#discussion_r202720265 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java --- @@ -65,7 +65,11 @@ key("yarn.containers.vcor

[GitHub] flink pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores...

2018-07-16 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/6294#discussion_r202719580 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java --- @@ -65,7 +65,11 @@ key("yarn.containers.vcor

[GitHub] flink pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores...

2018-07-16 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/6294#discussion_r202722162 --- Diff: docs/ops/deployment/yarn_setup.md --- @@ -132,7 +132,7 @@ Stop the YARN session by stopping the unix process (using CTRL+C) or by entering

[jira] [Commented] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

2018-07-16 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545318#comment-16545318 ] Yun Tang commented on FLINK-9598: - Hi [~premsantosh], the "Minimum Pause Between Checkpoi

[jira] [Created] (FLINK-9865) flink-hadoop-compatibility should assume Hadoop as provided

2018-07-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-9865: --- Summary: flink-hadoop-compatibility should assume Hadoop as provided Key: FLINK-9865 URL: https://issues.apache.org/jira/browse/FLINK-9865 Project: Flink Issu

[jira] [Comment Edited] (FLINK-9813) Build xTableSource from Avro schemas

2018-07-16 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545255#comment-16545255 ] François Lacombe edited comment on FLINK-9813 at 7/16/18 3:12 PM: -

[GitHub] flink issue #6337: [FLINK-9853][Tabel API & SQL] add HEX support

2018-07-16 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6337 +1, from my side ---

[jira] [Comment Edited] (FLINK-9814) CsvTableSource "lack of column" warning

2018-07-16 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545270#comment-16545270 ] François Lacombe edited comment on FLINK-9814 at 7/16/18 3:11 PM: -

[jira] [Commented] (FLINK-9853) add hex support in table api and sql

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

[jira] [Commented] (FLINK-9857) Processing-time timers fire too early

2018-07-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545286#comment-16545286 ] Aljoscha Krettek commented on FLINK-9857: - On a side note: even if we change this

[jira] [Commented] (FLINK-9842) Job submission fails via CLI with SSL enabled

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

[jira] [Commented] (FLINK-9839) End-to-end test: Streaming job with SSL

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

[jira] [Commented] (FLINK-9380) Failing end-to-end tests should not clean up logs

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

[GitHub] flink pull request #6340: [FLINK-9842][rest] Pass actual configuration to Bl...

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

[jira] [Comment Edited] (FLINK-9814) CsvTableSource "lack of column" warning

2018-07-16 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545270#comment-16545270 ] François Lacombe edited comment on FLINK-9814 at 7/16/18 2:50 PM: -

[GitHub] flink pull request #6327: [FLINK-9839][e2e] add end-to-end tests with SSL en...

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

[GitHub] flink pull request #6289: [FLINK-9380]: Modified end to end test runner scri...

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

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

2018-07-16 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545270#comment-16545270 ] François Lacombe commented on FLINK-9814: - Fabien, My comments on each point bel

[jira] [Commented] (FLINK-9813) Build xTableSource from Avro schemas

2018-07-16 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545255#comment-16545255 ] François Lacombe commented on FLINK-9813: - Hi Fabien, I am suggesting to build a

[jira] [Created] (FLINK-9864) Make timestamp extraction more flexible in SQL Client

2018-07-16 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9864: --- Summary: Make timestamp extraction more flexible in SQL Client Key: FLINK-9864 URL: https://issues.apache.org/jira/browse/FLINK-9864 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9748) create_source_release pollutes flink root directory

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

[jira] [Updated] (FLINK-9748) create_source_release pollutes flink root directory

2018-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9748: -- Labels: pull-request-available (was: ) > create_source_release pollutes flink root directory >

  1   2   3   >