[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136679#comment-17136679
]
Piotr Nowojski commented on FLINK-17824:
Still I don't see why it is or why does it have to be
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136624#comment-17136624
]
Roman Khachatryan commented on FLINK-17824:
---
"200 records" is measured closer to sink.
Source
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136548#comment-17136548
]
Piotr Nowojski commented on FLINK-17824:
{quote}
Waiting for job to process up to 200 records,
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136450#comment-17136450
]
Roman Khachatryan commented on FLINK-17824:
---
I've published a PR to fix the test:
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135897#comment-17135897
]
Piotr Nowojski commented on FLINK-17824:
Ok, let's try to increase the sleep_time. But this
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135572#comment-17135572
]
Roman Khachatryan commented on FLINK-17824:
---
> Is it taking couple of minutes to process the
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134028#comment-17134028
]
Piotr Nowojski commented on FLINK-17824:
> 1. stop the sources immediately: though the
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133014#comment-17133014
]
Roman Khachatryan commented on FLINK-17824:
---
[~rmetzger], yes I think it's the same issue.
>
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132984#comment-17132984
]
Robert Metzger commented on FLINK-17824:
[~roman_khachatryan] do you think this is the same
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132567#comment-17132567
]
Roman Khachatryan commented on FLINK-17824:
---
TLDR: If there is an ongoing checkpoint then it
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128952#comment-17128952
]
Roman Khachatryan commented on FLINK-17824:
---
I'm looking into this issue and found so far:
1.
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126379#comment-17126379
]
Piotr Nowojski commented on FLINK-17824:
As it was first reported around feature when we were
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125795#comment-17125795
]
Robert Metzger commented on FLINK-17824:
Another instance on master (which makes the Hadoop
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125594#comment-17125594
]
Robert Metzger commented on FLINK-17824:
hadoop 3.1.3
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124618#comment-17124618
]
Robert Metzger commented on FLINK-17824:
Now with logs:
[
https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118758#comment-17118758
]
Robert Metzger commented on FLINK-17824:
Introduced a timeout for this test so that we can debug
16 matches
Mail list logo
