[jira] [Created] (FLINK-4713) Implementing ranking evaluation scores for recommender systems

2016-09-29 Thread JIRA
Domokos Miklós Kelen created FLINK-4713: --- Summary: Implementing ranking evaluation scores for recommender systems Key: FLINK-4713 URL: https://issues.apache.org/jira/browse/FLINK-4713 Project

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

2016-09-29 Thread JIRA
[ 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

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

2016-09-29 Thread JIRA
[ 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

[jira] [Updated] (FLINK-3204) TaskManagers are not shutting down properly on YARN

2016-10-03 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-3204: -- Assignee: Nikolay Vasilishin > TaskManagers are not shutting down properly on Y

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

2016-10-18 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585097#comment-15585097 ] Gábor Hermann commented on FLINK-1807: -- Hi all, I have a workaround in mind f

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

2016-10-18 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585716#comment-15585716 ] Gábor Hermann commented on FLINK-1807: -- Thanks for your reply! Then,

[jira] [Commented] (FLINK-3902) Discarded FileSystem checkpoints are lingering around

2016-10-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591808#comment-15591808 ] Jan Zajíc commented on FLINK-3902: -- WE have same issue on Linux in docker, but *

[jira] [Comment Edited] (FLINK-3902) Discarded FileSystem checkpoints are lingering around

2016-10-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591808#comment-15591808 ] Jan Zajíc edited comment on FLINK-3902 at 10/20/16 1:2

[jira] [Comment Edited] (FLINK-3902) Discarded FileSystem checkpoints are lingering around

2016-10-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591808#comment-15591808 ] Jan Zajíc edited comment on FLINK-3902 at 10/20/16 1:2

[jira] [Created] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN

2016-10-27 Thread JIRA
Mischa Krüger created FLINK-4943: Summary: flink-mesos/ConfigConstants: Typo: YYARN -> YARN Key: FLINK-4943 URL: https://issues.apache.org/jira/browse/FLINK-4943 Project: Flink Issue T

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

2016-10-28 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-4712: Assignee: Gábor Hermann > Implementing ranking predictions for

[jira] [Assigned] (FLINK-4713) Implementing ranking evaluation scores for recommender systems

2016-10-28 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-4713: Assignee: Gábor Hermann > Implementing ranking evaluation scores for recommender syst

[jira] [Created] (FLINK-4961) SGD for Matrix Factorization

2016-10-28 Thread JIRA
Gábor Hermann created FLINK-4961: Summary: SGD for Matrix Factorization Key: FLINK-4961 URL: https://issues.apache.org/jira/browse/FLINK-4961 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-4961) SGD for Matrix Factorization

2016-10-28 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann updated FLINK-4961: - Description: We have started an implementation of distributed stochastic gradient descent for

[jira] [Created] (FLINK-4979) Submit Job view: Replace checkboxes for job entry with a link on the job name

2016-10-31 Thread JIRA
Mischa Krüger created FLINK-4979: Summary: Submit Job view: Replace checkboxes for job entry with a link on the job name Key: FLINK-4979 URL: https://issues.apache.org/jira/browse/FLINK-4979 Project

[jira] [Created] (FLINK-4978) Present dropdown list with possible entry points for job

2016-10-31 Thread JIRA
Mischa Krüger created FLINK-4978: Summary: Present dropdown list with possible entry points for job Key: FLINK-4978 URL: https://issues.apache.org/jira/browse/FLINK-4978 Project: Flink Issue

[jira] [Created] (FLINK-4981) Job Plan view: Not very readable and informative

2016-10-31 Thread JIRA
Mischa Krüger created FLINK-4981: Summary: Job Plan view: Not very readable and informative Key: FLINK-4981 URL: https://issues.apache.org/jira/browse/FLINK-4981 Project: Flink Issue Type

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

2016-10-31 Thread JIRA
Mischa Krüger created FLINK-4982: Summary: quickstart example: Can't see the output Key: FLINK-4982 URL: https://issues.apache.org/jira/browse/FLINK-4982 Project: Flink Issue Type

[jira] [Created] (FLINK-4983) Web UI: Add favicon

2016-10-31 Thread JIRA
Mischa Krüger created FLINK-4983: Summary: Web UI: Add favicon Key: FLINK-4983 URL: https://issues.apache.org/jira/browse/FLINK-4983 Project: Flink Issue Type: Improvement

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

2016-11-01 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15625611#comment-15625611 ] Mischa Krüger commented on FLINK-4982: -- I only have a single task manager, and

[jira] [Created] (FLINK-4989) Completed job -> Properties: Misleading label

2016-11-01 Thread JIRA
Mischa Krüger created FLINK-4989: Summary: Completed job -> Properties: Misleading label Key: FLINK-4989 URL: https://issues.apache.org/jira/browse/FLINK-4989 Project: Flink Issue T

[jira] [Commented] (FLINK-4713) Implementing ranking evaluation scores for recommender systems

2016-11-02 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15629109#comment-15629109 ] Gábor Hermann commented on FLINK-4713: -- We have managed to rework the evalua

[jira] [Commented] (FLINK-5755) Flink with Kafka connection

2017-02-09 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859565#comment-15859565 ] Fábio Dias commented on FLINK-5755: --- Thanks for the reply. I follow your advice.

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

2017-03-06 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897030#comment-15897030 ] Ismaël Mejía commented on FLINK-3026: - [~jgrier] I have been following the prog

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

2017-03-06 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897030#comment-15897030 ] Ismaël Mejía edited comment on FLINK-3026 at 3/6/17 10:1

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

2017-03-06 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897040#comment-15897040 ] Ismaël Mejía commented on FLINK-3026: - There are other pending issues if we go wi

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

2017-03-06 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897040#comment-15897040 ] Ismaël Mejía edited comment on FLINK-3026 at 3/6/17 10:3

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

2017-03-06 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897066#comment-15897066 ] Ismaël Mejía commented on FLINK-3026: - Other thing that we have to decide afterw

[jira] [Created] (FLINK-6003) Change docker image to be based on the openjdk one (debian+alpine)

2017-03-08 Thread JIRA
Ismaël Mejía created FLINK-6003: --- Summary: Change docker image to be based on the openjdk one (debian+alpine) Key: FLINK-6003 URL: https://issues.apache.org/jira/browse/FLINK-6003 Project: Flink

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

2017-03-08 Thread JIRA
[ 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: Patrick Lucas (was: Ismaël Mejía) I am reassigning this to you after the

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

2017-03-08 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15902136#comment-15902136 ] Ismaël Mejía edited comment on FLINK-3026 at 3/8/17 10:5

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

2017-03-09 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-6003: Summary: Add docker image based on the openjdk one (debian+alpine) (was: Change docker image to be

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

2017-03-09 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903128#comment-15903128 ] Ismaël Mejía commented on FLINK-3026: - I wonder still how could we address the i

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

2017-03-09 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903127#comment-15903127 ] Ismaël Mejía commented on FLINK-3026: - I suppose most projects do this to a

[jira] [Created] (FLINK-5378) Update Scopt version to 3.5.0

2016-12-21 Thread JIRA
Lorenz Bühmann created FLINK-5378: - Summary: Update Scopt version to 3.5.0 Key: FLINK-5378 URL: https://issues.apache.org/jira/browse/FLINK-5378 Project: Flink Issue Type: Wish Affects

[jira] [Updated] (FLINK-5378) Update Scopt version to 3.5.0

2016-12-21 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenz Bühmann updated FLINK-5378: -- Description: Is it possible to increase the Scopt version to 3.5.0? This version does also

[jira] [Created] (FLINK-5392) flink-dist build failed when change scala version to 2.11

2016-12-25 Thread JIRA
刘喆 created FLINK-5392: - Summary: flink-dist build failed when change scala version to 2.11 Key: FLINK-5392 URL: https://issues.apache.org/jira/browse/FLINK-5392 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5392) flink-dist build failed when change scala version to 2.11

2016-12-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15777399#comment-15777399 ] 刘喆 commented on FLINK-5392: --- I do a pull request: https://github.com/apache/flink/pull/

[jira] [Issue Comment Deleted] (FLINK-5392) flink-dist build failed when change scala version to 2.11

2016-12-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 刘喆 updated FLINK-5392: -- Comment: was deleted (was: I do a pull request: https://github.com/apache/flink/pull/3043) > flink-dist build fai

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

2017-01-06 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mischa Krüger closed FLINK-4982. Resolution: Fixed > quickstart example: Can't see th

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

2017-01-06 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804411#comment-15804411 ] Mischa Krüger commented on FLINK-4982: -- Solved, I retried with the examples from

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

2017-01-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15829719#comment-15829719 ] Josep Rubió commented on FLINK-1707: Closed :) > Add an Affinity Propagation

[jira] [Commented] (FLINK-4719) KryoSerializer random exception

2017-01-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15831458#comment-15831458 ] Marc Hübner commented on FLINK-4719: I get a similar exception, when spilling to

[jira] [Comment Edited] (FLINK-4719) KryoSerializer random exception

2017-01-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15831458#comment-15831458 ] Marc Hübner edited comment on FLINK-4719 at 1/20/17 10:4

[jira] (FLINK-3606) Expose Configuration from RichFunctions

2017-01-30 Thread JIRA
message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)

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

2017-02-07 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15856104#comment-15856104 ] Ismaël Mejía commented on FLINK-4326: - [~StephanEwen] Sorry for the late answe

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

2017-02-07 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15856113#comment-15856113 ] Ismaël Mejía commented on FLINK-4326: - Just for reference of the origin of

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

2017-02-09 Thread JIRA
Michał Jurkiewicz created FLINK-5753: Summary: CEP timeout handler. Key: FLINK-5753 URL: https://issues.apache.org/jira/browse/FLINK-5753 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5755) Flink with Kafka connection

2017-02-09 Thread JIRA
Fábio Dias created FLINK-5755: - Summary: Flink with Kafka connection Key: FLINK-5755 URL: https://issues.apache.org/jira/browse/FLINK-5755 Project: Flink Issue Type: Bug Components

[jira] [Commented] (FLINK-5405) Add streaming connection to twitter through a internet proxy

2018-10-10 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645016#comment-16645016 ] Luis Angel Hernández Acosta commented on FLINK-5405: Yes. pl

[jira] [Commented] (FLINK-5405) Add streaming connection to twitter through a internet proxy

2018-10-10 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645018#comment-16645018 ] Luis Angel Hernández Acosta commented on FLINK-5405: Or, n

[jira] [Created] (FLINK-10660) Failed index data to Elastic search using Flink-connector-elasticsearch with JUNIT test

2018-10-23 Thread JIRA
孙达 created FLINK-10660: -- Summary: Failed index data to Elastic search using Flink-connector-elasticsearch with JUNIT test Key: FLINK-10660 URL: https://issues.apache.org/jira/browse/FLINK-10660 Project: Flink

[jira] [Created] (FLINK-11030) Cannot use Avro logical types with ConfluentRegistryAvroDeserializationSchema

2018-11-29 Thread JIRA
Maciej Bryński created FLINK-11030: -- Summary: Cannot use Avro logical types with ConfluentRegistryAvroDeserializationSchema Key: FLINK-11030 URL: https://issues.apache.org/jira/browse/FLINK-11030

[jira] [Updated] (FLINK-11030) Cannot use Avro logical types with ConfluentRegistryAvroDeserializationSchema

2018-11-29 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-11030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-11030: --- Description: I created Specific class for Kafka topic. Avro schema includes logicalTypes

[jira] [Commented] (FLINK-11076) Processing for Avro generated classes is very slow

2018-12-05 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-11076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709850#comment-16709850 ] Maciej Bryński commented on FLINK-11076: In my workload removing &quo

[jira] [Created] (FLINK-11076) Processing for Avro generated classes is very slow

2018-12-05 Thread JIRA
Maciej Bryński created FLINK-11076: -- Summary: Processing for Avro generated classes is very slow Key: FLINK-11076 URL: https://issues.apache.org/jira/browse/FLINK-11076 Project: Flink Issue

[jira] [Comment Edited] (FLINK-11076) Processing for Avro generated classes is very slow

2018-12-05 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-11076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709850#comment-16709850 ] Maciej Bryński edited comment on FLINK-11076 at 12/5/18 10:0

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

2017-05-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010121#comment-16010121 ] Michał Jurkiewicz commented on FLINK-5753: -- Hi [~kkl0u], Here is what I

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

2017-05-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16018367#comment-16018367 ] Michał Jurkiewicz commented on FLINK-5753: -- Hi [~kkl0u], Regarding the i

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

2017-05-23 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020954#comment-16020954 ] Michał Jurkiewicz commented on FLINK-5753: -- I

[jira] [Created] (FLINK-10319) Avoid requestPartitionState from JM but always try retrigger

2018-09-11 Thread JIRA
陈梓立 created FLINK-10319: --- Summary: Avoid requestPartitionState from JM but always try retrigger Key: FLINK-10319 URL: https://issues.apache.org/jira/browse/FLINK-10319 Project: Flink Issue Type

[jira] [Created] (FLINK-10320) Introduce JobMaster schedule micro-benchmark

2018-09-11 Thread JIRA
陈梓立 created FLINK-10320: --- Summary: Introduce JobMaster schedule micro-benchmark Key: FLINK-10320 URL: https://issues.apache.org/jira/browse/FLINK-10320 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-10322) Unused instance variable MetricRegistry in ResourceManager

2018-09-12 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611699#comment-16611699 ] 陈梓立 commented on FLINK-10322: - Maybe we could expand {{MetricRegistry}} so that get met

[jira] [Comment Edited] (FLINK-10322) Unused instance variable MetricRegistry in ResourceManager

2018-09-12 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611699#comment-16611699 ] 陈梓立 edited comment on FLINK-10322 at 9/12/18 7:30 AM: -- Mayb

[jira] [Updated] (FLINK-10319) Too many requestPartitionState would crash JM

2018-09-12 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10319: Summary: Too many requestPartitionState would crash JM (was: Avoid requestPartitionState from JM but always try

[jira] [Commented] (FLINK-10320) Introduce JobMaster schedule micro-benchmark

2018-09-12 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16612408#comment-16612408 ] 陈梓立 commented on FLINK-10320: - [~pnowojski] thanks for your quick reply! Seems lik

[jira] [Commented] (FLINK-10320) Introduce JobMaster schedule micro-benchmark

2018-09-13 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16613148#comment-16613148 ] 陈梓立 commented on FLINK-10320: - Taking another reconsideration, what it comes to schedu

[jira] [Assigned] (FLINK-10275) StreamTask support object reuse

2018-09-13 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 reassigned FLINK-10275: --- Assignee: (was: 陈梓立) > StreamTask support object re

[jira] [Updated] (FLINK-10275) StreamTask support object reuse

2018-09-13 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10275: Description: StreamTask support efficient object reuse. The purpose behind this is to reduce pressure on the

[jira] [Commented] (FLINK-10240) Pluggable scheduling strategy for batch job

2018-09-13 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16614335#comment-16614335 ] 陈梓立 commented on FLINK-10240: - Introduce pluggable schedule strategy is an excellent

[jira] [Commented] (FLINK-10302) Mark legacy(non-flip 6) code as Deprecated

2018-09-14 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16615193#comment-16615193 ] 陈梓立 commented on FLINK-10302: - Does it mean Flink 1.7.0 contains the REMOVAL of legacy

[jira] [Commented] (FLINK-10256) Port legacy jobmanager test to FILP-6

2018-09-14 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16615610#comment-16615610 ] 陈梓立 commented on FLINK-10256: - Thanks [~till.rohrmann]! It works for me. However, may

[jira] [Comment Edited] (FLINK-10256) Port legacy jobmanager test to FILP-6

2018-09-14 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16615610#comment-16615610 ] 陈梓立 edited comment on FLINK-10256 at 9/15/18 5:53 AM: -- Th

[jira] [Created] (FLINK-10349) Unify stopActor* utils

2018-09-15 Thread JIRA
陈梓立 created FLINK-10349: --- Summary: Unify stopActor* utils Key: FLINK-10349 URL: https://issues.apache.org/jira/browse/FLINK-10349 Project: Flink Issue Type: Improvement Components: Core

[jira] [Updated] (FLINK-10349) Unify stopActor utils

2018-09-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10349: Summary: Unify stopActor utils (was: Unify stopActor* utils) > Unify stopActor ut

[jira] [Resolved] (FLINK-10349) Unify stopActor utils

2018-09-18 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 resolved FLINK-10349. - Resolution: Won't Do close since it's nearly all about legacy code. > Unify st

[jira] [Updated] (FLINK-10349) Unify stopActor utils

2018-09-18 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10349: Description: close since it is nearly all about legacy code > Unify stopActor ut

[jira] [Commented] (FLINK-10320) Introduce JobMaster schedule micro-benchmark

2018-09-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16620511#comment-16620511 ] 陈梓立 commented on FLINK-10320: - We have some cases when our customers set parallelis

[jira] [Assigned] (FLINK-10376) BlobCacheCleanupTest.testPermanentBlobCleanup failed on Travis

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 reassigned FLINK-10376: --- Assignee: 陈梓立 > BlobCacheCleanupTest.testPermanentBlobCleanup failed on Tra

[jira] [Commented] (FLINK-10376) BlobCacheCleanupTest.testPermanentBlobCleanup failed on Travis

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16622029#comment-16622029 ] 陈梓立 commented on FLINK-10376: - Highly suspect this is caused by a thread unsafe me

[jira] [Comment Edited] (FLINK-10376) BlobCacheCleanupTest.testPermanentBlobCleanup failed on Travis

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16622029#comment-16622029 ] 陈梓立 edited comment on FLINK-10376 at 9/20/18 1:23 PM: -- Hi

[jira] [Created] (FLINK-10378) Hide/Comment out contribute guide from PULL_REQUEST_TEMPLATE

2018-09-20 Thread JIRA
陈梓立 created FLINK-10378: --- Summary: Hide/Comment out contribute guide from PULL_REQUEST_TEMPLATE Key: FLINK-10378 URL: https://issues.apache.org/jira/browse/FLINK-10378 Project: Flink Issue Type

[jira] [Updated] (FLINK-10302) Mark legacy(non-flip 6) code as Deprecated

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10302: Priority: Minor (was: Major) > Mark legacy(non-flip 6) code as Depreca

[jira] [Commented] (FLINK-10302) Mark legacy(non-flip 6) code as Deprecated

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16622966#comment-16622966 ] 陈梓立 commented on FLINK-10302: - So we need not to add such annotations since they

[jira] [Closed] (FLINK-10302) Mark legacy(non-flip 6) code as Deprecated

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 closed FLINK-10302. --- Resolution: Won't Do > Mark legacy(non-flip 6) code as De

[jira] [Created] (FLINK-10385) Implement a waitUntilCondition utils

2018-09-20 Thread JIRA
陈梓立 created FLINK-10385: --- Summary: Implement a waitUntilCondition utils Key: FLINK-10385 URL: https://issues.apache.org/jira/browse/FLINK-10385 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-10385) Implement a waitUntilCondition utils

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10385: Attachment: example.java > Implement a waitUntilCondition ut

[jira] [Updated] (FLINK-10385) Implement a waitUntilCondition utils

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10385: Description: Recently when I refine some tests, I notice that it is a common requirement to wait until a (stable

[jira] [Created] (FLINK-10386) Remove legacy class TaskExecutionStateListener

2018-09-20 Thread JIRA
陈梓立 created FLINK-10386: --- Summary: Remove legacy class TaskExecutionStateListener Key: FLINK-10386 URL: https://issues.apache.org/jira/browse/FLINK-10386 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-10385) Implement a waitUntilCondition utils

2018-09-21 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16623196#comment-16623196 ] 陈梓立 commented on FLINK-10385: - Maybe a waiting utils based on {{sleep}} and test would

[jira] [Comment Edited] (FLINK-10385) Implement a waitUntilCondition utils

2018-09-21 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16623196#comment-16623196 ] 陈梓立 edited comment on FLINK-10385 at 9/21/18 7:36 AM: -- May

[jira] [Commented] (FLINK-10315) Let JDBCAppendTableSink be built with java.sql.Connection

2018-09-24 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16625611#comment-16625611 ] François Lacombe commented on FLINK-10315: -- HI [~yanghua], thank you for

[jira] [Created] (FLINK-10424) Inconsistency between JsonSchemaConveerter and FlinkTypeFactory

2018-09-25 Thread JIRA
Dominik Wosiński created FLINK-10424: Summary: Inconsistency between JsonSchemaConveerter and FlinkTypeFactory Key: FLINK-10424 URL: https://issues.apache.org/jira/browse/FLINK-10424 Project

[jira] [Updated] (FLINK-10424) Inconsistency between JsonSchemaConveerter and FlinkTypeFactory

2018-09-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dominik Wosiński updated FLINK-10424: - Description: There is still an inconsistency between _JsonSchemaConverter_ and

[jira] [Commented] (FLINK-10424) Inconsistency between JsonSchemaConveerter and FlinkTypeFactory

2018-09-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16627440#comment-16627440 ] Dominik Wosiński commented on FLINK-10424: -- Two possible ways of solving

[jira] [Created] (FLINK-10479) Add Firebase Firestore Connector

2018-10-02 Thread JIRA
Niklas Gögge created FLINK-10479: Summary: Add Firebase Firestore Connector Key: FLINK-10479 URL: https://issues.apache.org/jira/browse/FLINK-10479 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-10480) Add Firebase Firestore Connector

2018-10-02 Thread JIRA
Niklas Gögge created FLINK-10480: Summary: Add Firebase Firestore Connector Key: FLINK-10480 URL: https://issues.apache.org/jira/browse/FLINK-10480 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-10480) Add Firebase Firestore Connector

2018-10-02 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Niklas Gögge closed FLINK-10480. Resolution: Duplicate > Add Firebase Firestore Connec

[jira] [Created] (FLINK-10486) Recover local mode on flink startup

2018-10-03 Thread JIRA
Ismaël Mejía created FLINK-10486: Summary: Recover local mode on flink startup Key: FLINK-10486 URL: https://issues.apache.org/jira/browse/FLINK-10486 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5405) Add streaming connection to twitter through a internet proxy

2018-10-05 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16640016#comment-16640016 ] Luis Angel Hernández Acosta commented on FLINK-5405: Can you be

<    1   2   3   4   5   6   7   8   9   10   >