Neng Lu

We have S3 Uploader which upload the topology with given creds. But there's no S3 downloader for getting the uploaded topology file into containers. And a general HttpDownloader doesn't work...

Need to update api/v1beta1/zz_generated.deepcopy.go

1

Hi, I just ran `make generate` against the master branch with latest commit: ``` commit 0310df76d6e2128cd5d2bc51fae4e842d370c463 (HEAD -> master, origin/master, origin/HEAD) Author: GoogleCloudPlatform Date: Sun Feb 28 21:07:18 2021 +0000...

**Is your feature request related to a problem? Please describe.** A clear and concise description of what the problem is. Ex. I'm always frustrated when [...] **Describe the solution you'd...

Due to the CVE: https://nvd.nist.gov/vuln/detail/CVE-2021-22569 Reference the fix in Apache Pulsar: https://github.com/apache/pulsar/pull/13695 Note: I also tried to update the protobuf plugin (com.github.os72:protoc-jar-maven-plugin), but there's no newer release other than 3.11.4...

There are many dangling code (especially some new connector flies) in the repo that is not being used. It increases the barrier to fully understand things in this repo

[BUG] Fail to Insert into an upsert table

2

**Describe the bug** Fail to create correct table sink when inserting into an upsert table **To Reproduce** for table: ``` CREATE TABLE some_table ( `order_id` STRING, `transaction_time` STRING, .... PRIMARY...

[BUG] Pulsar Properties is not handled correctly when creating sink

1

**Describe the bug** When using `properties.pulsar.blockIfQueueFull` in the table config for sink, the flink job fails to run with the follow exception: ``` Caused by: org.apache.pulsar.shade.com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: Unrecognized field "blockifqueuefull" (class...

**Describe the bug** The `upsert-pulsar` connector is not supported in current setting **To Reproduce** Steps to reproduce the behavior: 1. Go to '...' 2. Click on '....' 3. Scroll down...

We need to find a way to return the row with additional pulsar message's metadata columns to help user do some queries based on these meta information