[jira] [Updated] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-22437: --- Description: when I execute batch sql as follow in flink-1.12.2, I found lots of small files in hdfs. In fi

[GitHub] [flink] flinkbot edited a comment on pull request #15741: [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests

flinkbot edited a comment on pull request #15741: URL: https://github.com/apache/flink/pull/15741#issuecomment-825816096 ## CI report: * 4dedb22ae1c4077758def2cea3213f87cdf1971e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-web] leonardBang commented on a change in pull request #436: Add Apache Flink release 1.13.0

leonardBang commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r619584456 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,374 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[jira] [Comment Edited] (FLINK-22433) CoordinatorEventsExactlyOnceITCase stalls on Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-22433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331135#comment-17331135 ] Guowei Ma edited comment on FLINK-22433 at 4/24/21, 3:43 AM: -

[jira] [Updated] (FLINK-22440) UpsertKafkaTableITCase fail due to create topic timeout

[ https://issues.apache.org/jira/browse/FLINK-22440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22440: -- Description: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=17132&view=logs&j=

[jira] [Created] (FLINK-22440) UpsertKafkaTableITCase fail due to create topic timeout

Guowei Ma created FLINK-22440: - Summary: UpsertKafkaTableITCase fail due to create topic timeout Key: FLINK-22440 URL: https://issues.apache.org/jira/browse/FLINK-22440 Project: Flink Issue Type:

[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331137#comment-17331137 ] Guowei Ma commented on FLINK-21538: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331136#comment-17331136 ] Guowei Ma commented on FLINK-22266: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22433) CoordinatorEventsExactlyOnceITCase stalls on Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-22433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331135#comment-17331135 ] Guowei Ma commented on FLINK-22433: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331134#comment-17331134 ] Guowei Ma commented on FLINK-22416: --- Another test cases failed because of timeouts ht

[jira] [Resolved] (FLINK-22439) UnalignedCheckpointITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-22439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma resolved FLINK-22439. --- Resolution: Duplicate > UnalignedCheckpointITCase hangs > --- > >

[jira] [Created] (FLINK-22439) UnalignedCheckpointITCase hangs

Guowei Ma created FLINK-22439: - Summary: UnalignedCheckpointITCase hangs Key: FLINK-22439 URL: https://issues.apache.org/jira/browse/FLINK-22439 Project: Flink Issue Type: Bug Component

[jira] [Commented] (FLINK-20723) testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed due to NoHostAvailableException

[ https://issues.apache.org/jira/browse/FLINK-20723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331133#comment-17331133 ] Guowei Ma commented on FLINK-20723: --- There are some failed tests on the 1.11 brach bec

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1733#comment-1733 ] Chen Qin commented on FLINK-10052: -- Set timeline on leader change to new address null e

[GitHub] [flink] flinkbot edited a comment on pull request #15741: [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests

flinkbot edited a comment on pull request #15741: URL: https://github.com/apache/flink/pull/15741#issuecomment-825816096 ## CI report: * e404636107b5c33805bb2b957a2698e754e2a47f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15741: [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests

flinkbot edited a comment on pull request #15741: URL: https://github.com/apache/flink/pull/15741#issuecomment-825816096 ## CI report: * e404636107b5c33805bb2b957a2698e754e2a47f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22059: --- Labels: auto-unassigned (was: stale-assigned) > add a new option is rocksdb statebackend to

[jira] [Commented] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331085#comment-17331085 ] Flink Jira Bot commented on FLINK-22059: This issue was marked "stale-assigned"

[GitHub] [flink] flinkbot edited a comment on pull request #15740: [hotfix] Do not use ExecutorService.submit since it can swallow exceptions

flinkbot edited a comment on pull request #15740: URL: https://github.com/apache/flink/pull/15740#issuecomment-825816009 ## CI report: * 41f2daa81345559942352164185d991b5478f172 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15709: [FLINK-22356][hive / filesystem] Fix partition-time commit failure when watermark is defined on TIMESTAMP_LTZ column

flinkbot edited a comment on pull request #15709: URL: https://github.com/apache/flink/pull/15709#issuecomment-824111246 ## CI report: * 450f7b2cae5990952b270153f1b225b4ffb52910 UNKNOWN * 797e97fe20c27e078ccb417b5451434489193353 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15736: [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

flinkbot edited a comment on pull request #15736: URL: https://github.com/apache/flink/pull/15736#issuecomment-825699179 ## CI report: * 816be9988521458dc0e2e56c5a0739e3e01efe82 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15739: [FLINK-22433][tests] Make CoordinatorEventsExactlyOnceITCase work with the Adaptive Scheduler.

flinkbot edited a comment on pull request #15739: URL: https://github.com/apache/flink/pull/15739#issuecomment-825772402 ## CI report: * 304d018d7738e10d2a61c1447b69c1dbd27d55c8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 5237b1460bc7089cef03814417a9f6e511c85f57 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15738: modify annotation

flinkbot edited a comment on pull request #15738: URL: https://github.com/apache/flink/pull/15738#issuecomment-825749642 ## CI report: * 1ff0101c6acb0384e5fa614327ae463bb056d430 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

flinkbot edited a comment on pull request #15728: URL: https://github.com/apache/flink/pull/15728#issuecomment-824960796 ## CI report: * 91418c6481fcd8dca9d343cda91f0cf5010dfbf7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15736: [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

flinkbot edited a comment on pull request #15736: URL: https://github.com/apache/flink/pull/15736#issuecomment-825699179 ## CI report: * 89d65ccb060ee31ab5a39e8a31ef426a41bc0d7c Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15741: [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests

flinkbot edited a comment on pull request #15741: URL: https://github.com/apache/flink/pull/15741#issuecomment-825816096 ## CI report: * e404636107b5c33805bb2b957a2698e754e2a47f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15740: [hotfix] Do not use ExecutorService.submit since it can swallow exceptions

flinkbot edited a comment on pull request #15740: URL: https://github.com/apache/flink/pull/15740#issuecomment-825816009 ## CI report: * 41f2daa81345559942352164185d991b5478f172 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15709: [FLINK-22356][hive / filesystem] Fix partition-time commit failure when watermark is defined on TIMESTAMP_LTZ column

flinkbot edited a comment on pull request #15709: URL: https://github.com/apache/flink/pull/15709#issuecomment-824111246 ## CI report: * 450f7b2cae5990952b270153f1b225b4ffb52910 UNKNOWN * fdc945df3436b179c39d0217f3ab3dfcc02f7e6b Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #15741: [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests

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

[GitHub] [flink] flinkbot commented on pull request #15740: [hotfix] Do not use ExecutorService.submit since it can swallow exceptions

flinkbot commented on pull request #15740: URL: https://github.com/apache/flink/pull/15740#issuecomment-825816009 ## CI report: * 41f2daa81345559942352164185d991b5478f172 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15741: [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests

flinkbot commented on pull request #15741: URL: https://github.com/apache/flink/pull/15741#issuecomment-825809919 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-22419) testScheduleRunAsync fail

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

[GitHub] [flink] zentol opened a new pull request #15741: [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests

zentol opened a new pull request #15741: URL: https://github.com/apache/flink/pull/15741 Several `RpcEndpoint` tests were verifying the handling of delays based via various `schedule*` methods by checking how long it took for a schedule unit to be exected Such tests are well known to be

[GitHub] [flink] flinkbot commented on pull request #15740: [hotfix] Do not use ExecutorService.submit since it can swallow exceptions

flinkbot commented on pull request #15740: URL: https://github.com/apache/flink/pull/15740#issuecomment-825805402 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] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 2c2c75788692871ed5d7d8771c817a83b5486787 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann opened a new pull request #15740: [hotfix] Do not use ExecutorService.submit since it can swallow exceptions

tillrohrmann opened a new pull request #15740: URL: https://github.com/apache/flink/pull/15740 This commit changes the KubernetesLeaderElector to use ExecutorService.execute instead of submit which ensures that potential exceptions are forwarded to the fatal uncaught exeception handler.

[jira] [Created] (FLINK-22438) add numRecordsOut metric for Async IO

Zhengqi Zhang created FLINK-22438: - Summary: add numRecordsOut metric for Async IO Key: FLINK-22438 URL: https://issues.apache.org/jira/browse/FLINK-22438 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-22438) add numRecordsOut metric for Async IO

[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhengqi Zhang updated FLINK-22438: -- Attachment: QQ截图20210424004201.png > add numRecordsOut metric for Async IO > -

[GitHub] [flink] tillrohrmann commented on a change in pull request #14012: [FLINK-17857][test] Make K8s e2e tests could run on Mac

tillrohrmann commented on a change in pull request #14012: URL: https://github.com/apache/flink/pull/14012#discussion_r619364433 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh ## @@ -25,7 +25,7 @@ MINIKUBE_START_RETRIES=3 MINIKUBE_START_BACKOFF=5 RESUL

[GitHub] [flink] tillrohrmann commented on a change in pull request #15739: [FLINK-22433][tests] Make CoordinatorEventsExactlyOnceITCase work with the Adaptive Scheduler.

tillrohrmann commented on a change in pull request #15739: URL: https://github.com/apache/flink/pull/15739#discussion_r619359407 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/CoordinatorEventsExactlyOnceITCase.java ## @@ -169,6 +171,

[GitHub] [flink] flinkbot edited a comment on pull request #15739: [FLINK-22433][tests] Make CoordinatorEventsExactlyOnceITCase work with the Adaptive Scheduler.

flinkbot edited a comment on pull request #15739: URL: https://github.com/apache/flink/pull/15739#issuecomment-825772402 ## CI report: * 304d018d7738e10d2a61c1447b69c1dbd27d55c8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15736: [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

flinkbot edited a comment on pull request #15736: URL: https://github.com/apache/flink/pull/15736#issuecomment-825699179 ## CI report: * 89d65ccb060ee31ab5a39e8a31ef426a41bc0d7c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15709: [FLINK-22356][hive / filesystem] Fix partition-time commit failure when watermark is defined on TIMESTAMP_LTZ column

flinkbot edited a comment on pull request #15709: URL: https://github.com/apache/flink/pull/15709#issuecomment-824111246 ## CI report: * 450f7b2cae5990952b270153f1b225b4ffb52910 UNKNOWN * fdc945df3436b179c39d0217f3ab3dfcc02f7e6b Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 2c2c75788692871ed5d7d8771c817a83b5486787 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330906#comment-17330906 ] Till Rohrmann commented on FLINK-10052: --- This exception is caused by the {{TaskExe

[jira] [Updated] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-22437: --- Description: when I execute batch sql as follow in flink-1.12.2, I found lots of small files in hdfs. In fi

[jira] [Comment Edited] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330904#comment-17330904 ] zoucao edited comment on FLINK-22437 at 4/23/21, 4:36 PM: -- == A

[GitHub] [flink-web] leonardBang commented on a change in pull request #436: Add Apache Flink release 1.13.0

leonardBang commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r619354907 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,374 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[jira] [Commented] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330904#comment-17330904 ] zoucao commented on FLINK-22437: == Abstract Syntax Tree == LogicalSink(table=[default_

[jira] [Commented] (FLINK-11103) Set a default uncaught exception handler

[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330903#comment-17330903 ] Till Rohrmann commented on FLINK-11103: --- I think the proposal makes sense. Making

[jira] [Created] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

zoucao created FLINK-22437: -- Summary: Miss adding parallesim for filter operator in batch mode Key: FLINK-22437 URL: https://issues.apache.org/jira/browse/FLINK-22437 Project: Flink Issue Type: Bug

[GitHub] [flink] leonardBang commented on pull request #15709: [FLINK-22356][hive / filesystem] Fix partition-time commit failure when watermark is defined on TIMESTAMP_LTZ column

leonardBang commented on pull request #15709: URL: https://github.com/apache/flink/pull/15709#issuecomment-825775200 @wuchong @twalthr Appreciate if you can help take a look. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[jira] [Closed] (FLINK-8971) Create general purpose testing job

[ https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8971. Resolution: Done > Create general purpose testing job > -- > >

[jira] [Closed] (FLINK-9002) Add operators with input type that goes through Avro serialization (with schema/generic)

[ https://issues.apache.org/jira/browse/FLINK-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9002. Resolution: Abandoned Closing because this issue seems to be abandoned. > Add operators with input

[GitHub] [flink-web] lirui-apache commented on a change in pull request #436: Add Apache Flink release 1.13.0

lirui-apache commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r619352011 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,374 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[GitHub] [flink] tillrohrmann closed pull request #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization

tillrohrmann closed pull request #7041: URL: https://github.com/apache/flink/pull/7041 -- 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 the specific comment. For queries about this service, ple

[jira] [Closed] (FLINK-9001) Add operators with input type that goes through Kryo serialization (registered/generic/custom)

[ https://issues.apache.org/jira/browse/FLINK-9001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9001. Resolution: Abandoned This issue has been abandoned. > Add operators with input type that goes thr

[GitHub] [flink] tillrohrmann commented on pull request #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization

tillrohrmann commented on pull request #7041: URL: https://github.com/apache/flink/pull/7041#issuecomment-825774314 This PR seems to be abandoned. -- 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] tillrohrmann commented on pull request #7042: [FLINK-9001] [e2e] Add operators with input type that goes through Kryo serialization

tillrohrmann commented on pull request #7042: URL: https://github.com/apache/flink/pull/7042#issuecomment-825773948 Close as abandoned. -- 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 the specif

[GitHub] [flink] tillrohrmann closed pull request #7042: [FLINK-9001] [e2e] Add operators with input type that goes through Kryo serialization

tillrohrmann closed pull request #7042: URL: https://github.com/apache/flink/pull/7042 -- 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 the specific comment. For queries about this service, ple

[jira] [Commented] (FLINK-8971) Create general purpose testing job

[ https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330896#comment-17330896 ] Till Rohrmann commented on FLINK-8971: -- I think so yes. Will do it. > Create genera

[GitHub] [flink] flinkbot commented on pull request #15739: [FLINK-22433][tests] Make CoordinatorEventsExactlyOnceITCase work with the Adaptive Scheduler.

flinkbot commented on pull request #15739: URL: https://github.com/apache/flink/pull/15739#issuecomment-825772402 ## CI report: * 304d018d7738e10d2a61c1447b69c1dbd27d55c8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15734: [FLINK-22424][network] Prevent releasing PipelinedSubpartition while Task can still write to it

flinkbot edited a comment on pull request #15734: URL: https://github.com/apache/flink/pull/15734#issuecomment-825656083 ## CI report: * 58eca058a951e59f9042e50efeb051cccac821ee UNKNOWN * 515284652bdb98796f0dfd573c49a2897f6be08b Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15736: [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

flinkbot edited a comment on pull request #15736: URL: https://github.com/apache/flink/pull/15736#issuecomment-825699179 ## CI report: * 89d65ccb060ee31ab5a39e8a31ef426a41bc0d7c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15738: modify annotation

flinkbot edited a comment on pull request #15738: URL: https://github.com/apache/flink/pull/15738#issuecomment-825749642 ## CI report: * 1ff0101c6acb0384e5fa614327ae463bb056d430 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330890#comment-17330890 ] Chen Qin commented on FLINK-10052: -- here is another exception we observed in another jo

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330890#comment-17330890 ] Chen Qin edited comment on FLINK-10052 at 4/23/21, 4:13 PM:

[GitHub] [flink-jira-bot] sjwiesman commented on pull request #11: [hotfix] Make comment language friendly to contributors

sjwiesman commented on pull request #11: URL: https://github.com/apache/flink-jira-bot/pull/11#issuecomment-825763637 @autophagy maybe you want to look at this as well? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink-jira-bot] sjwiesman opened a new pull request #11: [hotfix] Make comment language friendly to contributors

sjwiesman opened a new pull request #11: URL: https://github.com/apache/flink-jira-bot/pull/11 -- 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 the specific comment. For queries about this serv

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330858#comment-17330858 ] Chen Qin edited comment on FLINK-10052 at 4/23/21, 4:04 PM:

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330883#comment-17330883 ] Till Rohrmann commented on FLINK-10052: --- I assume that we should not fail on certa

[GitHub] [flink] tillrohrmann commented on a change in pull request #15736: [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

tillrohrmann commented on a change in pull request #15736: URL: https://github.com/apache/flink/pull/15736#discussion_r619327232 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Failing.java ## @@ -58,7 +58,7 @@ public void cancel() {

[jira] [Comment Edited] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330877#comment-17330877 ] Leonard Xu edited comment on FLINK-22356 at 4/23/21, 3:52 PM:

[jira] [Commented] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330877#comment-17330877 ] Leonard Xu commented on FLINK-22356: After offline discussion with Timo and Jark,  w

[jira] [Commented] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330875#comment-17330875 ] John Lonergan commented on FLINK-17464: --- As far as I know this is still a critical

[GitHub] [flink] flinkbot commented on pull request #15738: modify annotation

flinkbot commented on pull request #15738: URL: https://github.com/apache/flink/pull/15738#issuecomment-825749642 ## CI report: * 1ff0101c6acb0384e5fa614327ae463bb056d430 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15734: [FLINK-22424][network] Prevent releasing PipelinedSubpartition while Task can still write to it

flinkbot edited a comment on pull request #15734: URL: https://github.com/apache/flink/pull/15734#issuecomment-825656083 ## CI report: * 58eca058a951e59f9042e50efeb051cccac821ee UNKNOWN * df3ce94d8f9819a8a938e68f841d96b9ec022e8a Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15687: [FLINK-22373][docs] Add Flink 1.13 release notes

flinkbot edited a comment on pull request #15687: URL: https://github.com/apache/flink/pull/15687#issuecomment-823276717 ## CI report: * c6cdeaa42cf3c4eff95e6e57b9bcc61c6adada5a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann commented on a change in pull request #15736: [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

tillrohrmann commented on a change in pull request #15736: URL: https://github.com/apache/flink/pull/15736#discussion_r619323704 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java ## @@ -281,9 +283,9 @@ void goToFailing( s

[jira] [Created] (FLINK-22436) twitter datastream connector gets Invalid 'expires' attribute

Jason Perez created FLINK-22436: --- Summary: twitter datastream connector gets Invalid 'expires' attribute Key: FLINK-22436 URL: https://issues.apache.org/jira/browse/FLINK-22436 Project: Flink

[jira] [Created] (FLINK-22435) twitter datastream connector gets Invalid 'expires' attribute

Jason Perez created FLINK-22435: --- Summary: twitter datastream connector gets Invalid 'expires' attribute Key: FLINK-22435 URL: https://issues.apache.org/jira/browse/FLINK-22435 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #15739: [FLINK-22433][tests] Make CoordinatorEventsExactlyOnceITCase work with the Adaptive Scheduler.

flinkbot commented on pull request #15739: URL: https://github.com/apache/flink/pull/15739#issuecomment-825747550 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-22433) CoordinatorEventsExactlyOnceITCase stalls on Adaptive Scheduler

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

[GitHub] [flink] StephanEwen opened a new pull request #15739: [FLINK-22433][tests] Make CoordinatorEventsExactlyOnceITCase work with the Adaptive Scheduler.

StephanEwen opened a new pull request #15739: URL: https://github.com/apache/flink/pull/15739 ## What does the Change do? The `CoordinatorEventsExactlyOnceITCase` test previously relied on an implicit contract that instances of OperatorCoordinators are never recreated on the same Jo

[GitHub] [flink] tillrohrmann commented on a change in pull request #15736: [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

tillrohrmann commented on a change in pull request #15736: URL: https://github.com/apache/flink/pull/15736#discussion_r619319940 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java ## @@ -281,9 +283,9 @@ void goToFailing( s

[GitHub] [flink] tillrohrmann commented on a change in pull request #15736: [FLINK-22431] Add information when and why the AdaptiveScheduler restarts or fails jobs

tillrohrmann commented on a change in pull request #15736: URL: https://github.com/apache/flink/pull/15736#discussion_r619319677 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Finished.java ## @@ -54,7 +54,12 @@ public ArchivedExecutionGr

[GitHub] [flink] flinkbot edited a comment on pull request #8321: [FLINK-12351][DataStream] Fix AsyncWaitOperator to deep copy StreamElement when object reuse is enabled

flinkbot edited a comment on pull request #8321: URL: https://github.com/apache/flink/pull/8321#issuecomment-825457841 ## CI report: * e741384860465e775ba57a230db9a2475c6bd3a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?

[jira] [Created] (FLINK-22434) Dispatcher does not store suspended jobs in execution graph store

Fabian Paul created FLINK-22434: --- Summary: Dispatcher does not store suspended jobs in execution graph store Key: FLINK-22434 URL: https://issues.apache.org/jira/browse/FLINK-22434 Project: Flink

[jira] [Commented] (FLINK-22414) Consider env.hadoop.conf.dir when looking for the hadoop configuration

[ https://issues.apache.org/jira/browse/FLINK-22414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330864#comment-17330864 ] Flavio Pompermaier commented on FLINK-22414: Yes, my problem as a user is th

[GitHub] [flink] flinkbot commented on pull request #15738: modify annotation

flinkbot commented on pull request #15738: URL: https://github.com/apache/flink/pull/15738#issuecomment-825736900 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] flinkbot edited a comment on pull request #15735: [FLINK-22432] Update upgrading.md with 1.13.x

flinkbot edited a comment on pull request #15735: URL: https://github.com/apache/flink/pull/15735#issuecomment-825669220 ## CI report: * a6d23e5efc77c018c32f35c15341a43c61dcc2ea Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

flinkbot edited a comment on pull request #15728: URL: https://github.com/apache/flink/pull/15728#issuecomment-824960796 ## CI report: * 08623bd7a97c4370592dd54b23812886459836e8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15630: [FLINK-22119][hive][doc] Update document for hive dialect

flinkbot edited a comment on pull request #15630: URL: https://github.com/apache/flink/pull/15630#issuecomment-820444005 ## CI report: * ab4a972eee6d9e2b5cb2f20efaeb3671ec6233bb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] sasukerui opened a new pull request #15738: modify annotation

sasukerui opened a new pull request #15738: URL: https://github.com/apache/flink/pull/15738 modify annotation -- 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 the specific comment. For queri

[jira] [Closed] (FLINK-22345) CoordinatorEventsExactlyOnceITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-22345. Resolution: Fixed > CoordinatorEventsExactlyOnceITCase hangs on azure > --

[jira] [Updated] (FLINK-22433) CoordinatorEventsExactlyOnceITCase stalls on Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-22433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22433: - Description: Logs of the test failure: https://dev.azure.com/apache-flink/apache-flink/_build/r

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330858#comment-17330858 ] Chen Qin commented on FLINK-10052: -- run load testing on pr, found following exception w

[jira] [Comment Edited] (FLINK-22345) CoordinatorEventsExactlyOnceITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330854#comment-17330854 ] Stephan Ewen edited comment on FLINK-22345 at 4/23/21, 3:20 PM: --

[jira] [Created] (FLINK-22433) CoordinatorEventsExactlyOnceITCase stalls on Adaptive Scheduler

Stephan Ewen created FLINK-22433: Summary: CoordinatorEventsExactlyOnceITCase stalls on Adaptive Scheduler Key: FLINK-22433 URL: https://issues.apache.org/jira/browse/FLINK-22433 Project: Flink

  1   2   3   4   5   6   7   8   9   >