Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id E27EA200CA6 for ; Tue, 13 Jun 2017 17:18:37 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id E0BA7160BDC; Tue, 13 Jun 2017 15:18:37 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 0BAB2160BC9 for ; Tue, 13 Jun 2017 17:18:36 +0200 (CEST) Received: (qmail 60360 invoked by uid 500); 13 Jun 2017 15:18:36 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 60350 invoked by uid 99); 13 Jun 2017 15:18:36 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 13 Jun 2017 15:18:36 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id A3AF41A0447 for ; Tue, 13 Jun 2017 15:18:35 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.379 X-Spam-Level: ** X-Spam-Status: No, score=2.379 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id QmNpoBafWX_J for ; Tue, 13 Jun 2017 15:18:32 +0000 (UTC) Received: from mail-qt0-f172.google.com (mail-qt0-f172.google.com [209.85.216.172]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 4A00660F9A for ; Tue, 13 Jun 2017 15:14:57 +0000 (UTC) Received: by mail-qt0-f172.google.com with SMTP id w1so175262513qtg.2 for ; Tue, 13 Jun 2017 08:14:57 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:references:in-reply-to:from:date:message-id:subject:to :cc; bh=lDPWwxb0I7FhKkE2o2sjHApvH7gg3EJ7M6v43+hBd0g=; b=qIBXo/SAugw1HdAOmQ1lOWG6Kx+cLLbocyMhgoPKR18GdXTw6YuexvQIvCvGXQJNUH 1zLKiVUNJ4Bs7jLaB6nJVFxfXaBEWefkO70Fh+XDSjbi5tcNwPyMyGSriZpSJI7LODfR 07+yF4yFWyqC5F6d7WU5PHL6wPqdeYMLk+4/sDAyCIfr0psBNlWBjrXfruwKk0U/61MO tVfDJlvFrPmA9fsKKbG7Ko1HR0VZvx3gfVnAclWd76qeZwEejR0EqsHciZOEHIgYp7RE p7metgxVfO/IUc/8K1J+8AalmJabGiQYWCbO2ARMonsmpOs/RpDAAWIACFYpPMq+8rm7 RRTg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:references:in-reply-to:from:date :message-id:subject:to:cc; bh=lDPWwxb0I7FhKkE2o2sjHApvH7gg3EJ7M6v43+hBd0g=; b=WWwTZx1TebetQv8HhUqFL0shJgBGI+tYQHsHp+OUZd8Dus6l67R/ibpt8I7LLYSJPJ Y0g54WcB6tQD5L0paXRHYYa7xcB7MwuKXUnobueplW0sjyyW19HkXmBdI/IFm7lXCmdW l73iRRDRHznz2TcPER/j9Do7SSO8FdVMjrlhHC0F51SkCx6eCbpqpbhfzkQ5d6nSlNwI klQkt/fPY7ET66S9G2biazJSN7ASz2/DpDCh6dg7USd59IfDvnF1J8lHBKIt1pZD7qKw g6K/iC1dy3rcXXECHcyawiG186afngZvDTeChD16nq9GEwKpl/wuLrJ/DyG/5Vy7P1Zi inTw== X-Gm-Message-State: AKS2vOxSZg7MX/u6GiGP8GW95asphrrJQXxZ7ig1AAPS+8v+ng9HYPJj VZIvolb7yfbqFzDwuVkQzct7E5PS0w== X-Received: by 10.200.44.36 with SMTP id d33mr531475qta.182.1497366895899; Tue, 13 Jun 2017 08:14:55 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: Michael Reid Date: Tue, 13 Jun 2017 15:14:45 +0000 Message-ID: Subject: Re: Flink 1.3 REST API wrapper for Scala To: Flavio Pompermaier Cc: user Content-Type: multipart/alternative; boundary="001a1140298cedb8320551d8e595" archived-at: Tue, 13 Jun 2017 15:18:38 -0000 --001a1140298cedb8320551d8e595 Content-Type: text/plain; charset="UTF-8" Thanks! Yes, it's available now on Maven Central - https://search.maven.org/#search%7Cga%7C1%7Ca%3A%22flink-wrapper_2.11%22 The README on Github has directions on how to add the project via SBT. - Mike On Mon, Jun 12, 2017 at 9:45 PM Flavio Pompermaier wrote: > Nice lib! Is it available also on maven central? > > On 13 Jun 2017 4:36 am, "Michael Reid" wrote: > >> I'm currently working on a project where I need to manage jobs >> programmatically without being tied to Flink, so I wrote a small, >> asynchronous Scala wrapper around the Flink REST API. I decided to open >> source the project in case anyone else needs something similar. Source is >> at https://github.com/mjreid/flink-rest-scala-wrapper , library is >> available on maven central at com.github.mjreid:flink-wrapper_2.11:0.0.1. >> >> Currently it supports basic job management functionality (uploading JARs, >> starting jobs, cancelling jobs) and a few of the job monitoring REST >> endpoints. There are a few monitoring endpoints which I didn't need for my >> use case, so they aren't implemented right now, but I would be happy to >> implement them if there's any interest. Any comments and/or feedback is >> appreciated! >> >> Thanks, >> >> - Mike >> > --001a1140298cedb8320551d8e595 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Thanks! Yes, it's available now on Maven Central -=C2= =A0https://search.maven.org/#search%7Cga%7C1%7Ca%3A%22flink-wrapp= er_2.11%22=C2=A0The README on Github has directions on how to add the p= roject via SBT.

- Mike

On Mon, Jun 12, 2017 at 9:45 PM Flavio Pompermaie= r <pompermaier@okkam.it> = wrote:
Nice lib! = Is it available also on maven central?

=
On 13 Jun 2017 4:36 am, "Michael Reid"= <reidmi= chaeljames@gmail.com> wrote:
I'm currently working on a project where I need to manage jobs= programmatically without being tied to Flink, so I wrote a small, asynchro= nous Scala wrapper around the Flink REST API. I decided to open source the = project in case anyone else needs something similar. Source is at=C2=A0https://github.com/mjreid/flink-rest-scal= a-wrapper=C2=A0, lib= rary is available on maven central at com.github.mjreid:flink-wrapper_2.11:0.0.1.
Currently it supports basic job management f= unctionality (uploading JARs, starting jobs, cancelling jobs) and a few of = the job monitoring REST endpoints. There are a few monitoring endpoints whi= ch I didn't need for my use case, so they aren't implemented right = now, but I would be happy to implement them if there's any interest. An= y comments and/or feedback is appreciated!

Thanks,

=
- Mike
--001a1140298cedb8320551d8e595--