[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596355#comment-16596355 ] ASF GitHub Bot commented on FLINK-10011: tillrohrmann commented on issue #6587: [FLINK-10011]

[GitHub] tillrohrmann commented on issue #6587: [FLINK-10011] Release JobGraph from SubmittedJobGraphStore

2018-08-29 Thread GitBox
tillrohrmann commented on issue #6587: [FLINK-10011] Release JobGraph from SubmittedJobGraphStore URL: https://github.com/apache/flink/pull/6587#issuecomment-416961912 Unfortunately, this only fixes half of the problem. There is still another problem with standby Dispatchers/JobMaster.

[jira] [Commented] (FLINK-7964) Add Apache Kafka 1.0/1.1 connectors

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596350#comment-16596350 ] ASF GitHub Bot commented on FLINK-7964: --- aljoscha commented on issue #6577: [FLINK-7964] Add Apache

[GitHub] aljoscha commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1 connectors

2018-08-29 Thread GitBox
aljoscha commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1 connectors URL: https://github.com/apache/flink/pull/6577#issuecomment-416960478 @yanghua Sorry for commenting so late but I have a proposal. I would like to take this chance and fix a shortcoming in the

[jira] [Created] (FLINK-10255) Standby Dispatcher locks submitted JobGraphs

2018-08-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10255: - Summary: Standby Dispatcher locks submitted JobGraphs Key: FLINK-10255 URL: https://issues.apache.org/jira/browse/FLINK-10255 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3875) Add a TableSink for Elasticsearch

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596329#comment-16596329 ] ASF GitHub Bot commented on FLINK-3875: --- dawidwys commented on a change in pull request #6611:

[jira] [Commented] (FLINK-3875) Add a TableSink for Elasticsearch

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596331#comment-16596331 ] ASF GitHub Bot commented on FLINK-3875: --- dawidwys commented on a change in pull request #6611:

[jira] [Commented] (FLINK-3875) Add a TableSink for Elasticsearch

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596330#comment-16596330 ] ASF GitHub Bot commented on FLINK-3875: --- dawidwys commented on a change in pull request #6611:

[GitHub] dawidwys commented on a change in pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch

2018-08-29 Thread GitBox
dawidwys commented on a change in pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch URL: https://github.com/apache/flink/pull/6611#discussion_r213664413 ## File path:

[GitHub] dawidwys commented on a change in pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch

2018-08-29 Thread GitBox
dawidwys commented on a change in pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch URL: https://github.com/apache/flink/pull/6611#discussion_r213665920 ## File path: docs/dev/table/connect.md ## @@ -583,6 +584,104 @@ Make

[GitHub] dawidwys commented on a change in pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch

2018-08-29 Thread GitBox
dawidwys commented on a change in pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch URL: https://github.com/apache/flink/pull/6611#discussion_r213597931 ## File path:

[jira] [Comment Edited] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

2018-08-29 Thread godfrey johnson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596318#comment-16596318 ] godfrey johnson edited comment on FLINK-9043 at 8/29/18 1:29 PM: -

[jira] [Comment Edited] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

2018-08-29 Thread godfrey johnson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596318#comment-16596318 ] godfrey johnson edited comment on FLINK-9043 at 8/29/18 1:28 PM: -

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

2018-08-29 Thread godfrey johnson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596318#comment-16596318 ] godfrey johnson commented on FLINK-9043:

[jira] [Commented] (FLINK-9343) Add Async Example with External Rest API call

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596314#comment-16596314 ] ASF GitHub Bot commented on FLINK-9343: --- azagrebin commented on issue #5996: [FLINK-9343] [Example]

[GitHub] azagrebin commented on issue #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call

2018-08-29 Thread GitBox
azagrebin commented on issue #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call URL: https://github.com/apache/flink/pull/5996#issuecomment-416948982 Hi @medcv, do you have some ETA for the PR changes?

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596312#comment-16596312 ] ASF GitHub Bot commented on FLINK-9043: --- GodfreyJohnson opened a new pull request #6630:

[GitHub] GodfreyJohnson opened a new pull request #6630: [FLINK-9043] restore from the latest job's completed checkpoint with …

2018-08-29 Thread GitBox
GodfreyJohnson opened a new pull request #6630: [FLINK-9043] restore from the latest job's completed checkpoint with … URL: https://github.com/apache/flink/pull/6630 - For

[GitHub] WheresAlice opened a new pull request #6629: [hotfix] [docs] Fix typo in batch connectors

2018-08-29 Thread GitBox
WheresAlice opened a new pull request #6629: [hotfix] [docs] Fix typo in batch connectors URL: https://github.com/apache/flink/pull/6629 Small fix for a typo in the docs. This is an automated message from the Apache Git

[jira] [Commented] (FLINK-10150) Inconsistent number of "Records received" / "Records sent"

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596294#comment-16596294 ] ASF GitHub Bot commented on FLINK-10150: azagrebin commented on a change in pull request #6599:

[GitHub] azagrebin commented on a change in pull request #6599: [FLINK-10150][metrics] Fix OperatorMetricGroup creation for Batch

2018-08-29 Thread GitBox
azagrebin commented on a change in pull request #6599: [FLINK-10150][metrics] Fix OperatorMetricGroup creation for Batch URL: https://github.com/apache/flink/pull/6599#discussion_r213666345 ## File path:

[jira] [Closed] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

2018-08-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9962. - Resolution: Fixed Merged on master with 7eb41f33fbce8da52cbba160f0ecff6fe96f124b and on

[jira] [Reopened] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

2018-08-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reopened FLINK-9962: --- > allow users to specify TimeZone in DateTimeBucketer >

[jira] [Reopened] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

2018-08-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reopened FLINK-9962: --- > allow users to specify TimeZone in DateTimeBucketer >

[GitHub] asfgit closed pull request #6492: [FLINK-9962] [FS connector] allow users to specify TimeZone in DateTimeBucketer

2018-08-29 Thread GitBox
asfgit closed pull request #6492: [FLINK-9962] [FS connector] allow users to specify TimeZone in DateTimeBucketer URL: https://github.com/apache/flink/pull/6492 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Closed] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

2018-08-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9962. - Resolution: Fixed Closed on master with 7eb41f33fbce8da52cbba160f0ecff6fe96f124b > allow users

[jira] [Commented] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596276#comment-16596276 ] ASF GitHub Bot commented on FLINK-9962: --- asfgit closed pull request #6492: [FLINK-9962] [FS

[jira] [Closed] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

2018-08-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9962. - Resolution: Fixed > allow users to specify TimeZone in DateTimeBucketer >

[jira] [Reopened] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

2018-08-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reopened FLINK-9962: --- > allow users to specify TimeZone in DateTimeBucketer >

[jira] [Updated] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

2018-08-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-9962: -- Fix Version/s: (was: 1.7.0) 1.6.1 > allow users to specify TimeZone in

[GitHub] Clarkkkkk opened a new pull request #6628: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase

2018-08-29 Thread GitBox
Clark opened a new pull request #6628: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase URL: https://github.com/apache/flink/pull/6628 ## What is the purpose of the change This PR introduce the HBase sink for Datastream which

[jira] [Closed] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

2018-08-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9962. - Resolution: Fixed And on release-1.6 with 3f6e0b7031ef94dfa36161a462958f856987356b > allow

[jira] [Commented] (FLINK-10245) Add DataStream HBase Sink

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596278#comment-16596278 ] ASF GitHub Bot commented on FLINK-10245: Clark opened a new pull request #6628:

[jira] [Assigned] (FLINK-10230) Support printing the query of a view

2018-08-29 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10230: Assignee: vinoyang > Support printing the query of a view >

[jira] [Commented] (FLINK-10225) Cannot access state from a empty taskmanager

2018-08-29 Thread Pierre Zemb (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596270#comment-16596270 ] Pierre Zemb commented on FLINK-10225: - I still want to give it a try ;) Do you have any additional

[jira] [Commented] (FLINK-10245) Add DataStream HBase Sink

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596269#comment-16596269 ] ASF GitHub Bot commented on FLINK-10245: Clark closed pull request #6627: [FLINK-10245]

[GitHub] Clarkkkkk closed pull request #6627: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Pr…

2018-08-29 Thread GitBox
Clark closed pull request #6627: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Pr… URL: https://github.com/apache/flink/pull/6627 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Closed] (FLINK-10137) YARN: Log completed Containers

2018-08-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10137. Resolution: Fixed master: c3a74a12a063129367945e0ca1fa60535f5ca8c9 1.6:

[jira] [Commented] (FLINK-10137) YARN: Log completed Containers

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596259#comment-16596259 ] ASF GitHub Bot commented on FLINK-10137: zentol closed pull request #6550: [FLINK-10137][YARN]

[GitHub] zentol closed pull request #6550: [FLINK-10137][YARN] Log completed containers.

2018-08-29 Thread GitBox
zentol closed pull request #6550: [FLINK-10137][YARN] Log completed containers. URL: https://github.com/apache/flink/pull/6550 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign

[jira] [Commented] (FLINK-10225) Cannot access state from a empty taskmanager

2018-08-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596237#comment-16596237 ] Till Rohrmann commented on FLINK-10225: --- In general this change is not too complicated. However,

[jira] [Created] (FLINK-10254) Fix check in stateBackend

2018-08-29 Thread aitozi (JIRA)
aitozi created FLINK-10254: -- Summary: Fix check in stateBackend Key: FLINK-10254 URL: https://issues.apache.org/jira/browse/FLINK-10254 Project: Flink Issue Type: Improvement Components:

[jira] [Commented] (FLINK-10225) Cannot access state from a empty taskmanager

2018-08-29 Thread Pierre Zemb (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596215#comment-16596215 ] Pierre Zemb commented on FLINK-10225: - Thanks [~till.rohrmann] for the reply! I'm not a Flink

[jira] [Commented] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596212#comment-16596212 ] ASF GitHub Bot commented on FLINK-10222: yanghua commented on issue #6622: [FLINK-10222] Table

[GitHub] yanghua commented on issue #6622: [FLINK-10222] Table scalar function expression parses error when function name equals the exists keyword suffix

2018-08-29 Thread GitBox
yanghua commented on issue #6622: [FLINK-10222] Table scalar function expression parses error when function name equals the exists keyword suffix URL: https://github.com/apache/flink/pull/6622#issuecomment-416919005 @walterddr

[jira] [Commented] (FLINK-9991) Add regexp_replace supported in TableAPI and SQL

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596210#comment-16596210 ] ASF GitHub Bot commented on FLINK-9991: --- yanghua commented on issue #6450: [FLINK-9991] [table] Add

[GitHub] yanghua commented on issue #6450: [FLINK-9991] [table] Add regexp_replace supported in TableAPI and SQL

2018-08-29 Thread GitBox
yanghua commented on issue #6450: [FLINK-9991] [table] Add regexp_replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6450#issuecomment-416918269 @xccui I have updated and rebased this PR, can you review it? thanks.

[jira] [Commented] (FLINK-8686) Improve basic embedded SQL client

2018-08-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596206#comment-16596206 ] Timo Walther commented on FLINK-8686: - The result size has been limited. Fixed in 1.7.0:

[jira] [Updated] (FLINK-8686) Improve basic embedded SQL client

2018-08-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8686: Description: This issue describes follow-up issues that should be fixes in order to make the SQL

[jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596197#comment-16596197 ] ASF GitHub Bot commented on FLINK-8532: --- Guibo-Pan commented on issue #6544: [FLINK-8532]

[GitHub] Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition

2018-08-29 Thread GitBox
Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition URL: https://github.com/apache/flink/pull/6544#issuecomment-416913773 @StephanEwen Thanks for your suggestion. I've made an update to it. For

[jira] [Updated] (FLINK-10206) Add hbase stream connector

2018-08-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10206: - Issue Type: New Feature (was: Improvement) > Add hbase stream connector >

[jira] [Commented] (FLINK-10206) Add hbase stream connector

2018-08-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596194#comment-16596194 ] Timo Walther commented on FLINK-10206: -- [~dangdangdang] for streaming sinks I think it might be

[jira] [Updated] (FLINK-10206) Add hbase stream connector

2018-08-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10206: - Fix Version/s: (was: 1.6.1) > Add hbase stream connector > -- > >

[jira] [Updated] (FLINK-10206) Add hbase stream connector

2018-08-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10206: - Priority: Major (was: Critical) > Add hbase stream connector > -- > >

[GitHub] asfgit closed pull request #6621: [FLINK-8686] [sql-client] Limit result size for prototyping modes

2018-08-29 Thread GitBox
asfgit closed pull request #6621: [FLINK-8686] [sql-client] Limit result size for prototyping modes URL: https://github.com/apache/flink/pull/6621 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance:

[jira] [Commented] (FLINK-8686) Improve basic embedded SQL client

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596185#comment-16596185 ] ASF GitHub Bot commented on FLINK-8686: --- asfgit closed pull request #6621: [FLINK-8686]

[jira] [Closed] (FLINK-10238) Make nightly builds easier discoverable

2018-08-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-10238. > Make nightly builds easier discoverable > --- > >

[jira] [Resolved] (FLINK-10238) Make nightly builds easier discoverable

2018-08-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-10238. -- Resolution: Done Done in 8541e8338868b5d7abba8cb38faa02d6d078ca02 > Make nightly builds

[jira] [Commented] (FLINK-10193) Default RPC timeout is used when triggering savepoint via JobMasterGateway

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596159#comment-16596159 ] ASF GitHub Bot commented on FLINK-10193: tillrohrmann commented on issue #6601: [FLINK-10193]

[GitHub] tillrohrmann commented on issue #6601: [FLINK-10193] Add @RpcTimeout to JobMasterGateway.triggerSavepoint

2018-08-29 Thread GitBox
tillrohrmann commented on issue #6601: [FLINK-10193] Add @RpcTimeout to JobMasterGateway.triggerSavepoint URL: https://github.com/apache/flink/pull/6601#issuecomment-416898324 You're right @GJL. Then I would vote for the first test case. Something along the lines: ``` Future future1

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596147#comment-16596147 ] ASF GitHub Bot commented on FLINK-9190: --- tillrohrmann commented on issue #5931:

[GitHub] tillrohrmann commented on issue #5931: [FLINK-9190][flip6, yarn] Request new container if container completed unexpectedly

2018-08-29 Thread GitBox
tillrohrmann commented on issue #5931: [FLINK-9190][flip6,yarn] Request new container if container completed unexpectedly URL: https://github.com/apache/flink/pull/5931#issuecomment-416895148 @TisonKun, yes #6132 implements the notification about failed allocations. However, the

[jira] [Commented] (FLINK-10225) Cannot access state from a empty taskmanager

2018-08-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596124#comment-16596124 ] Till Rohrmann commented on FLINK-10225: --- Thanks for reporting this issue [~PierreZ]. Your analysis

[jira] [Updated] (FLINK-9991) Add regexp_replace supported in TableAPI and SQL

2018-08-29 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-9991: Summary: Add regexp_replace supported in TableAPI and SQL (was: Add regex_replace supported in TableAPI

[jira] [Commented] (FLINK-10137) YARN: Log completed Containers

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596108#comment-16596108 ] ASF GitHub Bot commented on FLINK-10137: GJL commented on issue #6550: [FLINK-10137][YARN] Log

[GitHub] GJL commented on issue #6550: [FLINK-10137][YARN] Log completed containers.

2018-08-29 Thread GitBox
GJL commented on issue #6550: [FLINK-10137][YARN] Log completed containers. URL: https://github.com/apache/flink/pull/6550#issuecomment-416882644 @zentol @yanghua Thanks for reviewing. @zentol I think this should be merged to 1.5, 1.6, and 1.7.

[jira] [Updated] (FLINK-10137) YARN: Log completed Containers

2018-08-29 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10137: - Fix Version/s: 1.5.4 1.7.0 1.6.1 > YARN: Log completed Containers

[jira] [Created] (FLINK-10253) Run MetricQueryService with lower priority

2018-08-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10253: - Summary: Run MetricQueryService with lower priority Key: FLINK-10253 URL: https://issues.apache.org/jira/browse/FLINK-10253 Project: Flink Issue Type:

[jira] [Created] (FLINK-10252) Handle oversized metric messges

2018-08-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10252: - Summary: Handle oversized metric messges Key: FLINK-10252 URL: https://issues.apache.org/jira/browse/FLINK-10252 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-10250) Flink doesn't support functions that extend RichAggregateFunction in a group window

2018-08-29 Thread PengYang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596098#comment-16596098 ] PengYang commented on FLINK-10250: -- @[~fhueske]  OK Thanks ! > Flink doesn't support functions that

[jira] [Created] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

2018-08-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10251: - Summary: Handle oversized response messages in AkkaRpcActor Key: FLINK-10251 URL: https://issues.apache.org/jira/browse/FLINK-10251 Project: Flink Issue

[jira] [Closed] (FLINK-10250) Flink doesn't support functions that extend RichAggregateFunction in a group window

2018-08-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-10250. - Resolution: Won't Fix > Flink doesn't support functions that extend RichAggregateFunction in a

[jira] [Commented] (FLINK-10250) Flink doesn't support functions that extend RichAggregateFunction in a group window

2018-08-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596089#comment-16596089 ] Fabian Hueske commented on FLINK-10250: --- Hi [~LaiAng], Thanks for your questions and welcome to

[jira] [Created] (FLINK-10250) Flink doesn't support functions that extend RichAggregateFunction in a group window

2018-08-29 Thread PengYang (JIRA)
PengYang created FLINK-10250: Summary: Flink doesn't support functions that extend RichAggregateFunction in a group window Key: FLINK-10250 URL: https://issues.apache.org/jira/browse/FLINK-10250 Project:

[jira] [Created] (FLINK-10249) Document hadoop/presto s3 file system configuration forwarding

2018-08-29 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10249: --- Summary: Document hadoop/presto s3 file system configuration forwarding Key: FLINK-10249 URL: https://issues.apache.org/jira/browse/FLINK-10249 Project: Flink

[jira] [Commented] (FLINK-8686) Improve basic embedded SQL client

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596072#comment-16596072 ] ASF GitHub Bot commented on FLINK-8686: --- fhueske commented on issue #6621: [FLINK-8686]

[GitHub] fhueske commented on issue #6621: [FLINK-8686] [sql-client] Limit result size for prototyping modes

2018-08-29 Thread GitBox
fhueske commented on issue #6621: [FLINK-8686] [sql-client] Limit result size for prototyping modes URL: https://github.com/apache/flink/pull/6621#issuecomment-416867688 Thanks for the update @twalthr. +1 to merge

[jira] [Created] (FLINK-10248) Add HBase Table Sink

2018-08-29 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10248: --- Summary: Add HBase Table Sink Key: FLINK-10248 URL: https://issues.apache.org/jira/browse/FLINK-10248 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-08-29 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596068#comment-16596068 ] Rong Rong commented on FLINK-9172: -- Yes. I think so too. the only thing missing was

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596066#comment-16596066 ] ASF GitHub Bot commented on FLINK-7243: --- fhueske commented on issue #6483:

[GitHub] fhueske commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-08-29 Thread GitBox
fhueske commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-416864894 Hi @HuangZhenQiu, agreed. Let's add filter push down later. I don't think we can limit the changes to `ParquetTableSource` (the

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

2018-08-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596059#comment-16596059 ] Timo Walther commented on FLINK-9172: - [~walterddr] the support for external catalogs is already

[jira] [Updated] (FLINK-10245) Add DataStream HBase Sink

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10245: --- Labels: pull-request-available (was: ) > Add DataStream HBase Sink >

[jira] [Commented] (FLINK-10245) Add DataStream HBase Sink

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596058#comment-16596058 ] ASF GitHub Bot commented on FLINK-10245: Clark opened a new pull request #6627:

[GitHub] Clarkkkkk opened a new pull request #6627: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Pr…

2018-08-29 Thread GitBox
Clark opened a new pull request #6627: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Pr… URL: https://github.com/apache/flink/pull/6627 ## What is the purpose of the change This PR introduce the HBase sink for Datastream which can support Pojo, Row, Tuple

[jira] [Commented] (FLINK-8686) Improve basic embedded SQL client

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596051#comment-16596051 ] ASF GitHub Bot commented on FLINK-8686: --- twalthr commented on issue #6621: [FLINK-8686]

[jira] [Created] (FLINK-10247) Run MetricQueryService in separate thread pool

2018-08-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10247: - Summary: Run MetricQueryService in separate thread pool Key: FLINK-10247 URL: https://issues.apache.org/jira/browse/FLINK-10247 Project: Flink Issue Type:

[GitHub] twalthr commented on issue #6621: [FLINK-8686] [sql-client] Limit result size for prototyping modes

2018-08-29 Thread GitBox
twalthr commented on issue #6621: [FLINK-8686] [sql-client] Limit result size for prototyping modes URL: https://github.com/apache/flink/pull/6621#issuecomment-416858616 Thank you @fhueske. I would be happy if you could take another look.

[jira] [Created] (FLINK-10246) Harden and separate MetricQueryService

2018-08-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10246: - Summary: Harden and separate MetricQueryService Key: FLINK-10246 URL: https://issues.apache.org/jira/browse/FLINK-10246 Project: Flink Issue Type:

[jira] [Created] (FLINK-10245) Add DataStream HBase Sink

2018-08-29 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10245: --- Summary: Add DataStream HBase Sink Key: FLINK-10245 URL: https://issues.apache.org/jira/browse/FLINK-10245 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

2018-08-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10241: -- Fix Version/s: 1.5.4 1.6.1 > Reduce performance/stability impact of

[jira] [Closed] (FLINK-9567) Flink does not release resource in Yarn Cluster mode

2018-08-29 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang closed FLINK-9567. -- > Flink does not release resource in Yarn Cluster mode >

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

2018-08-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10241: -- Fix Version/s: 1.7.0 > Reduce performance/stability impact of latency metrics >

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

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596031#comment-16596031 ] ASF GitHub Bot commented on FLINK-9682: --- zentol commented on issue #6266: [FLINK-9682] Add

[GitHub] zentol commented on issue #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

2018-08-29 Thread GitBox
zentol commented on issue #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#issuecomment-416853509 Not at the moment.

[jira] [Commented] (FLINK-10238) Make nightly builds easier discoverable

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596030#comment-16596030 ] ASF GitHub Bot commented on FLINK-10238: StephanEwen commented on issue #121: [FLINK-10238]

[jira] [Commented] (FLINK-10238) Make nightly builds easier discoverable

2018-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16596028#comment-16596028 ] ASF GitHub Bot commented on FLINK-10238: asfgit closed pull request #121: [FLINK-10238] Link

[jira] [Created] (FLINK-10244) Add option to measure latency as absolute value

2018-08-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10244: Summary: Add option to measure latency as absolute value Key: FLINK-10244 URL: https://issues.apache.org/jira/browse/FLINK-10244 Project: Flink

[jira] [Created] (FLINK-10243) Add option to reduce latency metrics granularity

2018-08-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10243: Summary: Add option to reduce latency metrics granularity Key: FLINK-10243 URL: https://issues.apache.org/jira/browse/FLINK-10243 Project: Flink

<    1   2   3   >