Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / googleclouddataproc/flink-bigquery-connector issues and pull requests

#181 - Fix restart strategy in e2e test

Pull Request - State: closed - Opened by jayehwhyehentee 13 days ago

#180 - Revert "Update CHANGES.md"

Pull Request - State: closed - Opened by jayehwhyehentee 19 days ago

#179 - [DO NOT MERGE] Modified Unbounded Integration Tests to read from GCS Bucket

Pull Request - State: open - Opened by shashambhavi 19 days ago - 5 comments

#178 - Add integration tests for exactly-once

Pull Request - State: closed - Opened by jayehwhyehentee 19 days ago

#177 - Included an unshaded guava specifically for BigQuery usage.

Pull Request - State: closed - Opened by nika-qubit 19 days ago - 1 comment

#176 - Troubleshooting Guide

Pull Request - State: open - Opened by prashastia 20 days ago

#175 - Update CHANGES.md

Pull Request - State: closed - Opened by jayehwhyehentee 22 days ago

#174 - Elaborate on restart strategy enforcement

Pull Request - State: closed - Opened by jayehwhyehentee 24 days ago

#173 - Update `Readme.md`

Pull Request - State: closed - Opened by prashastia 24 days ago

#172 - Update examples, readme and changes md

Pull Request - State: closed - Opened by jayehwhyehentee 25 days ago

#171 - Add Flink Metrics for exactly once approach

Pull Request - State: closed - Opened by prashastia 25 days ago

#170 - Add support for Flink Metrics in Atleast Once Approach.

Pull Request - State: closed - Opened by prashastia 27 days ago - 1 comment

#169 - Revert "Addition of Flink Metrics in Atleast Once Implementation."

Pull Request - State: closed - Opened by jayehwhyehentee about 1 month ago

#168 - Implement Sink Class For Exactly Once

Pull Request - State: closed - Opened by jayehwhyehentee about 1 month ago

#167 - questions: how to write timestamp schema information using avro

Issue - State: closed - Opened by caicancai about 1 month ago - 3 comments

#166 - Question: How to synchronize string correctly

Issue - State: closed - Opened by caicancai about 1 month ago - 6 comments

#165 - Bump org.apache.avro:avro from 1.11.3 to 1.11.4

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 1 comment
Labels: dependencies, java

#164 - Improve debugability

Pull Request - State: closed - Opened by prashastia about 2 months ago - 1 comment

#163 - imporve: tinyint should convert byte

Pull Request - State: closed - Opened by caicancai about 2 months ago - 9 comments

#162 - question: BigQuery's datetime type is not supported

Issue - State: closed - Opened by caicancai about 2 months ago - 16 comments

#161 - feat: support flink1.18

Pull Request - State: closed - Opened by caicancai about 2 months ago - 2 comments

#160 - feat: support flink1.18

Issue - State: closed - Opened by caicancai about 2 months ago - 1 comment

#159 - Preparing for next release

Pull Request - State: closed - Opened by prashastia about 2 months ago

#158 - Track Read and Write API usage

Pull Request - State: closed - Opened by prashastia about 2 months ago

#157 - Committer for exactly once sink

Pull Request - State: closed - Opened by jayehwhyehentee about 2 months ago - 3 comments

#156 - Buffered writer for exactly once sink

Pull Request - State: closed - Opened by jayehwhyehentee about 2 months ago - 1 comment

#155 - Support for upserts

Issue - State: closed - Opened by mkozik-lb 2 months ago - 1 comment

#154 - Addition of Flink Metrics in Atleast Once Implementation.

Pull Request - State: closed - Opened by prashastia 2 months ago

#153 - IllegalArgumentException: Project ID required for service

Issue - State: open - Opened by HitenUnify 2 months ago - 1 comment

#152 - BQ write client for exactly once

Pull Request - State: closed - Opened by jayehwhyehentee 2 months ago - 1 comment

#151 - Add signatures for exactly once sink

Pull Request - State: closed - Opened by jayehwhyehentee 2 months ago - 1 comment

#150 - Exo writer

Pull Request - State: closed - Opened by jayehwhyehentee 2 months ago

#149 - Exo write client

Pull Request - State: closed - Opened by jayehwhyehentee 2 months ago

#148 - Add signatures for exactly once sink

Pull Request - State: closed - Opened by jayehwhyehentee 2 months ago

#146 - fix: BQ partition utils intervals

Pull Request - State: closed - Opened by amstee 3 months ago - 5 comments

#145 - Update changes md for next release

Pull Request - State: closed - Opened by prashastia 3 months ago - 2 comments

#144 - Adds more config options to the connector.

Pull Request - State: closed - Opened by prashastia 4 months ago - 3 comments

#143 - Add null check for execution env in sink [DO_NOT_MERGE]

Pull Request - State: closed - Opened by jayehwhyehentee 4 months ago

#142 - Documentation changes for 0.3.0

Pull Request - State: closed - Opened by prashastia 4 months ago

#141 - Adds Integration tests for Table API Implementation.

Pull Request - State: closed - Opened by prashastia 4 months ago

#140 - Modify storage client faker to create different instances

Pull Request - State: closed - Opened by jayehwhyehentee 4 months ago

#139 - Bump to next version

Pull Request - State: closed - Opened by jayehwhyehentee 4 months ago - 1 comment

#138 - Bump certifi from 2023.11.17 to 2024.7.4 in /cloudbuild/nightly/scripts/python-scripts

Pull Request - State: closed - Opened by dependabot[bot] 4 months ago - 1 comment
Labels: dependencies, python

#137 - Implementation for `BigQueryDynamicSink` and `BigQueryDynamicSinkFactory`

Pull Request - State: closed - Opened by prashastia 5 months ago - 1 comment

#136 - Adds implementation for `AvroToRowDataConvertors`

Pull Request - State: closed - Opened by prashastia 5 months ago

#135 - [DSP-113] fixes for source connector

Pull Request - State: closed - Opened by jeremyb-ps 5 months ago - 1 comment

#134 - [Q] Unbounded source data freshness ?

Issue - State: closed - Opened by jeremyb-ps 5 months ago

#131 - Bump urllib3 from 2.1.0 to 2.2.2 in /cloudbuild/nightly/scripts/python-scripts

Pull Request - State: closed - Opened by dependabot[bot] 5 months ago - 1 comment
Labels: dependencies, python

#130 - Adds tests for `BigQueryReadTableConfig` and `BigQueryConnectorOptions`

Pull Request - State: closed - Opened by prashastia 5 months ago - 1 comment

#129 - Adds more tests for `RowDataProtoSerializer`

Pull Request - State: closed - Opened by prashastia 5 months ago - 1 comment

#128 - Modifies Table API `AvroSchemaConvertor` implementation.

Pull Request - State: closed - Opened by prashastia 5 months ago - 2 comments

#127 - Increase sink max parallelism

Pull Request - State: closed - Opened by jayehwhyehentee 5 months ago - 1 comment

#125 - Adds more tests for the serializer

Pull Request - State: closed - Opened by prashastia 5 months ago - 2 comments

#124 - Initial implementation of the serializer for Table API Support.

Pull Request - State: closed - Opened by prashastia 6 months ago - 2 comments

#122 - POC of the Table API

Pull Request - State: closed - Opened by prashastia 6 months ago - 1 comment

#121 - Bump requests from 2.31.0 to 2.32.0 in /cloudbuild/nightly/scripts/python-scripts

Pull Request - State: closed - Opened by dependabot[bot] 6 months ago - 1 comment
Labels: dependencies, python

#120 - Release 0.2.0

Pull Request - State: closed - Opened by jayehwhyehentee 6 months ago - 2 comments

#119 - Optimization for handleUnionSchema.

Pull Request - State: closed - Opened by prashastia 6 months ago - 4 comments

#118 - WIP: Improving Union handling

Pull Request - State: open - Opened by talatuyarer 7 months ago

#117 - Prepare for 0.2.0-preview release

Pull Request - State: closed - Opened by jayehwhyehentee 7 months ago

#116 - Prepare for release to maven

Pull Request - State: closed - Opened by jayehwhyehentee 7 months ago

#115 - Local build generate non consumable pom files

Pull Request - State: closed - Opened by talatuyarer 7 months ago - 5 comments

#114 - Add distribution management in pom for nexus

Pull Request - State: closed - Opened by jayehwhyehentee 7 months ago - 1 comment

#113 - Documentation Updates

Pull Request - State: closed - Opened by jayehwhyehentee 7 months ago - 2 comments

#112 - Modifies documentation for Integration Test file

Pull Request - State: closed - Opened by prashastia 7 months ago

#111 - Changes to make sure dataproc 2.2 runs.

Pull Request - State: closed - Opened by prashastia 7 months ago - 1 comment

#110 - Integration Tests for Sink Implementation

Pull Request - State: closed - Opened by prashastia 7 months ago

#109 - Add nexus release profile

Pull Request - State: closed - Opened by jayehwhyehentee 7 months ago - 1 comment

#108 - Update changes md

Pull Request - State: closed - Opened by jayehwhyehentee 7 months ago - 1 comment

#107 - Add a changes md file

Pull Request - State: closed - Opened by jayehwhyehentee 7 months ago

#106 - Bump idna from 3.6 to 3.7 in /cloudbuild/nightly/scripts/python-scripts

Pull Request - State: closed - Opened by dependabot[bot] 7 months ago - 1 comment
Labels: dependencies, python

#105 - Default sink implementation

Pull Request - State: closed - Opened by jayehwhyehentee 7 months ago - 3 comments

#102 - Add the ability to write results of Flink jobs to BigQuery tables

Issue - State: closed - Opened by Moustafazeinhaat 8 months ago - 1 comment

#101 - Adds support for `serialize()` for Logical Types datatypes.

Pull Request - State: closed - Opened by prashastia 8 months ago

#99 - Adds implementation to enable conversion of AvroSchema to Descriptor Proto.

Pull Request - State: closed - Opened by prashastia 8 months ago - 3 comments

#98 - Support Write Client In BQ Services

Pull Request - State: closed - Opened by jayehwhyehentee 8 months ago - 1 comment

#97 - Obtain BQ table schema and convert to avro schema

Pull Request - State: closed - Opened by prashastia 9 months ago

#95 - Adds Serialisation Methods: Obtain Descriptor from Avro Schema.

Pull Request - State: closed - Opened by prashastia 9 months ago - 1 comment

#94 - Define signatures for default sink

Pull Request - State: closed - Opened by jayehwhyehentee 9 months ago - 1 comment

#92 - Define skeletal interfaces and classes for sink

Pull Request - State: closed - Opened by jayehwhyehentee 9 months ago

#91 - Define skeletal interfaces and classes for sink

Pull Request - State: closed - Opened by jayehwhyehentee 9 months ago - 1 comment

#90 - Bump avro from 1.11.1 to 1.11.3 in /cloudbuild/nightly/scripts/python-scripts

Pull Request - State: closed - Opened by dependabot[bot] 10 months ago - 3 comments
Labels: dependencies, python

#89 - BQ Sink POC

Pull Request - State: open - Opened by jayehwhyehentee 10 months ago

#88 - Fixes the unbounded read test for the nightly job.

Pull Request - State: closed - Opened by prashastia 10 months ago - 2 comments

#86 - Bump avro from 1.11.1 to 1.11.3 in /cloudbuild/python-scripts

Pull Request - State: closed - Opened by dependabot[bot] 11 months ago - 2 comments
Labels: dependencies, python

#85 - Adds yaml file for nightly cancel job

Pull Request - State: closed - Opened by prashastia 11 months ago - 1 comment

#84 - Adds dockerfile and requirements.txt for the execution of the script.

Pull Request - State: closed - Opened by prashastia 11 months ago - 1 comment

#83 - Adds shell script that executes job cancellation, cluster and bucket deletion.

Pull Request - State: closed - Opened by prashastia 11 months ago - 1 comment