[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition...

2016-12-14 Thread tony810430
Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/3001 @tzulitai as you wish =) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wish

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750667#comment-15750667 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tony810430 commented on the iss

[jira] [Commented] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp / Date

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750659#comment-15750659 ] ASF GitHub Bot commented on FLINK-4523: --- Github user tzulitai commented on the issue

[GitHub] flink issue #2916: [FLINK-4523] [kinesis] Allow Kinesis Consumer to start fr...

2016-12-14 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2916 Thanks for addressing the final comments. I'll add the docs and merge this by the end of the day :) --- If your project is set up for it, you can reply to this email and have your reply appear on G

[GitHub] flink issue #2985: [FLINK-5104] Bipartite graph validation

2016-12-14 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2985 @greghogan Thank you for the review. Can you give me an example of how you document joins? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-5104) Implement BipartiteGraph validator

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750656#comment-15750656 ] ASF GitHub Bot commented on FLINK-5104: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-4647) Implement BipartiteGraph reader

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750651#comment-15750651 ] ASF GitHub Bot commented on FLINK-4647: --- Github user mushketyk commented on the issu

[GitHub] flink issue #2987: [FLINK-4647] Read bipartite graph

2016-12-14 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2987 Hi @greghogan , I've rebased this PR on top of master. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750647#comment-15750647 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750648#comment-15750648 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750646#comment-15750646 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

2016-12-14 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r92554905 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -294,11 +296

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

2016-12-14 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r92554828 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -294,11 +296

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

2016-12-14 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r92555340 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -294,11 +296

[jira] [Commented] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750634#comment-15750634 ] ASF GitHub Bot commented on FLINK-5324: --- Github user hzyuemeng1 commented on the iss

[jira] [Commented] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750635#comment-15750635 ] ASF GitHub Bot commented on FLINK-5324: --- Github user hzyuemeng1 closed the pull requ

[GitHub] flink pull request #2994: [FLINK-5324] [yarn] JVM Opitons will work for both...

2016-12-14 Thread hzyuemeng1
Github user hzyuemeng1 closed the pull request at: https://github.com/apache/flink/pull/2994 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink issue #2994: [FLINK-5324] [yarn] JVM Opitons will work for both YarnAp...

2016-12-14 Thread hzyuemeng1
Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/2994 @wuchong ,can u check this issue? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabl

[jira] [Updated] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5342: -- Description: On Flink table API, a query will be translated to operators without parallelism. And user d

[jira] [Updated] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5342: -- Description: On Flink table API, a query will be translated to operators without parallelism. And user d

[jira] [Updated] (FLINK-5342) Setting the parallelism automatically for Operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5342: -- Summary: Setting the parallelism automatically for Operators base on cost model (was: Setting the paral

[jira] [Updated] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5342: -- Summary: Setting the parallelism automatically for operators base on cost model (was: Setting the paral

[jira] [Created] (FLINK-5342) Setting the parallelism automatically for DataSet Operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
godfrey he created FLINK-5342: - Summary: Setting the parallelism automatically for DataSet Operators base on cost model Key: FLINK-5342 URL: https://issues.apache.org/jira/browse/FLINK-5342 Project: Flink

[jira] [Updated] (FLINK-5342) Setting the parallelism automatically for DataSet Operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5342: -- Description: On Flink table API, a query will be translated to operators without parallelism. And user d

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-14 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750273#comment-15750273 ] Jark Wu commented on FLINK-5280: Hi [~ivan.mushketyk], thanks for your detailed and clear

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750207#comment-15750207 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

2016-12-14 Thread bjlovegithub
Github user bjlovegithub commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r92536062 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java --- @@ -0,0 +1,58 @@ +/* + *

[jira] [Commented] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

2016-12-14 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750108#comment-15750108 ] Kurt Young commented on FLINK-5144: --- I'm interested to solve this problem :) > Error wh

[jira] [Assigned] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

2016-12-14 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-5144: - Assignee: Kurt Young > Error while applying rule AggregateJoinTransposeRule > ---

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750067#comment-15750067 ] ASF GitHub Bot commented on FLINK-4883: --- Github user Renkai commented on the issue:

[GitHub] flink issue #2729: [FLINK-4883]Prevent UDFs implementations through Scala si...

2016-12-14 Thread Renkai
Github user Renkai commented on the issue: https://github.com/apache/flink/pull/2729 Hi, @aljoscha I'm wondering about how could the warning be "big", should it have a different color in the console or pop out an alert window when people submit apps from web? --- If your project is

[GitHub] flink pull request #2962: [FLINK-5051] Backwards compatibility for serialize...

2016-12-14 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/2962 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749873#comment-15749873 ] ASF GitHub Bot commented on FLINK-5051: --- Github user StefanRRichter closed the pull

[jira] [Created] (FLINK-5341) Add a metric exposing how many times a job has been restarted

2016-12-14 Thread Dan Bress (JIRA)
Dan Bress created FLINK-5341: Summary: Add a metric exposing how many times a job has been restarted Key: FLINK-5341 URL: https://issues.apache.org/jira/browse/FLINK-5341 Project: Flink Issue Ty

[jira] [Updated] (FLINK-5340) Add a metric exposing jobs uptimes

2016-12-14 Thread Dan Bress (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dan Bress updated FLINK-5340: - Summary: Add a metric exposing jobs uptimes (was: I would like a metric exposing job uptime) > Add a met

[jira] [Created] (FLINK-5340) I would like a metric exposing job uptime

2016-12-14 Thread Dan Bress (JIRA)
Dan Bress created FLINK-5340: Summary: I would like a metric exposing job uptime Key: FLINK-5340 URL: https://issues.apache.org/jira/browse/FLINK-5340 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-5340) I would like a metric exposing job uptime

2016-12-14 Thread Dan Bress (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dan Bress updated FLINK-5340: - Priority: Minor (was: Major) > I would like a metric exposing job uptime > --

[jira] [Commented] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749732#comment-15749732 ] ASF GitHub Bot commented on FLINK-5320: --- Github user ymarzougui commented on the iss

[GitHub] flink issue #2995: [FLINK-5320] Fix result TypeInformation in WindowedStream...

2016-12-14 Thread ymarzougui
Github user ymarzougui commented on the issue: https://github.com/apache/flink/pull/2995 @StephanEwen @aljoscha, I added a test for `WindowedStream.fold()` similar to the one in [EventTimeAllWindowCheckpointingITCase](https://github.com/apache/flink/blob/master/flink-tests/src/test/ja

[GitHub] flink issue #2985: [FLINK-5104] Bipartite graph validation

2016-12-14 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2985 Sorry for the failing build. I've removed the unused imports so it should be fine now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[jira] [Commented] (FLINK-5104) Implement BipartiteGraph validator

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749656#comment-15749656 ] ASF GitHub Bot commented on FLINK-5104: --- Github user mushketyk commented on the issu

[GitHub] flink issue #2987: [FLINK-4647] Read bipartite graph

2016-12-14 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2987 #2832 has been committed to master. Please rebase. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-4647) Implement BipartiteGraph reader

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749561#comment-15749561 ] ASF GitHub Bot commented on FLINK-4647: --- Github user greghogan commented on the issu

[jira] [Updated] (FLINK-4936) Operator names for Gelly inputs

2016-12-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4936: -- Fix Version/s: 1.2.0 > Operator names for Gelly inputs > --- > >

[jira] [Closed] (FLINK-4936) Operator names for Gelly inputs

2016-12-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4936. - Resolution: Implemented Implemented in 09e0817306e8c077aeea96252a7c98fbd0f9747b > Operator names for Gell

[jira] [Commented] (FLINK-4936) Operator names for Gelly inputs

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

[GitHub] flink pull request #2832: [FLINK-4936] [gelly] Operator names for Gelly inpu...

2016-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2832 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-5104) Implement BipartiteGraph validator

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749452#comment-15749452 ] ASF GitHub Bot commented on FLINK-5104: --- Github user greghogan commented on the issu

[GitHub] flink issue #2985: [FLINK-5104] Bipartite graph validation

2016-12-14 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2985 @mushketyk the build is failing due to unused imports (IntelliJ can be configured to automatically remove these). There are so many ways to implement the validator. Projections would reduce

[jira] [Commented] (FLINK-4936) Operator names for Gelly inputs

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749308#comment-15749308 ] ASF GitHub Bot commented on FLINK-4936: --- Github user greghogan commented on the issu

[GitHub] flink issue #2832: [FLINK-4936] [gelly] Operator names for Gelly inputs

2016-12-14 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2832 That's odd, your last comment was not propagated to JIRA @vasia. Might have been an outage at that time. Will merge this ... --- If your project is set up for it, you can reply to this email and h

[jira] [Commented] (FLINK-4861) Package optional project artifacts

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749204#comment-15749204 ] ASF GitHub Bot commented on FLINK-4861: --- Github user greghogan commented on the issu

[GitHub] flink issue #3000: [FLINK-4861] [build] Package optional project artifacts

2016-12-14 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3000 `flink-avro` is included in the distribution. Will adding a scala suffix to`flink-hcatalog` break API compatibility? I see now that we can use `combine.self="override"` to allow con

[jira] [Commented] (FLINK-4782) log4j & slf4j-log4j are present in jar-with-dependencies artifacts

2016-12-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15749108#comment-15749108 ] Greg Hogan commented on FLINK-4782: --- flink-metrics-dropwizard-1.2-SNAPSHOT-jar-with-depe

[GitHub] flink issue #2962: [FLINK-5051] Backwards compatibility for serializers in b...

2016-12-14 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2962 I merged this. Thanks a lot for your work. 👍 Could you please close this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

2016-12-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748860#comment-15748860 ] Aljoscha Krettek commented on FLINK-5051: - I think this is only partially solved b

[jira] [Closed] (FLINK-5034) Don't Write StateDescriptor to RocksDB Snapshot

2016-12-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5034. --- Resolution: Fixed Solved by 21d1d8b49337e734ce3defb5f1b9344f748cb49e which was addressing FLI

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748852#comment-15748852 ] ASF GitHub Bot commented on FLINK-5051: --- Github user aljoscha commented on the issue

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748829#comment-15748829 ] ASF GitHub Bot commented on FLINK-4391: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

2016-12-14 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r92436971 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java --- @@ -0,0 +1,58 @@ +/* + *

[jira] [Commented] (FLINK-5323) CheckpointNotifier should be removed from docs

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748737#comment-15748737 ] ASF GitHub Bot commented on FLINK-5323: --- Github user abhishsi commented on the issue

[GitHub] flink issue #3006: [FLINK-5323] CheckpointNotifier should be removed from do...

2016-12-14 Thread abhishsi
Github user abhishsi commented on the issue: https://github.com/apache/flink/pull/3006 @rmetzger - not sure why CI failed. How do I rerun it? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have t

[GitHub] flink issue #3006: [FLINK-5323] CheckpointNotifier should be removed from do...

2016-12-14 Thread abhishsi
Github user abhishsi commented on the issue: https://github.com/apache/flink/pull/3006 retest this please --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, o

[jira] [Commented] (FLINK-5323) CheckpointNotifier should be removed from docs

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748733#comment-15748733 ] ASF GitHub Bot commented on FLINK-5323: --- Github user abhishsi commented on the issue

[GitHub] flink pull request #2997: [FLINK-5240][tests] ensure state backends are prop...

2016-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2997 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling

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

[jira] [Resolved] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling

2016-12-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-5240. --- Resolution: Fixed Assignee: Maximilian Michels Added a test case to verify closi

[jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748686#comment-15748686 ] ASF GitHub Bot commented on FLINK-4973: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #3008: [FLINK-4973] Let LatencyMarksEmitter use StreamTas...

2016-12-14 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3008 [FLINK-4973] Let LatencyMarksEmitter use StreamTask's ProcessingTimeService The LatencyMarksEmitter class uses now the StreamTask's ProcessingTimeService to schedule latency mark emission.

[jira] [Commented] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748669#comment-15748669 ] ASF GitHub Bot commented on FLINK-5240: --- Github user mxm commented on the issue:

[GitHub] flink issue #2997: [FLINK-5240][tests] ensure state backends are properly cl...

2016-12-14 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2997 Thanks for the review, will merge then. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Commented] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748632#comment-15748632 ] ASF GitHub Bot commented on FLINK-5240: --- Github user aljoscha commented on the issue

[GitHub] flink issue #2997: [FLINK-5240][tests] ensure state backends are properly cl...

2016-12-14 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2997 +1, please go ahead and merge. And thank for fixing. 👍 😃 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your proje

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748589#comment-15748589 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748587#comment-15748587 ] ASF GitHub Bot commented on FLINK-3551: --- Github user ch33hau commented on the issue:

[GitHub] flink issue #2925: [FLINK-4574] [kinesis] Strengthen fetch interval implemen...

2016-12-14 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2925 I'm definitely planning to look at this over the next few days :) Currently quite overwhelmed right now. Thanks for all your recent work on the Kinesis connector @tony810430, and very sorry

[GitHub] flink issue #2761: [FLINK-3551] [examples] Sync Scala Streaming Examples

2016-12-14 Thread ch33hau
Github user ch33hau commented on the issue: https://github.com/apache/flink/pull/2761 Hi @thvasilo, thanks for the help, it's ok, knew that everyone is quite busy =) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If you

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748576#comment-15748576 ] ASF GitHub Bot commented on FLINK-3551: --- Github user thvasilo commented on the issue

[GitHub] flink issue #2761: [FLINK-3551] [examples] Sync Scala Streaming Examples

2016-12-14 Thread thvasilo
Github user thvasilo commented on the issue: https://github.com/apache/flink/pull/2761 Hello @ch33hau, sorry for the late reply, I've been at a conference the past week. With the latest changes this LGTM, I've edited the fix version in JIRA to 1.2.0 to give this more visibility for th

[jira] [Resolved] (FLINK-4429) Move Redis Sink from Flink to Bahir

2016-12-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4429. --- Resolution: Fixed Fix Version/s: 1.2.0 Redis is now in Bahir, so I deleted it from Flin

[jira] [Updated] (FLINK-3551) Sync Scala and Java Streaming Examples

2016-12-14 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-3551: --- Fix Version/s: (was: 1.0.1) 1.2.0 > Sync Scala and Java Streami

[jira] [Commented] (FLINK-4704) Move Table API to org.apache.flink.table

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748549#comment-15748549 ] ASF GitHub Bot commented on FLINK-4704: --- Github user ex00 commented on the issue:

[GitHub] flink issue #2958: [FLINK-4704] Move Table API to org.apache.flink.table

2016-12-14 Thread ex00
Github user ex00 commented on the issue: https://github.com/apache/flink/pull/2958 PR has been updated. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or

[jira] [Commented] (FLINK-5323) CheckpointNotifier should be removed from docs

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748525#comment-15748525 ] ASF GitHub Bot commented on FLINK-5323: --- Github user rmetzger commented on the issue

[GitHub] flink issue #3006: [FLINK-5323] CheckpointNotifier should be removed from do...

2016-12-14 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3006 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if th

[jira] [Commented] (FLINK-5319) ClassCastException when reusing an inherited method reference as KeySelector for different classes

2016-12-14 Thread Alexander Chermenin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748508#comment-15748508 ] Alexander Chermenin commented on FLINK-5319: Well, we can change the signature

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748491#comment-15748491 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748486#comment-15748486 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748493#comment-15748493 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748494#comment-15748494 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748488#comment-15748488 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748495#comment-15748495 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748485#comment-15748485 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748501#comment-15748501 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748489#comment-15748489 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748490#comment-15748490 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748496#comment-15748496 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748498#comment-15748498 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748487#comment-15748487 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748500#comment-15748500 ] ASF GitHub Bot commented on FLINK-5008: --- Github user fhueske commented on a diff in

  1   2   3   >