[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421135#comment-15421135 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri], I'm redoing the imple

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421317#comment-15421317 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri] No worries :) No is

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri], I changed the implementa

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389 ] Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:1

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389 ] Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:1

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389 ] Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:1

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389 ] Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:1

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430445#comment-15430445 ] Jean-Baptiste Onofré commented on FLINK-3298: - By the way guys, why

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434446#comment-15434446 ] Ismaël Mejía commented on FLINK-4326: - Just to make some progress here, I see t

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15442548#comment-15442548 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri] I've pushed a new vers

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15442548#comment-15442548 ] Josep Rubió edited comment on FLINK-1707 at 8/28/16 1:4

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15442548#comment-15442548 ] Josep Rubió edited comment on FLINK-1707 at 8/28/16 1:4

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15443415#comment-15443415 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri], Yeps, I'll do that.

[jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenz Bühmann updated FLINK-2662: -- Attachment: FlinkBug.scala A minimal example that leads to the reported exception. While

[jira] [Comment Edited] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15464487#comment-15464487 ] Lorenz Bühmann edited comment on FLINK-2662 at 9/5/16 8:5

[jira] [Comment Edited] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15464487#comment-15464487 ] Lorenz Bühmann edited comment on FLINK-2662 at 9/5/16 8:5

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15466242#comment-15466242 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri], I have updated the code if

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389 ] Josep Rubió edited comment on FLINK-1707 at 9/8/16 3:4

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473506#comment-15473506 ] Lorenz Bühmann commented on FLINK-2662: --- No problem, just let me know if you

[jira] [Created] (FLINK-4613) Extend ALS to handle implicit feedback datasets

Gábor Hermann created FLINK-4613: Summary: Extend ALS to handle implicit feedback datasets Key: FLINK-4613 URL: https://issues.apache.org/jira/browse/FLINK-4613 Project: Flink Issue Type

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15488555#comment-15488555 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri], I'm not sure I unders

[jira] [Created] (FLINK-4632) when yarn nodemanager lost, flink hung

刘喆 created FLINK-4632: - Summary: when yarn nodemanager lost, flink hung Key: FLINK-4632 URL: https://issues.apache.org/jira/browse/FLINK-4632 Project: Flink Issue Type: Bug Components

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15505243#comment-15505243 ] 刘喆 commented on FLINK-4632: --- Yes. The job's status is canceling, then hung. Web p

[jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15505243#comment-15505243 ] 刘喆 edited comment on FLINK-4632 at 9/20/16 1:26 AM: Yes. The j

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508441#comment-15508441 ] 刘喆 commented on FLINK-4632: --- The container is killed by two reasons: 1, yarn preempti

[jira] [Created] (FLINK-4652) Don't pass credentials explicitly to AmazonClient - use credentials provider instead

Kristian Frøhlich Hansen created FLINK-4652: --- Summary: Don't pass credentials explicitly to AmazonClient - use credentials provider instead Key: FLINK-4652 URL: https://issues.apache.org/jira/b

[jira] [Updated] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-4663: -- Assignee: Swapnil Chougule > Flink JDBCOutputFormat logs wrong WARN mess

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15516530#comment-15516530 ] 刘喆 commented on FLINK-4632: --- It is (2). I make a new idle hadoop yarn cluster, and use

[jira] [Commented] (FLINK-3026) Publish the flink docker container to the docker registry

[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903272#comment-15903272 ] Ismaël Mejía commented on FLINK-3026: - Great, taking a look right now, I will re

[jira] [Commented] (FLINK-3026) Publish the flink docker container to the docker registry

[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906513#comment-15906513 ] Ismaël Mejía commented on FLINK-3026: - Ok, we are going progress fast, that’s g

[jira] [Commented] (FLINK-3026) Publish the flink docker container to the docker registry

[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906514#comment-15906514 ] Ismaël Mejía commented on FLINK-3026: - One thing we need to discuss is the inclu

[jira] [Commented] (FLINK-3026) Publish the flink docker container to the docker registry

[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906515#comment-15906515 ] Ismaël Mejía commented on FLINK-3026: - I saw the images you built, probably it

[jira] [Commented] (FLINK-6003) Add docker image based on the openjdk one (debian+alpine)

[ https://issues.apache.org/jira/browse/FLINK-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940298#comment-15940298 ] Ismaël Mejía commented on FLINK-6003: - Just for reference, the current work on

[jira] [Created] (FLINK-6203) DataSet Transformations

苏拓 created FLINK-6203: - Summary: DataSet Transformations Key: FLINK-6203 URL: https://issues.apache.org/jira/browse/FLINK-6203 Project: Flink Issue Type: Bug Components: DataSet API

[jira] [Assigned] (FLINK-4900) Implement Docker image support

[ https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mischa Krüger reassigned FLINK-4900: Assignee: Mischa Krüger (was: Eron Wright ) > Implement Docker image supp

[jira] [Updated] (FLINK-4900) Implement Docker image support

[ https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mischa Krüger updated FLINK-4900: - Labels: release (was: ) > Implement Docker image supp

[jira] [Updated] (FLINK-4900) Implement Docker image support

[ https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mischa Krüger updated FLINK-4900: - Labels: release review (was: release) > Implement Docker image supp

[jira] [Updated] (FLINK-4900) Implement Docker image support

[ https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mischa Krüger updated FLINK-4900: - Labels: release (was: release review) > Implement Docker image supp

[jira] [Created] (FLINK-5109) Invalid Content-Encoding Header in REST API responses

Móger Tibor László created FLINK-5109: - Summary: Invalid Content-Encoding Header in REST API responses Key: FLINK-5109 URL: https://issues.apache.org/jira/browse/FLINK-5109 Project: Flink

[jira] [Updated] (FLINK-5109) Invalid Content-Encoding Header in REST API responses

[ https://issues.apache.org/jira/browse/FLINK-5109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Móger Tibor László updated FLINK-5109: -- Description: On REST API calls the Flink runtime responds with the header Content

[jira] [Updated] (FLINK-5109) Invalid Content-Encoding Header in REST API responses

[ https://issues.apache.org/jira/browse/FLINK-5109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Móger Tibor László updated FLINK-5109: -- Affects Version/s: 1.1.0 1.1.1 1.1.2

[jira] [Created] (FLINK-5156) Consolidate streaming FieldAccessor functionality

Márton Balassi created FLINK-5156: - Summary: Consolidate streaming FieldAccessor functionality Key: FLINK-5156 URL: https://issues.apache.org/jira/browse/FLINK-5156 Project: Flink Issue Type

[jira] [Resolved] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-3702. --- Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 1f04542 and 870e219. > DataStr

[jira] [Updated] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josep Rubió updated FLINK-1707: --- Description: This issue proposes adding the an implementation of the Affinity Propagation algorithm

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714684#comment-15714684 ] 刘喆 commented on FLINK-4632: --- It appears again. This time I get the logs. On JobManager:

[jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714684#comment-15714684 ] 刘喆 edited comment on FLINK-4632 at 12/2/16 10:10 AM: - It app

[jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714684#comment-15714684 ] 刘喆 edited comment on FLINK-4632 at 12/2/16 10:10 AM: - It app

[jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714684#comment-15714684 ] 刘喆 edited comment on FLINK-4632 at 12/2/16 10:11 AM: - This

[jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714684#comment-15714684 ] 刘喆 edited comment on FLINK-4632 at 12/2/16 10:32 AM: - This

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715048#comment-15715048 ] 刘喆 commented on FLINK-4632: --- Thank you Ufuk Celebi. It depends on the strategy of restar

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715047#comment-15715047 ] 刘喆 commented on FLINK-4632: --- Thank you Ufuk Celebi. It depends on the strategy of restar

[jira] [Issue Comment Deleted] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 刘喆 updated FLINK-4632: -- Comment: was deleted (was: Thank you Ufuk Celebi. It depends on the strategy of restarting. Here I use auto restarting

[jira] [Commented] (FLINK-4300) Improve error message for different Scala versions of JM and Client

[ https://issues.apache.org/jira/browse/FLINK-4300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721686#comment-15721686 ] Sergio Fernández commented on FLINK-4300: - Any progress on this? As [do

[jira] [Commented] (FLINK-4982) quickstart example: Can't see the output

[ https://issues.apache.org/jira/browse/FLINK-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725705#comment-15725705 ] Mischa Krüger commented on FLINK-4982: -- Ping, still can't find t

[jira] [Created] (FLINK-5267) TaskManager logs not scrollable

Mischa Krüger created FLINK-5267: Summary: TaskManager logs not scrollable Key: FLINK-5267 URL: https://issues.apache.org/jira/browse/FLINK-5267 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5298) Web UI crashes when TM log not existant

Mischa Krüger created FLINK-5298: Summary: Web UI crashes when TM log not existant Key: FLINK-5298 URL: https://issues.apache.org/jira/browse/FLINK-5298 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-5298) TaskManager crashes when TM log not existant

[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mischa Krüger updated FLINK-5298: - Summary: TaskManager crashes when TM log not existant (was: Web UI crashes when TM log not

[jira] [Commented] (FLINK-5298) TaskManager crashes when TM log not existant

[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732728#comment-15732728 ] Mischa Krüger commented on FLINK-5298: -- This happened when the log was requested

[jira] [Created] (FLINK-5301) Can't upload job via Web UI when using a proxy

Mischa Krüger created FLINK-5301: Summary: Can't upload job via Web UI when using a proxy Key: FLINK-5301 URL: https://issues.apache.org/jira/browse/FLINK-5301 Project: Flink Issue Type

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

Ismaël Mejía created FLINK-4118: --- Summary: The docker-flink image is outdated (1.0.2) and can be slimmed down Key: FLINK-4118 URL: https://issues.apache.org/jira/browse/FLINK-4118 Project: Flink

[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&focusedCommentId=15349470#comment-15349470 ] Ismaël Mejía commented on FLINK-4118: - I am working on this and I have a PR ready

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349699#comment-15349699 ] Josep Rubió commented on FLINK-1707: Hi Vasia, Maybe does not make sense to cont

[jira] [Created] (FLINK-4120) Lightweight fault tolerance through recomputing lost state

Dénes Vadász created FLINK-4120: --- Summary: Lightweight fault tolerance through recomputing lost state Key: FLINK-4120 URL: https://issues.apache.org/jira/browse/FLINK-4120 Project: Flink Issue

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351211#comment-15351211 ] Josep Rubió commented on FLINK-1707: Agree, I put this same statement in the de

[jira] [Commented] (FLINK-4120) Lightweight fault tolerance through recomputing lost state

[ https://issues.apache.org/jira/browse/FLINK-4120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351739#comment-15351739 ] Dénes Vadász commented on FLINK-4120: - Whether the state is re-computed or rest

[jira] [Comment Edited] (FLINK-4120) Lightweight fault tolerance through recomputing lost state

[ https://issues.apache.org/jira/browse/FLINK-4120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351739#comment-15351739 ] Dénes Vadász edited comment on FLINK-4120 at 6/27/16 8:2

[jira] [Created] (FLINK-4136) Add a JobHistory Server service

Márton Balassi created FLINK-4136: - Summary: Add a JobHistory Server service Key: FLINK-4136 URL: https://issues.apache.org/jira/browse/FLINK-4136 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4209) Docker image breaks with multiple NICs

Ismaël Mejía created FLINK-4209: --- Summary: Docker image breaks with multiple NICs Key: FLINK-4209 URL: https://issues.apache.org/jira/browse/FLINK-4209 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4208) Support Running Flink processes in foreground mode

Ismaël Mejía created FLINK-4208: --- Summary: Support Running Flink processes in foreground mode Key: FLINK-4208 URL: https://issues.apache.org/jira/browse/FLINK-4208 Project: Flink Issue Type

[jira] [Closed] (FLINK-4208) Support Running Flink processes in foreground mode

[ https://issues.apache.org/jira/browse/FLINK-4208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía closed FLINK-4208. --- Resolution: Fixed I decided to remove the issue for foreground mode and change the docker script to

[jira] [Updated] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

[ https://issues.apache.org/jira/browse/FLINK-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-4209: Summary: Fix issue on docker with multiple NICs and remove supervisord dependency (was: Docker

[jira] [Closed] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy()

[ https://issues.apache.org/jira/browse/FLINK-4259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-4259. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 5d7e949. > Unclosed FSDataOutputStr

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401814#comment-15401814 ] Lorenz Bühmann commented on FLINK-2662: --- I do have the same problem: Exceptio

[jira] [Updated] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josep Rubió updated FLINK-1707: --- Description: This issue proposes adding the an implementation of the Affinity Propagation algorithm

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406651#comment-15406651 ] Josep Rubió commented on FLINK-1707: Hi all, Sorry for my late response but I

[jira] [Assigned] (FLINK-3026) Publish the flink docker container to the docker registry

[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned FLINK-3026: --- Assignee: Ismaël Mejía > Publish the flink docker container to the docker regis

[jira] [Commented] (FLINK-3026) Publish the flink docker container to the docker registry

[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410906#comment-15410906 ] Ismaël Mejía commented on FLINK-3026: - I assign myself this issue following

[jira] [Updated] (FLINK-3155) Update Flink docker version to latest stable Flink version

[ https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-3155: Affects Version/s: 1.1.0 > Update Flink docker version to latest stable Flink vers

[jira] [Updated] (FLINK-3155) Update Flink docker version to latest stable Flink version

[ https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-3155: Fix Version/s: 1.2.0 > Update Flink docker version to latest stable Flink vers

[jira] [Updated] (FLINK-3155) Update Flink docker version to latest stable Flink version

[ https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-3155: Fix Version/s: (was: 1.2.0) > Update Flink docker version to latest stable Flink vers

[jira] [Updated] (FLINK-3155) Update Flink docker version to latest stable Flink version

[ https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-3155: Priority: Minor (was: Major) > Update Flink docker version to latest stable Flink vers

[jira] [Created] (FLINK-4327) Error in link to downlad version for hadoop 2.7 and scala 2.11

Ismaël Mejía created FLINK-4327: --- Summary: Error in link to downlad version for hadoop 2.7 and scala 2.11 Key: FLINK-4327 URL: https://issues.apache.org/jira/browse/FLINK-4327 Project: Flink

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411605#comment-15411605 ] Ismaël Mejía commented on FLINK-4326: - For ref this is the commit of my prop

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15413252#comment-15413252 ] Ismaël Mejía commented on FLINK-4326: - Well it is good to know that there is inte

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15414182#comment-15414182 ] Ismaël Mejía commented on FLINK-4326: - Well that's the question I was

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417255#comment-15417255 ] Ismaël Mejía commented on FLINK-4326: - A separation of (daemon/console) scripts w

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961748#comment-15961748 ] Markus Müller commented on FLINK-4319: -- For a reference implementation on Blu

[jira] [Created] (FLINK-6317) History server - wrong default directory

Lorenz Bühmann created FLINK-6317: - Summary: History server - wrong default directory Key: FLINK-6317 URL: https://issues.apache.org/jira/browse/FLINK-6317 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-6317) History server - wrong default directory

[ https://issues.apache.org/jira/browse/FLINK-6317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenz Bühmann updated FLINK-6317: -- Description: When the history server is started without a directory specified in the

[jira] [Commented] (FLINK-2147) Approximate calculation of frequencies in data streams

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15981414#comment-15981414 ] Gábor Hermann commented on FLINK-2147: -- I would prefer emitting updates on a wi

[jira] [Commented] (FLINK-5753) CEP timeout handler.

[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007743#comment-16007743 ] Michał Jurkiewicz commented on FLINK-5753: -- [~kkl0u], My job is operatin

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15522303#comment-15522303 ] 刘喆 commented on FLINK-4632: --- I tried the lastest github version, the problem is still t

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528781#comment-15528781 ] 刘喆 commented on FLINK-4632: --- I can't reproduce it now. I only save the TaskManager&#x

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528833#comment-15528833 ] 刘喆 commented on FLINK-4632: --- I think it is related to checkpoint. When I use checkpoint

[jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528833#comment-15528833 ] 刘喆 edited comment on FLINK-4632 at 9/28/16 8:13 AM: I think i

[jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528833#comment-15528833 ] 刘喆 edited comment on FLINK-4632 at 9/28/16 8:25 AM: I think i

[jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528833#comment-15528833 ] 刘喆 edited comment on FLINK-4632 at 9/28/16 11:00 AM: - I think i

[jira] [Created] (FLINK-4706) Is there a way to load user classes first?

刘喆 created FLINK-4706: - Summary: Is there a way to load user classes first? Key: FLINK-4706 URL: https://issues.apache.org/jira/browse/FLINK-4706 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4712) Implementing ranking predictions for ALS

Domokos Miklós Kelen created FLINK-4712: --- Summary: Implementing ranking predictions for ALS Key: FLINK-4712 URL: https://issues.apache.org/jira/browse/FLINK-4712 Project: Flink Issue

[jira] [Updated] (FLINK-4712) Implementing ranking predictions for ALS

[ https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Domokos Miklós Kelen updated FLINK-4712: Description: We started working on implementing ranking predictions for recommender

  1   2   3   4   5   6   7   8   9   10   >