Re: [DISCUSS] Adding streaming connectors from Apache Flink to Bahir

Having Flink connectors in the same repo seems to make more sense at the moment. Certain artifacts can be shared between the two types of connectors. Flink seems to have more frequent releases recently. But Bahir doesn't have to follow each Flink patch release. Just my two cents. On Thu, Aug

Re: [VOTE] Apache Bahir 2.0.0 (RC1)

+1 Built from source. Checked license. Ran unit test suite which passed. On Sat, Aug 6, 2016 at 3:11 AM, Luciano Resende wrote: > Please vote to approve the release of the following candidate as Apache > Bahir version 2.0.0 based on Apache Spark 2.0.0. > > The tag to be

Re: Release 2.1.0

+1 On Fri, Feb 3, 2017 at 8:48 AM, Luciano Resende wrote: > Now that we are done with the Bahir release to support Spark 2.0.2, should > we move to the new release supporting 2.1.0 ? > > -- > Luciano Resende > http://twitter.com/lresende1975 > http://lresende.blogspot.com/

Re: [VOTE] Apache Bahir 2.1.0 (RC1)

+1 Checked signature. Ran test suite which passed: [INFO] Apache Bahir - Spark SQL Streaming MQTT SUCCESS [ 46.165 s] [INFO] Apache Bahir - Spark Streaming Twitter . SUCCESS [ 25.158 s] [INFO] Apache Bahir - Spark Streaming ZeroMQ .. SUCCESS [ 21.848 s]

Re: [VOTE] Apache Bahir 2.0.2 (RC3)

Looks like the vote passed. When would the artifacts be ready in maven ? Thanks > On Jan 23, 2017, at 12:56 PM, Christian Kadner wrote: > > Of course, my own (unbinding) vote: > > +1 > > Thanks, > Christian > >> On 01/21/2017 03:31 AM, Christian Kadner wrote: >> Please

Re: [ANNOUNCE] Apache Bahir 2.1.0 Released

When would the Maven artifacts be available ? Thanks > On Feb 22, 2017, at 4:07 AM, Christian Kadner wrote: > > The Apache Bahir community is pleased to announce the release > of Apache Bahir 2.1.0 which provides the following extensions for > Apache Spark 2.1.0: > > -

Re: [ANNOUNCE] Apache Bahir 2.1.0 Released

Flink connectors are maintained in the following repo: https://github.com/apache/bahir-flink/ On Wed, Feb 22, 2017 at 6:12 PM, sebb AT ASF wrote: > On 22 February 2017 at 23:36, Christian Kadner wrote: > > Hi Sebastian, > > > > thanks for your feedback. We

Re: How to deal with sporadically failing test cases in sql-streaming-mqtt BasicMQTTSourceSuite

I think marking these two tests as ignored is fine. Cheers > On Jan 16, 2017, at 9:52 PM, Christian Kadner wrote: > > The latest two votes for an Apache Bahir 2.0.2 release candidate have > been side-tracked by failing test cases in sql-streaming-mqtt >

Re: [DISCUSS] Bahir-flink versioning and releasing

Fine by me. bq. HBase streaming connector incoming I will review it. Thanks On Thu, Aug 25, 2016 at 5:31 AM, Robert Metzger wrote: > Hi, > > I was wondering how we want to version the modules in the "bahir-flink" > repository. > > I would actually like to do the versions

Re: Next Releases

+1 > On Sep 26, 2016, at 11:33 AM, Jean-Baptiste Onofré wrote: > > +1 > > Regards > JB > >> On 09/26/2016 08:32 PM, Luciano Resende wrote: >> Looks like Spark is working on 2.0.1 release (RC3 being voted now), and I >> was wondering if we should use this opportunity to

Re: [ANNOUNCE] New Apache Bahir Committer : Robert Metzger

Congratulations, Robert On Wed, Oct 19, 2016 at 2:54 PM, Luciano Resende wrote: > The Project Management Committee (PMC) for Apache Bahirhas invited > Robert Metzger to become a committer and we are pleased to announce > that he has accepted. > > Robert has been a key

Re: Next Releases

Spark 2.0.1 is in maven: https://repo1.maven.org/maven2/org/apache/spark/spark-core_2.11/2.0.1/ Time to roll Bahir for Spark 2.0.1 release ? On Mon, Sep 26, 2016 at 11:48 AM, Ted Yu <yuzhih...@gmail.com> wrote: > +1 > > > On Sep 26, 2016, at 11:33 AM, Jean-Baptiste Onofré

Re: [VOTE] Apache Bahir 2.0.2 (RC1)

Is it a proper time to start preparing the next RC ? Cheers On Sat, Dec 3, 2016 at 10:08 AM, Luciano Resende wrote: > Please vote to approve the release of the following candidate as Apache > Bahir version 2.0.2 based on Apache Spark 2.0.2. > > The difference between

Re: [VOTE] Apache Bahir 2.0.2 (RC1)

give it a second attempt. > > Best regards, > Christian Kadner > > [image: Inactive hide details for Ted Yu ---01/10/2017 08:58:06 AM---Is it > a proper time to start preparing the next RC ? Cheers]Ted Yu > ---01/10/2017 08:58:06 AM---Is it a proper time to start preparing th

Re: [VOTE] Apache Bahir 2.0.2 (RC2)

That's one way of making the test stable. On Wed, Jan 11, 2017 at 10:27 AM, Christian R Kadner wrote: > Yup, this is a noisy test suite. Are you advocating to limit the log > output? > > >

Re: [VOTE] Apache Bahir 2.0.2 (RC2)

A few more rounds of running the test (based on suggestion from Christian) but it didn't pass. I think this is not a blocker for release since other people cannot reproduce it. On Thu, Jan 12, 2017 at 1:55 AM, Ted Yu <yuzhih...@gmail.com> wrote: > Running with PR #33, I got: > &g

Re: [VOTE] Apache Bahir 2.0.2 (RC2)

d line: mvn package On Thu, Jan 12, 2017 at 1:43 AM, Christian R Kadner <ckad...@us.ibm.com> wrote: > Hi Ted, > > your pastebin (http://pastebin.com/xRJaCa6H) shows that test case "Send > and receive 100 messages" failed. Could this be an intermittent problem? >

Re: [VOTE] Apache Bahir 2.0.2 (RC2)

ran test suite and saw: http://pastebin.com/xRJaCa6H On Wed, Jan 11, 2017 at 3:33 AM, Christian Kadner wrote: > Please vote to approve the second release candidate for Apache Bahir > version 2.0.2 based on Apache Spark 2.0.2. > > The difference between 2.0.1 and 2.0.2 RC2

Re: [VOTE] Apache Bahir 2.0.2 (RC1)

── > ─── > > The complete test suite BasicMQTTSourceSuite failed 56/100 times. > > Similar behavior with Spark 2.0.1. so it should not be a regression. > > I opened a JIRA to track/fix this: > https://issues.apache.org/jira/browse/BAHIR-83 > > Bes

Fwd: Java library for Flink-Kudu integration

Forwarding to Bahir dev mailing list. -- Forwarded message -- From: Date: Mon, Mar 27, 2017 at 9:14 AM Subject: Java library for Flink-Kudu integration To: u...@flink.apache.org Hi all, I apologize for sending the email to both user and

Re: Java library for Flink-Kudu integration

Ruben: If you have bandwidth, you can create a Bahir JIRA and port your code over to: https://github.com/apache/bahir-flink/ Cheers On Mon, Mar 27, 2017 at 10:31 AM, Ted Yu <yuzhih...@gmail.com> wrote: > Forwarding to Bahir dev mailing list. > > -- Forwarded message --

Re: Flink extensions artifact id

+1 On Thu, Apr 6, 2017 at 11:39 AM, Luciano Resende wrote: > I was looking at some of the flink extensions, which are implemented in > Java (except akka one), but have the _2.11 as if it was a Scala project. > > Should I just remove the _2.11 and leave them with a normal

Re: failing build question BAHIR-100 PR

> http://169.45.79.58:8080/job/bahir_spark_pr_builder/69/console > > On 06/07/2017, 23:08, "Ted Yu" <yuzhih...@gmail.com> wrote: > > Can you give the URL where the error was reported ? > > Thanks > > On Thu, Jul 6, 2017 at 1:05 PM, Rosenstark, David < &

Re: [VOTE] Apache Bahir 2.2.0 (RC1)

+1 Checked signatures Ran thru unit test suite which passed. On Wed, Aug 16, 2017 at 10:17 PM, Luciano Resende wrote: > Dear community member, > > Please vote to approve the release of Apache Bahir 2.2.0 (RC1) based on > Apache Spark 2.2.0. > > Tag: v2.2.0-rc1

Re: Bahir Flink release

Yes. Ready for testing. On Wed, May 3, 2017 at 8:13 AM, Luciano Resende wrote: > I see all PRs related to issues found during the latest RC review are > merged. > > Are we ready for a new RC ? > > -- > Luciano Resende > http://twitter.com/lresende1975 >

Re: [VOTE] Apache Bahir Flink extensions 1.0 (RC5)

I suggest getting BAHIR-88 fixed - this may affect future release(s). On Tue, May 23, 2017 at 12:29 PM, Luciano Resende wrote: > The issue reported was for Spark extensions > https://issues.apache.org/jira/browse/BAHIR-88 >

Re: [VOTE] Apache Bahir 2.1.1 (RC2)

When I ran test suite (using jdk 8), I got: BasicAkkaSourceSuite: - basic usage - Send and receive 100 messages. *** FAILED *** 1 did not equal 100 (AkkaStreamSourceSuite.scala:116) Has anyone else seen similar test failure ? Cheers On Wed, Jun 7, 2017 at 11:24 PM, Luciano Resende

Re: [DISCUSS][bahir-flink] Drop Java 7 support

+1 on dropping Java 7 support.  Original message From: Robert Metzger Date: 9/16/17 2:04 AM (GMT-08:00) To: dev@bahir.apache.org Subject: [DISCUSS][bahir-flink] Drop Java 7 support Hi, In the Flink InfluxDB Sink PR [1], there is a little discussion

Re: [VOTE] Apache Bahir 2.2.1 (RC1)

+1 Ran test suite which passed. On Thu, Jun 14, 2018 at 2:16 AM, Luciano Resende wrote: > Here is my +1 for the release. > > On Wed, Jun 6, 2018 at 5:50 PM Luciano Resende > wrote: > > > Dear community member, > > > > Please vote to approve the release of Apache Bahir 2.2.1 (RC1) based on > >

Re: [VOTE] Apache Bahir 2.1.2 (RC1)

+1 Downloaded source and built. Ran test suite which passed. On Thu, May 31, 2018 at 10:13 PM, Luciano Resende wrote: > Dear community member, > > Please vote to approve the release of Apache Bahir 2.1.2 (RC1) based on > Apache Spark 2.1.2. > > Tag: v2.1.2-rc1

Re: [VOTE] Apache Bahir 2.1.2 (RC1)

I tried to download the source but https://dist.apache.org/repos/ dist/dev/bahir/bahir-spark/2.1.2-rc1/ wasn't accessible using either Chrome or Firefox. FYI On Thu, May 31, 2018 at 10:13 PM, Luciano Resende wrote: > Dear community member, > > Please vote to approve the release of Apache Bahir

Re: Catching up on Spark Releases

Spark 2.1.3 has been released: http://search-hadoop.com/m/Spark/q3RTtDu0Z8V9VMZ?subj=+ANNOUNCE+Apache+Spark+2+1+3 Looking forward to the corresponding Bahir release. On Fri, Jun 29, 2018 at 5:07 AM, Luciano Resende wrote: > Just heads up that Spark is currently voting on Spark 2.1.3 and

Re: Catching up on Spark Releases

2.2.2 has been released too: http://search-hadoop.com/m/Spark/q3RTt4hGjQ15zeqM?subj=+ANNOUNCE+Apache+Spark+2+2+2 On Sun, Jul 1, 2018 at 5:31 PM Ted Yu wrote: > Spark 2.1.3 has been released: > > > http://search-hadoop.com/m/Spark/q3RTtDu0Z8V9VMZ?subj=+ANNOUNCE+Apache+Spark+2+1+3

Re: Catching up on Spark Releases

bq. catching up with Spark releases +1 Looking forward to the RC. On Sun, Apr 22, 2018 at 3:24 PM, Luciano Resende wrote: > I am planning to start looking at catching up with Spark releases. If > anyone has anything they want to add to the release, please speak up. > >

Re: [VOTE] Apache Bahir 2.2.2 (RC1)

+1 Ran unit test suite which passed. On Thu, Nov 8, 2018 at 1:34 PM Luciano Resende wrote: > Dear community member, > > Please vote to approve the release of Apache Bahir 2.2.2 (RC1) based on > Apache Spark 2.2.2. > > Tag: v2.2.2-rc1 (821a8c67c21f4f4ab4a7caa8e2f85a2c396683d4) > >

Re: Upgrading to Scala 2.12

+1 on keeping backward compatibility with Scala 2.11 Original message From: Łukasz Antoniak Date: 1/22/19 2:54 AM (GMT-08:00) To: dev@bahir.apache.org Subject: Upgrading to Scala 2.12 Team, Since version 2.4.0 Spark team decided to introduce support for Scala 2.12 and

Re: [VOTE] Apache Bahir 2.3.0 (RC1)

+1 Ran test suite which passed. On Fri, Nov 30, 2018 at 6:43 AM Luciano Resende wrote: > Dear community member, > > Please vote to approve the release of Apache Bahir 2.3.0 (RC1) based on > Apache Spark 2.3.0. > > Tag: v2.3.0-rc1 (e2d138bd2a927d0ab42e45739d8938eefafca352) > >

Re: [PROPOSAL] Move to gitbox.apache.org

+1 Original message From: Prashant Sharma Date: 12/7/18 9:01 PM (GMT-08:00) To: dev@bahir.apache.org Subject: Re: [PROPOSAL] Move to gitbox.apache.org +1 On Sat, Dec 8, 2018 at 2:56 AM Christian Kadner wrote: > +1 > > Thanks JB! > > On 2018/12/07 17:20:59, Luciano

Re: [VOTE] Apache Bahir 2.3.2 (RC1)

+1 Ran test suite which passed On Fri, Nov 30, 2018 at 12:57 PM Luciano Resende wrote: > Dear community member, > > Please vote to approve the release of Apache Bahir 2.3.2 (RC1) based on > Apache Spark 2.3.2. > > Tag: v2.3.2-rc1 (6d24b270fd713352faf1c93f08f835e39e496489) > >

Re: [VOTE] Apache Bahir 2.3.1 (RC1)

+1 Ran test suite which passed. On Fri, Nov 30, 2018 at 9:13 PM Jean-Baptiste Onofré wrote: > +1 (binding) > > Regards > JB > > On 30/11/2018 17:11, Luciano Resende wrote: > > Dear community member, > > > > Please vote to approve the release of Apache Bahir 2.3.1 (RC1) based on > > Apache

Re: [VOTE] Apache Bahir 2.3.3 (RC1)

+1 On Sat, May 25, 2019 at 5:51 PM Luciano Resende wrote: > Off course, my +1 for the release. > > We are still looking for an extra vote to approve the release, please > take a little time and help approve the release. > > On Sun, May 19, 2019 at 9:15 AM Luciano Resende > wrote: > > > > Dear

Re: [VOTE] Apache Bahir 2.2.3 (RC1)

+1 On Thu, May 30, 2019 at 9:01 AM Luciano Resende wrote: > Thanks, Christian, > > We are still looking for one more vote. Note that we had two > concurrent votes going on and this is a different vote thread (e.g. > 2.2.3 versus 2.3.3) > > On Tue, May 28, 2019 at 12:20 AM Christian Kadner >

Re: [VOTE] Apache Bahir 2.3.4 (RC1)

+1 On Fri, Sep 20, 2019 at 12:37 PM Luciano Resende wrote: > Off course, my +1 > I know a lot of us are just between travels (returning from ApacheCon) > but are any other volunteers available to review the release? > > On Wed, Sep 11, 2019 at 5:42 PM Luciano Resende > wrote: > > > > Dear

Re: [VOTE] Apache Bahir 2.4.0 (RC1)

+1 On Fri, Sep 20, 2019 at 12:37 PM Luciano Resende wrote: > Off course, my +1 > I know a lot of us are just between travels (returning from ApacheCon) > but are any other volunteers available to review the release? > > On Fri, Sep 13, 2019 at 10:38 AM Luciano Resende > wrote: > > > > Dear

[jira] [Resolved] (BAHIR-59) Improve ActiveMQ Connector

[ https://issues.apache.org/jira/browse/BAHIR-59?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved BAHIR-59. - Resolution: Fixed Assignee: Robert Metzger Fix Version/s: Flink-0.1 Thanks Robert. > Impr

[jira] [Created] (BAHIR-107) Build and test Bahir against Scala 2.12

Ted Yu created BAHIR-107: Summary: Build and test Bahir against Scala 2.12 Key: BAHIR-107 URL: https://issues.apache.org/jira/browse/BAHIR-107 Project: Bahir Issue Type: Improvement

[jira] [Updated] (BAHIR-107) Build and test Bahir against Scala 2.12

[ https://issues.apache.org/jira/browse/BAHIR-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-107: - Description: Spark has started effort for accommodating Scala 2.12 See SPARK-14220 This JIRA is to track

[jira] [Updated] (BAHIR-107) Build and test Bahir against Scala 2.12

[ https://issues.apache.org/jira/browse/BAHIR-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-107: - Description: Spark has started effort for accommodating Scala 2.12 See SPARK-14220 This JIRA is to track

[jira] [Resolved] (BAHIR-136) HBase Spark connector

[ https://issues.apache.org/jira/browse/BAHIR-136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved BAHIR-136. -- Resolution: Won't Fix Fix Version/s: Not Applicable > HBase Spark connec

[jira] [Commented] (BAHIR-136) HBase Spark connector

[ https://issues.apache.org/jira/browse/BAHIR-136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166884#comment-16166884 ] Ted Yu commented on BAHIR-136: -- This was created before recent exchanges on the mailing list. Proposal

[jira] [Updated] (BAHIR-107) Build and test Bahir against Scala 2.12

[ https://issues.apache.org/jira/browse/BAHIR-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-107: - Description: Spark has started effort for accommodating Scala 2.12 See SPARK-14220 This JIRA is to track

[jira] [Created] (BAHIR-136) HBase Spark connector

Ted Yu created BAHIR-136: Summary: HBase Spark connector Key: BAHIR-136 URL: https://issues.apache.org/jira/browse/BAHIR-136 Project: Bahir Issue Type: Improvement Reporter: Ted Yu

[jira] [Updated] (BAHIR-107) Build and test Bahir against Scala 2.12

[ https://issues.apache.org/jira/browse/BAHIR-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-107: - Description: Spark has started effort for accommodating Scala 2.12 See SPARK-14220 This JIRA is to track

[jira] [Updated] (BAHIR-172) Avoid FileInputStream/FileOutputStream

[ https://issues.apache.org/jira/browse/BAHIR-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-172: - Description: They rely on finalizers (before Java 11), which create unnecessary GC load. The alternatives

[jira] [Updated] (BAHIR-172) Avoid FileInputStream/FileOutputStream

[ https://issues.apache.org/jira/browse/BAHIR-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-172: - Description: They rely on finalizers (before Java 11), which create unnecessary GC load. The alternatives

[jira] [Commented] (BAHIR-173) Upgrade bahir-flink to support Flink 1.5.1

[ https://issues.apache.org/jira/browse/BAHIR-173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547766#comment-16547766 ] Ted Yu commented on BAHIR-173: -- Please go ahead. Thanks > Upgrade bahir-flink to support Flink 1.

[jira] [Updated] (BAHIR-172) Avoid FileInputStream/FileOutputStream

[ https://issues.apache.org/jira/browse/BAHIR-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-172: - Description: They rely on finalizers (before Java 11), which create unnecessary GC load. The alternatives

[jira] [Updated] (BAHIR-107) Build and test Bahir against Scala 2.12

[ https://issues.apache.org/jira/browse/BAHIR-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BAHIR-107: - Description: Spark has started effort for accommodating Scala 2.12 See SPARK-14220 . This JIRA is to track

[jira] [Commented] (BAHIR-173) Upgrade bahir-flink to support Flink 1.5.1

[ https://issues.apache.org/jira/browse/BAHIR-173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543417#comment-16543417 ] Ted Yu commented on BAHIR-173: -- Currently I saw: {code} [ERROR] warning: [options] bootstrap class path

[jira] [Created] (BAHIR-173) Upgrade bahir-flink to support Flink 1.5.1

Ted Yu created BAHIR-173: Summary: Upgrade bahir-flink to support Flink 1.5.1 Key: BAHIR-173 URL: https://issues.apache.org/jira/browse/BAHIR-173 Project: Bahir Issue Type: Improvement