[jira] [Updated] (FLINK-21600) Resuming Savepoint (rocks, no parallelism change, heap timers) end-to-end test failed

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21600: -- Description:

[jira] [Updated] (FLINK-21594) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

2021-03-03 Thread Bhagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-21594: -- Attachment: image-2021-03-04-13-27-00-728.png > Flink - {"errors":["Service temporarily unavailable due to an

[jira] [Created] (FLINK-21600) Resuming Savepoint (rocks, no parallelism change, heap timers) end-to-end test failed

2021-03-03 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21600: - Summary: Resuming Savepoint (rocks, no parallelism change, heap timers) end-to-end test failed Key: FLINK-21600 URL: https://issues.apache.org/jira/browse/FLINK-21600

[jira] [Commented] (FLINK-21591) Flink using OSS Backend on Native K8S found some errors

2021-03-03 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295069#comment-17295069 ] Yang Wang commented on FLINK-21591: --- It seems to be a INFO log of aliyun oss. Could you please check

[GitHub] [flink-docker] rmetzger commented on pull request #67: Dev 1.12: Add GPG and update testing script for 1.12.2

2021-03-03 Thread GitBox
rmetzger commented on pull request #67: URL: https://github.com/apache/flink-docker/pull/67#issuecomment-790400272 It seems there's something wrong with the `wget -nv -O flink.tgz https://www.apache.org/dyn/closer.cgi?action=download=flink/flink-1.12.2/flink-1.12.2-bin-scala_2.11.tgz`

[jira] [Closed] (FLINK-21599) execute[Parallel union, p = 10](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) failed because of oom.

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-21599. - Resolution: Duplicate > execute[Parallel union, p = >

[jira] [Commented] (FLINK-21535) UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space"

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295064#comment-17295064 ] Guowei Ma commented on FLINK-21535: ---

[jira] [Created] (FLINK-21599) execute[Parallel union, p = 10](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) failed because of oom.

2021-03-03 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21599: - Summary: execute[Parallel union, p = 10](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) failed because of oom. Key: FLINK-21599 URL:

[GitHub] [flink-docker] rmetzger commented on pull request #67: Dev 1.12: Add GPG and update testing script for 1.12.2

2021-03-03 Thread GitBox
rmetzger commented on pull request #67: URL: https://github.com/apache/flink-docker/pull/67#issuecomment-790393873 I manually restarted the travis build This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot commented on pull request #15083: [FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-03 Thread GitBox
flinkbot commented on pull request #15083: URL: https://github.com/apache/flink/pull/15083#issuecomment-790393119 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] LinyuYao1021 commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-03-03 Thread GitBox
LinyuYao1021 commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r587221640 ## File path: flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/User.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #15082: [FLINK-21592][table-planner-blink] RemoveSingleAggregateRule fails du…

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15082: URL: https://github.com/apache/flink/pull/15082#issuecomment-790381856 ## CI report: * 02251f131e8c7d3c398a6a59617b1e7899150fec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15058: [FLINK-21419][coordination] Remove GC cleaner mechanism for unsafe memory segments

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15058: URL: https://github.com/apache/flink/pull/15058#issuecomment-788795717 ## CI report: * 5693fa8be61c954d3662cc8ffe27689e5f6d097e Azure:

[jira] [Updated] (FLINK-21242) Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21242: --- Labels: pull-request-available (was: ) > Support state access API for the

[GitHub] [flink] WeiZhong94 opened a new pull request #15083: [FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-03 Thread GitBox
WeiZhong94 opened a new pull request #15083: URL: https://github.com/apache/flink/pull/15083 ## What is the purpose of the change *This pull request supports state access API for the map/flat_map/filter/reduce operations of Python KeyedStream.* ## Verifying this change

[jira] [Updated] (FLINK-21482) Fix bug when use grouping set/rollup/cube syntax in Window TVF

2021-03-03 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21482: - Summary: Fix bug when use grouping set/rollup/cube syntax in Window TVF (was: Support grouping set syntax for

[GitHub] [flink] beyond1920 commented on pull request #15081: [FLINK-21553][table-runtime-blink] Copy record if needed when flush window buffer records to state

2021-03-03 Thread GitBox
beyond1920 commented on pull request #15081: URL: https://github.com/apache/flink/pull/15081#issuecomment-790389209 @wuchong Thanks for your review, I've address all your comments. This is an automated message from the

[GitHub] [flink] leonardBang commented on a change in pull request #14684: [FLINK-20460][Connector-HBase] Support async lookup for HBase connector

2021-03-03 Thread GitBox
leonardBang commented on a change in pull request #14684: URL: https://github.com/apache/flink/pull/14684#discussion_r587208036 ## File path: flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/util/HBaseSerde.java ## @@ -225,6 +217,13

[jira] [Commented] (FLINK-21414) javax.net.ssl.SSLHandshakeException: Received fatal alert: certificate_unknown

2021-03-03 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295056#comment-17295056 ] Matthias commented on FLINK-21414: -- Hello Bhagi, this could be a configuration issue. Have you been

[GitHub] [flink] ruanhang1993 edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-03-03 Thread GitBox
ruanhang1993 edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-790247456 > @ruanhang1993 Many thanks for finding issues of this PR. > I tried to solve two issues you raised. > > 1. Regarding the first issue, I relocate protobuf

[jira] [Closed] (FLINK-21594) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

2021-03-03 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-21594. Resolution: Duplicate Hi Bhagi, it sounds like this is still the issue that is already discussed in

[GitHub] [flink] wuchong commented on a change in pull request #15081: [FLINK-21553][table-runtime-blink] Copy record if needed when flush window buffer records to state

2021-03-03 Thread GitBox
wuchong commented on a change in pull request #15081: URL: https://github.com/apache/flink/pull/15081#discussion_r587210465 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/WindowDistinctAggregateITCase.scala

[GitHub] [flink] wuchong commented on a change in pull request #15081: [FLINK-21553][table-runtime-blink] Copy record if needed when flush window buffer records to state

2021-03-03 Thread GitBox
wuchong commented on a change in pull request #15081: URL: https://github.com/apache/flink/pull/15081#discussion_r587207786 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/combines/CombineRecordsFunction.java

[GitHub] [flink] flinkbot commented on pull request #15082: [FLINK-21592][table-planner-blink] RemoveSingleAggregateRule fails du…

2021-03-03 Thread GitBox
flinkbot commented on pull request #15082: URL: https://github.com/apache/flink/pull/15082#issuecomment-790381856 ## CI report: * 02251f131e8c7d3c398a6a59617b1e7899150fec UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15058: [FLINK-21419][coordination] Remove GC cleaner mechanism for unsafe memory segments

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15058: URL: https://github.com/apache/flink/pull/15058#issuecomment-788795717 ## CI report: * 5693fa8be61c954d3662cc8ffe27689e5f6d097e Azure:

[GitHub] [flink] rmetzger commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-03-03 Thread GitBox
rmetzger commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-790381549 Thanks for your review @dannycranmer! Before we can merge this PR, we need to make sure that CI is passing without credentials (this is the case in the PR CI

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * ecdc2416f67f8cf580a65b30374c1a0bc08b1c0e Azure:

[jira] [Commented] (FLINK-21537) SavepointITCase fails on azure

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295046#comment-17295046 ] Guowei Ma commented on FLINK-21537: ---

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[jira] [Created] (FLINK-21598) testDetachedModeSecureWithPreInstallKeytab fail

2021-03-03 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21598: - Summary: testDetachedModeSecureWithPreInstallKeytab fail Key: FLINK-21598 URL: https://issues.apache.org/jira/browse/FLINK-21598 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-21598) testDetachedModeSecureWithPreInstallKeytab fail

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21598: -- Component/s: (was: Runtime / Checkpointing) Runtime / Coordination >

[GitHub] [flink] rmetzger commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-03-03 Thread GitBox
rmetzger commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r587207858 ## File path: flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/User.java ## @@ -0,0

[GitHub] [flink] rmetzger commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-03-03 Thread GitBox
rmetzger commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r587207722 ## File path: flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/User.java ## @@ -0,0

[jira] [Assigned] (FLINK-21242) Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong reassigned FLINK-21242: - Assignee: Wei Zhong > Support state access API for the map/flat_map/filter/reduce operations

[jira] [Updated] (FLINK-21242) Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21242: -- Summary: Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

[GitHub] [flink] flinkbot commented on pull request #15082: [FLINK-21592][table-planner-blink] RemoveSingleAggregateRule fails du…

2021-03-03 Thread GitBox
flinkbot commented on pull request #15082: URL: https://github.com/apache/flink/pull/15082#issuecomment-790377746 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-21592) RemoveSingleAggregateRule fails due to nullability mismatch

2021-03-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21592: --- Labels: pull-request-available (was: ) > RemoveSingleAggregateRule fails due to

[GitHub] [flink] lirui-apache opened a new pull request #15082: [FLINK-21592][table-planner-blink] RemoveSingleAggregateRule fails du…

2021-03-03 Thread GitBox
lirui-apache opened a new pull request #15082: URL: https://github.com/apache/flink/pull/15082 …e to nullability mismatch ## What is the purpose of the change Fix query plan failure due to RemoveSingleAggregateRule. ## Brief change log - Don't

[GitHub] [flink] rmetzger commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-03-03 Thread GitBox
rmetzger commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-790375946 I pushed this PR to my personal azure, where the CI credentials are provided: https://dev.azure.com/rmetzger/Flink/_build/results?buildId=8929=results

[GitHub] [flink] rmetzger commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-03-03 Thread GitBox
rmetzger commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-790375151 Looks like the e2e test is failing. Can you write the e2e test in a way that it only executes if the credentials are available? (personal Azure accounts won't have

[jira] [Updated] (FLINK-21528) Rest Api Support Wildcard

2021-03-03 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21528: - Priority: Major (was: Blocker) > Rest Api Support Wildcard > - > >

[jira] [Updated] (FLINK-21588) unable to create catalogs for postgresql

2021-03-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21588: Fix Version/s: (was: 1.12.0) > unable to create catalogs for postgresql >

[jira] [Created] (FLINK-21597) testMapAfterRepartitionHasCorrectParallelism2 Fail because of "NoResourceAvailableException"

2021-03-03 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21597: - Summary: testMapAfterRepartitionHasCorrectParallelism2 Fail because of "NoResourceAvailableException" Key: FLINK-21597 URL: https://issues.apache.org/jira/browse/FLINK-21597

[jira] [Updated] (FLINK-21588) unable to create catalogs for postgresql

2021-03-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21588: Component/s: (was: Deployment / Kubernetes) Connectors / JDBC > unable to create

[GitHub] [flink] rmetzger commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-03-03 Thread GitBox
rmetzger commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r587203685 ## File path: flink-end-to-end-tests/flink-glue-schema-registry-test/pom.xml ## @@ -0,0 +1,259 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Commented] (FLINK-21588) unable to create catalogs for postgresql

2021-03-03 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295041#comment-17295041 ] Matthias commented on FLINK-21588: -- Hi Bhagi, thanks for raising this issue. Can you verify that the

[jira] [Updated] (FLINK-21596) CheckpointFailureManagerITCase.testAsyncCheckpointFailureTriggerJobFailed fail

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21596: -- Labels: test-stability (was: ) >

[jira] [Created] (FLINK-21596) CheckpointFailureManagerITCase.testAsyncCheckpointFailureTriggerJobFailed fail

2021-03-03 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21596: - Summary: CheckpointFailureManagerITCase.testAsyncCheckpointFailureTriggerJobFailed fail Key: FLINK-21596 URL: https://issues.apache.org/jira/browse/FLINK-21596 Project:

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295040#comment-17295040 ] Kezhu Wang commented on FLINK-21564: [~nicholasjiang] Not about simplification, but guarantee to

[jira] [Updated] (FLINK-21595) DispatcherResourceManagerComponent.deregisterApplication times out

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21595: -- Summary: DispatcherResourceManagerComponent.deregisterApplication times out (was:

[jira] [Created] (FLINK-21595) DispatcherResourceManagerComponent.deregisterApplication time-out

2021-03-03 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21595: - Summary: DispatcherResourceManagerComponent.deregisterApplication time-out Key: FLINK-21595 URL: https://issues.apache.org/jira/browse/FLINK-21595 Project: Flink

[jira] [Closed] (FLINK-21576) Remove ExecutionVertex#getPreferredLocations

2021-03-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-21576. --- Resolution: Done Done via 2233cb2ebad5908464e36ac890f0ab54bd57d35a > Remove

[jira] [Commented] (FLINK-21587) FineGrainedSlotManagerTest.testNotificationAboutNotEnoughResources is unstable

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295035#comment-17295035 ] Guowei Ma commented on FLINK-21587: ---

[jira] [Updated] (FLINK-21588) unable to create catalogs for postgresql

2021-03-03 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21588: - Priority: Minor (was: Blocker) > unable to create catalogs for postgresql >

[jira] [Comment Edited] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295033#comment-17295033 ] Nicholas Jiang edited comment on FLINK-21564 at 3/4/21, 6:46 AM: -

[jira] [Comment Edited] (FLINK-21515) SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295034#comment-17295034 ] Guowei Ma edited comment on FLINK-21515 at 3/4/21, 6:46 AM: another case

[jira] [Comment Edited] (FLINK-21515) SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295034#comment-17295034 ] Guowei Ma edited comment on FLINK-21515 at 3/4/21, 6:46 AM: another case

[jira] [Closed] (FLINK-21515) SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-21515. - Resolution: Fixed > SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is > failing

[jira] [Updated] (FLINK-21554) Remove the magical classpath setting stuff in docker-entrypoint.sh

2021-03-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21554: --- Labels: pull-request-available (was: ) > Remove the magical classpath setting stuff in

[GitHub] [flink-docker] wangyang0918 opened a new pull request #69: [FLINK-21554] Remove the magical classpath setting stuff in docker-entrypoint.sh

2021-03-03 Thread GitBox
wangyang0918 opened a new pull request #69: URL: https://github.com/apache/flink-docker/pull/69 After FLINK-21128 is done, we could remove the magical classpath setting stuff in docker-entrypoint.sh. ``` # Set the Flink related environments export

[jira] [Reopened] (FLINK-21515) SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reopened FLINK-21515: ---

[jira] [Comment Edited] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295033#comment-17295033 ] Nicholas Jiang edited comment on FLINK-21564 at 3/4/21, 6:43 AM: -

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295033#comment-17295033 ] Nicholas Jiang commented on FLINK-21564: [~kezhuw], according to the logic of the codes you

[jira] [Created] (FLINK-21594) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

2021-03-03 Thread Bhagi (Jira)
Bhagi created FLINK-21594: - Summary: Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]} Key: FLINK-21594 URL: https://issues.apache.org/jira/browse/FLINK-21594

[jira] [Updated] (FLINK-21593) RocksDBListStatePerformanceTest.testRocksDbListStateAPI fail because of timeout

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21593: -- Description:

[GitHub] [flink] xiaoHoly commented on a change in pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and

2021-03-03 Thread GitBox
xiaoHoly commented on a change in pull request #14531: URL: https://github.com/apache/flink/pull/14531#discussion_r587193000 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java ## @@ -423,14

[jira] [Created] (FLINK-21593) RocksDBListStatePerformanceTest.testRocksDbListStateAPI fail because of timeout

2021-03-03 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21593: - Summary: RocksDBListStatePerformanceTest.testRocksDbListStateAPI fail because of timeout Key: FLINK-21593 URL: https://issues.apache.org/jira/browse/FLINK-21593 Project:

[jira] [Commented] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP

2021-03-03 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295030#comment-17295030 ] Huang Xingbo commented on FLINK-21559: -- The expected result of this test depends on the order of

[jira] [Commented] (FLINK-21103) E2e tests time out on azure

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295028#comment-17295028 ] Guowei Ma commented on FLINK-21103: ---

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2021-03-03 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295027#comment-17295027 ] Guowei Ma commented on FLINK-20329: ---

[jira] [Commented] (FLINK-21592) RemoveSingleAggregateRule fails due to nullability mismatch

2021-03-03 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295024#comment-17295024 ] Rui Li commented on FLINK-21592: I think the root cause is because

[jira] [Commented] (FLINK-21115) Add AggregatingState and corresponding StateDescriptor for Python DataStream API

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295023#comment-17295023 ] Wei Zhong commented on FLINK-21115: --- Merged via 044f8e17237d0fdbff96ca973817c932a3c985ba > Add

[jira] [Commented] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP

2021-03-03 Thread Shuiqiang Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295025#comment-17295025 ] Shuiqiang Chen commented on FLINK-21559: Thank you for reporting the issue, I am looking at it.

[jira] [Closed] (FLINK-21115) Add AggregatingState and corresponding StateDescriptor for Python DataStream API

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21115. - Resolution: Fixed > Add AggregatingState and corresponding StateDescriptor for Python DataStream > API

[jira] [Closed] (FLINK-21434) When UDAF return ROW type, and the number of fields is more than 14, the crash happend

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21434. - Resolution: Fixed > When UDAF return ROW type, and the number of fields is more than 14, the > crash

[jira] [Commented] (FLINK-21434) When UDAF return ROW type, and the number of fields is more than 14, the crash happend

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295022#comment-17295022 ] Wei Zhong commented on FLINK-21434: --- Fixed via:  - master: 1b0e592cf56005bff430252b0d59b8b6da1347f8  

[GitHub] [flink] flinkbot edited a comment on pull request #15080: [FLINK-21587][coordination] Harden FineGrainedSlotManagerTest and AbstractFineGrainedSlotManagerITCase

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15080: URL: https://github.com/apache/flink/pull/15080#issuecomment-790241029 ## CI report: * ac7a34047e2ffe43d2b6c42f233ac6e908e0ba84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * ecdc2416f67f8cf580a65b30374c1a0bc08b1c0e Azure:

[GitHub] [flink] becketqin commented on a change in pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and

2021-03-03 Thread GitBox
becketqin commented on a change in pull request #14531: URL: https://github.com/apache/flink/pull/14531#discussion_r587183656 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java ## @@ -423,14

[jira] [Updated] (FLINK-21592) RemoveSingleAggregateRule fails due to nullability mismatch

2021-03-03 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-21592: --- Description: The test case to reproduce the issue: {code} @Test public void test() throws Exception

[jira] [Created] (FLINK-21592) RemoveSingleAggregateRule fails due to nullability mismatch

2021-03-03 Thread Rui Li (Jira)
Rui Li created FLINK-21592: -- Summary: RemoveSingleAggregateRule fails due to nullability mismatch Key: FLINK-21592 URL: https://issues.apache.org/jira/browse/FLINK-21592 Project: Flink Issue Type:

[jira] [Updated] (FLINK-21103) E2e tests time out on azure

2021-03-03 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-21103: -- Component/s: (was: Runtime / State Backends) Thanks for the follow up [~dwysakowicz] and [~rmetzger]!

[jira] [Closed] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

2021-03-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-21552. Resolution: Fixed Fixed via * master (1.13): 1e71b1c35c25063ce80abd35d1ac59e437c858c3 *

[GitHub] [flink] flinkbot edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-772182984 ## CI report: * 60e427103cca73ac1fc29fb18893e3996edb1c7a UNKNOWN * cbaf10a07272ce5b3019e98a51cb0ef7f1cdd86b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14800: [FLINK-21192][python] Support setting namespace in RemoteKeyedStateBackend

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14800: URL: https://github.com/apache/flink/pull/14800#issuecomment-769581041 ## CI report: * c4c73b24c730472d974aa3d874e0a5c2e116ca51 Azure:

[GitHub] [flink] xintongsong closed pull request #15057: [FLINK-21552][runtime] Unreserve managed memory if OpaqueMemoryResour…

2021-03-03 Thread GitBox
xintongsong closed pull request #15057: URL: https://github.com/apache/flink/pull/15057 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

[GitHub] [flink] KarmaGYZ commented on pull request #15080: [FLINK-21587][coordination] Harden FineGrainedSlotManagerTest and AbstractFineGrainedSlotManagerITCase

2021-03-03 Thread GitBox
KarmaGYZ commented on pull request #15080: URL: https://github.com/apache/flink/pull/15080#issuecomment-790315596 cc @xintongsong This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] zhuzhurk merged pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-03 Thread GitBox
zhuzhurk merged pull request #15069: URL: https://github.com/apache/flink/pull/15069 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] zhuzhurk commented on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-03 Thread GitBox
zhuzhurk commented on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-790307951 The failed test case is a known issue FLINK-21574. Merging. This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-772182984 ## CI report: * 60e427103cca73ac1fc29fb18893e3996edb1c7a UNKNOWN * cbaf10a07272ce5b3019e98a51cb0ef7f1cdd86b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15069: [FLINK-21576][runtime] Remove legacy ExecutionVertex#getPreferredLocations()

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15069: URL: https://github.com/apache/flink/pull/15069#issuecomment-789495972 ## CI report: * b75bc5b5a449ad252c6ba49e42484ca7228dc4de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15066: [FLINK-21488] [connectors/jdbc] Embed JobID into XID's global transaction ID

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15066: URL: https://github.com/apache/flink/pull/15066#issuecomment-789284217 ## CI report: * 57eb15aee5784699b0a167dd1f763a3dd03dab81 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15048: [FLINK-21477][table-planner-blink] Lookup joins now deal with intermediate table scans containing just the table source correctly

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15048: URL: https://github.com/apache/flink/pull/15048#issuecomment-787621304 ## CI report: * a1687a0edd159a5b8be339a59c08a79ddfee5069 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15081: [FLINK-21553][table-runtime-blink] Copy record if needed when flush window buffer records to state

2021-03-03 Thread GitBox
flinkbot edited a comment on pull request #15081: URL: https://github.com/apache/flink/pull/15081#issuecomment-790283597 ## CI report: * e5392081f205893b2f504a66e9ea3e9d7d0c0432 Azure:

[GitHub] [flink] flinkbot commented on pull request #15081: [FLINK-21553][table-runtime-blink] Copy record if needed when flush window buffer records to state

2021-03-03 Thread GitBox
flinkbot commented on pull request #15081: URL: https://github.com/apache/flink/pull/15081#issuecomment-790283597 ## CI report: * e5392081f205893b2f504a66e9ea3e9d7d0c0432 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-20496) RocksDB partitioned index filter option

2021-03-03 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-20496. - Resolution: Implemented Merged into master via: be78727ae125c036cbb297d020e8a7ad23aae083

[GitHub] [flink] carp84 closed pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

2021-03-03 Thread GitBox
carp84 closed pull request #14341: URL: https://github.com/apache/flink/pull/14341 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

[jira] [Comment Edited] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-03 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294981#comment-17294981 ] Andy edited comment on FLINK-21553 at 3/4/21, 4:26 AM: --- [~jark] [~dwysakowicz]

[jira] [Comment Edited] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

2021-03-03 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294981#comment-17294981 ] Andy edited comment on FLINK-21553 at 3/4/21, 4:24 AM: --- [~jark] [~dwysakowicz]

[GitHub] [flink] flinkbot commented on pull request #15081: [FLINK-21553][table-runtime-blink] Copy record if needed when flush window buffer records to state

2021-03-03 Thread GitBox
flinkbot commented on pull request #15081: URL: https://github.com/apache/flink/pull/15081#issuecomment-790279431 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

  1   2   3   4   5   >