[GitHub] [flink] flinkbot edited a comment on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * a0225769113bc5163d40f7dfa600f7636629a530 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * 5babde60923df8d09e936677752ac1140f69993f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rkhachatryan commented on pull request #14073: [FLINK-20145][task] Don't expose modifiable PrioritizedDeque.iterator

2020-11-14 Thread GitBox
rkhachatryan commented on pull request #14073: URL: https://github.com/apache/flink/pull/14073#issuecomment-727525870 AZP build failed because of FLINK-20149 ``` *2020-11-15T03:22:38.3437135Z Nov 15 03:22:38 [ERROR] Failures: 2020-11-15T03:22:38.3438208Z Nov 15 03:22:38 [ERROR]

[jira] [Commented] (FLINK-20163) Translate page 'raw type' into Chinese

2020-11-14 Thread taojiayun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232204#comment-17232204 ] taojiayun commented on FLINK-20163: --- Hi,[~hailong wang],Could you assign this issue to

[GitHub] [flink] flinkbot edited a comment on pull request #14074: [FLINK-20129][table ecosystem] Create a zh download page for all optional sql client components

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14074: URL: https://github.com/apache/flink/pull/14074#issuecomment-727311077 ## CI report: * 17635c6f6c3ebddef63bc22798968ea5bf7e UNKNOWN * 503c48b2703bbcf02f32ead5aa3a2dae9f094560 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14071: [FLINK-16753] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRnnable

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14071: URL: https://github.com/apache/flink/pull/14071#issuecomment-727151742 ## CI report: * f5da32b8c5b1d77c84f36d5bdacc552f6c32923c Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/201450104) Bot comman

[GitHub] [flink] flinkbot edited a comment on pull request #14071: [FLINK-16753] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRnnable

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14071: URL: https://github.com/apache/flink/pull/14071#issuecomment-727151742 ## CI report: * f5da32b8c5b1d77c84f36d5bdacc552f6c32923c Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/201450104) Bot comman

[GitHub] [flink] Jiayi-Liao commented on pull request #14071: [FLINK-16753] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRnnable

2020-11-14 Thread GitBox
Jiayi-Liao commented on pull request #14071: URL: https://github.com/apache/flink/pull/14071#issuecomment-727491346 The failure is from python testing module, which should be unrelated to my changes. This is an automated mes

[GitHub] [flink] Jiayi-Liao commented on pull request #14071: [FLINK-16753] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRnnable

2020-11-14 Thread GitBox
Jiayi-Liao commented on pull request #14071: URL: https://github.com/apache/flink/pull/14071#issuecomment-727490526 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * d9ea02a589918185fb18189cf5d1d1fac42234e8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14074: [FLINK-20129][table ecosystem] Create a zh download page for all optional sql client components

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14074: URL: https://github.com/apache/flink/pull/14074#issuecomment-727311077 ## CI report: * 17635c6f6c3ebddef63bc22798968ea5bf7e UNKNOWN * 503c48b2703bbcf02f32ead5aa3a2dae9f094560 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * d9ea02a589918185fb18189cf5d1d1fac42234e8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wangxlong commented on pull request #14074: [FLINK-20129][table ecosystem] Create a zh download page for all optional sql client components

2020-11-14 Thread GitBox
wangxlong commented on pull request #14074: URL: https://github.com/apache/flink/pull/14074#issuecomment-727395792 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #14073: [FLINK-20145][task] Don't expose modifiable PrioritizedDeque.iterator

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14073: URL: https://github.com/apache/flink/pull/14073#issuecomment-727280506 ## CI report: * 399fbe50a7f2e1e09525bc24e41b50eda8b59e55 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14074: [FLINK-20129][table ecosystem] Create a zh download page for all optional sql client components

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14074: URL: https://github.com/apache/flink/pull/14074#issuecomment-727311077 ## CI report: * 17635c6f6c3ebddef63bc22798968ea5bf7e UNKNOWN * 503c48b2703bbcf02f32ead5aa3a2dae9f094560 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-20163) Translate page 'raw type' into Chinese

2020-11-14 Thread hailong wang (Jira)
hailong wang created FLINK-20163: Summary: Translate page 'raw type' into Chinese Key: FLINK-20163 URL: https://issues.apache.org/jira/browse/FLINK-20163 Project: Flink Issue Type: Improvemen

[GitHub] [flink] flinkbot edited a comment on pull request #14051: [FLINK-20107][network] Make InputChannel.statePersister immutable

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-726175036 ## CI report: * 9fcb590d47c3e38c04e8fb083108166589c97607 UNKNOWN * ef07f72934a41c332894e820441cb12c84ef819c Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14074: [FLINK-20129][table ecosystem] Create a zh download page for all optional sql client components

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14074: URL: https://github.com/apache/flink/pull/14074#issuecomment-727311077 ## CI report: * 17635c6f6c3ebddef63bc22798968ea5bf7e UNKNOWN * 503c48b2703bbcf02f32ead5aa3a2dae9f094560 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot commented on pull request #14074: [FLINK-20129][table ecosystem] Create a zh download page for all optional sql client components

2020-11-14 Thread GitBox
flinkbot commented on pull request #14074: URL: https://github.com/apache/flink/pull/14074#issuecomment-727311077 ## CI report: * 17635c6f6c3ebddef63bc22798968ea5bf7e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #14074: [FLINK-20129][table ecosystem] Create a zh download page for all optional sql client components

2020-11-14 Thread GitBox
flinkbot commented on pull request #14074: URL: https://github.com/apache/flink/pull/14074#issuecomment-727297098 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] wangxlong opened a new pull request #14074: [FLINK-20129][table ecosystem] Create a zh download page for all optional sql client components

2020-11-14 Thread GitBox
wangxlong opened a new pull request #14074: URL: https://github.com/apache/flink/pull/14074 ## What is the purpose of the change Create a zh download page for all optional sql client components ## Brief change log 1. Create download.zh.md 2. Update depedencies lin

[jira] [Updated] (FLINK-20129) Create a zh download page for all optional sql client components

2020-11-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20129: --- Labels: pull-request-available (was: ) > Create a zh download page for all optional sql cli

[GitHub] [flink-web] wangxlong opened a new pull request #393: [FLINK-20129] Link to zh SQL components download page

2020-11-14 Thread GitBox
wangxlong opened a new pull request #393: URL: https://github.com/apache/flink-web/pull/393 Link to zh SQL components download page This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink-web] wangxlong closed pull request #392: [FLINK-20093] Link to zh SQL components download page

2020-11-14 Thread GitBox
wangxlong closed pull request #392: URL: https://github.com/apache/flink-web/pull/392 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

[GitHub] [flink-web] wangxlong opened a new pull request #392: [FLINK-20093] Link to zh SQL components download page

2020-11-14 Thread GitBox
wangxlong opened a new pull request #392: URL: https://github.com/apache/flink-web/pull/392 Link to zh SQL components download page This is an automated message from the Apache Git Service. To respond to the message, please l

[jira] [Comment Edited] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232187#comment-17232187 ] Dian Fu edited comment on FLINK-20149 at 11/15/20, 1:14 AM:

[jira] [Commented] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232187#comment-17232187 ] Dian Fu commented on FLINK-20149: - Found the following log: {code} 13:45:17,570 [ Thread

[jira] [Commented] (FLINK-20135) Test Python DataStream API

2020-11-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232186#comment-17232186 ] Dian Fu commented on FLINK-20135: -  [~csq] Thanks a lot~ > Test Python DataStream API >

[jira] [Assigned] (FLINK-20135) Test Python DataStream API

2020-11-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20135: --- Assignee: Shuiqiang Chen > Test Python DataStream API > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * a0225769113bc5163d40f7dfa600f7636629a530 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * 94b400f3a36ba2d65950b196a9d2650effb64cdc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14073: [FLINK-20145][task] Don't expose modifiable PrioritizedDeque.iterator

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14073: URL: https://github.com/apache/flink/pull/14073#issuecomment-727280506 ## CI report: * 399fbe50a7f2e1e09525bc24e41b50eda8b59e55 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14073: [FLINK-20145][task] Don't expose modifiable PrioritizedDeque.iterator

2020-11-14 Thread GitBox
flinkbot commented on pull request #14073: URL: https://github.com/apache/flink/pull/14073#issuecomment-727280506 ## CI report: * 399fbe50a7f2e1e09525bc24e41b50eda8b59e55 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * 94b400f3a36ba2d65950b196a9d2650effb64cdc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14051: [FLINK-20107][network] Make InputChannel.statePersister immutable

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-726175036 ## CI report: * 9fcb590d47c3e38c04e8fb083108166589c97607 UNKNOWN * da63201e58ce9ec0cbf5546a19ffc645a80046b7 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-20145) Streaming job fails with IllegalStateException: Should only poll priority events

2020-11-14 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232171#comment-17232171 ] Roman Khachatryan edited comment on FLINK-20145 at 11/14/20, 11:10 PM: ---

[jira] [Commented] (FLINK-20145) Streaming job fails with IllegalStateException: Should only poll priority events

2020-11-14 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232171#comment-17232171 ] Roman Khachatryan commented on FLINK-20145: --- I came across this issue while de

[GitHub] [flink] flinkbot commented on pull request #14073: [FLINK-20145][task] Don't expose modifiable PrioritizedDeque.iterator

2020-11-14 Thread GitBox
flinkbot commented on pull request #14073: URL: https://github.com/apache/flink/pull/14073#issuecomment-727278544 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-20145) Streaming job fails with IllegalStateException: Should only poll priority events

2020-11-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20145: --- Labels: pull-request-available (was: ) > Streaming job fails with IllegalStateException: Sh

[GitHub] [flink] rkhachatryan opened a new pull request #14073: [FLINK-20145][task] Don't expose modifiable PrioritizedDeque.iterator

2020-11-14 Thread GitBox
rkhachatryan opened a new pull request #14073: URL: https://github.com/apache/flink/pull/14073 ## What is the purpose of the change Don't expose modifiable PrioritizedDeque.iterator to prevent inconsistency between `numPriorityElements` and `deque`. ## Verifying this change

[GitHub] [flink] flinkbot edited a comment on pull request #14051: [FLINK-20107][network] Make InputChannel.statePersister immutable

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-726175036 ## CI report: * 9fcb590d47c3e38c04e8fb083108166589c97607 UNKNOWN * da63201e58ce9ec0cbf5546a19ffc645a80046b7 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * d9ea02a589918185fb18189cf5d1d1fac42234e8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232116#comment-17232116 ] Robert Metzger commented on FLINK-20149: https://dev.azure.com/apache-flink/apac

[jira] [Updated] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20149: --- Priority: Blocker (was: Critical) > SQLClientKafkaITCase.testKafka failed with "Did not get

[jira] [Commented] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232117#comment-17232117 ] Robert Metzger commented on FLINK-20149: Upgrading to blocker, all e2e tests are

[jira] [Commented] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232114#comment-17232114 ] Robert Metzger commented on FLINK-20149: https://dev.azure.com/apache-flink/apac

[GitHub] [flink] flinkbot edited a comment on pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14042: URL: https://github.com/apache/flink/pull/14042#issuecomment-725744439 ## CI report: * e3b7dd66064055ba3fac57199e8a5acc7f00a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14042: URL: https://github.com/apache/flink/pull/14042#issuecomment-725744439 ## CI report: * 789adc9519b48d6474d12b282d529ea0a024bfc9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232106#comment-17232106 ] Robert Metzger commented on FLINK-20149: https://dev.azure.com/apache-flink/apac

[GitHub] [flink] Acesine commented on a change in pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-14 Thread GitBox
Acesine commented on a change in pull request #14042: URL: https://github.com/apache/flink/pull/14042#discussion_r523448225 ## File path: flink-core/src/main/java/org/apache/flink/core/io/PostVersionedIOReadableWritable.java ## @@ -62,16 +62,23 @@ public void write(DataOutputV

[jira] [Comment Edited] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types

2020-11-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232086#comment-17232086 ] Benoît Paris edited comment on FLINK-15867 at 11/14/20, 5:29 PM: -

[jira] [Updated] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types

2020-11-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-15867: - Summary: LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types (was

[jira] [Commented] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types

2020-11-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232086#comment-17232086 ] Benoît Paris commented on FLINK-15867: -- Edited it if that's ok with you [~jark] >

[jira] [Commented] (FLINK-15867) LAST_VALUE aggregate function does not support time-related types

2020-11-14 Thread Jannik Schmeier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232071#comment-17232071 ] Jannik Schmeier commented on FLINK-15867: - I would also like to include the time

[jira] [Commented] (FLINK-20152) Document which execution.target values are supported

2020-11-14 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232065#comment-17232065 ] Kostas Kloudas commented on FLINK-20152: That is correct. I will remove then the

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * 8b54a6b03978f1443620a8c06ec8f3388fabf322 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * 8b54a6b03978f1443620a8c06ec8f3388fabf322 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20155) java.lang.OutOfMemoryError: Direct buffer memory

2020-11-14 Thread roee hershko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] roee hershko updated FLINK-20155: - Description: update: this issue occur every time after a job fails the only way to fix it is to

[jira] [Commented] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232013#comment-17232013 ] Till Rohrmann commented on FLINK-20149: --- Another instance: https://dev.azure.com/

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

2020-11-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232011#comment-17232011 ] Till Rohrmann commented on FLINK-19461: --- I cannot confirm what [~rmetzger] is repo

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

2020-11-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232012#comment-17232012 ] Till Rohrmann commented on FLINK-19461: --- [~azagrebin] can we improve the error mes

[GitHub] [flink] tillrohrmann commented on a change in pull request #14070: [FLINK-20152] Document supported execution.target values

2020-11-14 Thread GitBox
tillrohrmann commented on a change in pull request #14070: URL: https://github.com/apache/flink/pull/14070#discussion_r523414990 ## File path: flink-core/src/main/java/org/apache/flink/configuration/DeploymentOptions.java ## @@ -34,7 +34,13 @@ key("exec

[jira] [Commented] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232006#comment-17232006 ] Till Rohrmann commented on FLINK-20138: --- W/o the debug logs it is hard to tell wha

[jira] [Commented] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232004#comment-17232004 ] Till Rohrmann commented on FLINK-20138: --- Unfortunately, FLINK-10052 won't make it

[jira] [Commented] (FLINK-20152) Document which execution.target values are supported

2020-11-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232002#comment-17232002 ] Till Rohrmann commented on FLINK-20152: --- But then the the valid target values can

[jira] [Comment Edited] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-14 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232000#comment-17232000 ] wgcn edited comment on FLINK-20138 at 11/14/20, 12:17 PM: -- [~tr

[jira] [Comment Edited] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-14 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232000#comment-17232000 ] wgcn edited comment on FLINK-20138 at 11/14/20, 12:13 PM: -- [~tr

[jira] [Comment Edited] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-14 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232000#comment-17232000 ] wgcn edited comment on FLINK-20138 at 11/14/20, 12:11 PM: -- [~tr

[jira] [Commented] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-14 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232000#comment-17232000 ] wgcn commented on FLINK-20138: -- [~trohrmann] , the log 'Connecting to ResourceManager x

[GitHub] [flink] flinkbot edited a comment on pull request #13580: [hotfix][flink-runtime-web] modify checkpoint time format

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #13580: URL: https://github.com/apache/flink/pull/13580#issuecomment-706475658 ## CI report: * c8adc676db1403b4a2eef7f9898970f2051dea1f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wuchong closed pull request #13738: [FLINK-19757][flink-table-common] fix the local datetime inconsistent…

2020-11-14 Thread GitBox
wuchong closed pull request #13738: URL: https://github.com/apache/flink/pull/13738 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #13738: [FLINK-19757][flink-table-common] fix the local datetime inconsistent…

2020-11-14 Thread GitBox
wuchong commented on pull request #13738: URL: https://github.com/apache/flink/pull/13738#issuecomment-727182430 Close as this is not a problem. See the discussion in JIRA issue. This is an automated message from the Apache G

[jira] [Closed] (FLINK-19757) TimeStampData can cause time inconsistent problem

2020-11-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19757. --- Resolution: Not A Problem As discussed, this is not a problem. I created https://issues.apache.org/jira/bro

[jira] [Created] (FLINK-20162) Fix time zone problems of some time related functions

2020-11-14 Thread Jark Wu (Jira)
Jark Wu created FLINK-20162: --- Summary: Fix time zone problems of some time related functions Key: FLINK-20162 URL: https://issues.apache.org/jira/browse/FLINK-20162 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-20162) Fix time zone problems form some time related functions

2020-11-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20162: Summary: Fix time zone problems form some time related functions (was: Fix time zone problems of some tim

[jira] [Updated] (FLINK-20162) Fix time zone problems for some time related functions

2020-11-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20162: Summary: Fix time zone problems for some time related functions (was: Fix time zone problems form some ti

[GitHub] [flink] yimingf closed pull request #13674: [FLINK-18743] [docs-zh] Modify English link to Chinese link

2020-11-14 Thread GitBox
yimingf closed pull request #13674: URL: https://github.com/apache/flink/pull/13674 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #14072: [FLINK-16753][checkpointing] Use CheckpointException to wrap exceptio…

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14072: URL: https://github.com/apache/flink/pull/14072#issuecomment-727151913 ## CI report: * 199fa6bf52667dee155e4d29dfe026114e5f4b0a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20160) Implement standard metrics in JDBC connectors.

2020-11-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20160: Component/s: Table SQL / Ecosystem > Implement standard metrics in JDBC connectors. >

[jira] [Assigned] (FLINK-20160) Implement standard metrics in JDBC connectors.

2020-11-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20160: --- Assignee: Lijie Wang > Implement standard metrics in JDBC connectors. > ---

[GitHub] [flink] flinkbot edited a comment on pull request #14071: [FLINK-16753] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRnnable

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #14071: URL: https://github.com/apache/flink/pull/14071#issuecomment-727151742 ## CI report: * f5da32b8c5b1d77c84f36d5bdacc552f6c32923c Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/201450104) Bot comman

[jira] [Commented] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-14 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231966#comment-17231966 ] wgcn commented on FLINK-20138: -- [~trohrmann] I upload the resource_manager_lock at the att

[jira] [Updated] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-14 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wgcn updated FLINK-20138: - Attachment: zk_resource_address_info.png > Flink Job can not recover due to timeout of requiring slots when fli

[GitHub] [flink] flinkbot edited a comment on pull request #13580: [hotfix][flink-runtime-web] modify checkpoint time format

2020-11-14 Thread GitBox
flinkbot edited a comment on pull request #13580: URL: https://github.com/apache/flink/pull/13580#issuecomment-706475658 ## CI report: * 5e7065d97069dac679f52c359b204004c9ec8969 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result