Jun Zhang created FLINK-32819:
-
Summary: flink can not parse the param `#` correctly in k8s
application mode
Key: FLINK-32819
URL: https://issues.apache.org/jira/browse/FLINK-32819
Project: Flink
Jun Zhang created FLINK-31459:
-
Summary: add UPDATE COLUMN POSITION for flink table store
Key: FLINK-31459
URL: https://issues.apache.org/jira/browse/FLINK-31459
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696840#comment-17696840
]
Jun Zhang commented on FLINK-31224:
---
[~lzljs3620320] ok，I agree with you，let us add the metrics later.
Jun Zhang created FLINK-31338:
-
Summary: support infer parallelism for flink table store
Key: FLINK-31338
URL: https://issues.apache.org/jira/browse/FLINK-31338
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-31224:
--
Description:
We can divide the metrics of the flink table store into three categories:
Jun Zhang created FLINK-31258:
-
Summary: can not get kerberos keytab in flink operator
Key: FLINK-31258
URL: https://issues.apache.org/jira/browse/FLINK-31258
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-31224:
-
Summary: Add metrics for flink table store
Key: FLINK-31224
URL: https://issues.apache.org/jira/browse/FLINK-31224
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-31128:
-
Summary: Add Create Table As for flink table store
Key: FLINK-31128
URL: https://issues.apache.org/jira/browse/FLINK-31128
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690123#comment-17690123
]
Jun Zhang commented on FLINK-3:
---
I think we should add a test class for parameterized test for
Jun Zhang created FLINK-31028:
-
Summary: Provide different compression methods for per level
Key: FLINK-31028
URL: https://issues.apache.org/jira/browse/FLINK-31028
Project: Flink
Issue Type:
Jun Zhang created FLINK-31011:
-
Summary: upgrade hiverunner version
Key: FLINK-31011
URL: https://issues.apache.org/jira/browse/FLINK-31011
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-31002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686948#comment-17686948
]
Jun Zhang commented on FLINK-31002:
---
I test that. ,and found this function has been implemented by
Jun Zhang created FLINK-30871:
-
Summary: add bloom filter for orc
Key: FLINK-30871
URL: https://issues.apache.org/jira/browse/FLINK-30871
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-30608:
-
Summary: support rename table
Key: FLINK-30608
URL: https://issues.apache.org/jira/browse/FLINK-30608
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-30595:
-
Summary: support create table like
Key: FLINK-30595
URL: https://issues.apache.org/jira/browse/FLINK-30595
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-23955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-23955:
--
Description:
1.when I configured the flink HA ,like this
{code:java}
high-availability: zookeeper
Jun Zhang created FLINK-23955:
-
Summary: submit flink sql job error when flink HA on yarn is
configured
Key: FLINK-23955
URL: https://issues.apache.org/jira/browse/FLINK-23955
Project: Flink
Jun Zhang created FLINK-22975:
-
Summary: Specify port or range for k8s service
Key: FLINK-22975
URL: https://issues.apache.org/jira/browse/FLINK-22975
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359063#comment-17359063
]
Jun Zhang commented on FLINK-19830:
---
May I know any updates for this?
> Properly implements
Jun Zhang created FLINK-22591:
-
Summary: add sub interface MapColumnVector for ColumnVector
Key: FLINK-22591
URL: https://issues.apache.org/jira/browse/FLINK-22591
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-21283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327181#comment-17327181
]
Jun Zhang commented on FLINK-21283:
---
hi,[~jark], does the community have plans to support this
Jun Zhang created FLINK-21286:
-
Summary: Support BUCKET for flink sql CREATE TABLE
Key: FLINK-21286
URL: https://issues.apache.org/jira/browse/FLINK-21286
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-21285:
-
Summary: Support MERGE INTO for flink sql
Key: FLINK-21285
URL: https://issues.apache.org/jira/browse/FLINK-21285
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-21282:
-
Summary: Support UPDATE for flink sql
Key: FLINK-21282
URL: https://issues.apache.org/jira/browse/FLINK-21282
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-21283:
-
Summary: Support sql extension for flink sql
Key: FLINK-21283
URL: https://issues.apache.org/jira/browse/FLINK-21283
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-21281:
-
Summary: Support DELETE FROM for flink sql
Key: FLINK-21281
URL: https://issues.apache.org/jira/browse/FLINK-21281
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-21198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-21198:
--
Description: I think we should add SHOW CREATE TABLE command for flink sql
client,so that we can view
[
https://issues.apache.org/jira/browse/FLINK-21198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-21198:
--
Environment: (was: I think we should add SHOW CREATE TABLE command for
flink sql client,so that
Jun Zhang created FLINK-21198:
-
Summary: Add show create table command support for flink sql client
Key: FLINK-21198
URL: https://issues.apache.org/jira/browse/FLINK-21198
Project: Flink
Issue
Jun Zhang created FLINK-21197:
-
Summary: DESC command in sql-client should show the column comment
Key: FLINK-21197
URL: https://issues.apache.org/jira/browse/FLINK-21197
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17269939#comment-17269939
]
Jun Zhang commented on FLINK-20977:
---
I found that USE CATALOG `mod` has the same problem
> can not
[
https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17269746#comment-17269746
]
Jun Zhang commented on FLINK-20977:
---
This bug only appears when using sqlclient ，it is no problem when
[
https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265646#comment-17265646
]
Jun Zhang commented on FLINK-20977:
---
hi, [~jark] the exception is like this, I tracked the code and
[
https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264784#comment-17264784
]
Jun Zhang commented on FLINK-20977:
---
it is ok in flink 1.11
> can not use `use` command to switch
Jun Zhang created FLINK-20977:
-
Summary: can not use `use` command to switch database
Key: FLINK-20977
URL: https://issues.apache.org/jira/browse/FLINK-20977
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-20809:
-
Summary: the limit push down invalid when use filter
Key: FLINK-20809
URL: https://issues.apache.org/jira/browse/FLINK-20809
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-20767:
-
Summary: add nested field support for SupportsFilterPushDown
Key: FLINK-20767
URL: https://issues.apache.org/jira/browse/FLINK-20767
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Attachment: (was: flink-19896.patch)
> Improve first-n-row fetching in the rank operator
>
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Attachment: flink-19896.patch
> Improve first-n-row fetching in the rank operator
>
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Attachment: (was: flink-19896.patch)
> Improve first-n-row fetching in the rank operator
>
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Attachment: flink-19896.patch
> Improve first-n-row fetching in the rank operator
>
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Summary: Improve first-n-row fetching in the rank operator (was: Improve
first-n-rows fetching in
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225815#comment-17225815
]
Jun Zhang commented on FLINK-19896:
---
We introduce a lightweight variant of AppendOnlyTopNFunction to
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Summary: Improve first-n-rows fetching in the rank operator (was: Improve
first-n-rows in the rank
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Attachment: flink-19896.patch
> Improve first-n-rows in the rank operator
>
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Attachment: (was: flink-19896.patch)
> Improve first-n-rows in the rank operator
>
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Attachment: flink-19896.patch
> Improve first-n-rows in the rank operator
>
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Summary: Improve first-n-rows in the rank operator (was: Support
first-n-rows deduplication in the
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224403#comment-17224403
]
Jun Zhang commented on FLINK-19896:
---
Thanks Jark, let's see how it fits into Rank operator.
> Support
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224037#comment-17224037
]
Jun Zhang commented on FLINK-19896:
---
Put aside the semantic or definition of "deduplicate", I think
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Description:
Currently Deduplicate operator only supports first-row deduplication (ordered
by
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Description:
Currently Deduplicate operator only supports first-row deduplication (ordered
by
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Description:
Currently Deduplicate operator only supports first-row deduplication (ordered
by
[
https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-19896:
--
Component/s: Table SQL / Planner
> Support first-n-rows deduplication in the Deduplicate operator
>
Jun Zhang created FLINK-19896:
-
Summary: Support first-n-rows deduplication in the Deduplicate
operator
Key: FLINK-19896
URL: https://issues.apache.org/jira/browse/FLINK-19896
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17200642#comment-17200642
]
Jun Zhang commented on FLINK-19358:
---
hi, [~kkl0u] , My job is working fine，but if I configure the HA ,
[
https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17200459#comment-17200459
]
Jun Zhang commented on FLINK-19358:
---
hi，[~kkl0u] in my application，only has one execute().
My
Jun Zhang created FLINK-19358:
-
Summary: when submit job on application mode with HA,the jobid
will be 00
Key: FLINK-19358
URL: https://issues.apache.org/jira/browse/FLINK-19358
Project: Flink
Jun Zhang created FLINK-19254:
-
Summary: Invalid UTF-8 start byte exception
Key: FLINK-19254
URL: https://issues.apache.org/jira/browse/FLINK-19254
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-18691:
-
Summary: add HiveCatalog Construction method with HiveConf
Key: FLINK-18691
URL: https://issues.apache.org/jira/browse/FLINK-18691
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang closed FLINK-18549.
-
Release Note: my hadoop version is 2.6-cdh 5.8 , I upgrade it to hadoop
3.1.2 ，it is successed
[
https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155165#comment-17155165
]
Jun Zhang commented on FLINK-18549:
---
To add, if I use a bounded source, such as
[
https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155161#comment-17155161
]
Jun Zhang commented on FLINK-18549:
---
hi ,[~jark]:
In my test, the partition result file is normal ,
[
https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-18549:
--
Description:
I use the sql of flink 1.11, read from kafka and writing to hdfs, I found that
the
Jun Zhang created FLINK-18549:
-
Summary: flink 1.11 can not commit partition automatically
Key: FLINK-18549
URL: https://issues.apache.org/jira/browse/FLINK-18549
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17150934#comment-17150934
]
Jun Zhang commented on FLINK-18479:
---
hi,[~lzljs3620320] if I want to use partition path with time zone
[
https://issues.apache.org/jira/browse/FLINK-18479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17150693#comment-17150693
]
Jun Zhang commented on FLINK-18479:
---
Hi,[~lzljs3620320] ,In this problem, the result of my test is
[
https://issues.apache.org/jira/browse/FLINK-18479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17150659#comment-17150659
]
Jun Zhang commented on FLINK-18479:
---
I am using the code compiled by tag release-1.11.0-rc4 , I found
Jun Zhang created FLINK-18479:
-
Summary: can not commit partition when set partition time
Key: FLINK-18479
URL: https://issues.apache.org/jira/browse/FLINK-18479
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-16818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068393#comment-17068393
]
Jun Zhang commented on FLINK-16818:
---
hi,[~ykt836] I share the execution graph on this link
[
https://issues.apache.org/jira/browse/FLINK-16709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068249#comment-17068249
]
Jun Zhang commented on FLINK-16709:
---
hi,[~jark] ,I am Sorry I should first discuss with the community.
Jun Zhang created FLINK-16818:
-
Summary: Optimize data skew when flink write data to hive dynamic
partition table
Key: FLINK-16818
URL: https://issues.apache.org/jira/browse/FLINK-16818
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068179#comment-17068179
]
Jun Zhang commented on FLINK-16709:
---
hi,[~jark] could you help me review the PR and give me some
[
https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067623#comment-17067623
]
Jun Zhang commented on FLINK-16799:
---
presto has a configuration ‘hive.query-partition-filter-required’
[
https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067616#comment-17067616
]
Jun Zhang commented on FLINK-16799:
---
hi,[~lzljs3620320] I submit a PR ,could you help me review the PR
[
https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067486#comment-17067486
]
Jun Zhang commented on FLINK-16799:
---
hi,[~lzljs3620320] ,hive has the configuration properties.
Jun Zhang created FLINK-16799:
-
Summary: add hive partition limit when read from hive
Key: FLINK-16799
URL: https://issues.apache.org/jira/browse/FLINK-16799
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-16709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065245#comment-17065245
]
Jun Zhang commented on FLINK-16709:
---
hi,[~ykt836] could you help me review the PR and give me some
Jun Zhang created FLINK-16731:
-
Summary: Support show partitions table command in sql client
Key: FLINK-16731
URL: https://issues.apache.org/jira/browse/FLINK-16731
Project: Flink
Issue Type:
Jun Zhang created FLINK-16709:
-
Summary: add a set command to set job name when submit job on sql
client
Key: FLINK-16709
URL: https://issues.apache.org/jira/browse/FLINK-16709
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062316#comment-17062316
]
Jun Zhang commented on FLINK-16646:
---
hi,[~lzljs3620320], I submit a PR to release-1.10 .
[
https://issues.apache.org/jira/browse/FLINK-16646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062256#comment-17062256
]
Jun Zhang commented on FLINK-16646:
---
hi,[~lzljs3620320] ,is it necessary to add a pr to release-1.10 ?
[
https://issues.apache.org/jira/browse/FLINK-12584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang closed FLINK-12584.
-
Resolution: Won't Fix
> Add Bucket File Syetem Table Sink
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-16646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061489#comment-17061489
]
Jun Zhang commented on FLINK-16646:
---
ContinuousFileReaderOperator use OrcRowInputFormat to read orc
[
https://issues.apache.org/jira/browse/FLINK-16646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-16646:
--
Component/s: (was: Connectors / Hive)
Formats (JSON, Avro, Parquet, ORC,
Jun Zhang created FLINK-16646:
-
Summary: flink read orc file throw a NullPointerException
Key: FLINK-16646
URL: https://issues.apache.org/jira/browse/FLINK-16646
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-16413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang updated FLINK-16413:
--
Affects Version/s: 1.10.0
> Reduce hive source parallelism when limit push down
>
Jun Zhang created FLINK-16623:
-
Summary: add the shorthand 'desc' for describe on sql client
Key: FLINK-16623
URL: https://issues.apache.org/jira/browse/FLINK-16623
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-16413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059204#comment-17059204
]
Jun Zhang commented on FLINK-16413:
---
hi,[~lzljs3620320], I add a test method on
[
https://issues.apache.org/jira/browse/FLINK-16413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058460#comment-17058460
]
Jun Zhang commented on FLINK-16413:
---
when limit push down ,we set the min(limit,parallelism) to
[
https://issues.apache.org/jira/browse/FLINK-16539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057725#comment-17057725
]
Jun Zhang commented on FLINK-16539:
---
I found that the system did a trim operation when parsing the
[
https://issues.apache.org/jira/browse/FLINK-16539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057711#comment-17057711
]
Jun Zhang commented on FLINK-16539:
---
If the attribute value is an int type with spaces in front, the
Jun Zhang created FLINK-16539:
-
Summary: sql client set param error
Key: FLINK-16539
URL: https://issues.apache.org/jira/browse/FLINK-16539
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-14739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973204#comment-16973204
]
Jun Zhang commented on FLINK-14739:
---
In the process of my development, I have found two kinds of
Jun Zhang created FLINK-14739:
-
Summary: add failOnCastException Configuration to Json
FormatDescriptor
Key: FLINK-14739
URL: https://issues.apache.org/jira/browse/FLINK-14739
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-13900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931002#comment-16931002
]
Jun Zhang commented on FLINK-13900:
---
I suggest that we should control the output speed of the stream
[
https://issues.apache.org/jira/browse/FLINK-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang closed FLINK-14077.
-
Fix Version/s: 1.9.0
Resolution: Fixed
> get java.util.ConcurrentModificationException when
[
https://issues.apache.org/jira/browse/FLINK-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930995#comment-16930995
]
Jun Zhang commented on FLINK-14077:
---
I excluded the kafka-clients in flink-connector-kafka and added
[
https://issues.apache.org/jira/browse/FLINK-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930190#comment-16930190
]
Jun Zhang commented on FLINK-14077:
---
[~yunta]thanks，I try to upgrade the version.
> get
[
https://issues.apache.org/jira/browse/FLINK-12898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang reassigned FLINK-12898:
-
Assignee: Jun Zhang
> FlinkSQL job fails when rowTime field encounters dirty data
>
1 - 100 of 143 matches
Mail list logo
