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

#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

#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

#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

#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

#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

#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

#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

#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