chun11 created FLINK-14667:
--
Summary: flink1.9,1.8.2 run flinkSql fat jar ,can't load the right
tableFactory (TableSourceFactory) for the kafka
Key: FLINK-14667
URL: https://issues.apache.org/jira/browse/FLINK-1
[
https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-14667:
---
Description:
[root@mj flink-1.9.1]# ./bin/flink run -m yarn-cluster
/root/cp19/streaming-view-0.0.1
[
https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969870#comment-16969870
]
chun11 commented on FLINK-14667:
The Kafka011TableSourceSinkFactory is packaged
[
https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969870#comment-16969870
]
chun11 edited comment on FLINK-14667 at 11/8/19 6:15 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969870#comment-16969870
]
chun11 edited comment on FLINK-14667 at 11/8/19 6:24 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-14667:
---
Description:
[root@mj flink-1.9.1]# ./bin/flink run -m yarn-cluster
/root/cp19/streaming-view-0.0.1
[
https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969952#comment-16969952
]
chun11 commented on FLINK-14667:
Thank you for your answer(y) !
You mean I ne
[
https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-14667:
---
Comment: was deleted
(was: Thank you for your answer(y) !
You mean I need to setup flink-kafka-co
[
https://issues.apache.org/jira/browse/FLINK-14667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969965#comment-16969965
]
chun11 commented on FLINK-14667:
You are right,Thank you very much (y):)
> flin
chun11 created FLINK-16918:
--
Summary: flink influxdb metrics depency
okio.BufferedSource.getBuffer() NoSuchMethodException
Key: FLINK-16918
URL: https://issues.apache.org/jira/browse/FLINK-16918
Pro
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 resolved FLINK-17447.
Resolution: Not A Bug
> Flink CEPOperator StateException
>
>
>
chun11 created FLINK-17447:
--
Summary: Flink CEPOperator StateException
Key: FLINK-17447
URL: https://issues.apache.org/jira/browse/FLINK-17447
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-17447:
---
Attachment: image-2020-04-29-10-21-10-717.png
> Flink CEPOperator StateException
> -
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-17447:
---
Description: !image-2020-04-29-10-21-10-717.png!
> Flink CEPOperator StateException
> --
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-17447:
---
Attachment: image-2020-04-29-10-22-20-645.png
> Flink CEPOperator StateException
> -
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-17447:
---
Attachment: image-2020-04-29-10-23-14-306.png
> Flink CEPOperator StateException
> -
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-17447:
---
Description:
!image-2020-04-29-10-21-10-717.png!
!image-2020-04-29-10-23-14-306.png!
!image-
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094998#comment-17094998
]
chun11 commented on FLINK-17447:
dataStream with multi cep patterns , Flink job
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094998#comment-17094998
]
chun11 edited comment on FLINK-17447 at 4/29/20, 2:25 AM:
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-17447:
---
Description:
!image-2020-04-29-11-55-12-995.png!!image-2020-04-29-10-21-10-717.png!
!image-2020-
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-17447:
---
Attachment: image-2020-04-29-11-55-12-995.png
> Flink CEPOperator StateException
> -
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 updated FLINK-17447:
---
Attachment: image-2020-04-30-11-37-20-411.png
> Flink CEPOperator StateException
> -
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096087#comment-17096087
]
chun11 commented on FLINK-17447:
TwoStagePatternedRule is a enum :
public en
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096085#comment-17096085
]
chun11 commented on FLINK-17447:
import java.util.ArrayList;
import java.util.
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096093#comment-17096093
]
chun11 commented on FLINK-17447:
in the job, one datastream math with five CEP P
[
https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096108#comment-17096108
]
chun11 commented on FLINK-17447:
[~aljoscha] I think the static code for create
chun11 created FLINK-17475:
--
Summary: Flink Multiple buffers ,IllgeaStateException
Key: FLINK-17475
URL: https://issues.apache.org/jira/browse/FLINK-17475
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-17475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chun11 closed FLINK-17475.
--
Resolution: Duplicate
> Flink Multiple buffers ,IllgeaStateException
> ---
28 matches
Mail list logo