Re: [PROPOSAL] Contribute Flink CDC Connectors project to Apache Flink

2023-12-12 Thread Krzysztof Zarzycki
Hello, I'm super excited that Flink CDC will join the Flink project! It will be so much easier to bring it into Flink-based projects we run. As I understand you're thinking with Flink CDC 3.0 to make the project broader than CDC, as more "Streaming Integration" framework. This will resemble Kafka

Re: [DISCUSS] Implementing SQL remote functions

2023-09-27 Thread Krzysztof Zarzycki
Hello Alan, At my company we implemented an open source Flink HTTP connector, that you might find interesting. It can be represented as a source table as well and be used in lookups. Here is the link https://github.com/getindata/flink-http-connector Best Krzysztof On Thu, Sep 21, 2023 at 7:34 

Re: Dynamic Flink SQL

2020-03-27 Thread Krzysztof Zarzycki
discussed above. [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/experimental.html#reinterpreting-a-pre-partitioned-data-stream-as-keyed-stream [2] https://flink.apache.org/news/2020/03/24/demo-fraud-detection-2.html > On Wed, Mar 25, 2020 at 6:15 PM Krzysztof Zarz

Re: Dynamic Flink SQL

2020-03-25 Thread Krzysztof Zarzycki
resulting code would be minimal > and easy to maintain. If the performance is not satisfying, you can always > make it more complicated. > > Best, > > Arvid > > > On Mon, Mar 23, 2020 at 7:02 PM Krzysztof Zarzycki > wrote: > >> Dear Flink community! >> >&

Dynamic Flink SQL

2020-03-23 Thread Krzysztof Zarzycki
Dear Flink community! In our company we have implemented a system that realize the dynamic business rules pattern. We spoke about it during Flink Forward 2019 https://www.youtube.com/watch?v=CyrQ5B0exqU. The system is a great success and we would like to improve it. Let me shortly mention what

[jira] [Created] (FLINK-3027) Cancel button in Flink job dashboard does not work

2015-11-17 Thread Krzysztof Zarzycki (JIRA)
Krzysztof Zarzycki created FLINK-3027: - Summary: Cancel button in Flink job dashboard does not work Key: FLINK-3027 URL: https://issues.apache.org/jira/browse/FLINK-3027 Project: Flink