[jira] [Commented] (FLINK-20146) Update zh connector and format dependencies link

[ https://issues.apache.org/jira/browse/FLINK-20146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231956#comment-17231956 ] hailong wang commented on FLINK-20146: -- Sorry, It can be included  by FLINK-20129 > Update zh

[jira] [Closed] (FLINK-20146) Update zh connector and format dependencies link

[ https://issues.apache.org/jira/browse/FLINK-20146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang closed FLINK-20146. Resolution: Duplicate > Update zh connector and format dependencies link >

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

flinkbot edited a comment on pull request #13580: URL: https://github.com/apache/flink/pull/13580#issuecomment-706475658 ## CI report: * 5e7065d97069dac679f52c359b204004c9ec8969 Azure:

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

flinkbot edited a comment on pull request #14072: URL: https://github.com/apache/flink/pull/14072#issuecomment-727151913 ## CI report: * 199fa6bf52667dee155e4d29dfe026114e5f4b0a Azure:

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

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

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

flinkbot commented on pull request #14072: URL: https://github.com/apache/flink/pull/14072#issuecomment-727151913 ## CI report: * 199fa6bf52667dee155e4d29dfe026114e5f4b0a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot commented on pull request #14071: URL: https://github.com/apache/flink/pull/14071#issuecomment-727151742 ## CI report: * f5da32b8c5b1d77c84f36d5bdacc552f6c32923c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot commented on pull request #14072: URL: https://github.com/apache/flink/pull/14072#issuecomment-727149736 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

[jira] [Commented] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

[ https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231938#comment-17231938 ] Jiayi Liao commented on FLINK-16753: [~zjwang] [~NicoK] The change is simple. I've submitted two

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

flinkbot commented on pull request #14071: URL: https://github.com/apache/flink/pull/14071#issuecomment-727149591 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

[GitHub] [flink] Jiayi-Liao opened a new pull request #14072: [FLINK-16753][checkpointing] Use CheckpointException to wrap exceptio…

Jiayi-Liao opened a new pull request #14072: URL: https://github.com/apache/flink/pull/14072 Cherry-pick from https://github.com/apache/flink/pull/11509 to branch release-1.11. ## What is the purpose of the change If an exception is thrown from task's async checkpoint process,

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

Jiayi-Liao opened a new pull request #14071: URL: https://github.com/apache/flink/pull/14071 Cherry-pick from https://github.com/apache/flink/pull/11509 to branch release-1.10. ## What is the purpose of the change If an exception is thrown from task's async checkpoint process,

[jira] [Created] (FLINK-20161) Consider switching from Travis CI to Github Actions for flink-statefun's CI workflows

Tzu-Li (Gordon) Tai created FLINK-20161: --- Summary: Consider switching from Travis CI to Github Actions for flink-statefun's CI workflows Key: FLINK-20161 URL:

[GitHub] [flink] SteNicholas commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

SteNicholas commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-727142827 > I am having a look right now @SteNicholas @kl0u Any other comments by you? This is an automated

[jira] [Commented] (FLINK-20159) [FLIP-27 source] FutureNotifier does not return a new future when Future::future() is invoked within the returned future's callback

[ https://issues.apache.org/jira/browse/FLINK-20159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231924#comment-17231924 ] Jiangjie Qin commented on FLINK-20159: -- [~sundaram] Thanks for reporting the issue. This part of

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

[ https://issues.apache.org/jira/browse/FLINK-20160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231923#comment-17231923 ] Lijie Wang edited comment on FLINK-20160 at 11/14/20, 3:29 AM: --- Hi [~jark] 

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

[ https://issues.apache.org/jira/browse/FLINK-20160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231923#comment-17231923 ] Lijie Wang commented on FLINK-20160: Hi [~jark], what do you think?  And I'm willing to take on this

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

Lijie Wang created FLINK-20160: -- Summary: Implement standard metrics in JDBC connectors. Key: FLINK-20160 URL: https://issues.apache.org/jira/browse/FLINK-20160 Project: Flink Issue Type:

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

flinkbot edited a comment on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-726175036 ## CI report: * 9fcb590d47c3e38c04e8fb083108166589c97607 UNKNOWN * da63201e58ce9ec0cbf5546a19ffc645a80046b7 Azure:

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

flinkbot edited a comment on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-726175036 ## CI report: * 932afb33fec9d29d35c0b29c3e3b4424c0db9210 Azure:

[GitHub] [flink-statefun] tzulitai commented on pull request #131: [FLINK-18968] Translate README.md to Chinese

tzulitai commented on pull request #131: URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-727117942 Thanks @wangzzu! Please remember to retain @billyrrr original commits, and consider opening a separate PR with your commits on top.

[jira] [Closed] (FLINK-20085) Remove RemoteFunctionStateMigrator code paths from StateFun

[ https://issues.apache.org/jira/browse/FLINK-20085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-20085. --- Release Note: Starting from version 2.3.0, directly upgrading from savepoints

[GitHub] [flink-statefun] tzulitai closed pull request #172: [FLINK-20085] Remove RemoteFunctionStateMigrator from restore code paths

tzulitai closed pull request #172: URL: https://github.com/apache/flink-statefun/pull/172 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

[jira] [Closed] (FLINK-20088) [Kinesis][Polling] Issue using Polling consumer at timestamp with empty shard

[ https://issues.apache.org/jira/browse/FLINK-20088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-20088. --- Assignee: Danny Cranmer Resolution: Fixed > [Kinesis][Polling] Issue using

[jira] [Commented] (FLINK-20088) [Kinesis][Polling] Issue using Polling consumer at timestamp with empty shard

[ https://issues.apache.org/jira/browse/FLINK-20088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231906#comment-17231906 ] Tzu-Li (Gordon) Tai commented on FLINK-20088: - flink/master:

[GitHub] [flink] tzulitai closed pull request #14034: [FLINK-20088][kinesis] Fix issue encountered when Polling consumer using timestamp with empty shard

tzulitai closed pull request #14034: URL: https://github.com/apache/flink/pull/14034 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

[jira] [Closed] (FLINK-20139) Enrich logs when MiniDispatcher shutting down

[ https://issues.apache.org/jira/browse/FLINK-20139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-20139. - Fix Version/s: 1.13.0 Resolution: Fixed master via 3dc43e6fa66d1253a37e8a4bcf242b6865e340a5 >

[GitHub] [flink] TisonKun merged pull request #14058: [FLINK-20139][dispatcher] Enrich logs when MiniDispatcher shutting down

TisonKun merged pull request #14058: URL: https://github.com/apache/flink/pull/14058 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

[GitHub] [flink] TisonKun commented on pull request #14058: [FLINK-20139][dispatcher] Enrich logs when MiniDispatcher shutting down

TisonKun commented on pull request #14058: URL: https://github.com/apache/flink/pull/14058#issuecomment-727093490 Thanks for your review @tillrohrmann ! Merging... This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

flinkbot edited a comment on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-726585261 ## CI report: * 6fe31d3968af835ed0ce694d2ed6193c11173f5f Azure:

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

flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * 94b400f3a36ba2d65950b196a9d2650effb64cdc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14070: [FLINK-20152] Document supported execution.target values

flinkbot edited a comment on pull request #14070: URL: https://github.com/apache/flink/pull/14070#issuecomment-726978459 ## CI report: * cbf96e7bb990402b6e591d1f829d55d1e3b2cd01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

flinkbot edited a comment on pull request #14033: URL: https://github.com/apache/flink/pull/14033#issuecomment-725388043 ## CI report: * fc9f926baa63a9070e7522e17211b43fd7003bca Azure:

[jira] [Closed] (FLINK-20159) [FLIP-27 source] FutureNotifier does not return a new future when Future::future() is invoked within the returned future's callback

[ https://issues.apache.org/jira/browse/FLINK-20159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sundaram Ananthanarayanan closed FLINK-20159. - Resolution: Invalid > [FLIP-27 source] FutureNotifier does not return a

[GitHub] [flink] flinkbot edited a comment on pull request #14062: [FLINK-17470] Send sigkill to hanging processes in standalone scripts

flinkbot edited a comment on pull request #14062: URL: https://github.com/apache/flink/pull/14062#issuecomment-726595780 ## CI report: * a7642904aa14cc5fa3c328c0a048fe203ebd9454 Azure:

[jira] [Updated] (FLINK-20159) [FLIP-27 source] FutureNotifier does not return a new future when Future::future() is invoked within the returned future's callback

[ https://issues.apache.org/jira/browse/FLINK-20159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sundaram Ananthanarayanan updated FLINK-20159: -- Priority: Minor (was: Major) > [FLIP-27 source] FutureNotifier does

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

flinkbot edited a comment on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-726175036 ## CI report: * 932afb33fec9d29d35c0b29c3e3b4424c0db9210 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14049: [FLINK-20043][kinesis] Add flink-sql-connector-kinesis package

flinkbot edited a comment on pull request #14049: URL: https://github.com/apache/flink/pull/14049#issuecomment-726094991 ## CI report: * 0a068c0f16865a2c91819d21f52d759151acb97e UNKNOWN * d15f6e11ca8d46da440ed6c2235f73937d70ab3a UNKNOWN *

[GitHub] [flink-statefun] gvauvert commented on pull request #173: Fix some typos in Java code in documentation

gvauvert commented on pull request #173: URL: https://github.com/apache/flink-statefun/pull/173#issuecomment-727056607 Nice, thanks. This is an automated message from the Apache Git Service. To respond to the message, please

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

flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * bcd846138434e9990c388d970ff4d313c5099978 Azure:

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

flinkbot edited a comment on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-726175036 ## CI report: * 932afb33fec9d29d35c0b29c3e3b4424c0db9210 Azure:

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

flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * 8b54a6b03978f1443620a8c06ec8f3388fabf322 Azure:

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

flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * bcd846138434e9990c388d970ff4d313c5099978 Azure:

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

flinkbot edited a comment on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-726175036 ## CI report: * 932afb33fec9d29d35c0b29c3e3b4424c0db9210 Azure:

[GitHub] [flink] rkhachatryan commented on pull request #14051: [FLINK-20107][network] Make InputChannel.statePersister immutable

rkhachatryan commented on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-727035792 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #14069: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner

flinkbot edited a comment on pull request #14069: URL: https://github.com/apache/flink/pull/14069#issuecomment-726868291 ## CI report: * 4502be25c65684496cedd3d6f50e6b45e93f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14067: [FLINK-18673][table] Improve support for ROW constructor

flinkbot edited a comment on pull request #14067: URL: https://github.com/apache/flink/pull/14067#issuecomment-726839630 ## CI report: * 2dd441a701a3d73281b3590b3d0c457826e8ed08 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

flinkbot edited a comment on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-726585261 ## CI report: * ffe1daf67c98e39f476f1f15279c77bbc83a1c98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

flinkbot edited a comment on pull request #14052: URL: https://github.com/apache/flink/pull/14052#issuecomment-726216034 ## CI report: * 14e0929bf9cebd4db7c60c5928d71e631fb4ad47 UNKNOWN * 9b6d028dde24fc8fd21e3a3542756c813fca9c13 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13920: [FLINK-19743] Add metric definitions in FLIP-33 and report some of them by default.

flinkbot edited a comment on pull request #13920: URL: https://github.com/apache/flink/pull/13920#issuecomment-721560528 ## CI report: * 42822708e859b4da17db868fac3acd3e47e371b6 Azure:

[jira] [Created] (FLINK-20159) [FLIP-27 source] FutureNotifier does not return a new future when Future::future() is invoked within the returned future's callback

Sundaram Ananthanarayanan created FLINK-20159: - Summary: [FLIP-27 source] FutureNotifier does not return a new future when Future::future() is invoked within the returned future's callback Key: FLINK-20159

[GitHub] [flink] flinkbot edited a comment on pull request #14070: [FLINK-20152] Document supported execution.target values

flinkbot edited a comment on pull request #14070: URL: https://github.com/apache/flink/pull/14070#issuecomment-726978459 ## CI report: * cbf96e7bb990402b6e591d1f829d55d1e3b2cd01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

flinkbot edited a comment on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-726585261 ## CI report: * ffe1daf67c98e39f476f1f15279c77bbc83a1c98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

flinkbot edited a comment on pull request #14033: URL: https://github.com/apache/flink/pull/14033#issuecomment-725388043 ## CI report: * 9e5179d99ac3f1ee67388f6236a5ffd087941a94 Azure:

[jira] [Commented] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231780#comment-17231780 ] Roman Khachatryan commented on FLINK-19940: --- While implementing the fix I

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

flinkbot commented on pull request #14070: URL: https://github.com/apache/flink/pull/14070#issuecomment-726978459 ## CI report: * cbf96e7bb990402b6e591d1f829d55d1e3b2cd01 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14062: [FLINK-17470] Send sigkill to hanging processes in standalone scripts

flinkbot edited a comment on pull request #14062: URL: https://github.com/apache/flink/pull/14062#issuecomment-726595780 ## CI report: * b598725a80261a4f0084bb13704629ca135fa332 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

flinkbot edited a comment on pull request #14033: URL: https://github.com/apache/flink/pull/14033#issuecomment-725388043 ## CI report: * 9e5179d99ac3f1ee67388f6236a5ffd087941a94 Azure:

[GitHub] [flink] kl0u commented on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

kl0u commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-726975923 I integrated your comments @aljoscha , let me know what you think. This is an automated message from the Apache

[GitHub] [flink] kl0u commented on a change in pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

kl0u commented on a change in pull request #14061: URL: https://github.com/apache/flink/pull/14061#discussion_r523161715 ## File path: docs/dev/connectors/file_sink.md ## @@ -0,0 +1,808 @@ +--- +title: "File Sink" +nav-title: File Sink +nav-parent_id: connectors +nav-pos: 5

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

flinkbot commented on pull request #14070: URL: https://github.com/apache/flink/pull/14070#issuecomment-726970610 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

[GitHub] [flink] kl0u opened a new pull request #14070: [FLINK-20152] Document supported execution.target values

kl0u opened a new pull request #14070: URL: https://github.com/apache/flink/pull/14070 ## What is the purpose of the change This PR document supported `execution.target` values. ## Brief change log Changed the description of the `DeploymentOptions.TARGET`. ##

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

[ https://issues.apache.org/jira/browse/FLINK-20152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20152: --- Labels: pull-request-available usability (was: usability) > Document which

[jira] [Commented] (FLINK-20158) KafkaSource does not implement ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-20158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231758#comment-17231758 ] Robert Metzger commented on FLINK-20158: [~becket_qin] I guess this would be a nice usability

[jira] [Created] (FLINK-20158) KafkaSource does not implement ResultTypeQueryable

Robert Metzger created FLINK-20158: -- Summary: KafkaSource does not implement ResultTypeQueryable Key: FLINK-20158 URL: https://issues.apache.org/jira/browse/FLINK-20158 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #14062: [FLINK-17470] Send sigkill to hanging processes in standalone scripts

flinkbot edited a comment on pull request #14062: URL: https://github.com/apache/flink/pull/14062#issuecomment-726595780 ## CI report: * b598725a80261a4f0084bb13704629ca135fa332 Azure:

[GitHub] [flink] rmetzger commented on pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

rmetzger commented on pull request #14033: URL: https://github.com/apache/flink/pull/14033#issuecomment-726961117 Thanks for the review. This CI run contained an open port by "dotnet":

[GitHub] [flink] rmetzger commented on a change in pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

rmetzger commented on a change in pull request #14033: URL: https://github.com/apache/flink/pull/14033#discussion_r523152338 ## File path: flink-end-to-end-tests/test-scripts/test-runner-common.sh ## @@ -110,10 +114,40 @@ function post_test_validation { fi } +# returns

[GitHub] [flink] rmetzger commented on a change in pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

rmetzger commented on a change in pull request #14033: URL: https://github.com/apache/flink/pull/14033#discussion_r523151423 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -822,11 +839,20 @@ internal_run_with_timeout() { ( command_pid=$BASHPID -

[GitHub] [flink] rmetzger commented on a change in pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

rmetzger commented on a change in pull request #14033: URL: https://github.com/apache/flink/pull/14033#discussion_r523147060 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -587,9 +588,25 @@ function tm_kill_all { # Kills all processes that match the given

[GitHub] [flink] rmetzger commented on pull request #14062: [FLINK-17470] Send sigkill to hanging processes in standalone scripts

rmetzger commented on pull request #14062: URL: https://github.com/apache/flink/pull/14062#issuecomment-726944724 Thanks a lot for the review. I've pushed a rebased version because of a weird CI failure. Once it's greener, I'll push it to master!

[GitHub] [flink] XComp commented on a change in pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

XComp commented on a change in pull request #14033: URL: https://github.com/apache/flink/pull/14033#discussion_r523122630 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -587,9 +588,25 @@ function tm_kill_all { # Kills all processes that match the given

[GitHub] [flink] flinkbot edited a comment on pull request #14049: [FLINK-20043][kinesis] Add flink-sql-connector-kinesis package

flinkbot edited a comment on pull request #14049: URL: https://github.com/apache/flink/pull/14049#issuecomment-726094991 ## CI report: * 0a068c0f16865a2c91819d21f52d759151acb97e UNKNOWN * d15f6e11ca8d46da440ed6c2235f73937d70ab3a UNKNOWN *

[jira] [Commented] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

[ https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231688#comment-17231688 ] Zhijiang commented on FLINK-16753: -- Thanks for the reminder [~NicoK]. I ever considered this concern

[GitHub] [flink] dannycranmer commented on a change in pull request #14049: [FLINK-20043][kinesis] Add flink-sql-connector-kinesis package

dannycranmer commented on a change in pull request #14049: URL: https://github.com/apache/flink/pull/14049#discussion_r523099583 ## File path: flink-end-to-end-tests/test-scripts/test_sql_client.sh ## @@ -61,15 +61,27 @@ for SQL_JAR in $SQL_JARS_DIR/*.jar; do ! [[

[GitHub] [flink] flinkbot edited a comment on pull request #14069: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner

flinkbot edited a comment on pull request #14069: URL: https://github.com/apache/flink/pull/14069#issuecomment-726868291 ## CI report: * 4502be25c65684496cedd3d6f50e6b45e93f Azure:

[GitHub] [flink] sjwiesman commented on pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

sjwiesman commented on pull request #14006: URL: https://github.com/apache/flink/pull/14006#issuecomment-726874200 @tillrohrmann sounds good. We can discuss that as a follow up This is an automated message from the Apache

[jira] [Commented] (FLINK-20147) "Invalid lambda deserialization" when trying to read metadata from Kafka in SQL

[ https://issues.apache.org/jira/browse/FLINK-20147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231622#comment-17231622 ] Timo Walther commented on FLINK-20147: -- Yes, this is very annoying. It also exists for Debezium and

[GitHub] [flink] flinkbot commented on pull request #14069: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner

flinkbot commented on pull request #14069: URL: https://github.com/apache/flink/pull/14069#issuecomment-726868291 ## CI report: * 4502be25c65684496cedd3d6f50e6b45e93f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * 8b54a6b03978f1443620a8c06ec8f3388fabf322 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14066: [FLINK-20144][docs] Change link format in docs/ops dir

flinkbot edited a comment on pull request #14066: URL: https://github.com/apache/flink/pull/14066#issuecomment-726763095 ## CI report: * 6d180cae9b82981c786f865ef7d077aff41187fb Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

tillrohrmann commented on a change in pull request #14006: URL: https://github.com/apache/flink/pull/14006#discussion_r523063603 ## File path: docs/ops/jobmanager_high_availability.md ## @@ -215,6 +215,76 @@ Starting zookeeper daemon on host localhost. $

[GitHub] [flink] tillrohrmann commented on a change in pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

tillrohrmann commented on a change in pull request #14006: URL: https://github.com/apache/flink/pull/14006#discussion_r523061517 ## File path: docs/ops/jobmanager_high_availability.md ## @@ -215,6 +215,76 @@ Starting zookeeper daemon on host localhost. $

[GitHub] [flink] tillrohrmann commented on a change in pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

tillrohrmann commented on a change in pull request #14006: URL: https://github.com/apache/flink/pull/14006#discussion_r523061199 ## File path: docs/ops/jobmanager_high_availability.md ## @@ -215,6 +215,76 @@ Starting zookeeper daemon on host localhost. $

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

[ https://issues.apache.org/jira/browse/FLINK-20152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231604#comment-17231604 ] Kostas Kloudas commented on FLINK-20152: The problem is though that the *-application options it

[jira] [Updated] (FLINK-20157) SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission

[ https://issues.apache.org/jira/browse/FLINK-20157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20157: --- Description: While setting up a test job using the new Kafka source for testing the RC1 of

[jira] [Commented] (FLINK-20157) SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission

[ https://issues.apache.org/jira/browse/FLINK-20157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231599#comment-17231599 ] Robert Metzger commented on FLINK-20157: [~becket_qin] Can you take a look? >

[GitHub] [flink] flinkbot commented on pull request #14069: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner

flinkbot commented on pull request #14069: URL: https://github.com/apache/flink/pull/14069#issuecomment-726854315 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

[jira] [Updated] (FLINK-20156) JavaDocs of WatermarkStrategy.withTimestampAssigner are wrong wrt Java 8

[ https://issues.apache.org/jira/browse/FLINK-20156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20156: --- Labels: pull-request-available usability (was: usability) > JavaDocs of

[GitHub] [flink] tillrohrmann opened a new pull request #14069: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner

tillrohrmann opened a new pull request #14069: URL: https://github.com/apache/flink/pull/14069 In order to compile with Java 8 we have to specify the generic parameter when chaining WatermarkStrategy.withTimestampAssigner. cc @aljoscha

[jira] [Commented] (FLINK-20124) Test pipelined region scheduler

[ https://issues.apache.org/jira/browse/FLINK-20124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231595#comment-17231595 ] Robert Metzger commented on FLINK-20124: Found this:

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

flinkbot commented on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * 8b54a6b03978f1443620a8c06ec8f3388fabf322 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-20156) JavaDocs of WatermarkStrategy.withTimestampAssigner are wrong wrt Java 8

[ https://issues.apache.org/jira/browse/FLINK-20156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-20156: - Assignee: Till Rohrmann > JavaDocs of WatermarkStrategy.withTimestampAssigner are

[jira] [Created] (FLINK-20157) SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission

Robert Metzger created FLINK-20157: -- Summary: SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission Key: FLINK-20157 URL: https://issues.apache.org/jira/browse/FLINK-20157

[GitHub] [flink] flinkbot edited a comment on pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

flinkbot edited a comment on pull request #14052: URL: https://github.com/apache/flink/pull/14052#issuecomment-726216034 ## CI report: * 14e0929bf9cebd4db7c60c5928d71e631fb4ad47 UNKNOWN * 9f30c9730919038a0247cd4b7a2929df05ee669f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14067: [FLINK-18673][table] Improve support for ROW constructor

flinkbot edited a comment on pull request #14067: URL: https://github.com/apache/flink/pull/14067#issuecomment-726839630 ## CI report: * 2dd441a701a3d73281b3590b3d0c457826e8ed08 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13920: [FLINK-19743] Add metric definitions in FLIP-33 and report some of them by default.

flinkbot edited a comment on pull request #13920: URL: https://github.com/apache/flink/pull/13920#issuecomment-721560528 ## CI report: * 7bc26d9294daf693f50bad393abf19165dcf9da0 Azure:

[jira] [Created] (FLINK-20156) JavaDocs of WatermarkStrategy.withTimestampAssigner are wrong wrt Java 8

Till Rohrmann created FLINK-20156: - Summary: JavaDocs of WatermarkStrategy.withTimestampAssigner are wrong wrt Java 8 Key: FLINK-20156 URL: https://issues.apache.org/jira/browse/FLINK-20156 Project:

[GitHub] [flink-docker] tillrohrmann commented on a change in pull request #43: [FLINK-19125] Adopt Jemalloc as default memory allocator to avoid memory leak

tillrohrmann commented on a change in pull request #43: URL: https://github.com/apache/flink-docker/pull/43#discussion_r523040310 ## File path: docker-entrypoint.sh ## @@ -93,21 +94,49 @@ prepare_job_manager_start() { envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv

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

roee hershko created FLINK-20155: Summary: java.lang.OutOfMemoryError: Direct buffer memory Key: FLINK-20155 URL: https://issues.apache.org/jira/browse/FLINK-20155 Project: Flink Issue Type:

  1   2   3   4   >