qubole kinesis-sql issues

qubole / kinesis-sql

Kinesis Connector for Structured Streaming

http://www.qubole.com

Apache License 2.0

137 stars 80 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Upgrade jackson-dataformat-cbor to version 2.14.3 and fix vulnerabilities.

#120 WonYong-Jang opened 2 months ago
0
could create Kinesis Connector for Spark structured streaming for 3.2.0

#119 gavbmribeiro opened 4 months ago
0
Bump jackson-dataformat-cbor from 2.10.0 to 2.11.4

#118 dependabot[bot] opened 1 year ago
0
AWS creds provider while running spark app on Kubernetes

#117 tbhangalenice opened 1 year ago
0
Data Loss when extracting data from Kinesis

#116 success-m opened 1 year ago
3
Bump protobuf-java from 3.16.1 to 3.16.3

#115 dependabot[bot] opened 1 year ago
0
Mark source project as no longer maintained; provide a link to the new project.

#114 roncemer closed 1 year ago
0
Fix stream dying after a period of inactivity; fix build for Spark 3.2.1.

#113 roncemer closed 1 year ago
0
Changes to make the library work on EMR on EKS Fargate.

#112 akshayar opened 2 years ago
0
The library does not work with EMR on EKS Fargate | Infinite Loop

#111 akshayar opened 2 years ago
0
What may be causing and how to work around StreamingQueryException: Gave up after 3 retries while fetching MetaData ?

#110 dgoldenberg-audiomack opened 2 years ago
2
Kinesis encrypted stream

#109 BreakpointsCA closed 2 years ago
1
Does this support kinesis fanout consumer ?

#108 itsmesrds opened 2 years ago
0
Data not receiving from Kinesis

#107 success-m opened 2 years ago
8
Bump protobuf-java from 2.6.1 to 3.16.1

#106 dependabot[bot] closed 1 year ago
0
Does Kinesis connector support reading compressed payloads on stream?

#105 sudeshnasengupta opened 2 years ago
1
Fix listShards to only specify nextToken

#104 Anthuang opened 2 years ago
2
client execution timeout configuration parameter

#103 gaborbarna opened 2 years ago
1
How do I ensure checkpointing for kafka streams?

#102 Vikas-kum opened 3 years ago
2
Cannot restart the streaming job from where it stopped previously in the kinesis stream

#101 prashanthvg89 opened 3 years ago
1
Issue with Stream containing a lot of NO PUT ACTIVITY

#100 WTa-hash opened 3 years ago
3
Continuous trigger fails on Spark 3, but works on Spark 2.4.5

#99 pburner opened 3 years ago
1
Error in the Kinesis connector for reading data on AWS

#98 alokika-dash opened 3 years ago
0
ProvisionedThroughputExceededException and new batches are triggered even if avoidEmptyBatches=true

#97 juliankeppel opened 3 years ago
6
Can't get newer records

#96 Tomaszuniek opened 3 years ago
3
Consumer requiring re-sharding of stream before starts consuming data

#95 marciodebarros opened 3 years ago
1
kinesis source timestamp (in milliseconds) starting position

#94 gaborbarna opened 3 years ago
0
startingPosition AT_TIMESTAMP iteratorOption NumberFormatException

#93 adamlbailey opened 3 years ago
9
Support for Spark 3.0 and scala 2.12

#92 itsvikramagr closed 3 years ago
0
StreamingQueryException: 'Error while Describe Stream

#91 manishkaushik29 closed 4 years ago
1
Remove lastReadSequenceNumber.isEmpty condition

#90 chadlagore closed 4 years ago
3
Switch to use Kinesis list-shards API

#89 chadlagore closed 3 years ago
7
Error On EMR 6.1 Spark 3.0

#88 rubenssoto closed 3 years ago
2
Not honoring maxFetchTimeInMs on empty streams

#87 chadlagore closed 4 years ago
4
feat: Add ability to bundle all records from one micro-batch into PutRecords

#86 leslieyanyan opened 4 years ago
2
Missing org/apache/spark/internal/Logging$class

#85 asafcombo closed 4 years ago
3
Loading credentials using Default Credential Provider Chain

#84 m-radzikowski closed 4 years ago
1
LimitExceededException with multiple running queries per application

#83 chadlagore closed 3 years ago
3
pyspark foreach/foreachPartition send http request failed

#82 tmylt closed 4 years ago
0
Fixing Kinesis Sink

#81 abhishekd0907 closed 4 years ago
1
Support scala 2.12?

#80 arnehuang closed 3 years ago
4
Fix retries while making Kinesis API calls

#79 itsvikramagr closed 4 years ago
0
Adding ability to set exact Kinesis position to start reading from

#78 snorochevskiy closed 4 years ago
2
Authentication with session token not working in PySpark

#77 pcojocar closed 4 years ago
5
Apply retries to kinesis exceptions with status code >= 500

#76 arnehuang closed 4 years ago
2
Spark job is failing because of AmazonKinesisException: null (Service: AmazonKinesis; Status Code: 503

#75 levontr closed 4 years ago
5
Null pointer exception when trying to read stream in cluster mode

#74 HariprasadAllaka1612 closed 4 years ago
2
intergation with localstack

#73 haniaruc opened 4 years ago
1
Added session based authentication

#72 guoming-xu closed 4 years ago
0
Make DefaultAWSCredentialsProviderChain available to choose

#71 hyeonseop-lee closed 4 years ago
2