Ecosyste.ms: Issues
An open API service for providing issue and pull request metadata for open source projects.
GitHub / qubole/kinesis-sql issues and pull requests
#117 - AWS creds provider while running spark app on Kubernetes
Issue -
State: open - Opened by tbhangalenice over 1 year ago
#116 - Data Loss when extracting data from Kinesis
Issue -
State: open - Opened by success-m over 1 year ago
- 3 comments
#115 - Bump protobuf-java from 3.16.1 to 3.16.3
Pull Request -
State: open - Opened by dependabot[bot] almost 2 years ago
Labels: dependencies
#114 - Mark source project as no longer maintained; provide a link to the new project.
Pull Request -
State: closed - Opened by roncemer almost 2 years ago
#113 - Fix stream dying after a period of inactivity; fix build for Spark 3.2.1.
Pull Request -
State: closed - Opened by roncemer almost 2 years ago
#112 - Changes to make the library work on EMR on EKS Fargate.
Pull Request -
State: open - Opened by akshayar about 2 years ago
#112 - Changes to make the library work on EMR on EKS Fargate.
Pull Request -
State: open - Opened by akshayar about 2 years ago
#111 - The library does not work with EMR on EKS Fargate | Infinite Loop
Issue -
State: open - Opened by akshayar about 2 years ago
#111 - The library does not work with EMR on EKS Fargate | Infinite Loop
Issue -
State: open - Opened by akshayar about 2 years ago
#110 - What may be causing and how to work around StreamingQueryException: Gave up after 3 retries while fetching MetaData ?
Issue -
State: open - Opened by dgoldenberg-audiomack over 2 years ago
- 2 comments
#110 - What may be causing and how to work around StreamingQueryException: Gave up after 3 retries while fetching MetaData ?
Issue -
State: open - Opened by dgoldenberg-audiomack over 2 years ago
- 2 comments
#109 - Kinesis encrypted stream
Issue -
State: closed - Opened by BreakpointsCA over 2 years ago
- 1 comment
#109 - Kinesis encrypted stream
Issue -
State: closed - Opened by BreakpointsCA over 2 years ago
- 1 comment
#108 - Does this support kinesis fanout consumer ?
Issue -
State: open - Opened by itsmesrds over 2 years ago
#108 - Does this support kinesis fanout consumer ?
Issue -
State: open - Opened by itsmesrds over 2 years ago
#107 - Data not receiving from Kinesis
Issue -
State: open - Opened by success-m over 2 years ago
- 8 comments
#106 - Bump protobuf-java from 2.6.1 to 3.16.1
Pull Request -
State: closed - Opened by dependabot[bot] over 2 years ago
Labels: dependencies
#105 - Does Kinesis connector support reading compressed payloads on stream?
Issue -
State: open - Opened by sudeshnasengupta over 2 years ago
- 1 comment
#105 - Does Kinesis connector support reading compressed payloads on stream?
Issue -
State: open - Opened by sudeshnasengupta over 2 years ago
- 1 comment
#104 - Fix listShards to only specify nextToken
Pull Request -
State: open - Opened by Anthuang over 2 years ago
- 2 comments
#104 - Fix listShards to only specify nextToken
Pull Request -
State: open - Opened by Anthuang over 2 years ago
- 2 comments
#103 - client execution timeout configuration parameter
Pull Request -
State: open - Opened by gaborbarna over 2 years ago
- 1 comment
#103 - client execution timeout configuration parameter
Pull Request -
State: open - Opened by gaborbarna over 2 years ago
- 1 comment
#102 - How do I ensure checkpointing for kafka streams?
Issue -
State: open - Opened by Vikas-kum almost 3 years ago
- 2 comments
#102 - How do I ensure checkpointing for kafka streams?
Issue -
State: open - Opened by Vikas-kum almost 3 years ago
- 2 comments
#101 - Cannot restart the streaming job from where it stopped previously in the kinesis stream
Issue -
State: open - Opened by prashanthvg89 about 3 years ago
- 1 comment
#101 - Cannot restart the streaming job from where it stopped previously in the kinesis stream
Issue -
State: open - Opened by prashanthvg89 about 3 years ago
- 1 comment
#100 - Issue with Stream containing a lot of NO PUT ACTIVITY
Issue -
State: open - Opened by WTa-hash over 3 years ago
- 3 comments
#100 - Issue with Stream containing a lot of NO PUT ACTIVITY
Issue -
State: open - Opened by WTa-hash over 3 years ago
- 3 comments
#99 - Continuous trigger fails on Spark 3, but works on Spark 2.4.5
Issue -
State: open - Opened by pburner over 3 years ago
- 1 comment
Labels: enhancement
#99 - Continuous trigger fails on Spark 3, but works on Spark 2.4.5
Issue -
State: open - Opened by pburner over 3 years ago
- 1 comment
Labels: enhancement
#98 - Error in the Kinesis connector for reading data on AWS
Issue -
State: open - Opened by alokika-dash over 3 years ago
#98 - Error in the Kinesis connector for reading data on AWS
Issue -
State: open - Opened by alokika-dash over 3 years ago
#97 - ProvisionedThroughputExceededException and new batches are triggered even if avoidEmptyBatches=true
Issue -
State: open - Opened by juliankeppel over 3 years ago
- 6 comments
#97 - ProvisionedThroughputExceededException and new batches are triggered even if avoidEmptyBatches=true
Issue -
State: open - Opened by juliankeppel over 3 years ago
- 6 comments
#96 - Can't get newer records
Issue -
State: open - Opened by Tomaszuniek over 3 years ago
- 3 comments
#95 - Consumer requiring re-sharding of stream before starts consuming data
Issue -
State: open - Opened by marciodebarros over 3 years ago
- 1 comment
#94 - kinesis source timestamp (in milliseconds) starting position
Pull Request -
State: open - Opened by gaborbarna over 3 years ago
#94 - kinesis source timestamp (in milliseconds) starting position
Pull Request -
State: open - Opened by gaborbarna over 3 years ago
#93 - startingPosition AT_TIMESTAMP iteratorOption NumberFormatException
Issue -
State: open - Opened by adamlbailey almost 4 years ago
- 9 comments
#93 - startingPosition AT_TIMESTAMP iteratorOption NumberFormatException
Issue -
State: open - Opened by adamlbailey almost 4 years ago
- 9 comments
#92 - Support for Spark 3.0 and scala 2.12
Pull Request -
State: closed - Opened by itsvikramagr almost 4 years ago
#91 - StreamingQueryException: 'Error while Describe Stream
Issue -
State: closed - Opened by manishkaushik29 almost 4 years ago
- 1 comment
#91 - StreamingQueryException: 'Error while Describe Stream
Issue -
State: closed - Opened by manishkaushik29 almost 4 years ago
- 1 comment
#90 - Remove lastReadSequenceNumber.isEmpty condition
Pull Request -
State: closed - Opened by chadlagore almost 4 years ago
- 3 comments
#90 - Remove lastReadSequenceNumber.isEmpty condition
Pull Request -
State: closed - Opened by chadlagore almost 4 years ago
- 3 comments
#89 - Switch to use Kinesis list-shards API
Pull Request -
State: closed - Opened by chadlagore almost 4 years ago
- 7 comments
#89 - Switch to use Kinesis list-shards API
Pull Request -
State: closed - Opened by chadlagore almost 4 years ago
- 7 comments
#88 - Error On EMR 6.1 Spark 3.0
Issue -
State: closed - Opened by rubenssoto almost 4 years ago
- 2 comments
#87 - Not honoring maxFetchTimeInMs on empty streams
Issue -
State: closed - Opened by chadlagore almost 4 years ago
- 4 comments
#87 - Not honoring maxFetchTimeInMs on empty streams
Issue -
State: closed - Opened by chadlagore almost 4 years ago
- 4 comments
#86 - feat: Add ability to bundle all records from one micro-batch into PutRecords
Pull Request -
State: open - Opened by leslieyanyan almost 4 years ago
- 2 comments
#86 - feat: Add ability to bundle all records from one micro-batch into PutRecords
Pull Request -
State: open - Opened by leslieyanyan almost 4 years ago
- 2 comments
#85 - Missing org/apache/spark/internal/Logging$class
Issue -
State: closed - Opened by asafcombo almost 4 years ago
- 3 comments
#85 - Missing org/apache/spark/internal/Logging$class
Issue -
State: closed - Opened by asafcombo almost 4 years ago
- 3 comments
#84 - Loading credentials using Default Credential Provider Chain
Issue -
State: closed - Opened by m-radzikowski almost 4 years ago
- 1 comment
#84 - Loading credentials using Default Credential Provider Chain
Issue -
State: closed - Opened by m-radzikowski almost 4 years ago
- 1 comment
#83 - LimitExceededException with multiple running queries per application
Issue -
State: closed - Opened by chadlagore almost 4 years ago
- 3 comments
#83 - LimitExceededException with multiple running queries per application
Issue -
State: closed - Opened by chadlagore almost 4 years ago
- 3 comments
#82 - pyspark foreach/foreachPartition send http request failed
Issue -
State: closed - Opened by tmylt almost 4 years ago
#82 - pyspark foreach/foreachPartition send http request failed
Issue -
State: closed - Opened by tmylt almost 4 years ago
#81 - Fixing Kinesis Sink
Pull Request -
State: closed - Opened by abhishekd0907 almost 4 years ago
- 1 comment
#81 - Fixing Kinesis Sink
Pull Request -
State: closed - Opened by abhishekd0907 almost 4 years ago
- 1 comment
#80 - Support scala 2.12?
Issue -
State: closed - Opened by arnehuang about 4 years ago
- 4 comments
#80 - Support scala 2.12?
Issue -
State: closed - Opened by arnehuang about 4 years ago
- 4 comments
#79 - Fix retries while making Kinesis API calls
Pull Request -
State: closed - Opened by itsvikramagr about 4 years ago
#79 - Fix retries while making Kinesis API calls
Pull Request -
State: closed - Opened by itsvikramagr about 4 years ago
#78 - Adding ability to set exact Kinesis position to start reading from
Pull Request -
State: closed - Opened by snorochevskiy about 4 years ago
- 2 comments
#78 - Adding ability to set exact Kinesis position to start reading from
Pull Request -
State: closed - Opened by snorochevskiy about 4 years ago
- 2 comments
#77 - Authentication with session token not working in PySpark
Issue -
State: closed - Opened by pcojocar about 4 years ago
- 5 comments
#76 - Apply retries to kinesis exceptions with status code >= 500
Pull Request -
State: closed - Opened by arnehuang about 4 years ago
- 2 comments
#76 - Apply retries to kinesis exceptions with status code >= 500
Pull Request -
State: closed - Opened by arnehuang about 4 years ago
- 2 comments
#75 - Spark job is failing because of AmazonKinesisException: null (Service: AmazonKinesis; Status Code: 503
Issue -
State: closed - Opened by levontr over 4 years ago
- 5 comments
#74 - Null pointer exception when trying to read stream in cluster mode
Issue -
State: closed - Opened by HariprasadAllaka1612 over 4 years ago
- 2 comments
#74 - Null pointer exception when trying to read stream in cluster mode
Issue -
State: closed - Opened by HariprasadAllaka1612 over 4 years ago
- 2 comments
#73 - intergation with localstack
Issue -
State: open - Opened by haniaruc over 4 years ago
- 1 comment
Labels: enhancement
#72 - Added session based authentication
Pull Request -
State: closed - Opened by guoming-xu over 4 years ago
#72 - Added session based authentication
Pull Request -
State: closed - Opened by guoming-xu over 4 years ago
#71 - Make DefaultAWSCredentialsProviderChain available to choose
Pull Request -
State: closed - Opened by hyeonseop-lee over 4 years ago
- 2 comments
#71 - Make DefaultAWSCredentialsProviderChain available to choose
Pull Request -
State: closed - Opened by hyeonseop-lee over 4 years ago
- 2 comments
#70 - Not supporting sessionToken/securityToken?
Issue -
State: closed - Opened by guoming-xu over 4 years ago
- 2 comments
#70 - Not supporting sessionToken/securityToken?
Issue -
State: closed - Opened by guoming-xu over 4 years ago
- 2 comments
#69 - passing aws_iam_role instead of awsSecretKey/awsAccessKeyId
Issue -
State: closed - Opened by cezgit over 4 years ago
- 1 comment
#69 - passing aws_iam_role instead of awsSecretKey/awsAccessKeyId
Issue -
State: closed - Opened by cezgit over 4 years ago
- 1 comment
#68 - Fix pom.xml
Pull Request -
State: closed - Opened by juliankeppel over 4 years ago
#67 - Maven build error
Issue -
State: closed - Opened by juliankeppel over 4 years ago
- 5 comments
#67 - Maven build error
Issue -
State: closed - Opened by juliankeppel over 4 years ago
- 5 comments
#66 - Kinesis Enhanced fan-out consumer ( using consumer ARN)
Issue -
State: open - Opened by senthilkumarkk over 4 years ago
- 3 comments
Labels: enhancement, good first issue
#66 - Kinesis Enhanced fan-out consumer ( using consumer ARN)
Issue -
State: open - Opened by senthilkumarkk over 4 years ago
- 3 comments
Labels: enhancement, good first issue
#65 - source configuration to set idle time between reads and to support per-shard read positions
Pull Request -
State: closed - Opened by PranshuAdhikari over 4 years ago
- 1 comment
#65 - source configuration to set idle time between reads and to support per-shard read positions
Pull Request -
State: closed - Opened by PranshuAdhikari over 4 years ago
- 1 comment
#64 - publish to maven central
Issue -
State: closed - Opened by israel over 4 years ago
- 5 comments
#64 - publish to maven central
Issue -
State: closed - Opened by israel over 4 years ago
- 5 comments
#63 - Fix issue with Reprocessing oldshards issue
Pull Request -
State: closed - Opened by itsvikramagr over 4 years ago
- 1 comment
#62 - Fix Deserialisation/Serialisation of KinesisOffsets
Pull Request -
State: closed - Opened by itsvikramagr over 4 years ago
#62 - Fix Deserialisation/Serialisation of KinesisOffsets
Pull Request -
State: closed - Opened by itsvikramagr over 4 years ago
#61 - to prevent the reprocessing of already processed records after scaling the shards.
Pull Request -
State: closed - Opened by PranshuAdhikari over 4 years ago
- 1 comment
#60 - reprocessing of already processed records after scaling the shards.
Issue -
State: closed - Opened by PranshuAdhikari over 4 years ago
- 1 comment
#59 - Handle deleted shards
Pull Request -
State: closed - Opened by itsvikramagr over 4 years ago
- 7 comments
#58 - Do we have support foreachbatch sinks
Issue -
State: closed - Opened by HariprasadAllaka1612 over 4 years ago
- 1 comment