[jira] [Comment Edited] (FLINK-21439) Adaptive Scheduler: Add support for exception history

2021-05-19 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348088#comment-17348088 ] Matthias edited comment on FLINK-21439 at 5/20/21, 6:58 AM:

[jira] [Commented] (FLINK-22693) EXPLAIN cannot be used on Hbase table when useing ROW type

2021-05-19 Thread sadfdddd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348097#comment-17348097 ] sadf commented on FLINK-22693: -- [~jark] The program can run without EXPLAIN PLAN FO

[jira] [Commented] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception

2021-05-19 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348096#comment-17348096 ] Andy commented on FLINK-22719: -- [~lzljs3620320] Thanks for point out the root cause , I wou

[GitHub] [flink] flinkbot edited a comment on pull request #15944: [FLINK-22694][e2e] Use sql file in TPCH end to end tests

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15944: URL: https://github.com/apache/flink/pull/15944#issuecomment-843049332 ## CI report: * b64a13c6b1f1c16817a40ca21a20574f51eabcfb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-05-19 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348093#comment-17348093 ] zoucao commented on FLINK-22437: hi [~wenlong.lwl], this problem had been fixed in 1.13

[jira] [Commented] (FLINK-22693) EXPLAIN cannot be used on Hbase table when useing ROW type

2021-05-19 Thread sadfdddd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348092#comment-17348092 ] sadf commented on FLINK-22693: -- [~jark]  I've uploaded my code,This error can stabl

[jira] [Commented] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception

2021-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348091#comment-17348091 ] Jingsong Lee commented on FLINK-22719: -- [~qingru zhang] Do not select row time fiel

[jira] [Updated] (FLINK-22693) EXPLAIN cannot be used on Hbase table when useing ROW type

2021-05-19 Thread sadfdddd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sadf updated FLINK-22693: - Attachment: pom.xml Driver.java > EXPLAIN cannot be used on Hbase table when useing ROW

[jira] [Updated] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

2021-05-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-20374: - Labels: (was: stale-critical) > Wrong result when shuffling changelog stream on non-primary-ke

[jira] [Commented] (FLINK-21439) Adaptive Scheduler: Add support for exception history

2021-05-19 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348088#comment-17348088 ] Matthias commented on FLINK-21439: -- Ah, you're right. I mixed up the failure handling a

[jira] [Comment Edited] (FLINK-21439) Adaptive Scheduler: Add support for exception history

2021-05-19 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346655#comment-17346655 ] Matthias edited comment on FLINK-21439 at 5/20/21, 6:16 AM:

[jira] [Comment Edited] (FLINK-21439) Adaptive Scheduler: Add support for exception history

2021-05-19 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346655#comment-17346655 ] Matthias edited comment on FLINK-21439 at 5/20/21, 6:15 AM:

[jira] [Commented] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception

2021-05-19 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348087#comment-17348087 ] Andy commented on FLINK-22719: -- Now there is no possible to do a regular join directly afte

[GitHub] [flink] fsk119 commented on a change in pull request #15944: [FLINK-22694][e2e] Use sql file in TPCH end to end tests

2021-05-19 Thread GitBox
fsk119 commented on a change in pull request #15944: URL: https://github.com/apache/flink/pull/15944#discussion_r635793767 ## File path: flink-end-to-end-tests/flink-tpch-test/src/main/java/org/apache/flink/table/tpch/TpchResultComparator.java ## @@ -81,7 +93,10 @@ public stat

[jira] [Commented] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception

2021-05-19 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348084#comment-17348084 ] Andy commented on FLINK-22719: -- [~lzljs3620320], There exists multiple cases in WindowJoinT

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

2021-05-19 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348082#comment-17348082 ] Wenlong Lyu commented on FLINK-22437: - [~zoucao] thanks for reporting the bug, the b

[jira] [Commented] (FLINK-22454) Failed to translate Lookup Join when join on a CAST expression on dimention table column

2021-05-19 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348075#comment-17348075 ] Wenlong Lyu commented on FLINK-22454: - Hi, [~fsk119], I think is error is by designe

[GitHub] [flink] leonardBang commented on pull request #15920: [FLINK-22661][hive] HiveInputFormatPartitionReader can return invalid…

2021-05-19 Thread GitBox
leonardBang commented on pull request #15920: URL: https://github.com/apache/flink/pull/15920#issuecomment-844721068 > Since we don't combine splits, there will be at least two splits to read. You're right that single split is ok because one single split won't do switch splits action

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 4529d29fc411304c78076e303eff3ebf81aa16ae Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844486999 ## CI report: * 6546dc571af0d7f4c04e9e063a6f4b89892e031c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 14ebe6d069fff468bda4f4bad5ecd3bdeb43cdb0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 14ebe6d069fff468bda4f4bad5ecd3bdeb43cdb0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * dced81c2ffc8c59f9d9311346e71309129aa73cf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22366) HiveSinkCompactionITCase fails on azure

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348054#comment-17348054 ] Guowei Ma commented on FLINK-22366: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Comment Edited] (FLINK-22704) ZooKeeperHaServicesTest.testCleanupJobData failed

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348049#comment-17348049 ] Guowei Ma edited comment on FLINK-22704 at 5/20/21, 4:46 AM: -

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348052#comment-17348052 ] Guowei Ma commented on FLINK-22613: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Comment Edited] (FLINK-22692) CheckpointStoreITCase.testRestartOnRecoveryFailure fails with RuntimeException

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347278#comment-17347278 ] Guowei Ma edited comment on FLINK-22692 at 5/20/21, 4:44 AM: -

[jira] [Created] (FLINK-22720) UpsertKafkaTableITCase.testAggregate fail due to ConcurrentModificationException

2021-05-19 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22720: - Summary: UpsertKafkaTableITCase.testAggregate fail due to ConcurrentModificationException Key: FLINK-22720 URL: https://issues.apache.org/jira/browse/FLINK-22720 Project: F

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348050#comment-17348050 ] Guowei Ma commented on FLINK-22702: --- KafkaSourceITCase.testValueOnlyDeserializer fail

[jira] [Updated] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22702: -- Affects Version/s: 1.14.0 > KafkaSourceITCase.testRedundantParallelism failed > --

[GitHub] [flink] wuchong commented on a change in pull request #15944: [FLINK-22694][e2e] Use sql file in TPCH end to end tests

2021-05-19 Thread GitBox
wuchong commented on a change in pull request #15944: URL: https://github.com/apache/flink/pull/15944#discussion_r635740045 ## File path: flink-end-to-end-tests/test-scripts/test_tpch.sh ## @@ -51,29 +51,27 @@ ORIGIN_QUERY_DIR="$TARGET_DIR/query" MODIFIED_QUERY_DIR="$TPCH_DATA

[jira] [Updated] (FLINK-22704) ZooKeeperHaServicesTest.testCleanupJobData failed

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22704: -- Affects Version/s: 1.14.0 > ZooKeeperHaServicesTest.testCleanupJobData failed > --

[jira] [Commented] (FLINK-22704) ZooKeeperHaServicesTest.testCleanupJobData failed

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348049#comment-17348049 ] Guowei Ma commented on FLINK-22704: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348047#comment-17348047 ] Guowei Ma commented on FLINK-22593: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] flinkbot edited a comment on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * dced81c2ffc8c59f9d9311346e71309129aa73cf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

2021-05-19 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348041#comment-17348041 ] Yun Gao commented on FLINK-21952: - Hi [~pnowojski] Very sorry for missing the notificati

[GitHub] [flink] lirui-apache commented on pull request #15920: [FLINK-22661][hive] HiveInputFormatPartitionReader can return invalid…

2021-05-19 Thread GitBox
lirui-apache commented on pull request #15920: URL: https://github.com/apache/flink/pull/15920#issuecomment-844671552 > Thanks @lirui-apache for the contribution, LGTM. > The bug also exists in single split and the test you used to mock reader for lookup also is single split. It will be

[GitHub] [flink] flinkbot edited a comment on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844486999 ## CI report: * a72b9147bc1f30b72a54ae0beff7515019d39326 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception

2021-05-19 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348032#comment-17348032 ] Andy commented on FLINK-22719: -- [~lzljs3620320] I agree with you, If join has two window no

[jira] [Created] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception

2021-05-19 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-22719: Summary: WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception Key: FLINK-22719 URL: https://issues.apache.org/jira/browse/FLINK-22719 P

[GitHub] [flink] flinkbot edited a comment on pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15927: URL: https://github.com/apache/flink/pull/15927#issuecomment-842054909 ## CI report: * 760d7a3b2f4d2cc87871f228316f1f2bf70fe8ae Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22718) Could not create actor system

2021-05-19 Thread HYUNHOO KWON (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HYUNHOO KWON updated FLINK-22718: - Summary: Could not create actor system (was: java.lang.Exception: Could not create actor system

[jira] [Created] (FLINK-22718) java.lang.Exception: Could not create actor system

2021-05-19 Thread HYUNHOO KWON (Jira)
HYUNHOO KWON created FLINK-22718: Summary: java.lang.Exception: Could not create actor system Key: FLINK-22718 URL: https://issues.apache.org/jira/browse/FLINK-22718 Project: Flink Issue Type

[GitHub] [flink] flinkbot edited a comment on pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15927: URL: https://github.com/apache/flink/pull/15927#issuecomment-842054909 ## CI report: * 760d7a3b2f4d2cc87871f228316f1f2bf70fe8ae Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

2021-05-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21803: --- Fix Version/s: (was: 1.13.0) > Tumbling / Sliding windows are unaware of daylight savings time >

[jira] [Comment Edited] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

2021-05-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348019#comment-17348019 ] Leonard Xu edited comment on FLINK-21803 at 5/20/21, 2:34 AM:

[jira] [Reopened] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

2021-05-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-21803: > Tumbling / Sliding windows are unaware of daylight savings time > --

[jira] [Comment Edited] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

2021-05-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348019#comment-17348019 ] Leonard Xu edited comment on FLINK-21803 at 5/20/21, 2:32 AM:

[jira] [Resolved] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

2021-05-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-21803. Fix Version/s: 1.13.0 Resolution: Implemented Since flink 1.13 you can define time attribut

[GitHub] [flink] paul8263 commented on pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

2021-05-19 Thread GitBox
paul8263 commented on pull request #15927: URL: https://github.com/apache/flink/pull/15927#issuecomment-844635880 Thank you @zentol . I reworked those codes in ce1bf53 . -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348016#comment-17348016 ] Guowei Ma commented on FLINK-20495: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348015#comment-17348015 ] Guowei Ma commented on FLINK-22613: --- 1.12 https://dev.azure.com/apache-flink/apache-fl

[jira] [Updated] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20498: -- Affects Version/s: 1.12.3 > SQLClientSchemaRegistryITCase.testReading test timed out after 12 > m

[jira] [Commented] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds

2021-05-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348013#comment-17348013 ] Guowei Ma commented on FLINK-20498: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-19 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348011#comment-17348011 ] Nicholas Jiang commented on FLINK-22698: [~austince], thanks for tracking this i

[GitHub] [flink] flinkbot edited a comment on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844486999 ## CI report: * a72b9147bc1f30b72a54ae0beff7515019d39326 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 14ebe6d069fff468bda4f4bad5ecd3bdeb43cdb0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15812: remove slotpoolImpl

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-829441551 ## CI report: * fa9018ec27b571fa64b2a5301926e2e663db0a75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15962: [WIP] [FLINK-22326] Fix Iterator Operation leading to checkpoint failure

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15962: URL: https://github.com/apache/flink/pull/15962#issuecomment-844547552 ## CI report: * 41505bab4cbfae474b07519657c8d0383f4bdd0a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 14ebe6d069fff468bda4f4bad5ecd3bdeb43cdb0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15812: remove slotpoolImpl

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-829441551 ## CI report: * 42cb97338993cfc7ca4ac179a66517719d6981c8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] FuyaoLi2017 commented on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
FuyaoLi2017 commented on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844606216 cc @zentol @sjwiesman Hello All, I think this PR should be ready. Please review. In addition, I have a side question, there are many third party dependencies over the pl

[GitHub] [flink] flinkbot edited a comment on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844486999 ## CI report: * a72b9147bc1f30b72a54ae0beff7515019d39326 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844486999 ## CI report: * a72b9147bc1f30b72a54ae0beff7515019d39326 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] sjwiesman commented on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
sjwiesman commented on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844578456 Yes -- 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

[GitHub] [flink] FuyaoLi2017 commented on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
FuyaoLi2017 commented on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844571777 > @zentol because the syntax highlighting comes from a file generated by Hugo but which is actually chroma under the hood > > The file is only called GitHu

[GitHub] [flink] sjwiesman commented on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
sjwiesman commented on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844566891 @zentol because the syntax highlighting comes from a file generated by Hugo but which is actually chroma under the hood The file is only called GitHub css because that’s

[GitHub] [flink] FuyaoLi2017 edited a comment on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
FuyaoLi2017 edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844565249 > @sjwiesman The licenses directory contains a file for chroma, but this isn't referenced in the NOTICE. What's up with that? This seems to be related to HUGO.

[GitHub] [flink] FuyaoLi2017 edited a comment on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
FuyaoLi2017 edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844565249 > @sjwiesman The licenses directory contains a file for chroma, but this isn't referenced in the NOTICE. What's up with that? This seems to be related to HUGO.

[GitHub] [flink] FuyaoLi2017 commented on pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
FuyaoLi2017 commented on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844565249 > @sjwiesman The licenses directory contains a file for chroma, but this isn't referenced in the NOTICE. What's up with that? This seems to be related to HUGO. I fo

[jira] [Updated] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

2021-05-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22326: --- Labels: pull-request-available (was: ) > Job contains Iterate Operator always fails on Chec

[GitHub] [flink] flinkbot edited a comment on pull request #15962: [WIP] [FLINK-22326] Fix Iterator Operation leading to checkpoint failure

2021-05-19 Thread GitBox
flinkbot edited a comment on pull request #15962: URL: https://github.com/apache/flink/pull/15962#issuecomment-844547552 ## CI report: * 41505bab4cbfae474b07519657c8d0383f4bdd0a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] FuyaoLi2017 commented on a change in pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
FuyaoLi2017 commented on a change in pull request #15961: URL: https://github.com/apache/flink/pull/15961#discussion_r635636746 ## File path: NOTICE ## @@ -28,8 +22,9 @@ See bundled license files for details. This project bundles the following dependencies under SIL OFL 1.1 li

[jira] [Updated] (FLINK-21928) DuplicateJobSubmissionException after JobManager failover

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21928: --- Labels: stale-critical (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jir

[GitHub] [flink] FuyaoLi2017 commented on a change in pull request #15961: [FLINK-22706][release]Update License information in NOTICE file

2021-05-19 Thread GitBox
FuyaoLi2017 commented on a change in pull request #15961: URL: https://github.com/apache/flink/pull/15961#discussion_r635636746 ## File path: NOTICE ## @@ -28,8 +22,9 @@ See bundled license files for details. This project bundles the following dependencies under SIL OFL 1.1 li

[jira] [Updated] (FLINK-19144) Error when writing to partitioned table with s3 FileSystem

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19144: --- Labels: auto-unassigned stale-critical (was: auto-unassigned) I am the [Flink Jira Bot|http

[jira] [Updated] (FLINK-21519) SQLClientHBaseITCase hangs on azure

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21519: --- Labels: auto-unassigned stale-critical test-stability (was: auto-unassigned test-stability)

[jira] [Updated] (FLINK-19248) The main method caused an error: No result found for job, was execute() called before getting the result

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19248: --- Labels: auto-unassigned pull-request-available stale-critical (was: auto-unassigned pull-re

[jira] [Updated] (FLINK-18356) Exit code 137 returned from process

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18356: --- Labels: auto-deprioritized-critical pull-request-available test-stability (was: pull-requ

[jira] [Updated] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20374: --- Labels: stale-critical (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jir

[jira] [Updated] (FLINK-17400) LocalStandaloneKafkaResource.setupKafkaDist fails due to download timeout

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17400: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22686: --- Labels: stale-blocker (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jira

[jira] [Updated] (FLINK-17519) Add Java State Bootstrapping E2E test for Stateful Functions

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17519: --- Labels: auto-deprioritized-critical (was: stale-critical) Priority: Major (was: Criti

[jira] [Updated] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17726: --- Labels: auto-deprioritized-critical (was: stale-critical) Priority: Major (was: Criti

[jira] [Updated] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20614: --- Labels: stale-critical (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jir

[jira] [Updated] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20427: --- Labels: stale-critical (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jir

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20431: --- Labels: auto-unassigned pull-request-available stale-critical test-stability (was: auto-una

[jira] [Updated] (FLINK-20432) SQLClientSchemaRegistryITCase hangs

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20432: --- Labels: auto-deprioritized-critical pull-request-available stale-critical test-stability (w

[jira] [Updated] (FLINK-18444) KafkaITCase failing with "Failed to send data to Kafka: This server does not host this topic-partition"

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18444: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20928: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-21065) Passing configuration from TableEnvironmentImpl to MiniCluster is not supported

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21065: --- Labels: auto-deprioritized-critical (was: stale-critical) Priority: Major (was: Criti

[jira] [Updated] (FLINK-21979) Job can be restarted from the beginning after it reached a terminal state

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21979: --- Labels: stale-critical (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jir

[jira] [Updated] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18800: --- Labels: auto-deprioritized-critical (was: stale-critical) Priority: Major (was: Criti

[jira] [Updated] (FLINK-17349) Reduce runtime of LocalExecutorITCase

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17349: --- Labels: auto-deprioritized-critical (was: stale-critical) Priority: Major (was: Criti

[jira] [Updated] (FLINK-18652) JDBCAppendTableSink to ClickHouse (data always repeating)

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18652: --- Labels: auto-deprioritized-critical (was: stale-critical) Priority: Major (was: Criti

[jira] [Updated] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22262: --- Labels: stale-major (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-b

[jira] [Updated] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22096: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-22108) Ephemeral socket address was checkpointed to state and restored back in CollectSinkOperatorCoordinator

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22108: --- Labels: stale-major (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-b

[jira] [Updated] (FLINK-21406) Add AvroParquetFileRecordFormat

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21406: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-21407) Clarify which sources and APIs support which formats

2021-05-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21407: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

  1   2   3   4   5   >