issues
search
GoogleCloudDataproc
/
flink-bigquery-connector
BigQuery integration to Apache Flink's Table API
Apache License 2.0
23
stars
14
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Implementation for `BigQueryDynamicSink` and `BigQueryDynamicSinkFactory`
#137
prashastia
closed
3 months ago
1
Adds implementation for `AvroToRowDataConvertors`
#136
prashastia
closed
4 months ago
0
[DSP-113] fixes for source connector
#135
jeremyb-ps
closed
4 months ago
1
[Q] Unbounded source data freshness ?
#134
jeremyb-ps
closed
4 months ago
0
_PARTITIONTIME do not appear on TableSchema, causing an Exception on `streamAvros`
#133
antonioc-ps
closed
3 months ago
2
Table API Implementation: `BigQuerySinkTableConfig` and `BigQueryConnectorOptions`
#132
prashastia
closed
4 months ago
1
Bump urllib3 from 2.1.0 to 2.2.2 in /cloudbuild/nightly/scripts/python-scripts
#131
dependabot[bot]
closed
4 months ago
1
Adds tests for `BigQueryReadTableConfig` and `BigQueryConnectorOptions`
#130
prashastia
closed
4 months ago
1
Adds more tests for `RowDataProtoSerializer`
#129
prashastia
closed
4 months ago
1
Modifies Table API `AvroSchemaConvertor` implementation.
#128
prashastia
closed
4 months ago
2
Increase sink max parallelism
#127
jayehwhyehentee
closed
5 months ago
1
Table API implementation is unable to read BigNumeric Records
#126
prashastia
opened
5 months ago
0
Adds more tests for the serializer
#125
prashastia
closed
5 months ago
2
Initial implementation of the serializer for Table API Support.
#124
prashastia
closed
5 months ago
2
java.lang.NoSuchMethodError: 'com.google.common.collect.ImmutableMap com.google.common.collect.ImmutableMap$Builder.buildKeepingLast()
#123
tao-cxs
opened
5 months ago
1
POC of the Table API
#122
prashastia
closed
2 months ago
1
Bump requests from 2.31.0 to 2.32.0 in /cloudbuild/nightly/scripts/python-scripts
#121
dependabot[bot]
closed
5 months ago
1
Release 0.2.0
#120
jayehwhyehentee
closed
6 months ago
2
Optimization for handleUnionSchema.
#119
prashastia
closed
5 months ago
4
WIP: Improving Union handling
#118
talatuyarer
closed
1 day ago
2
Prepare for 0.2.0-preview release
#117
jayehwhyehentee
closed
6 months ago
0
Prepare for release to maven
#116
jayehwhyehentee
closed
6 months ago
0
Local build generate non consumable pom files
#115
talatuyarer
closed
6 months ago
5
Add distribution management in pom for nexus
#114
jayehwhyehentee
closed
6 months ago
1
Documentation Updates
#113
jayehwhyehentee
closed
7 months ago
2
Modifies documentation for Integration Test file
#112
prashastia
closed
7 months ago
0
Changes to make sure dataproc 2.2 runs.
#111
prashastia
closed
7 months ago
1
Integration Tests for Sink Implementation
#110
prashastia
closed
7 months ago
0
Add nexus release profile
#109
jayehwhyehentee
closed
7 months ago
1
Update changes md
#108
jayehwhyehentee
closed
7 months ago
1
Add a changes md file
#107
jayehwhyehentee
closed
7 months ago
0
Bump idna from 3.6 to 3.7 in /cloudbuild/nightly/scripts/python-scripts
#106
dependabot[bot]
closed
7 months ago
1
Default sink implementation
#105
jayehwhyehentee
closed
7 months ago
3
Adds support for `serialize()` for Primitive, `RECORD`, `UNION` and `ARRAY` datatypes.
#104
prashastia
closed
7 months ago
1
Implements conversion of `ARRAY` avro type to be converted to Bigquery Descriptors.
#103
prashastia
closed
7 months ago
0
Add the ability to write results of Flink jobs to BigQuery tables
#102
Moustafazeinhaat
closed
6 months ago
1
Adds support for `serialize()` for Logical Types datatypes.
#101
prashastia
closed
7 months ago
0
Implements conversion of `MAP` and `ARRAY` avro type to be converted to Bigquery Descriptors.
#100
prashastia
closed
7 months ago
1
Adds implementation to enable conversion of AvroSchema to Descriptor Proto.
#99
prashastia
closed
7 months ago
3
Support Write Client In BQ Services
#98
jayehwhyehentee
closed
7 months ago
1
Obtain BQ table schema and convert to avro schema
#97
prashastia
closed
8 months ago
0
Approach to add support for conversion of Avro Records to ByteString to write using the Storage API
#96
prashastia
closed
8 months ago
2
Adds Serialisation Methods: Obtain Descriptor from Avro Schema.
#95
prashastia
closed
8 months ago
1
Define signatures for default sink
#94
jayehwhyehentee
closed
8 months ago
1
Enabling profile support - Added separate modules for flink version 1.17
#93
prashastia
closed
7 months ago
0
Define skeletal interfaces and classes for sink
#92
jayehwhyehentee
closed
9 months ago
0
Define skeletal interfaces and classes for sink
#91
jayehwhyehentee
closed
9 months ago
1
Bump avro from 1.11.1 to 1.11.3 in /cloudbuild/nightly/scripts/python-scripts
#90
dependabot[bot]
closed
7 months ago
3
BQ Sink POC
#89
jayehwhyehentee
closed
1 day ago
0
Fixes the unbounded read test for the nightly job.
#88
prashastia
closed
10 months ago
2
Previous
Next