Liu created FLINK-10949:
---
Summary: When use flink-1.6.2's intervalJoin funtion, the thread
is stucked in rockdb's seek for too long time
Key: FLINK-10949
URL: https://issues.apache.org/jira/browse/FLINK-10949
P
[
https://issues.apache.org/jira/browse/FLINK-10949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-10949:
Description:
0down vote
[favorite|https://stackoverflow.com/questions/53393775/when-use-flink-1-6-2s-intervaljoin
[
https://issues.apache.org/jira/browse/FLINK-10949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-10949:
Description:
0down vote
[favorite|https://stackoverflow.com/questions/53393775/when-use-flink-1-6-2s-intervaljoin
Liu created FLINK-11050:
---
Summary: When IntervalJoin, get left or right buffer's entries
more quickly by assigning lowerBound
Key: FLINK-11050
URL: https://issues.apache.org/jira/browse/FLINK-11050
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-11050:
Description:
When IntervalJoin, it is very slow to get left or right buffer's entries.
Because we have to sca
[
https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-11050:
Description:
When IntervalJoin, it is very slow to get left or right buffer's entries.
Because we have to sca
[
https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-11050:
Fix Version/s: (was: 1.7.1)
> When IntervalJoin, get left or right buffer's entries more quickly by
> assigni
liu created FLINK-20230:
---
Summary: PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW
FileNotFoundException
Key: FLINK-20230
URL: https://issues.apache.org/jira/browse/FLINK-20230
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liu updated FLINK-20230:
Environment:
TABLE DDL:
CREATE TABLE IF NOT EXISTS test1 (
uid string,
truename string,
dt string
)
ROW FORM
[
https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liu updated FLINK-20230:
Description:
if table has PARTITIONED, USE SQL "INSERT INTO VALUES", WHEN THE VALUES IS
NULL, AND IT WILL THROW F
liu created FLINK-20238:
---
Summary: flink-sql-connector-elasticsearch does not support
Elasticsearch auth
Key: FLINK-20238
URL: https://issues.apache.org/jira/browse/FLINK-20238
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liu updated FLINK-20230:
Description:
table USE SQL "INSERT INTO VALUES", WHEN THE VALUES IS NULL, AND IT WILL THROW
FileNotFoundExceptio
[
https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liu updated FLINK-20230:
Summary: INSERT INTO EMPTY VALUES, THROW FileNotFoundException (was:
PARTITIONED TABLE, INSERT INTO EMPTY VALUE
liu created FLINK-20330:
---
Summary: Flink connector has error in support hive external tables
(hbase or es)
Key: FLINK-20330
URL: https://issues.apache.org/jira/browse/FLINK-20330
Project: Flink
Issue
Liu created FLINK-19409:
---
Summary: The comment for getValue has wrong code in class ListView
Key: FLINK-19409
URL: https://issues.apache.org/jira/browse/FLINK-19409
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-19409:
Description:
The comment for getValue is as following currently:
{code:java}
* @Override
* public Long get
[
https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202519#comment-17202519
]
Liu commented on FLINK-19409:
-
[~jark] I would like to fix it. Can you assign this ticket to
[
https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202936#comment-17202936
]
Liu commented on FLINK-19409:
-
Hi, [~jark]. Please review the code. Thank you.
> The commen
Liu created FLINK-18959:
---
Summary: Fail to archiveExecutionGraph because job is not finished
when dispatcher close
Key: FLINK-18959
URL: https://issues.apache.org/jira/browse/FLINK-18959
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-18959:
Description:
When job is cancelled, we expect to see it in flink's history server. But I can
not see my job after
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-18959:
Description:
When job is cancelled, we expect to see it in flink's history server. But I can
not see my job after
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-18959:
Attachment: flink-debug-log
> Fail to archiveExecutionGraph because job is not finished when dispatcher
> close
>
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177706#comment-17177706
]
Liu commented on FLINK-18959:
-
Thank you, [~rmetzger] .The job is per-job and is running on
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178414#comment-17178414
]
Liu commented on FLINK-18959:
-
Thank you, [~trohrmann]. I have the same confusion with you.
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-18959:
Description:
When job is cancelled, we expect to see it in flink's history server. But I can
not see my job after
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181706#comment-17181706
]
Liu commented on FLINK-18959:
-
Hi, [~trohrmann]. The problem has been raised for some time.
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183137#comment-17183137
]
Liu commented on FLINK-18959:
-
[~trohrmann], thanks for your advice. I just try to revert th
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183683#comment-17183683
]
Liu commented on FLINK-18959:
-
Thanks for the reply, [~trohrmann] and [~aljoscha]. After rev
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1717#comment-1717
]
Liu edited comment on FLINK-18959 at 9/2/20, 12:34 AM:
---
Hi, [~troh
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1717#comment-1717
]
Liu commented on FLINK-18959:
-
Hi, [~trohrmann] and [~aljoscha]. If we just revert the {{Min
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1717#comment-1717
]
Liu edited comment on FLINK-18959 at 9/2/20, 12:36 AM:
---
Hi, [~troh
Liu created FLINK-17446:
---
Summary: Blink supports cube and window together in group by
Key: FLINK-17446
URL: https://issues.apache.org/jira/browse/FLINK-17446
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-17446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-17446:
Description:
Blink planner supports CUBE. CUBE can be used together with a field but
not window. For exampl
Liu created FLINK-18625:
---
Summary: Maintain redundant taskmanagers to speed up failover
Key: FLINK-18625
URL: https://issues.apache.org/jira/browse/FLINK-18625
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-18625:
Description:
When flink job fails because of killed taskmanagers, it will request new
containers when restarting.
[
https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160856#comment-17160856
]
Liu edited comment on FLINK-18625 at 7/20/20, 2:43 AM:
---
Thanks for
[
https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160856#comment-17160856
]
Liu commented on FLINK-18625:
-
Thanks for [~xintongsong] 's reply. The following is my cons
[
https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160856#comment-17160856
]
Liu edited comment on FLINK-18625 at 7/20/20, 2:46 AM:
---
Thanks for
[
https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160901#comment-17160901
]
Liu commented on FLINK-18625:
-
Yes, I can do it. Please assign this feature to me. Thank you
[
https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-18625:
Description:
When flink job fails because of killed taskmanagers, it will request new
containers when restarting.
[
https://issues.apache.org/jira/browse/FLINK-18760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167666#comment-17167666
]
Liu commented on FLINK-18760:
-
Thanks for report this case, [~xintongsong]. I will fix it la
[
https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742338#comment-17742338
]
Liu commented on FLINK-19249:
-
[~ym] [~zjwang] [~pnowojski] [~xtsong] Any progress on this i
Liu created FLINK-32133:
---
Summary: Batch requests and remove requests in the end to reduce
YarnResourceManager's excess containers
Key: FLINK-32133
URL: https://issues.apache.org/jira/browse/FLINK-32133
Project
[
https://issues.apache.org/jira/browse/FLINK-32133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724268#comment-17724268
]
Liu commented on FLINK-32133:
-
A related issue is https://issues.apache.org/jira/browse/FLIN
[
https://issues.apache.org/jira/browse/FLINK-32133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724829#comment-17724829
]
Liu commented on FLINK-32133:
-
[~huwh] Thanks for the detail analysis. Although the problem
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725186#comment-17725186
]
Liu commented on FLINK-30629:
-
[~Weijie Guo] [~Sergey Nuyanzin] I will have a look.
> Cli
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727062#comment-17727062
]
Liu commented on FLINK-30629:
-
[~Sergey Nuyanzin] I have tried multi times but can not repro
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728714#comment-17728714
]
Liu commented on FLINK-30629:
-
[~Sergey Nuyanzin] Thanks. From the log, we can see the logs
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730783#comment-17730783
]
Liu commented on FLINK-30629:
-
[~Sergey Nuyanzin] Fixed. Please review the code. Thanks.
>
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730942#comment-17730942
]
Liu commented on FLINK-30629:
-
Rebased. Thanks.
> ClientHeartbeatTest.testJobRunningIfClien
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675533#comment-17675533
]
Liu commented on FLINK-30629:
-
[~xtsong] Thanks. I would fix it as soon as possible.
> Clie
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-30629:
Attachment: ClientHeartbeatTestLog.txt
> ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable
> -
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675921#comment-17675921
]
Liu commented on FLINK-30629:
-
[~xtsong] I have reproduced the failure locally and upload th
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675921#comment-17675921
]
Liu edited comment on FLINK-30629 at 1/12/23 10:10 AM:
---
[~xtsong]
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677179#comment-17677179
]
Liu commented on FLINK-30629:
-
[~xtsong] Have a look at the code? Thanks.
> ClientHeartbeat
[
https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717449#comment-17717449
]
Liu commented on FLINK-30773:
-
[~mxm] The rescaling api is useful in many situations such as
[
https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717449#comment-17717449
]
Liu edited comment on FLINK-30773 at 4/28/23 6:43 AM:
--
[~mxm] The r
Liu created FLINK-32023:
---
Summary: execution.buffer-timeout cannot be set to -1 ms
Key: FLINK-32023
URL: https://issues.apache.org/jira/browse/FLINK-32023
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720395#comment-17720395
]
Liu commented on FLINK-32023:
-
[~wanglijie] [~fanrui] Thanks for the reply. I would to fix i
[
https://issues.apache.org/jira/browse/FLINK-23203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-23203:
Attachment: image-2021-07-01-18-56-24-263.png
> Program cannot parse the parameter value with special characters
>
[
https://issues.apache.org/jira/browse/FLINK-23203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372631#comment-17372631
]
Liu commented on FLINK-23203:
-
Hi, I have checked the case but not reproduce. Maybe you can
Liu created FLINK-23300:
---
Summary: Job fails very slow because of no notifyAllocationFailure
for DeclarativeSlotManager
Key: FLINK-23300
URL: https://issues.apache.org/jira/browse/FLINK-23300
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-23300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376985#comment-17376985
]
Liu commented on FLINK-23300:
-
Thanks, [~Thesharing]. I will focus on the issues you mention
[
https://issues.apache.org/jira/browse/FLINK-23300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu closed FLINK-23300.
---
Resolution: Duplicate
> Job fails very slow because of no notifyAllocationFailure for
> DeclarativeSlotManager
> --
[
https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379070#comment-17379070
]
Liu commented on FLINK-23216:
-
I have met the same problem
[FLINK-23300|https://issues.apac
[
https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379117#comment-17379117
]
Liu commented on FLINK-23216:
-
Thanks, [~trohrmann] The basic idea is as you said before. Wh
[
https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379117#comment-17379117
]
Liu edited comment on FLINK-23216 at 7/12/21, 10:46 AM:
Thanks,
Liu created FLINK-20762:
---
Summary: Remove unused checkpointStorage path after job finished
Key: FLINK-20762
URL: https://issues.apache.org/jira/browse/FLINK-20762
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-20762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-20762:
Description:
Current checkpoint structure is as following:
{code:java}
/user-defined-checkpoint-dir
|
[
https://issues.apache.org/jira/browse/FLINK-20762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254936#comment-17254936
]
Liu commented on FLINK-20762:
-
[~yunta] Thank you for your information. I have read the FLIN
[
https://issues.apache.org/jira/browse/FLINK-20762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu closed FLINK-20762.
---
Resolution: Duplicate
> Remove unused checkpointStorage path after job finished
> --
Liu created FLINK-20872:
---
Summary: Job resume from history savepoint when failover if
checkpoint is disabled
Key: FLINK-20872
URL: https://issues.apache.org/jira/browse/FLINK-20872
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-20872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-20872:
Affects Version/s: (was: 1.11.0)
1.10.0
> Job resume from history savepoint when failov
[
https://issues.apache.org/jira/browse/FLINK-20872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260408#comment-17260408
]
Liu commented on FLINK-20872:
-
[~yunta] Thank you. For you questions:
1. Yes. The job is c
[
https://issues.apache.org/jira/browse/FLINK-20872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260893#comment-17260893
]
Liu commented on FLINK-20872:
-
[~yunta] Since it is designed to be this, I am ok with it. Ma
Liu created FLINK-22453:
---
Summary: Can not stop job when not ust "-m" option
Key: FLINK-22453
URL: https://issues.apache.org/jira/browse/FLINK-22453
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-22453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-22453:
Description:
flink version: 1.12.2
yarn version : 3.1.1 (hdp 3.1.5)
h3. Starting a Flink Session on YARN
when i
[
https://issues.apache.org/jira/browse/FLINK-22453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-22453:
Description:
flink version: 1.12.2
yarn version : 3.1.1 (hdp 3.1.5)
h3. Starting a Flink Session on YARN
when i
[
https://issues.apache.org/jira/browse/FLINK-22453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-22453:
Summary: Can not stop job when do not use "-m" option arg (was: Can not
stop job when do not use "-m" option)
[
https://issues.apache.org/jira/browse/FLINK-22453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-22453:
Summary: Can not stop job when do not use "-m" option (was: Can not stop
job when not ust "-m" option)
> Can no
[
https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345827#comment-17345827
]
liu commented on FLINK-22540:
-
For user-define-function,I want to know how to create functio
[
https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345827#comment-17345827
]
liu edited comment on FLINK-22540 at 5/17/21, 2:21 AM:
---
For user-d
[
https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345851#comment-17345851
]
liu commented on FLINK-19973:
-
When use flink-sql-client , how to set {{execution.target to
[
https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346753#comment-17346753
]
liu commented on FLINK-22540:
-
Hi,[~jark], I understand about "make the construtor arguments
[
https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347443#comment-17347443
]
liu commented on FLINK-22540:
-
Thanks a lot [~jark],I got it.
> Remove YAML environment fil
[
https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17037105#comment-17037105
]
Liu commented on FLINK-16030:
-
Sorry for late reply. For quick fix, I send ping message to s
Liu created FLINK-16229:
---
Summary: testCompressionOnRelativePath() fails due to
Files.createDirectory() in macOS
Key: FLINK-16229
URL: https://issues.apache.org/jira/browse/FLINK-16229
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-16229:
Description:
I am using flink 1.10.0. In macOS, cd flink/flink-core and execute "mvn
-Dtest=org.apache.fli
[
https://issues.apache.org/jira/browse/FLINK-16229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-16229:
Description:
I am using flink 1.10.0. In macOS, cd flink/flink-core and execute "mvn
-Dtest=org.apache.fli
liu created FLINK-14981:
---
Summary: web frontend support dynamic adjustment of the log level
Key: FLINK-14981
URL: https://issues.apache.org/jira/browse/FLINK-14981
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-11215:
Description:
Sometimes, job will fail after 5 minutes because register fail at resource
manager.
!https://wiki.c
[
https://issues.apache.org/jira/browse/FLINK-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-11215:
Description:
Sometimes, job will fail after 5 minutes because register fail at resource
manager.
!https://wiki.c
[
https://issues.apache.org/jira/browse/FLINK-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-11215:
Description:
Sometimes, job will fail after 5 minutes because register fail at resource
manager.
!https://wiki.c
Liu created FLINK-11215:
---
Summary: TaskExecutor RegistrationTimeoutException within the
specified maximum registration duration 30ms
Key: FLINK-11215
URL: https://issues.apache.org/jira/browse/FLINK-11215
P
[
https://issues.apache.org/jira/browse/FLINK-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16728607#comment-16728607
]
Liu commented on FLINK-11215:
-
Yes, the problem is the same. Thank you for your reply.
> Ta
[
https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413464#comment-17413464
]
Liu commented on FLINK-23969:
-
[~syhily] I have written E2E test just like KafkaSourceE2ECas
[
https://issues.apache.org/jira/browse/FLINK-23821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413715#comment-17413715
]
Liu commented on FLINK-23821:
-
Hi, [~hxbks2ks]. I have read the loopback mode and find that
[
https://issues.apache.org/jira/browse/FLINK-23821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413715#comment-17413715
]
Liu edited comment on FLINK-23821 at 9/12/21, 2:29 PM:
---
Hi, [~hxbk
[
https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414505#comment-17414505
]
Liu commented on FLINK-23969:
-
Hello, [~arvid] and [~syhily] . Could you review my code? Tha
[
https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414682#comment-17414682
]
Liu commented on FLINK-23969:
-
[~syhily] I have reviewed your code. The additional Shared a
1 - 100 of 1480 matches
Mail list logo