[jira] [Created] (FLINK-19795) When TOPN handles duplicate data, it will throw an exception
jinxin created FLINK-19795: -- Summary: When TOPN handles duplicate data, it will throw an exception Key: FLINK-19795 URL: https://issues.apache.org/jira/browse/FLINK-19795 Project: Flink Issue Type: Bug Components: Table SQL / Runtime Affects Versions: 1.11.2 Reporter: jinxin When TOPN handles duplicate data, it will throw an exception : "Can not retract a non-existent record. This should never happen." -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-18897) Add documentation for the maxwell-json format
[ https://issues.apache.org/jira/browse/FLINK-18897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176198#comment-17176198 ] jinxin commented on FLINK-18897: Ok,i will finish it soon > Add documentation for the maxwell-json format > - > > Key: FLINK-18897 > URL: https://issues.apache.org/jira/browse/FLINK-18897 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Formats (JSON, Avro, Parquet, ORC, > SequenceFile), Table SQL / Ecosystem >Reporter: Jark Wu >Priority: Major > Fix For: 1.12.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-18844) support maxwell-json for Maxwell binlog collector
jinxin created FLINK-18844: -- Summary: support maxwell-json for Maxwell binlog collector Key: FLINK-18844 URL: https://issues.apache.org/jira/browse/FLINK-18844 Project: Flink Issue Type: Improvement Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile) Affects Versions: 1.11.1 Reporter: jinxin Hi,i have finish these code .So, can assign this issule to me ? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Reopened] (FLINK-18314) There are some problems in docs
[
https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jinxin reopened FLINK-18314:
sorry ,i change the wrong state . i mean it's not fixed now
> There are some problems in docs
> ---
>
> Key: FLINK-18314
> URL: https://issues.apache.org/jira/browse/FLINK-18314
> Project: Flink
> Issue Type: Bug
> Components: Documentation
>Affects Versions: 1.11.0, 1.12.0
>Reporter: jinxin
>Priority: Major
>
> In this page
> [https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html.|https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html]
> Maven dependency should be flink-connector-kafka-0.11 instead of
> flink-connector-kafka-011, which is missing `.`
> flink-connector-kafka-010_2.11 has the same problem.
> I read the source code, the content of kafka.md is wrong.
> In the same page,DDL should be
> {{`properties.bootstrap.servers` instead of }}{{properties.bootstrap.server.}}
> {{when i used}} {{properties.bootstrap.server,i got a exception :}}
> Caused by: org.apache.flink.table.api.ValidationException: One or more
> required options are missing.
> Missing required options are:
> properties.bootstrap.servers
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Resolved] (FLINK-18314) There are some problems in docs
[
https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jinxin resolved FLINK-18314.
Resolution: Fixed
> There are some problems in docs
> ---
>
> Key: FLINK-18314
> URL: https://issues.apache.org/jira/browse/FLINK-18314
> Project: Flink
> Issue Type: Bug
> Components: Documentation
>Affects Versions: 1.11.0, 1.12.0
>Reporter: jinxin
>Priority: Major
>
> In this page
> [https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html.|https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html]
> Maven dependency should be flink-connector-kafka-0.11 instead of
> flink-connector-kafka-011, which is missing `.`
> flink-connector-kafka-010_2.11 has the same problem.
> I read the source code, the content of kafka.md is wrong.
> In the same page,DDL should be
> {{`properties.bootstrap.servers` instead of }}{{properties.bootstrap.server.}}
> {{when i used}} {{properties.bootstrap.server,i got a exception :}}
> Caused by: org.apache.flink.table.api.ValidationException: One or more
> required options are missing.
> Missing required options are:
> properties.bootstrap.servers
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-18314) There are some problems in docs
[
https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jinxin updated FLINK-18314:
---
Affects Version/s: 1.12.0
> There are some problems in docs
> ---
>
> Key: FLINK-18314
> URL: https://issues.apache.org/jira/browse/FLINK-18314
> Project: Flink
> Issue Type: Bug
> Components: Documentation
>Affects Versions: 1.11.0, 1.12.0
>Reporter: jinxin
>Priority: Major
>
> In this page
> [https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html.|https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html]
> Maven dependency should be flink-connector-kafka-0.11 instead of
> flink-connector-kafka-011, which is missing `.`
> flink-connector-kafka-010_2.11 has the same problem.
> I read the source code, the content of kafka.md is wrong.
> In the same page,DDL should be
> {{`properties.bootstrap.servers` instead of }}{{properties.bootstrap.server.}}
> {{when i used}} {{properties.bootstrap.server,i got a exception :}}
> Caused by: org.apache.flink.table.api.ValidationException: One or more
> required options are missing.
> Missing required options are:
> properties.bootstrap.servers
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-18314) There are some problems in docs
[
https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jinxin updated FLINK-18314:
---
Description:
In this page
[https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html.|https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html]
Maven dependency should be flink-connector-kafka-0.11 instead of
flink-connector-kafka-011, which is missing `.`
flink-connector-kafka-010_2.11 has the same problem.
I read the source code, the content of kafka.md is wrong.
In the same page,DDL should be
{{`properties.bootstrap.servers` instead of }}{{properties.bootstrap.server.}}
{{when i used}} {{properties.bootstrap.server,i got a exception :}}
Caused by: org.apache.flink.table.api.ValidationException: One or more required
options are missing.
Missing required options are:
properties.bootstrap.servers
was:
In this page
[https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html.|https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html]
Maven dependency should be flink-connector-kafka-0.11 instead of
flink-connector-kafka-011, which is missing `.`
flink-connector-kafka-010_2.11 has the same problem.
I read the source code, the content of kafka.md is wrong.
In the same page,DDL should be
{{`properties.bootstrap.servers` instead of }}{{properties.bootstrap.server.}}
{{when i used}} {{properties.bootstrap.server,i got a exception :}}
{{}}
Caused by: org.apache.flink.table.api.ValidationException: One or more required
options are missing.
{{}}
Missing required options are:
{{}}
properties.bootstrap.servers
{{}}
> There are some problems in docs
> ---
>
> Key: FLINK-18314
> URL: https://issues.apache.org/jira/browse/FLINK-18314
> Project: Flink
> Issue Type: Bug
> Components: Documentation
>Affects Versions: 1.11.0
>Reporter: jinxin
>Priority: Major
>
> In this page
> [https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html.|https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html]
> Maven dependency should be flink-connector-kafka-0.11 instead of
> flink-connector-kafka-011, which is missing `.`
> flink-connector-kafka-010_2.11 has the same problem.
> I read the source code, the content of kafka.md is wrong.
> In the same page,DDL should be
> {{`properties.bootstrap.servers` instead of }}{{properties.bootstrap.server.}}
> {{when i used}} {{properties.bootstrap.server,i got a exception :}}
> Caused by: org.apache.flink.table.api.ValidationException: One or more
> required options are missing.
> Missing required options are:
> properties.bootstrap.servers
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Created] (FLINK-18314) There are some problems in docs
jinxin created FLINK-18314:
--
Summary: There are some problems in docs
Key: FLINK-18314
URL: https://issues.apache.org/jira/browse/FLINK-18314
Project: Flink
Issue Type: Bug
Components: Documentation
Affects Versions: 1.11.0
Reporter: jinxin
In this page
[https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html.|https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html]
Maven dependency should be flink-connector-kafka-0.11 instead of
flink-connector-kafka-011, which is missing `.`
flink-connector-kafka-010_2.11 has the same problem.
I read the source code, the content of kafka.md is wrong.
In the same page,DDL should be
{{`properties.bootstrap.servers` instead of }}{{properties.bootstrap.server.}}
{{when i used}} {{properties.bootstrap.server,i got a exception :}}
{{}}
Caused by: org.apache.flink.table.api.ValidationException: One or more required
options are missing.
{{}}
Missing required options are:
{{}}
properties.bootstrap.servers
{{}}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-16333) After exiting from the command line client, the process still exists
[ https://issues.apache.org/jira/browse/FLINK-16333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinxin updated FLINK-16333: --- Priority: Major (was: Trivial) > After exiting from the command line client, the process still exists > > > Key: FLINK-16333 > URL: https://issues.apache.org/jira/browse/FLINK-16333 > Project: Flink > Issue Type: Bug > Components: Command Line Client >Affects Versions: 1.10.0 > Environment: JDK 8 > Flink 1.10 >Reporter: jinxin >Priority: Major > Attachments: 微信图片_20200228190743.png, 微信图片_20200228190935.png > > > After exiting from flink scala shell, the process still exists. Then I tried > to kill him with kill -9 PID, but it still didn't work. Process still exists. > Similar problems also appear in SQL client.Fortunately, kill-9 takes effect. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-16333) After exiting from the command line client, the process still exists
jinxin created FLINK-16333: -- Summary: After exiting from the command line client, the process still exists Key: FLINK-16333 URL: https://issues.apache.org/jira/browse/FLINK-16333 Project: Flink Issue Type: Bug Components: Command Line Client Affects Versions: 1.10.0 Environment: JDK 8 Flink 1.10 Reporter: jinxin Attachments: 微信图片_20200228190743.png, 微信图片_20200228190935.png After exiting from flink scala shell, the process still exists. Then I tried to kill him with kill -9 PID, but it still didn't work. Process still exists. Similar problems also appear in SQL client.Fortunately, kill-9 takes effect. -- This message was sent by Atlassian Jira (v8.3.4#803005)
