[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&focusedCommentId=17186125#comment-17186125 ] Luciano Resende commented on BAHIR-245: --- What configurations are you planning to cha

[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 J

[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 > Number

[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 > NumberForma

[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 s

[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&focusedCommentId=17127798#comment-17127798 ] Luciano Resende commented on BAHIR-133: --- I haven't seen a PR around this. > Add Mon

[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 desc

[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: Fixe

[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 > Faster

[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 > A

[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 Travi

[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&focusedCommentId=16919083#comment-16919083 ] Luciano Resende commented on BAHIR-217: --- Thanks [~abhishekd0907], please submit a PR

[jira] [Resolved] (BAHIR-215) bump flink to 1.9.0

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

[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&focusedCommentId=16888529#comment-16888529 ] Luciano Resende commented on BAHIR-212: --- If you basically want to update the connect

[jira] [Assigned] (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 reassigned BAHIR-192: - Assignee: Wang Yanlin > Add jdbc sink support for Structured Streaming >

[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 Str

[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) Spark-2.4.

[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 kudu-test-uti

[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: Spark-2.3.

[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: Flink-Ne

[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 databas

[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: Spark-2.2.

[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 Comp

[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&focusedCommentId=16782469#comment-16782469 ] Luciano Resende commented on BAHIR-107: --- For non released code (SNAPSHOT), you need

[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 Remo

[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] [Resolved] (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 resolved BAHIR-107. --- Resolution: Fixed Fix Version/s: Spark-2.4.0 > Build and test Bahir against Scala 2.12

[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 > Recov

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

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

[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 if

[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 SPARK-1696

[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 Strea

[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 ba

[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 wit

[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 Spark

[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 ca

[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] [Assigned] (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 reassigned BAHIR-49: Assignee: Lukasz Antoniak > Add MQTTSink to SQL Streaming MQTT. > --

[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-165) The avro messages to streaming-mqtt gives negative value.

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

[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 > Migr

[jira] [Resolved] (BAHIR-164) Spark Streaming with MQTT fails with Spark 2.3.0

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

[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 u

[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 o

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

[ https://issues.apache.org/jira/browse/BAHIR-172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16632644#comment-16632644 ] Luciano Resende commented on BAHIR-172: --- Patches are welcome. > Avoid FileInputStre

[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 1.5.

[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] [Resolved] (BAHIR-171) Download page should not link to unreleased code

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

[jira] [Resolved] (BAHIR-170) Please use HTTPS for sigs and hashes

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

[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&focusedCommentId=16514738#comment-16514738 ] Luciano Resende commented on BAHIR-168: --- Sorry for the delay responding, I have been

[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&focusedCommentId=16494688#comment-16494688 ] Luciano Resende commented on BAHIR-168: --- Thanks, we are in the process of migrating

[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 and

[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&focusedCommentId=16452910#comment-16452910 ] Luciano Resende commented on BAHIR-163: --- Builds are now passing in Travis.CI https:/

[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: Improvem

[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: Ba

[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&focusedCommentId=16414294#comment-16414294 ] Luciano Resende commented on BAHIR-161: --- [~emlaver] > How to access all available da

[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 from

[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 th

[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 sql

[jira] [Resolved] (BAHIR-137) Load performance improvements for _changes API in sql-cloudant

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

[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-128) Test failing sporadically in sql-cloudant's CloudantChangesDFSuite

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

[jira] [Resolved] (BAHIR-138) Fix sql-cloudant deprecation messages

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

[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-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 resolved BAHIR-148. --- Resolution: Fixed Fix Version/s: Spark-2.2.1 > Use same version of MQTT client in all MQ

[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 2.

[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-149) Upgrade cloudant dependency to release 2.11.0

Luciano Resende created BAHIR-149: - Summary: Upgrade cloudant dependency to release 2.11.0 Key: BAHIR-149 URL: https://issues.apache.org/jira/browse/BAHIR-149 Project: Bahir Issue Type: Bug

  1   2   3   >