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

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

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

[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] [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 https://travis-ci.org

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

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

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

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

[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-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] [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 Stream

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

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

[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

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

[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 & Loggin

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

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

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

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

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

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

[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] [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 SP

[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] [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 K

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

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

[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

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

[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

[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

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

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

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

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

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

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

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

[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

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

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

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

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

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

[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

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

[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

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

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

[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/FileOutputStr

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

[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

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

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

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

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

[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/S

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

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

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

[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

[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

<    1   2   3