pingle wang created FLINK-17088:
---
Summary: Search TaskManager log content based on keywords function
Key: FLINK-17088
URL: https://issues.apache.org/jira/browse/FLINK-17088
Project: Flink
Issue
pingle wang created FLINK-16714:
---
Summary: Kafka committedOffsets value <0
Key: FLINK-16714
URL: https://issues.apache.org/jira/browse/FLINK-16714
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-13425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pingle wang updated FLINK-13425:
Description:
The flink job running in our online environment, from the beginning of the 1st
to th
pingle wang created FLINK-13425:
---
Summary: Table api sqlUpdate execute case when expression occur
data error
Key: FLINK-13425
URL: https://issues.apache.org/jira/browse/FLINK-13425
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-13401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pingle wang closed FLINK-13401.
---
Resolution: Not A Bug
> Flink SQL sqlUpdate sql where complex conditional expressions do not take
>
pingle wang created FLINK-13401:
---
Summary: Flink SQL sqlUpdate sql where complex conditional
expressions do not take effect
Key: FLINK-13401
URL: https://issues.apache.org/jira/browse/FLINK-13401
Projec
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pingle wang updated FLINK-11982:
Description:
java code :
{code:java}
val connector = FileSystem().path("data/in/test.json")
val de
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pingle wang updated FLINK-11982:
Description:
java code :
{code:java}
val connector = FileSystem().path("data/in/test.json")
val de
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pingle wang updated FLINK-11982:
Affects Version/s: 1.8.0
> BatchTableSourceFactory support Json Format File
>
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16800498#comment-16800498
]
pingle wang commented on FLINK-11982:
-
why?
> BatchTableSourceFactory support Json
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16798865#comment-16798865
]
pingle wang commented on FLINK-11982:
-
this class support connector is kafka, not fi
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pingle wang updated FLINK-11982:
Summary: BatchTableSourceFactory support Json Format File (was:
BatchTableSourceFactory support J
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797876#comment-16797876
]
pingle wang edited comment on FLINK-11982 at 3/21/19 8:06 AM:
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pingle wang updated FLINK-11982:
Description:
java code :
{code:java}
val connector = FileSystem().path("data/in/test.json")
val de
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pingle wang updated FLINK-11982:
Summary: BatchTableSourceFactory support Json Format (was:
org.apache.flink.table.api.NoMatchingT
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797876#comment-16797876
]
pingle wang commented on FLINK-11982:
-
sorry, I use BatchEnv. StreamEnv support. so
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797846#comment-16797846
]
pingle wang commented on FLINK-11982:
-
[~frank wang] so do you think this issue?
>
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797735#comment-16797735
]
pingle wang commented on FLINK-11982:
-
I add flink-json jar and
/META-INF/services
[
https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pingle wang updated FLINK-11982:
Description:
java code :
{code:java}
val desc = tEnv.connect(connector)
.withFormat(
new Json()
.s
pingle wang created FLINK-11982:
---
Summary: org.apache.flink.table.api.NoMatchingTableFactoryException
Key: FLINK-11982
URL: https://issues.apache.org/jira/browse/FLINK-11982
Project: Flink
Issu
20 matches
Mail list logo
