[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354542#comment-15354542 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on the issue:

[GitHub] flink issue #2152: [FLINK-3920] Distributed Linear Algebra: block-based matr...

Github user chiwanpark commented on the issue: https://github.com/apache/flink/pull/2152 This PR contains unnecessary code changes related to `DistributedRowMatrix` (`DistributedRowMatrix.scala` and `DistributedRowMatrixSuite.scala`). Please sync this PR with current master. --- If

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r68885212 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala --- @@ -0,0 +1,287 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354539#comment-15354539 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[jira] [Commented] (FLINK-4128) compile error about git-commit-id-plugin

[ https://issues.apache.org/jira/browse/FLINK-4128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354385#comment-15354385 ] Mao, Wei commented on FLINK-4128: - Thanks for the info. Then I think it's make sense to upgrade to latest

[jira] [Commented] (FLINK-4128) compile error about git-commit-id-plugin

[ https://issues.apache.org/jira/browse/FLINK-4128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354215#comment-15354215 ] ASF GitHub Bot commented on FLINK-4128: --- Github user mwws commented on the issue:

[GitHub] flink issue #2179: [FLINK-4128] compile error about git-commit-id-plugin

Github user mwws commented on the issue: https://github.com/apache/flink/pull/2179 Yes, I am also confused about why it can compile before. But according to [archived flink-dev

[GitHub] flink pull request #2178: [Flink-1815] Add methods to read and write a Graph...

Github user fobeligi commented on a diff in the pull request: https://github.com/apache/flink/pull/2178#discussion_r68848969 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -408,6 +408,79 @@ public static GraphCsvReader

[GitHub] flink pull request #2178: [Flink-1815] Add methods to read and write a Graph...

Github user fobeligi commented on a diff in the pull request: https://github.com/apache/flink/pull/2178#discussion_r68848469 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -408,6 +408,79 @@ public static GraphCsvReader

[GitHub] flink pull request #2178: [Flink-1815] Add methods to read and write a Graph...

Github user fobeligi commented on a diff in the pull request: https://github.com/apache/flink/pull/2178#discussion_r68846112 --- Diff: flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala --- @@ -1127,8 +1194,7 @@ TypeInformation :

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353687#comment-15353687 ] ASF GitHub Bot commented on FLINK-3879: --- Github user vasia commented on the issue:

[GitHub] flink issue #1967: [FLINK-3879] [gelly] Native implementation of HITS algori...

Github user vasia commented on the issue: https://github.com/apache/flink/pull/1967 Hey @greghogan, was there consensus regarding this change? I see the numbers, but did anyone review this PR? I've been offline for the past few days, and I now see that nobody reviewed #2160,

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353650#comment-15353650 ] ASF GitHub Bot commented on FLINK-3879: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-3879) Native implementation of HITS algorithm

[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3879. - Resolution: Fixed Implemented in 40749ddcd73c4634d81c2153f64e8934d519be3d > Native implementation of

[GitHub] flink pull request #1967: [FLINK-3879] [gelly] Native implementation of HITS...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1967 --- 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 pull request #2178: [Flink-1815] Add methods to read and write a Graph...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2178#discussion_r68832940 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -408,6 +408,79 @@ public static GraphCsvReader

[GitHub] flink pull request #2178: [Flink-1815] Add methods to read and write a Graph...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2178#discussion_r68832549 --- Diff: flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala --- @@ -1127,8 +1194,7 @@ TypeInformation :

[GitHub] flink pull request #2178: [Flink-1815] Add methods to read and write a Graph...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2178#discussion_r68832491 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java --- @@ -408,6 +408,79 @@ public static GraphCsvReader

[jira] [Closed] (FLINK-3277) Use Value types in Gelly API

[ https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3277. - Resolution: Fixed Implemented in 40749ddcd73c4634d81c2153f64e8934d519be3d > Use Value types in Gelly API

[jira] [Commented] (FLINK-3277) Use Value types in Gelly API

[ https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353602#comment-15353602 ] ASF GitHub Bot commented on FLINK-3277: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #1671: [FLINK-3277] Use Value types in Gelly API

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1671 --- 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

[jira] [Created] (FLINK-4129) HITSAlgorithm should test for element-wise convergence

Greg Hogan created FLINK-4129: - Summary: HITSAlgorithm should test for element-wise convergence Key: FLINK-4129 URL: https://issues.apache.org/jira/browse/FLINK-4129 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes

[ https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353525#comment-15353525 ] ASF GitHub Bot commented on FLINK-4127: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request #2177: [FLINK-4127] Check API compatbility for 1.1 in fli...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2177#discussion_r68819516 --- Diff: docs/setup/config.md --- @@ -85,6 +85,8 @@ The default fraction for managed memory can be adjusted using the `taskmanager.m -

[GitHub] flink issue #2179: [Flink-4128] fix flink-runtime compile error about git-co...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2179 The modified line is ancient code. It's not clear why this is necessary. --- 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

[jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction

[ https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353454#comment-15353454 ] ASF GitHub Bot commented on FLINK-3477: --- Github user greghogan commented on the issue:

[GitHub] flink issue #1517: [FLINK-3477] [runtime] Add hash-based combine strategy fo...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/1517 +1 with just a few superficial comments. Reading back through the discussion I see that there are many ideas for future performance enhancements. If not already suggested I'd like to

[jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353430#comment-15353430 ] ramkrishna.s.vasudevan commented on FLINK-3674: --- So in all the Stream UDF implementations if

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353421#comment-15353421 ] Greg Hogan commented on FLINK-3879: --- Using CombineHint.HASH the HITS timings dropped from/to: scale 10:

[jira] [Created] (FLINK-4128) compile error about git-commit-id-plugin

Mao, Wei created FLINK-4128: --- Summary: compile error about git-commit-id-plugin Key: FLINK-4128 URL: https://issues.apache.org/jira/browse/FLINK-4128 Project: Flink Issue Type: Bug

[GitHub] flink pull request #2179: [Flink-4128]fix flink-runtime compile error about ...

GitHub user mwws opened a pull request: https://github.com/apache/flink/pull/2179 [Flink-4128]fix flink-runtime compile error about git-commit-id-plugin When I build with latest flink code, I got following error: > [INFO]

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353348#comment-15353348 ] Greg Hogan commented on FLINK-3879: --- I had not realized pr1517 was defaulting to the old sort-based

[GitHub] flink pull request #2178: [Flink-1815] Add methods to read and write a Graph...

GitHub user fobeligi opened a pull request: https://github.com/apache/flink/pull/2178 [Flink-1815] Add methods to read and write a Graph as adjacency list Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[GitHub] flink issue #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2146 I moved the checkpoint metrics into the Tracker (and reverted the changed to ExecutionGraph). Currently trying it out locally. Regarding the exception catching in the metrics: I can't decide

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353280#comment-15353280 ] ASF GitHub Bot commented on FLINK-1550: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4085) Set Kinesis Consumer Agent to Flink

[ https://issues.apache.org/jira/browse/FLINK-4085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353092#comment-15353092 ] ASF GitHub Bot commented on FLINK-4085: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes

[ https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353027#comment-15353027 ] ASF GitHub Bot commented on FLINK-4127: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request #2177: [FLINK-4127] Check API compatbility for 1.1 in fli...

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/2177 [FLINK-4127] Check API compatbility for 1.1 in flink-core I checked all the newly introduced methods in public APIs by going through the reports generated from japicmp. I've also put the

[jira] [Commented] (FLINK-2352) [Graph Visualization] Integrate Gelly with Gephi

[ https://issues.apache.org/jira/browse/FLINK-2352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352996#comment-15352996 ] Greg Hogan commented on FLINK-2352: --- I do not think that this ticket is a good fit for Flink.

[jira] [Commented] (FLINK-4085) Set Kinesis Consumer Agent to Flink

[ https://issues.apache.org/jira/browse/FLINK-4085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352988#comment-15352988 ] ASF GitHub Bot commented on FLINK-4085: --- Github user rmetzger commented on a diff in the pull

[jira] [Commented] (FLINK-4085) Set Kinesis Consumer Agent to Flink

[ https://issues.apache.org/jira/browse/FLINK-4085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352989#comment-15352989 ] ASF GitHub Bot commented on FLINK-4085: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2175: [FLINK-4085][Kinesis] Set Flink-specific user agent

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2175 Thank you for the review. It seems that I'm not that focused today ;) --- 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

[jira] [Commented] (FLINK-4085) Set Kinesis Consumer Agent to Flink

[ https://issues.apache.org/jira/browse/FLINK-4085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352986#comment-15352986 ] ASF GitHub Bot commented on FLINK-4085: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request #2175: [FLINK-4085][Kinesis] Set Flink-specific user agen...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2175#discussion_r68757090 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@

[GitHub] flink pull request #2175: [FLINK-4085][Kinesis] Set Flink-specific user agen...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2175#discussion_r68757009 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@

[GitHub] flink issue #2176: [FLINK-4118] The docker-flink image is outdated (1.0.2) a...

Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2176 Sorry I had to rebase my previous PR but this is the definitive one. --- 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

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352966#comment-15352966 ] ASF GitHub Bot commented on FLINK-4118: --- Github user iemejia commented on the issue:

[jira] [Commented] (FLINK-4085) Set Kinesis Consumer Agent to Flink

[ https://issues.apache.org/jira/browse/FLINK-4085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352961#comment-15352961 ] ASF GitHub Bot commented on FLINK-4085: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #2175: [FLINK-4085][Kinesis] Set Flink-specific user agen...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2175#discussion_r68752991 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@

[jira] [Commented] (FLINK-4085) Set Kinesis Consumer Agent to Flink

[ https://issues.apache.org/jira/browse/FLINK-4085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352957#comment-15352957 ] ASF GitHub Bot commented on FLINK-4085: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #2175: [FLINK-4085][Kinesis] Set Flink-specific user agen...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2175#discussion_r68752667 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352950#comment-15352950 ] ASF GitHub Bot commented on FLINK-4118: --- Github user iemejia commented on the issue:

[GitHub] flink issue #2176: Flink 4118

Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2176 The docker images script was simplified and the image size was reduced. Previous image: flink latest 6475add651c7 24 minutes ago 711.6 MB Image after FLINK-4118 flink latest

[GitHub] flink pull request #2176: Flink 4118

GitHub user iemejia opened a pull request: https://github.com/apache/flink/pull/2176 Flink 4118 Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the items into

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352937#comment-15352937 ] ASF GitHub Bot commented on FLINK-4084: --- Github user alkagin commented on a diff in the pull

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

Github user alkagin commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68750010 --- Diff: flink-dist/src/main/flink-bin/bin/flink --- @@ -17,20 +17,41 @@ # limitations under the License.

[GitHub] flink issue #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2154 Thanks for updating/fixing the documentation @aljoscha ! I had some comments that I posted here. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352922#comment-15352922 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on the issue:

[jira] [Commented] (FLINK-3034) Redis SInk Connector

[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352920#comment-15352920 ] ASF GitHub Bot commented on FLINK-3034: --- Github user subhankarb commented on the issue:

[GitHub] flink issue #1813: [FLINK-3034] Redis Sink Connector

Github user subhankarb commented on the issue: https://github.com/apache/flink/pull/1813 @mjsax , @rmetzger plz review. The changed model is described in the PR description. thanks, subhankar --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352914#comment-15352914 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68746527 --- Diff: flink-dist/src/main/flink-bin/bin/flink --- @@ -17,20 +17,41 @@ # limitations under the License.

[jira] [Updated] (FLINK-4127) Clean up configuration and check breaking API changes

[ https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4127: -- Attachment: flink-streaming-scala.html flink-streaming-java.html

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352896#comment-15352896 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[jira] [Commented] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-4075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352897#comment-15352897 ] ASF GitHub Bot commented on FLINK-4075: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2174: [FLINK-4075] ContinuousFileProcessingCheckpointITCase fai...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2174 Thanks for fixing this! I had some comments but they should be easy to address. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68744858 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352894#comment-15352894 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[GitHub] flink issue #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2146 I've tested the PR locally and the JobManager metrics were shown properly. Good job @zentol :-) Thus, there are only a test case for the job manager metrics, the question whether to

[jira] [Updated] (FLINK-4127) Clean up configuration and check breaking API changes

[ https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4127: -- Attachment: flink-java.html flink-core.html > Clean up configuration and check

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352895#comment-15352895 ] ASF GitHub Bot commented on FLINK-1550: --- Github user tillrohrmann commented on the issue:

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68744802 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352889#comment-15352889 ] ASF GitHub Bot commented on FLINK-1550: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Closed] (FLINK-3898) Adamic-Adar Similarity

[ https://issues.apache.org/jira/browse/FLINK-3898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3898. - Resolution: Fixed Implemented in f9552d8dc25564405b37f3f0b6ac9addf497b722 > Adamic-Adar Similarity >

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352887#comment-15352887 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[jira] [Commented] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-4075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352886#comment-15352886 ] ASF GitHub Bot commented on FLINK-4075: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68744357 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -663,6 +677,9 @@ public boolean

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68744340 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[GitHub] flink pull request #2174: [FLINK-4075] ContinuousFileProcessingCheckpointITC...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2174#discussion_r68744213 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java --- @@ -405,6 +414,9 @@

[GitHub] flink pull request #2174: [FLINK-4075] ContinuousFileProcessingCheckpointITC...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2174#discussion_r68744278 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java --- @@ -191,11 +197,11 @@

[jira] [Commented] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-4075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352884#comment-15352884 ] ASF GitHub Bot commented on FLINK-4075: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-4075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352881#comment-15352881 ] ASF GitHub Bot commented on FLINK-4075: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #2174: [FLINK-4075] ContinuousFileProcessingCheckpointITC...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2174#discussion_r68744158 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java --- @@ -104,7 +104,13 @@

[GitHub] flink pull request #2174: [FLINK-4075] ContinuousFileProcessingCheckpointITC...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2174#discussion_r68743982 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java --- @@ -104,7 +104,13 @@

[jira] [Commented] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-4075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352878#comment-15352878 ] ASF GitHub Bot commented on FLINK-4075: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-4075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352877#comment-15352877 ] ASF GitHub Bot commented on FLINK-4075: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2174: [FLINK-4075] ContinuousFileProcessingCheckpointITCase fai...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2174 I think having `splitsToFwdOrderedAscByModTime` and `currentSplitsToFwd` as fields that are checkpointed is no longer necessary since `monitorDirAndForwardSplits()` is called in lock scope and

[jira] [Created] (FLINK-4127) Clean up configuration and check breaking API changes

Robert Metzger created FLINK-4127: - Summary: Clean up configuration and check breaking API changes Key: FLINK-4127 URL: https://issues.apache.org/jira/browse/FLINK-4127 Project: Flink Issue

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352872#comment-15352872 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352871#comment-15352871 ] ASF GitHub Bot commented on FLINK-4084: --- Github user alkagin commented on a diff in the pull

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68743505 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

Github user alkagin commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68743480 --- Diff: flink-dist/src/main/flink-bin/bin/flink --- @@ -17,20 +17,41 @@ # limitations under the License.

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352865#comment-15352865 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

Github user alkagin commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68743195 --- Diff: flink-dist/src/main/flink-bin/bin/flink --- @@ -17,20 +17,41 @@ # limitations under the License.

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352867#comment-15352867 ] ASF GitHub Bot commented on FLINK-4084: --- Github user alkagin commented on a diff in the pull

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68743168 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352859#comment-15352859 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68742875 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-4085) Set Kinesis Consumer Agent to Flink

[ https://issues.apache.org/jira/browse/FLINK-4085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352858#comment-15352858 ] ASF GitHub Bot commented on FLINK-4085: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request #2175: [FLINK-4085][Kinesis] Set Flink-specific user agen...

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/2175 [FLINK-4085][Kinesis] Set Flink-specific user agent I was asked by Amazon to set a Flink specific user agent when accessing the AWS APIs. I've set an agent for the consumer, for the producer I

  1   2   3   >