[jira] [Resolved] (BAHIR-254) Redis or RedisDescriptorTest use sql or tab api will run exception(flink1.11) :becase use Deprecated method and feild

[ https://issues.apache.org/jira/browse/BAHIR-254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-254. --- Assignee: housezhang Resolution: Fixed > Redis or RedisDescriptorTest use sql or tab

[jira] [Resolved] (BAHIR-239) Fix Bugs in SQSClient

[ https://issues.apache.org/jira/browse/BAHIR-239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-239. --- Fix Version/s: Spark-2.4.0 Resolution: Fixed > Fix Bugs in SQSClient >

[jira] [Resolved] (BAHIR-245) Add asf.yml

[ https://issues.apache.org/jira/browse/BAHIR-245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-245. --- Fix Version/s: Flink-Next Resolution: Fixed > Add asf.yml > --- > >

[jira] [Commented] (BAHIR-245) Add asf.yml

[ https://issues.apache.org/jira/browse/BAHIR-245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186125#comment-17186125 ] Luciano Resende commented on BAHIR-245: --- What configurations are you planning to change? > Add

[jira] [Updated] (BAHIR-225) flink-connector-redis Jedis connect to Redis cluster throws NumberFormatException For input string 112@112

[ https://issues.apache.org/jira/browse/BAHIR-225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende updated BAHIR-225: -- Fix Version/s: (was: Not Applicable) Flink-Next > flink-connector-redis

[jira] [Assigned] (BAHIR-225) flink-connector-redis Jedis connect to Redis cluster throws NumberFormatException For input string 112@112

[ https://issues.apache.org/jira/browse/BAHIR-225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-225: - Assignee: sam lin > flink-connector-redis Jedis connect to Redis cluster throws >

[jira] [Resolved] (BAHIR-225) flink-connector-redis Jedis connect to Redis cluster throws NumberFormatException For input string 112@112

[ https://issues.apache.org/jira/browse/BAHIR-225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-225. --- Resolution: Fixed > flink-connector-redis Jedis connect to Redis cluster throws >

[jira] [Reopened] (BAHIR-225) flink-connector-redis Jedis connect to Redis cluster throws NumberFormatException For input string 112@112

[ https://issues.apache.org/jira/browse/BAHIR-225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reopened BAHIR-225: --- > flink-connector-redis Jedis connect to Redis cluster throws > NumberFormatException For input

[jira] [Commented] (BAHIR-133) Add MongoDB Source/Sink for Flink Streaming

[ https://issues.apache.org/jira/browse/BAHIR-133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127798#comment-17127798 ] Luciano Resende commented on BAHIR-133: --- I haven't seen a PR around this. > Add MongoDB Source/Sink

[jira] [Resolved] (BAHIR-220) Add redis descriptor to make redis connection as a table

[ https://issues.apache.org/jira/browse/BAHIR-220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-220. --- Fix Version/s: Flink-Next Assignee: yuemeng Resolution: Fixed > Add redis

[jira] [Resolved] (BAHIR-222) Update Readme with details of SQL Streaming SQS connector

[ https://issues.apache.org/jira/browse/BAHIR-222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-222. --- Fix Version/s: (was: Not Applicable) Spark-2.4.0 Resolution:

[jira] [Resolved] (BAHIR-213) Faster S3 file Source for Structured Streaming with SQS

[ https://issues.apache.org/jira/browse/BAHIR-213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-213. --- Fix Version/s: Spark-2.4.0 Assignee: Abhishek Dixit Resolution: Fixed >

[jira] [Resolved] (BAHIR-155) Add expire to redis sink

[ https://issues.apache.org/jira/browse/BAHIR-155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-155. --- Fix Version/s: (was: Flink-1.0) Flink-Next Resolution: Fixed >

[jira] [Resolved] (BAHIR-214) Improve KuduConnector speed

[ https://issues.apache.org/jira/browse/BAHIR-214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-214. --- Fix Version/s: Flink-Next Resolution: Fixed > Improve KuduConnector speed >

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

[ https://issues.apache.org/jira/browse/BAHIR-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-172. --- Fix Version/s: Spark-2.4.0 Resolution: Fixed > Avoid FileInputStream/FileOutputStream

[jira] [Assigned] (BAHIR-217) Install of Oracle JDK 8 Failing in Travis CI

[ https://issues.apache.org/jira/browse/BAHIR-217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-217: - Assignee: Abhishek Dixit > Install of Oracle JDK 8 Failing in Travis CI >

[jira] [Resolved] (BAHIR-217) Install of Oracle JDK 8 Failing in Travis CI

[ https://issues.apache.org/jira/browse/BAHIR-217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-217. --- Fix Version/s: Spark-2.4.0 Resolution: Fixed > Install of Oracle JDK 8 Failing in

[jira] [Commented] (BAHIR-217) Install of Oracle JDK 8 Failing in Travis CI

[ https://issues.apache.org/jira/browse/BAHIR-217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919083#comment-16919083 ] Luciano Resende commented on BAHIR-217: --- Thanks [~abhishekd0907], please submit a PR. > Install of

[jira] [Resolved] (BAHIR-210) bump flink version to 1.8.1

[ https://issues.apache.org/jira/browse/BAHIR-210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-210. --- Fix Version/s: Flink-Next Resolution: Fixed > bump flink version to 1.8.1 >

[jira] [Commented] (BAHIR-212) MQTT support to flink connector

[ https://issues.apache.org/jira/browse/BAHIR-212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888529#comment-16888529 ] Luciano Resende commented on BAHIR-212: --- If you basically want to update the connector from the

[jira] [Resolved] (BAHIR-192) Add jdbc sink support for Structured Streaming

[ https://issues.apache.org/jira/browse/BAHIR-192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-192. --- Resolution: Fixed Fix Version/s: Spark-2.4.0 > Add jdbc sink support for Structured

[jira] [Resolved] (BAHIR-205) add password support for flink sink of redis cluster

[ https://issues.apache.org/jira/browse/BAHIR-205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-205. --- Resolution: Fixed Fix Version/s: (was: Not Applicable)

[jira] [Reopened] (BAHIR-205) add password support for flink sink of redis cluster

[ https://issues.apache.org/jira/browse/BAHIR-205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reopened BAHIR-205: --- Assignee: yanfeng > add password support for flink sink of redis cluster >

[jira] [Resolved] (BAHIR-200) change from docker tests to kudu-test-utils

[ https://issues.apache.org/jira/browse/BAHIR-200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-200. --- Resolution: Fixed Fix Version/s: Flink-Next > change from docker tests to

[jira] [Resolved] (BAHIR-206) bump flink to 1.8.0

[ https://issues.apache.org/jira/browse/BAHIR-206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-206. --- Resolution: Fixed Fix Version/s: Flink-Next > bump flink to 1.8.0 >

[jira] [Assigned] (BAHIR-177) Siddhi Library state recovery causes an Exception

[ https://issues.apache.org/jira/browse/BAHIR-177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-177: - Assignee: Dominik Wosiński > Siddhi Library state recovery causes an Exception >

[jira] [Assigned] (BAHIR-202) Improve KuduSink throughput by using async FlushMode

[ https://issues.apache.org/jira/browse/BAHIR-202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-202: - Assignee: Suxing Lee > Improve KuduSink throughput by using async FlushMode >

[jira] [Resolved] (BAHIR-203) Pubsub manual acknowledgement

[ https://issues.apache.org/jira/browse/BAHIR-203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-203. --- Resolution: Fixed Assignee: Lukasz Antoniak Fix Version/s: (was:

[jira] [Resolved] (BAHIR-202) Improve KuduSink throughput by using async FlushMode

[ https://issues.apache.org/jira/browse/BAHIR-202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-202. --- Resolution: Fixed > Improve KuduSink throughput by using async FlushMode >

[jira] [Resolved] (BAHIR-177) Siddhi Library state recovery causes an Exception

[ https://issues.apache.org/jira/browse/BAHIR-177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-177. --- Resolution: Fixed Assignee: (was: Dominik Wosiński) Fix Version/s:

[jira] [Resolved] (BAHIR-190) ActiveMQ connector stops on empty queue

[ https://issues.apache.org/jira/browse/BAHIR-190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-190. --- Resolution: Fixed Fix Version/s: Flink-Next > ActiveMQ connector stops on empty queue

[jira] [Resolved] (BAHIR-187) Reduce size of sql-cloudant test database

[ https://issues.apache.org/jira/browse/BAHIR-187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-187. --- Resolution: Fixed Fix Version/s: Spark-2.4.0 > Reduce size of sql-cloudant test

[jira] [Resolved] (BAHIR-141) Support for Array[Byte] in SparkGCPCredentials.jsonServiceAccount

[ https://issues.apache.org/jira/browse/BAHIR-141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-141. --- Resolution: Fixed Assignee: Lukasz Antoniak Fix Version/s: (was:

[jira] [Created] (BAHIR-197) Add FlumeSink to Flume connector

Luciano Resende created BAHIR-197: - Summary: Add FlumeSink to Flume connector Key: BAHIR-197 URL: https://issues.apache.org/jira/browse/BAHIR-197 Project: Bahir Issue Type: Bug

[jira] [Commented] (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:comment-tabpanel=16782469#comment-16782469 ] Luciano Resende commented on BAHIR-107: --- For non released code (SNAPSHOT), you need to checkout the

[jira] [Resolved] (BAHIR-184) Please delete old releases from mirroring system

[ https://issues.apache.org/jira/browse/BAHIR-184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-184. --- Resolution: Fixed Assignee: Luciano Resende Fix Version/s: Not Applicable

[jira] [Resolved] (BAHIR-191) update flume version to 1.9.0

[ https://issues.apache.org/jira/browse/BAHIR-191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-191. --- Resolution: Fixed Fix Version/s: Flink-Next > update flume version to 1.9.0 >

[jira] [Resolved] (BAHIR-195) bump flink version to 1.7.1

[ https://issues.apache.org/jira/browse/BAHIR-195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-195. --- Resolution: Fixed Fix Version/s: Flink-Next > bump flink version to 1.7.1 >

[jira] [Resolved] (BAHIR-194) update kudu version to 1.8.0

[ https://issues.apache.org/jira/browse/BAHIR-194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-194. --- Resolution: Fixed Fix Version/s: Flink-Next > update kudu version to 1.8.0 >

[jira] [Assigned] (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 ] Luciano Resende reassigned BAHIR-107: - Assignee: Lukasz Antoniak > Build and test Bahir against Scala 2.12 >

[jira] [Resolved] (BAHIR-175) Recovering from Failures with Checkpointing Exception(Mqtt)

[ https://issues.apache.org/jira/browse/BAHIR-175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-175. --- Resolution: Fixed Assignee: Lukasz Antoniak Fix Version/s: Spark-2.4.0 >

[jira] [Resolved] (BAHIR-45) Add cleanup support to SQL-STREAMING-MQTT Source once SPARK-16963 is fixed.

[ https://issues.apache.org/jira/browse/BAHIR-45?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-45. -- Resolution: Fixed Fix Version/s: Spark-2.4.0 Resolving per comment above, please reopen

[jira] [Assigned] (BAHIR-45) Add cleanup support to SQL-STREAMING-MQTT Source once SPARK-16963 is fixed.

[ https://issues.apache.org/jira/browse/BAHIR-45?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-45: Assignee: Prashant Sharma > Add cleanup support to SQL-STREAMING-MQTT Source once

[jira] [Resolved] (BAHIR-183) Using HDFS for saving message for mqtt source

[ https://issues.apache.org/jira/browse/BAHIR-183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-183. --- Resolution: Fixed Assignee: Wang Yanlin Fix Version/s: (was: Spark-2.2.1)

[jira] [Resolved] (BAHIR-186) Support SSL connection in MQTT SQL Streaming

[ https://issues.apache.org/jira/browse/BAHIR-186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-186. --- Resolution: Fixed Fix Version/s: Spark-2.4.0 > Support SSL connection in MQTT SQL

[jira] [Assigned] (BAHIR-186) Support SSL connection in MQTT SQL Streaming

[ https://issues.apache.org/jira/browse/BAHIR-186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-186: - Assignee: Lukasz Antoniak > Support SSL connection in MQTT SQL Streaming >

[jira] [Resolved] (BAHIR-103) Refactoring of files BahirUtils.scala & Logging.scala into bahir-common

[ https://issues.apache.org/jira/browse/BAHIR-103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-103. --- Resolution: Fixed Fix Version/s: Spark-2.4.0 > Refactoring of files BahirUtils.scala &

[jira] [Assigned] (BAHIR-103) Refactoring of files BahirUtils.scala & Logging.scala into bahir-common

[ https://issues.apache.org/jira/browse/BAHIR-103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-103: - Assignee: Lukasz Antoniak > Refactoring of files BahirUtils.scala & Logging.scala into

[jira] [Resolved] (BAHIR-147) Update Flink extensions documentation with latest contents

[ https://issues.apache.org/jira/browse/BAHIR-147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-147. --- Resolution: Fixed Fix Version/s: Flink-Next > Update Flink extensions documentation

[jira] [Resolved] (BAHIR-188) update flink to 1.7.0

[ https://issues.apache.org/jira/browse/BAHIR-188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-188. --- Resolution: Fixed Fix Version/s: Flink-Next > update flink to 1.7.0 >

[jira] [Assigned] (BAHIR-147) Update Flink extensions documentation with latest contents

[ https://issues.apache.org/jira/browse/BAHIR-147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-147: - Assignee: Joao Boto > Update Flink extensions documentation with latest contents >

[jira] [Assigned] (BAHIR-182) Create PubNub extension for Apache Spark Streaming

[ https://issues.apache.org/jira/browse/BAHIR-182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-182: - Assignee: Lukasz Antoniak > Create PubNub extension for Apache Spark Streaming >

[jira] [Resolved] (BAHIR-182) Create PubNub extension for Apache Spark Streaming

[ https://issues.apache.org/jira/browse/BAHIR-182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-182. --- Resolution: Fixed Fix Version/s: Spark-2.3.0 > Create PubNub extension for Apache

[jira] [Resolved] (BAHIR-66) Add test that ZeroMQ streaming connector can receive data

[ https://issues.apache.org/jira/browse/BAHIR-66?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-66. -- Resolution: Fixed Fix Version/s: Spark-2.3.0 > Add test that ZeroMQ streaming connector

[jira] [Assigned] (BAHIR-66) Add test that ZeroMQ streaming connector can receive data

[ https://issues.apache.org/jira/browse/BAHIR-66?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-66: Assignee: Lukasz Antoniak > Add test that ZeroMQ streaming connector can receive data >

[jira] [Resolved] (BAHIR-49) Add MQTTSink to SQL Streaming MQTT.

[ https://issues.apache.org/jira/browse/BAHIR-49?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-49. -- Resolution: Fixed Fix Version/s: Spark-2.3.0 > Add MQTTSink to SQL Streaming MQTT. >

[jira] [Resolved] (BAHIR-166) Migrate akka sql streaming source to datasrouce v2 API

[ https://issues.apache.org/jira/browse/BAHIR-166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-166. --- Resolution: Fixed Assignee: Takako Shimamoto Fix Version/s: Spark-2.3.0 >

[jira] [Resolved] (BAHIR-181) username and password should be available for pyspark when using mqtt streaming

[ https://issues.apache.org/jira/browse/BAHIR-181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-181. --- Resolution: Fixed Assignee: Carrey Zhan Fix Version/s: Spark-2.3.0 > username

[jira] [Resolved] (BAHIR-114) Flink Flume connector missing automated unit tests

[ https://issues.apache.org/jira/browse/BAHIR-114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-114. --- Resolution: Fixed Fix Version/s: Flink-Next > Flink Flume connector missing automated

[jira] [Resolved] (BAHIR-178) Add option to create database in influxdb connector

[ https://issues.apache.org/jira/browse/BAHIR-178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-178. --- Resolution: Fixed Assignee: Wojciech Luczkow Fix Version/s: Flink-Next > Add

[jira] [Resolved] (BAHIR-176) [FLINK] update flink to 1.6.0

[ https://issues.apache.org/jira/browse/BAHIR-176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-176. --- Resolution: Fixed Fix Version/s: Flink-Next > [FLINK] update flink to 1.6.0 >

[jira] [Resolved] (BAHIR-99) Kudu connector to read/write from/to Kudu

[ https://issues.apache.org/jira/browse/BAHIR-99?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-99. -- Resolution: Fixed > Kudu connector to read/write from/to Kudu >

[jira] [Assigned] (BAHIR-99) Kudu connector to read/write from/to Kudu

[ https://issues.apache.org/jira/browse/BAHIR-99?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-99: Assignee: Joao Boto (was: Rubén Casado) > Kudu connector to read/write from/to Kudu >

[jira] [Resolved] (BAHIR-174) Siddhi Module should not use TypeInfoParser

[ https://issues.apache.org/jira/browse/BAHIR-174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-174. --- Resolution: Fixed > Siddhi Module should not use TypeInfoParser >

[jira] [Assigned] (BAHIR-174) Siddhi Module should not use TypeInfoParser

[ https://issues.apache.org/jira/browse/BAHIR-174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-174: - Assignee: Dominik Wosiński > Siddhi Module should not use TypeInfoParser >

[jira] [Resolved] (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:all-tabpanel ] Luciano Resende resolved BAHIR-173. --- Resolution: Fixed Fix Version/s: Flink-Next > Upgrade bahir-flink to support Flink

[jira] [Assigned] (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:all-tabpanel ] Luciano Resende reassigned BAHIR-173: - Assignee: Joao Boto > Upgrade bahir-flink to support Flink 1.5.1 >

[jira] [Commented] (BAHIR-168) Kinesis support in Structured Streaming

[ https://issues.apache.org/jira/browse/BAHIR-168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514738#comment-16514738 ] Luciano Resende commented on BAHIR-168: --- Sorry for the delay responding, I have been traveling.

[jira] [Commented] (BAHIR-168) Kinesis support in Structured Streaming

[ https://issues.apache.org/jira/browse/BAHIR-168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494688#comment-16494688 ] Luciano Resende commented on BAHIR-168: --- Thanks, we are in the process of migrating to datasource

[jira] [Resolved] (BAHIR-162) Update release scripts to stop publishing MD5 hash (updated release policy)

[ https://issues.apache.org/jira/browse/BAHIR-162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-162. --- Resolution: Fixed Fix Version/s: Not Applicable Update release script for both Spark

[jira] [Resolved] (BAHIR-163) Move Bahir-Spark build infrastructure to use Travis.CI

[ https://issues.apache.org/jira/browse/BAHIR-163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-163. --- Resolution: Fixed Fix Version/s: Not Applicable > Move Bahir-Spark build infrastructure

[jira] [Commented] (BAHIR-163) Move build infrastructure to use Travis.CI

[ https://issues.apache.org/jira/browse/BAHIR-163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16452910#comment-16452910 ] Luciano Resende commented on BAHIR-163: --- Builds are now passing in Travis.CI

[jira] [Updated] (BAHIR-163) Move Bahir-Spark build infrastructure to use Travis.CI

[ https://issues.apache.org/jira/browse/BAHIR-163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende updated BAHIR-163: -- Summary: Move Bahir-Spark build infrastructure to use Travis.CI (was: Move build infrastructure

[jira] [Created] (BAHIR-163) Move build infrastructure to use Travis.CI

Luciano Resende created BAHIR-163: - Summary: Move build infrastructure to use Travis.CI Key: BAHIR-163 URL: https://issues.apache.org/jira/browse/BAHIR-163 Project: Bahir Issue Type:

[jira] [Created] (BAHIR-162) Update release scripts to stop publishing MD5 hash (updated release policy)

Luciano Resende created BAHIR-162: - Summary: Update release scripts to stop publishing MD5 hash (updated release policy) Key: BAHIR-162 URL: https://issues.apache.org/jira/browse/BAHIR-162 Project:

[jira] [Commented] (BAHIR-161) How to access all available databases from cloudant ?

[ https://issues.apache.org/jira/browse/BAHIR-161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16414294#comment-16414294 ] Luciano Resende commented on BAHIR-161: --- [~emlaver] > How to access all available databases from

[jira] [Assigned] (BAHIR-159) Our project needs to use org.apache.bahir:spark-sql-streaming-mqtt_2.11:2.2.0, which has dependency conflict problem.

[ https://issues.apache.org/jira/browse/BAHIR-159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-159: - Assignee: Luciano Resende Fix Version/s: Spark-2.3 > Our project needs to use >

[jira] [Resolved] (BAHIR-159) Our project needs to use org.apache.bahir:spark-sql-streaming-mqtt_2.11:2.2.0, which has dependency conflict problem.

[ https://issues.apache.org/jira/browse/BAHIR-159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-159. --- Resolution: Won't Fix Doing a quick search, these seem to be transient dependencies coming

[jira] [Resolved] (BAHIR-157) The current documentation for extensions contains bad version (2.2.0.1.0.0-SNAPSHOT)

[ https://issues.apache.org/jira/browse/BAHIR-157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-157. --- Resolution: Fixed Fix Version/s: Not Applicable Good catch, and thanks for describing

[jira] [Assigned] (BAHIR-157) The current documentation for extensions contains bad version (2.2.0.1.0.0-SNAPSHOT)

[ https://issues.apache.org/jira/browse/BAHIR-157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende reassigned BAHIR-157: - Assignee: Sergii Iarovyi > The current documentation for extensions contains bad version

[jira] [Resolved] (BAHIR-154) Refactor sql-cloudant to use Cloudant's java-cloudant features

[ https://issues.apache.org/jira/browse/BAHIR-154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-154. --- Resolution: Fixed Fix Version/s: Spark-2.3 Spark-2.2.1 > Refactor

[jira] [Resolved] (BAHIR-104) MQTT Dstream returned by the new multi topic support API is not a pairRDD

[ https://issues.apache.org/jira/browse/BAHIR-104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-104. --- Resolution: Fixed Assignee: Francesco Beneventi Fix Version/s: Spark-2.3

[jira] [Resolved] (BAHIR-152) License header not enforced for Java sources

[ https://issues.apache.org/jira/browse/BAHIR-152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-152. --- Resolution: Fixed > License header not enforced for Java sources >

[jira] [Resolved] (BAHIR-149) Upgrade cloudant dependency to release 2.11.0

[ https://issues.apache.org/jira/browse/BAHIR-149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-149. --- Resolution: Fixed Fix Version/s: Spark-2.2.1 > Upgrade cloudant dependency to release

[jira] [Updated] (BAHIR-148) Use same version of MQTT client in all MQTT extensions

[ https://issues.apache.org/jira/browse/BAHIR-148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende updated BAHIR-148: -- Component/s: Spark Structured Streaming Connectors Spark Streaming Connectors >

[jira] [Created] (BAHIR-148) Use same version of MQTT client in all MQTT extensions

Luciano Resende created BAHIR-148: - Summary: Use same version of MQTT client in all MQTT extensions Key: BAHIR-148 URL: https://issues.apache.org/jira/browse/BAHIR-148 Project: Bahir Issue

[jira] [Created] (BAHIR-147) Update Flink extensions documentation with latest contents

Luciano Resende created BAHIR-147: - Summary: Update Flink extensions documentation with latest contents Key: BAHIR-147 URL: https://issues.apache.org/jira/browse/BAHIR-147 Project: Bahir

[jira] [Commented] (BAHIR-142) Unable to download InfluxDB connector dependency

[ https://issues.apache.org/jira/browse/BAHIR-142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16278644#comment-16278644 ] Luciano Resende commented on BAHIR-142: --- Here is the snapshot jar:

[jira] [Commented] (BAHIR-127) Move "flink-connector-twitter & flink-connector-wikiedits" from flink to bahir-flink

[ https://issues.apache.org/jira/browse/BAHIR-127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16141720#comment-16141720 ] Luciano Resende commented on BAHIR-127: --- Can we please have one jira/PR per extension. Other then

[jira] [Resolved] (BAHIR-126) Update Akka dependency to version 2.4.20

[ https://issues.apache.org/jira/browse/BAHIR-126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-126. --- Resolution: Fixed Fix Version/s: Spark-2.2.0 > Update Akka dependency to version 2.4.20

[jira] [Created] (BAHIR-126) Update Akka dependency to version 2.4.20

Luciano Resende created BAHIR-126: - Summary: Update Akka dependency to version 2.4.20 Key: BAHIR-126 URL: https://issues.apache.org/jira/browse/BAHIR-126 Project: Bahir Issue Type: Bug

[jira] [Resolved] (BAHIR-125) Update Bahir pom to use JAVA 8 and to align with Spark 2.2.0 dependencies

[ https://issues.apache.org/jira/browse/BAHIR-125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-125. --- Resolution: Fixed > Update Bahir pom to use JAVA 8 and to align with Spark 2.2.0 dependencies

[jira] [Resolved] (BAHIR-124) Update Bahir to use Spark 2.2.0 dependency

[ https://issues.apache.org/jira/browse/BAHIR-124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-124. --- Resolution: Fixed > Update Bahir to use Spark 2.2.0 dependency >

[jira] [Created] (BAHIR-125) Update Bahir pom to use JAVA 8 and to align with Spark 2.2.0 dependencies

Luciano Resende created BAHIR-125: - Summary: Update Bahir pom to use JAVA 8 and to align with Spark 2.2.0 dependencies Key: BAHIR-125 URL: https://issues.apache.org/jira/browse/BAHIR-125 Project:

[jira] [Created] (BAHIR-124) Update Bahir to use Spark 2.2.0 dependency

Luciano Resende created BAHIR-124: - Summary: Update Bahir to use Spark 2.2.0 dependency Key: BAHIR-124 URL: https://issues.apache.org/jira/browse/BAHIR-124 Project: Bahir Issue Type: Bug

[jira] [Resolved] (BAHIR-110) Implement _changes API for non-streaming receiver

[ https://issues.apache.org/jira/browse/BAHIR-110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-110. --- Resolution: Fixed Assignee: Esteban Laver Fix Version/s: Spark-2.2.0 >

[jira] [Resolved] (BAHIR-100) Providing MQTT Spark Streaming to return encoded Byte[] message without corruption

[ https://issues.apache.org/jira/browse/BAHIR-100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-100. --- Resolution: Fixed Fix Version/s: Spark-2.2.0 > Providing MQTT Spark Streaming to return

[jira] [Resolved] (BAHIR-116) Add Spark streaming connector for Google cloud Pub/Sub

[ https://issues.apache.org/jira/browse/BAHIR-116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-116. --- Resolution: Fixed Assignee: Bin Chen Fix Version/s: Spark-2.1.1 > Add Spark

[jira] [Resolved] (BAHIR-120) Akka SQL Streaming build fails with Apache Spark 2.1.1

[ https://issues.apache.org/jira/browse/BAHIR-120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende resolved BAHIR-120. --- Resolution: Fixed Assignee: Subhobrata Dey Fix Version/s: Spark-2.1.1 > Akka

[jira] [Updated] (BAHIR-120) Akka SQL Streaming build fails with Apache Spark 2.1.1

[ https://issues.apache.org/jira/browse/BAHIR-120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luciano Resende updated BAHIR-120: -- Attachment: hs_err_pid55411.log > Akka SQL Streaming build fails with Apache Spark 2.1.1 >

  1   2   >