Re: [VOTE] Apache Bahir 2.2.0 (RC1)

2017-08-22 Thread Rosenstark, David
+1

On 22/08/2017, 17:33, "Luciano Resende"  wrote:

Off course, my +1

On Thu, Aug 17, 2017 at 1:17 AM, 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 (d927289fdad0e66953606869639fe2f153c37b05)
>
> https://github.com/apache/bahir/tree/v2.2.0-rc1
>
> Release files:
>
> https://repository.apache.org/content/repositories/orgapachebahir-1020
>
> Source distribution:
>
> https://dist.apache.org/repos/dist/dev/bahir/bahir-spark/2.2.0-rc1/
>
>
> The vote is open for at least 72 hours and passes if a majority of at
> least
> 3 +1 PMC votes are cast.
>
>   [ ] +1 Release this package as Apache Bahir 2.2.0
>   [ ] -1 Do not release this package because ...
>
>
> Thanks for your vote!
>
> --
> Luciano Resende
> http://twitter.com/lresende1975
> http://lresende.blogspot.com/
>



-- 
Luciano Resende
http://twitter.com/lresende1975
http://lresende.blogspot.com/


-
Intel Electronics Ltd.

This e-mail and any attachments may contain confidential material for
the sole use of the intended recipient(s). Any review or distribution
by others is strictly prohibited. If you are not the intended
recipient, please contact the sender and delete all copies.


BAHIR-100

2017-07-10 Thread Rosenstark, David
Hi I have sent PR for BAHIR-100 and it now passes. What are the next steps 
needed to get it merged?
-
Intel Electronics Ltd.

This e-mail and any attachments may contain confidential material for
the sole use of the intended recipient(s). Any review or distribution
by others is strictly prohibited. If you are not the intended
recipient, please contact the sender and delete all copies.


failing build question BAHIR-100 PR

2017-07-06 Thread Rosenstark, David
Hi my build passes fine on my machine running oracle java 8.
But I see it failed on a different sub-project not affected by my PR on 
Jenkins. But this is the output: (see below)
Is this a known intermittent issue? Is there some issue on build machine? 
Any other hints?

12:48:40 - Send & Receive messages of size 128000 bytes.
12:48:40 AkkaStreamSourceSuite:
12:48:40 BasicAkkaSourceSuite:
12:48:50 - basic usage
12:49:00 - Send and receive 100 messages.
12:49:00 - params not provided
12:49:10 - Recovering offset from the last processed offset
112:49:10 - Recovering offset from the last processed offset
12:49:10 #
12:49:10 # A fatal error has been detected by the Java Runtime Environment:
12:49:10 #
12:49:10 #  SIGSEGV (0xb) at pc=0x7f3970105120, pid=24784, 
tid=139896151623424
12:49:10 #
12:49:10 # JRE version: OpenJDK Runtime Environment (8.0_91-b14) (build 
1.8.0_91-b14)
12:49:10 # Java VM: OpenJDK 64-Bit Server VM (25.91-b14 mixed mode 
linux-amd64 compressed oops)
12:49:10 # Problematic frame:
12:49:10 # C  0x7f3970105120
12:49:10 #
12:49:10 # Failed to write core dump. Core dumps have been disabled. To 
enable core dumping, try "ulimit -c unlimited" before starting Java again
12:49:10 #
12:49:10 # An error report file with more information is saved as:
12:49:10 # 
/var/lib/jenkins/workspace/bahir_spark_pr_builder/sql-streaming-akka/hs_err_pid24784.log
12:49:10 #
12:49:10 # If you would like to submit a bug report, please visit:
12:49:10 #   http://bugreport.java.com/bugreport/crash.jsp
12:49:10 # The crash happened outside the Java Virtual Machine in native 
code.
12:49:10 # See problematic frame for where to report the bug.





-
Intel Electronics Ltd.

This e-mail and any attachments may contain confidential material for
the sole use of the intended recipient(s). Any review or distribution
by others is strictly prohibited. If you are not the intended
recipient, please contact the sender and delete all copies.


MQTT Stream change from string to byte array

2017-07-05 Thread Rosenstark, David
I have just started using this library and it so far works great.

I have a need to receive MQTT data as binary and not ASCII
I use the MQTTPairedInputStream so I made the changes there (leave it as 
Array[Byte] to test to see if it all would work and it does

So, I assume we would not want to break backward compatibility so would it make 
sense to create new function createMQTTPairedInputStreamByteArray?
I assume for consistency we would need to do this for regular stream too.

Thanks
David


-
Intel Electronics Ltd.

This e-mail and any attachments may contain confidential material for
the sole use of the intended recipient(s). Any review or distribution
by others is strictly prohibited. If you are not the intended
recipient, please contact the sender and delete all copies.