Spongebob created FLINK-33855:
-
Summary: send flag message like checkpoint barrier
Key: FLINK-33855
URL: https://issues.apache.org/jira/browse/FLINK-33855
Project: Flink
Issue Type: Technical
[
https://issues.apache.org/jira/browse/FLINK-32970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-32970.
-
Resolution: Won't Fix
> could not load external class using "-C" option
>
[
https://issues.apache.org/jira/browse/FLINK-32970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760800#comment-17760800
]
Spongebob commented on FLINK-32970:
---
Hi [~martijnvisser] , I think I should not create another
[
https://issues.apache.org/jira/browse/FLINK-32970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-32970:
--
Description:
Firstly, the "connectors.jar" contains "test-connector" and I put it in user
libs.
Spongebob created FLINK-32970:
-
Summary: could not load external class using "-C" option
Key: FLINK-32970
URL: https://issues.apache.org/jira/browse/FLINK-32970
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-32361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-32361.
-
Resolution: Cannot Reproduce
> error after replace dependent jar file
>
[
https://issues.apache.org/jira/browse/FLINK-32739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-32739.
-
Resolution: Not A Problem
> restarting not work
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-32739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750937#comment-17750937
]
Spongebob commented on FLINK-32739:
---
Thanks [~JunRuiLi] , this option helps. When one of regions
[
https://issues.apache.org/jira/browse/FLINK-32739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750648#comment-17750648
]
Spongebob edited comment on FLINK-32739 at 8/3/23 9:44 AM:
---
[~JunRuiLi] Hi
[
https://issues.apache.org/jira/browse/FLINK-32739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750648#comment-17750648
]
Spongebob edited comment on FLINK-32739 at 8/3/23 9:44 AM:
---
[~JunRuiLi] Hi
[
https://issues.apache.org/jira/browse/FLINK-32739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750648#comment-17750648
]
Spongebob commented on FLINK-32739:
---
[~JunRuiLi] Hi Junrui, I had uploaded the JM partitial logs
[
https://issues.apache.org/jira/browse/FLINK-32739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-32739:
--
Attachment: jobmanager.log
> restarting not work
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-32739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-32739:
--
Description:
In my flink standalone cluster, I config 2 taskmanagers. Then I test with
following
[
https://issues.apache.org/jira/browse/FLINK-32739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-32739:
--
Description:
In my flink standalone cluster, I config 2 taskmanagers. Then I test with
following
Spongebob created FLINK-32739:
-
Summary: restarting not work
Key: FLINK-32739
URL: https://issues.apache.org/jira/browse/FLINK-32739
Project: Flink
Issue Type: Bug
Components: API /
[
https://issues.apache.org/jira/browse/FLINK-24837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-24837.
-
Resolution: Won't Fix
> submit flink job failed via restapi
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-32361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob reopened FLINK-32361:
---
Hi [~Adhip] yes I think this is a bug so I report this issue here.
> error after replace dependent jar
[
https://issues.apache.org/jira/browse/FLINK-32361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733980#comment-17733980
]
Spongebob edited comment on FLINK-32361 at 6/19/23 1:57 AM:
Hi [~mapohl] yes
Spongebob created FLINK-32361:
-
Summary: error after replace dependent jar file
Key: FLINK-32361
URL: https://issues.apache.org/jira/browse/FLINK-32361
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-32308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-32308:
--
Affects Version/s: 1.14.5
> RestClusterClient submit job to remote cluster
>
Spongebob created FLINK-32308:
-
Summary: RestClusterClient submit job to remote cluster
Key: FLINK-32308
URL: https://issues.apache.org/jira/browse/FLINK-32308
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-32274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-32274.
-
Release Note: try to replace
`org.apache.kafka.common.serialization.StringSerializer` with
Spongebob created FLINK-32274:
-
Summary: kafka class could not be found while using appliction
mode.
Key: FLINK-32274
URL: https://issues.apache.org/jira/browse/FLINK-32274
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722121#comment-17722121
]
Spongebob edited comment on FLINK-32065 at 5/12/23 11:15 AM:
-
Hi
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722121#comment-17722121
]
Spongebob commented on FLINK-32065:
---
Hi [~Thesharing] Does it likelihood due to the incorrect starting
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722094#comment-17722094
]
Spongebob commented on FLINK-32065:
---
Hi, [~Thesharing] , may be I could provide these logs for you.
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-32065:
--
Attachment: image-2023-05-12-17-37-09-002.png
> Got NoSuchFileException when initialize source
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-32065:
--
Description:
When I submit an application to flink standalone cluster, I got a
NoSuchFileException.
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-32065:
--
Attachment: image-2023-05-12-14-26-46-268.png
> Got NoSuchFileException when initialize source
Spongebob created FLINK-32065:
-
Summary: Got NoSuchFileException when initialize source function.
Key: FLINK-32065
URL: https://issues.apache.org/jira/browse/FLINK-32065
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-30500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-30500:
--
Description:
I can use the `addInsertSql` function nornally in norm situation, but when I
create the
Spongebob created FLINK-30500:
-
Summary: Got an null pointer exception when using table
environment in sub-thread
Key: FLINK-30500
URL: https://issues.apache.org/jira/browse/FLINK-30500
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610368#comment-17610368
]
Spongebob commented on FLINK-29428:
---
when I disable the multiple input operator, it turned to be
Spongebob created FLINK-29428:
-
Summary: got an ambigious exception in flinksql
Key: FLINK-29428
URL: https://issues.apache.org/jira/browse/FLINK-29428
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob resolved FLINK-29216.
---
Resolution: Not A Problem
> rows belong to update rowkind are transfered into delete and insert
>
[
https://issues.apache.org/jira/browse/FLINK-29216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17601167#comment-17601167
]
Spongebob commented on FLINK-29216:
---
Thanks [~lincoln.86xy] , it apparents normal when I set this
[
https://issues.apache.org/jira/browse/FLINK-29216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-29216:
--
Description:
When I declared primary key on the sink table, all UPDATE rows were transfered
into
Spongebob created FLINK-29216:
-
Summary: rows belong to update rowkind are transfered into delete
and insert
Key: FLINK-29216
URL: https://issues.apache.org/jira/browse/FLINK-29216
Project: Flink
Spongebob created FLINK-27969:
-
Summary: StreamPhysicalOverAggregate doesn't support consuming
update and delete changes
Key: FLINK-27969
URL: https://issues.apache.org/jira/browse/FLINK-27969
Project:
[
https://issues.apache.org/jira/browse/FLINK-27638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob reopened FLINK-27638:
---
> failed to join with table function
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-27638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540880#comment-17540880
]
Spongebob commented on FLINK-27638:
---
[~fsk119] I had not set any finish condition in the table
[
https://issues.apache.org/jira/browse/FLINK-27638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-27638:
--
Attachment: (was: image-2022-05-16-19-08-25-477.png)
> failed to join with table function
>
[
https://issues.apache.org/jira/browse/FLINK-27638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-27638:
--
Attachment: image-2022-05-16-19-40-23-179.png
Description:
# register two table function named
[
https://issues.apache.org/jira/browse/FLINK-27638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-27638:
--
Attachment: (was: image-2022-05-16-19-08-50-286.png)
> failed to join with table function
>
[
https://issues.apache.org/jira/browse/FLINK-27638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-27638:
--
Description:
# regiseter one table function named `GET_STREAMING_MODEL_SINK_FILTER`
# create two
Spongebob created FLINK-27638:
-
Summary: failed to join with table function
Key: FLINK-27638
URL: https://issues.apache.org/jira/browse/FLINK-27638
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-27462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-27462.
-
Release Note:
Flink will stop checkpointing when some subtasks turn to be finished. And we
can switch
[
https://issues.apache.org/jira/browse/FLINK-27462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-27462:
--
Description:
I found that it could not trigger checkpoints despite I had enable it in
environment.
[
https://issues.apache.org/jira/browse/FLINK-27462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-27462:
--
Attachment: image-2022-05-01-11-23-24-938.png
> could not trigger checkpoint when using table
[
https://issues.apache.org/jira/browse/FLINK-27462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-27462:
--
Attachment: image-2022-05-01-11-23-07-063.png
> could not trigger checkpoint when using table
Spongebob created FLINK-27462:
-
Summary: could not trigger checkpoint when using table function
Key: FLINK-27462
URL: https://issues.apache.org/jira/browse/FLINK-27462
Project: Flink
Issue Type:
[ https://issues.apache.org/jira/browse/FLINK-27436 ]
Spongebob deleted comment on FLINK-27436:
---
was (Author: spongebobz):
Hi [~martijnvisser] , When I deploy my flinksql application that contains
multiple insertion sql that are both executed by
[
https://issues.apache.org/jira/browse/FLINK-27436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530329#comment-17530329
]
Spongebob commented on FLINK-27436:
---
Hi [~martijnvisser] , When I deploy my flinksql application that
[
https://issues.apache.org/jira/browse/FLINK-27436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529278#comment-17529278
]
Spongebob commented on FLINK-27436:
---
[~martijnvisser] Great I can see it now follow your advise. But
[
https://issues.apache.org/jira/browse/FLINK-27436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529260#comment-17529260
]
Spongebob commented on FLINK-27436:
---
[~martijnvisser] I had not. By the ways I could see this option
Spongebob created FLINK-27436:
-
Summary: option `properties.group.id` is not effective in kafka
connector for finksql
Key: FLINK-27436
URL: https://issues.apache.org/jira/browse/FLINK-27436
Project:
[
https://issues.apache.org/jira/browse/FLINK-26925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-26925.
-
Resolution: Not A Problem
> loss scale in union situation
> -
>
>
Spongebob created FLINK-26925:
-
Summary: loss scale in union situation
Key: FLINK-26925
URL: https://issues.apache.org/jira/browse/FLINK-26925
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-26461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502100#comment-17502100
]
Spongebob commented on FLINK-26461:
---
Hi lincoln, I found this problem just occur in the version that
[
https://issues.apache.org/jira/browse/FLINK-26461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500647#comment-17500647
]
Spongebob commented on FLINK-26461:
---
Hi Lincoln, this is my application code:
{code:java}
//代码占位符
Spongebob created FLINK-26461:
-
Summary: Throw CannotPlanException in TableFunction
Key: FLINK-26461
URL: https://issues.apache.org/jira/browse/FLINK-26461
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-26384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-26384.
-
Resolution: Not A Problem
> This exception indicates that the query uses an unsupported SQL feature.
>
Spongebob created FLINK-26384:
-
Summary: This exception indicates that the query uses an
unsupported SQL feature.
Key: FLINK-26384
URL: https://issues.apache.org/jira/browse/FLINK-26384
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-26327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497243#comment-17497243
]
Spongebob commented on FLINK-26327:
---
{code:java}
//代码占位符
Exception in thread "main"
Spongebob created FLINK-26327:
-
Summary: throw not a literal exception in
callContext.getArgumentValue when getTypeInference
Key: FLINK-26327
URL: https://issues.apache.org/jira/browse/FLINK-26327
Spongebob created FLINK-25502:
-
Summary: eval method of Flink ScalerFunction only run one time
Key: FLINK-25502
URL: https://issues.apache.org/jira/browse/FLINK-25502
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-25373.
-
Resolution: Not A Problem
> task manager can not free memory when jobs are finished
>
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462420#comment-17462420
]
Spongebob commented on FLINK-25373:
---
Hi Xintong,
Thanks for your kind explanatory, now I will close
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462403#comment-17462403
]
Spongebob commented on FLINK-25373:
---
Hi Xintong,
# I have checked the memory usage of Task Manager
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-25373:
--
Description:
I submit my Flinksql jobs to the Flink standalone cluster and what out of my
Spongebob created FLINK-25373:
-
Summary: task manager can not free memory when jobs are finished
Key: FLINK-25373
URL: https://issues.apache.org/jira/browse/FLINK-25373
Project: Flink
Issue
Spongebob created FLINK-24837:
-
Summary: submit flink job failed via restapi
Key: FLINK-24837
URL: https://issues.apache.org/jira/browse/FLINK-24837
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-24473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425607#comment-17425607
]
Spongebob commented on FLINK-24473:
---
Hi Jark, I am dealing with the RowData objects in
[
https://issues.apache.org/jira/browse/FLINK-24473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-24473:
--
Attachment: image-2021-10-07-21-17-20-192.png
> getString value from any datatype columns
>
[
https://issues.apache.org/jira/browse/FLINK-24473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-24473:
--
Description:
Hope flink would support getting string value from any other datatype column,
such as
Spongebob created FLINK-24473:
-
Summary: getString value from any datatype columns
Key: FLINK-24473
URL: https://issues.apache.org/jira/browse/FLINK-24473
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-24338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418603#comment-17418603
]
Spongebob commented on FLINK-24338:
---
Hi Patrick, I'd like to ask that how can I validate FlinkSQL with
[
https://issues.apache.org/jira/browse/FLINK-24338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417599#comment-17417599
]
Spongebob commented on FLINK-24338:
---
Our system receives FLINK SQL from website input and then need
Spongebob created FLINK-24338:
-
Summary: Provide an interface to validate flinksql
Key: FLINK-24338
URL: https://issues.apache.org/jira/browse/FLINK-24338
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-24289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415395#comment-17415395
]
Spongebob commented on FLINK-24289:
---
So are there any ways that could make the source table to be
Spongebob created FLINK-24289:
-
Summary: Load data repeatedly between different jobs
Key: FLINK-24289
URL: https://issues.apache.org/jira/browse/FLINK-24289
Project: Flink
Issue Type:
Spongebob created FLINK-24104:
-
Summary: incorrect validation of sink schema
Key: FLINK-24104
URL: https://issues.apache.org/jira/browse/FLINK-24104
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-23177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371891#comment-17371891
]
Spongebob commented on FLINK-23177:
---
Thanks for your reply. It works normally now that is basic on
[
https://issues.apache.org/jira/browse/FLINK-23177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-23177:
--
Description:
I have assigned watermark in dataStream and then use the `createTemporaryView`
method
Spongebob created FLINK-23177:
-
Summary: watermarks generated in dateStream can not flow into table
Key: FLINK-23177
URL: https://issues.apache.org/jira/browse/FLINK-23177
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-22874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-22874.
-
Release Note: my misunderstanding of streaming partition sink cause this
issue, it worked normally
[
https://issues.apache.org/jira/browse/FLINK-22874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358996#comment-17358996
]
Spongebob commented on FLINK-22874:
---
Yes my misunderstanding of streaming partition sink cause this
Spongebob created FLINK-22874:
-
Summary: flink table partition trigger doesn't effect as
expectation when sink into hive table
Key: FLINK-22874
URL: https://issues.apache.org/jira/browse/FLINK-22874
[
https://issues.apache.org/jira/browse/FLINK-22190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347469#comment-17347469
]
Spongebob commented on FLINK-22190:
---
my mistake lead to this issus. But I found that I must set
[
https://issues.apache.org/jira/browse/FLINK-22458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331808#comment-17331808
]
Spongebob commented on FLINK-22458:
---
can you explain why this happened and how to avoid this issue?
>
Spongebob created FLINK-22458:
-
Summary: Failed when operating empty catalog table
Key: FLINK-22458
URL: https://issues.apache.org/jira/browse/FLINK-22458
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331698#comment-17331698
]
Spongebob commented on FLINK-21914:
---
anyone can help with this issue? When this issue happen, there
[
https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-21914:
--
Labels: (was: stale-critical)
> Trying to access closed classloader
>
[
https://issues.apache.org/jira/browse/FLINK-22422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331429#comment-17331429
]
Spongebob commented on FLINK-22422:
---
Actually it works normally when using "-m yarn-cluster" only.
[
https://issues.apache.org/jira/browse/FLINK-22422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331382#comment-17331382
]
Spongebob commented on FLINK-22422:
---
Hi Yang, here's the command: flink run -m yarn-cluster -ys 1 -yjm
Spongebob created FLINK-22422:
-
Summary: -ynm option doesn't effect when deploying flink on yarn
Key: FLINK-22422
URL: https://issues.apache.org/jira/browse/FLINK-22422
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-22247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-22247:
--
Environment:
flink: 1.12.2
rabbitmq: 3.8.4
was:
flink: 2.12.2
rabbitmq: 3.8.4
> can not pass
Spongebob created FLINK-22247:
-
Summary: can not pass AddressList when connecting to rabbitmq
Key: FLINK-22247
URL: https://issues.apache.org/jira/browse/FLINK-22247
Project: Flink
Issue Type:
Spongebob created FLINK-22190:
-
Summary: no guarantee on Flink exactly_once sink to Kafka
Key: FLINK-22190
URL: https://issues.apache.org/jira/browse/FLINK-22190
Project: Flink
Issue Type: Bug
Spongebob created FLINK-22165:
-
Summary: How to set rabbitmq correlationId when using rabbitmq
sink in dataStreamEnv
Key: FLINK-22165
URL: https://issues.apache.org/jira/browse/FLINK-22165
Project: Flink
1 - 100 of 123 matches
Mail list logo
