Hi,I am trying to use the Table API which will convert the Table data into
Datastream. API is StreamTableEnvironment.toChangelogStream(Table table).I have
noticed that its parallelism is always single i.e. One (1). How can set more
than one?
If it is intended to execute with a single thread
rs
for debugging. And it is more suitable for flow batch integration.For a small
part of jobs which can not be expressed through SQL, we will choose a job by
DataStream API.
Best,Hang
ravi_suryavanshi.yahoo.com via user 于2023年3月24日周五
17:25写道：
Hello Team,Need your advice on which method is recomm
ink the SQL job is better. Flink SQL jobs can be easily shared with others
for debugging. And it is more suitable for flow batch integration.For a small
part of jobs which can not be expressed through SQL, we will choose a job by
DataStream API.
Best,Hang
ravi_suryavanshi.yahoo.com via user 于2023
Hello Team,Need your advice on which method is recommended considering don't
want to change my query code when the Flink is updated/upgraded to the higher
version.
Here I am seeking advice for writing the SQL using java code(Table API
function and Expression) or using pure SQL.
I am assuming
he.org/jira/issues/?jql=project%20%3D%20FLINK
. I have used kafka/jdbc/hive in production too, they work well.
Best,Shammon
On Fri, Mar 10, 2023 at 1:42 AM Yaroslav Tkachenko wrote:
Hi Ravi,
All of them should be production ready. I've personally used half of them in
production.
Do you hav
?
On Thu, Mar 9, 2023 at 9:39 AM ravi_suryavanshi.yahoo.com via user
wrote:
Hi,Can anyone help me here?
Thanks and regards,Ravi
On Monday, 27 February, 2023 at 09:33:18 am IST, ravi_suryavanshi.yahoo.com
via user wrote:
Hi Team,
In Flink 1.16.0, we would like to use some
Hi,Can anyone help me here?
Thanks and regards,Ravi
On Monday, 27 February, 2023 at 09:33:18 am IST, ravi_suryavanshi.yahoo.com
via user wrote:
Hi Team,
In Flink 1.16.0, we would like to use some of the Table API Connectors for
production. Kindly let me know if the below connectors
Hi Team,
In Flink 1.16.0, we would like to use some of the Table API Connectors for
production. Kindly let me know if the below connectors are production ready or
only for testing purposes.
| Name | Version | Source | Sink |
| Filesystem | | Bounded and Unbounded Scan, Lookup | Streaming
