[jira] [Created] (FLINK-24287) Bump virtualenv to the latest version

2021-09-14 Thread Dian Fu (Jira)
Dian Fu created FLINK-24287: --- Summary: Bump virtualenv to the latest version Key: FLINK-24287 URL: https://issues.apache.org/jira/browse/FLINK-24287 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24286) Flink TableEnvironment executesql on IntelliJ leads to Could not find a file system implementation for scheme 's3a'

2021-09-14 Thread James Kim (Jira)
James Kim created FLINK-24286: - Summary: Flink TableEnvironment executesql on IntelliJ leads to Could not find a file system implementation for scheme 's3a' Key: FLINK-24286 URL:

[jira] [Created] (FLINK-24285) Flink Table API Could not find any format factory for identifier 'csv' in the classpath.

2021-09-14 Thread James Kim (Jira)
James Kim created FLINK-24285: - Summary: Flink Table API Could not find any format factory for identifier 'csv' in the classpath. Key: FLINK-24285 URL: https://issues.apache.org/jira/browse/FLINK-24285

Re: Beam with Flink runner - Issues when writing to S3 in Parquet Format

2021-09-14 Thread David Morávek
Hi Sandeep, Jan has already provided pretty good guidelines for getting more context on the issue ;) Because this is not for the first time, I would like to raise awareness, that it's not OK to send a user related question to four Apache mailing list (that I know of). Namely: -

Beam with Flink runner - Issues when writing to S3 in Parquet Format

2021-09-14 Thread Kathula, Sandeep
Hi, We have a simple Beam application which reads from Kafka, converts to parquet and write to S3 with Flink runner (Beam 2.29 and Flink 1.12). We have a fixed window of 5 minutes after conversion to PCollection and then writing to S3. We have around 320 columns in our data. Our intention is

[jira] [Created] (FLINK-24284) Add a greeter and a showcase for the JavaScript SDK

2021-09-14 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-24284: Summary: Add a greeter and a showcase for the JavaScript SDK Key: FLINK-24284 URL: https://issues.apache.org/jira/browse/FLINK-24284 Project: Flink Issue

[jira] [Created] (FLINK-24283) Pulsar connector won't use given hash ranges in Key_Shared mode

2021-09-14 Thread Yufan Sheng (Jira)
Yufan Sheng created FLINK-24283: --- Summary: Pulsar connector won't use given hash ranges in Key_Shared mode Key: FLINK-24283 URL: https://issues.apache.org/jira/browse/FLINK-24283 Project: Flink

[jira] [Created] (FLINK-24282) KafkaRecordSerializationSchema TopicSelector is not serializable

2021-09-14 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-24282: --- Summary: KafkaRecordSerializationSchema TopicSelector is not serializable Key: FLINK-24282 URL: https://issues.apache.org/jira/browse/FLINK-24282 Project: Flink

Re: Contribute to Flink StateFun

2021-09-14 Thread Igal Shilman
Hi Evans, Welcome aboard :) I'll definitely keep that in mind! Meanwhile I would also like to point out that Statefun is built using Apache Flink, and any improvement in Flink, directly contributes to StateFun, so I would definitely encourage you to consider contributing to Flink as-well, I'm

[jira] [Created] (FLINK-24281) Migrate all existing tests to new Kafka Sink

2021-09-14 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-24281: --- Summary: Migrate all existing tests to new Kafka Sink Key: FLINK-24281 URL: https://issues.apache.org/jira/browse/FLINK-24281 Project: Flink Issue Type:

[jira] [Created] (FLINK-24280) Support manual checkpoints triggering from a MiniCluster

2021-09-14 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24280: Summary: Support manual checkpoints triggering from a MiniCluster Key: FLINK-24280 URL: https://issues.apache.org/jira/browse/FLINK-24280 Project: Flink

Contribute to Flink StateFun

2021-09-14 Thread Evans Ye
Hi team, I'm Evans Ye and I'd like to contribute more to the Flink StateFun project. Previously Gordon gave me a hand on mentoring me thus I had a lot of fun contributing to the multi-lang E2E tests framework. I know that the project PMC got a direction of the project, so it would be great if the

[jira] [Created] (FLINK-24279) Support withBroadcast in DataStream API

2021-09-14 Thread ZHANG ZHIPENG (Jira)
ZHANG ZHIPENG created FLINK-24279: - Summary: Support withBroadcast in DataStream API Key: FLINK-24279 URL: https://issues.apache.org/jira/browse/FLINK-24279 Project: Flink Issue Type: New

[jira] [Created] (FLINK-24278) [FLIP-171] Async Sink Base Sink Developer Guide for Documentation

2021-09-14 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-24278: -- Summary: [FLIP-171] Async Sink Base Sink Developer Guide for Documentation Key: FLINK-24278 URL: https://issues.apache.org/jira/browse/FLINK-24278 Project: Flink

退订

2021-09-14 Thread pang pan

[jira] [Created] (FLINK-24277) Offset commit should be disabled if consumer group ID is not specified in KafkaSource

2021-09-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-24277: - Summary: Offset commit should be disabled if consumer group ID is not specified in KafkaSource Key: FLINK-24277 URL: https://issues.apache.org/jira/browse/FLINK-24277