Thanks Lasse, I think you can create an issue and update the document if
there is any wrong
Best,
Shammon FY
On Wed, Mar 29, 2023 at 3:48 AM Lasse Nedergaard <
lassenedergaardfl...@gmail.com> wrote:
> Hi.
> I have figured it out. The documentation are wrong in both places.
>
> Med venlig hilsen
Hi Lasse
Does your job table/sql or datastream? Here's the doc [1] for customized
source in table and there is an example of socket source.
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/
Best,
Shammon FY
On Mon, Mar 27, 2023 at 8:02 PM Lasse Nedergaard <
Hi Bin,
Flinks Kafka source has been rewritten using the new Source API.
You can find it here:
https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java
On Wed, Aug 4, 2021 at 8:51 PM Xinbin Huang wro
Hi Roman,
In general, the use of inconsistent types is discouraged but there is
little that you can do on your end.
I think your approach with SourceFunction is good but I'd probably not use
Row already but rather some POJO or source format record. Note, that I have
never seen side-outputs in a s
Hi!
I have the class, I want to create objects using the values extraced from
the JSON text, my fault haha.
Sorry for that
2016-05-15 19:10 GMT+02:00 Gábor Horváth :
> Hi!
>
> On 14 May 2016 at 23:47, iñaki williams wrote:
>
>> Hi Flink Community!
>>
>> I am new using Apache Flink and I have a
Hi!
On 14 May 2016 at 23:47, iñaki williams wrote:
> Hi Flink Community!
>
> I am new using Apache Flink and I have a problem reading a JSON.
>
> I am using a JSON from a webpage, this JSON is changing continuosly so I
> decided to use my own Source Function in order to grab the JSON using a URL
