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

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

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

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 4529d29fc411304c78076e303eff3ebf81aa16ae Azure:

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

flinkbot edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844486999 ## CI report: * 6546dc571af0d7f4c04e9e063a6f4b89892e031c Azure:

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

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 14ebe6d069fff468bda4f4bad5ecd3bdeb43cdb0 Azure:

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

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 14ebe6d069fff468bda4f4bad5ecd3bdeb43cdb0 Azure:

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

flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * dced81c2ffc8c59f9d9311346e71309129aa73cf Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-22366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348054#comment-17348054 ] Guowei Ma commented on FLINK-22366: ---

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348052#comment-17348052 ] Guowei Ma commented on FLINK-22613: ---

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

[ https://issues.apache.org/jira/browse/FLINK-22692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348050#comment-17348050 ] Guowei Ma commented on FLINK-22702: --- KafkaSourceITCase.testValueOnlyDeserializer fail because of same

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

[ 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

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"

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-22704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348049#comment-17348049 ] Guowei Ma commented on FLINK-22704: ---

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

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348047#comment-17348047 ] Guowei Ma commented on FLINK-22593: ---

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

flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * dced81c2ffc8c59f9d9311346e71309129aa73cf Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348041#comment-17348041 ] Yun Gao commented on FLINK-21952: - Hi [~pnowojski] Very sorry for missing the notification and response

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

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

flinkbot edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844486999 ## CI report: * a72b9147bc1f30b72a54ae0beff7515019d39326 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348032#comment-17348032 ] Andy commented on FLINK-22719: -- [~lzljs3620320] I agree with you, If join has two window nodes as input

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

Jingsong Lee created FLINK-22719: Summary: WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception Key: FLINK-22719 URL: https://issues.apache.org/jira/browse/FLINK-22719

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

flinkbot edited a comment on pull request #15927: URL: https://github.com/apache/flink/pull/15927#issuecomment-842054909 ## CI report: * 760d7a3b2f4d2cc87871f228316f1f2bf70fe8ae Azure:

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

[ 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

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

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

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

flinkbot edited a comment on pull request #15927: URL: https://github.com/apache/flink/pull/15927#issuecomment-842054909 ## CI report: * 760d7a3b2f4d2cc87871f228316f1f2bf70fe8ae Azure:

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348019#comment-17348019 ] Leonard Xu edited comment on FLINK-21803 at 5/20/21, 2:34 AM: -- Since flink

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348019#comment-17348019 ] Leonard Xu edited comment on FLINK-21803 at 5/20/21, 2:32 AM: -- Since flink

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

[ 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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348016#comment-17348016 ] Guowei Ma commented on FLINK-20495: ---

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

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348015#comment-17348015 ] Guowei Ma commented on FLINK-22613: --- 1.12

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

[ 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 >

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

[ https://issues.apache.org/jira/browse/FLINK-20498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348013#comment-17348013 ] Guowei Ma commented on FLINK-20498: ---

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

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348011#comment-17348011 ] Nicholas Jiang commented on FLINK-22698: [~austince], thanks for tracking this issue. From this

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

flinkbot edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844486999 ## CI report: * a72b9147bc1f30b72a54ae0beff7515019d39326 Azure:

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

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 14ebe6d069fff468bda4f4bad5ecd3bdeb43cdb0 Azure:

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

flinkbot edited a comment on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-829441551 ## CI report: * fa9018ec27b571fa64b2a5301926e2e663db0a75 Azure:

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

flinkbot edited a comment on pull request #15962: URL: https://github.com/apache/flink/pull/15962#issuecomment-844547552 ## CI report: * 41505bab4cbfae474b07519657c8d0383f4bdd0a Azure:

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

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 14ebe6d069fff468bda4f4bad5ecd3bdeb43cdb0 Azure:

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

flinkbot edited a comment on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-829441551 ## CI report: * 42cb97338993cfc7ca4ac179a66517719d6981c8 Azure:

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

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

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

flinkbot edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844486999 ## CI report: * a72b9147bc1f30b72a54ae0beff7515019d39326 Azure:

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

flinkbot edited a comment on pull request #15961: URL: https://github.com/apache/flink/pull/15961#issuecomment-844486999 ## CI report: * a72b9147bc1f30b72a54ae0beff7515019d39326 Azure:

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

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

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

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

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

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

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

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

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

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

[ 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

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

flinkbot edited a comment on pull request #15962: URL: https://github.com/apache/flink/pull/15962#issuecomment-844547552 ## CI report: * 41505bab4cbfae474b07519657c8d0383f4bdd0a Azure:

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

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

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

[ 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

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

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

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

[ 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

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

[ 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

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

[ 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

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

[ 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:

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

[ 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

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

[ 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

[ 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

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

[ 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:

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

[ 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:

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

[ 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

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

[ 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

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

[ 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:

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

[ 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

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

[ 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

[ 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

[ 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:

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

[ 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

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

[ 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:

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

[ 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:

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

[ 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:

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

[ 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

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

[ 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

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

[ 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

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

[ 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)

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

[ 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)

[jira] [Updated] (FLINK-22111) ClientTest.testSimpleRequests fail

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

[jira] [Updated] (FLINK-22347) Support renaming shipped archives on Yarn

[ https://issues.apache.org/jira/browse/FLINK-22347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22347: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22090) Upload logs fails

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

[jira] [Updated] (FLINK-22126) when i set ssl ,the jobmanager got certificate_unknown exception

[ https://issues.apache.org/jira/browse/FLINK-22126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22126: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22114) Streaming File Sink s3 end-to-end test fail because the test did not finish after 900 seconds.

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

[jira] [Updated] (FLINK-22091) env.java.home option didn't take effect in resource negotiator

[ https://issues.apache.org/jira/browse/FLINK-22091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22091: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22309) Reduce response time when using SQL Client submit query(SELECT)

[ https://issues.apache.org/jira/browse/FLINK-22309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22309: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

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

[jira] [Updated] (FLINK-21209) Update stackbrew maintainer field

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

[jira] [Updated] (FLINK-22112) EmulatedPubSubSinkTest fail due to pull docker image failure

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

[jira] [Updated] (FLINK-22118) Always apply projection push down in blink planner

[ https://issues.apache.org/jira/browse/FLINK-22118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22118: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-21374) Upgrade built-in Hive to 2.3.8

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

[jira] [Updated] (FLINK-21438) Broken links in content.zh/docs/concepts/flink-architecture.md

[ https://issues.apache.org/jira/browse/FLINK-21438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21438: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

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

[jira] [Updated] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

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

[jira] [Updated] (FLINK-22189) Flink SQL Client Hudi batch write crashes JobManager

[ https://issues.apache.org/jira/browse/FLINK-22189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22189: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-21562) Add more informative message on CSV parsing errors

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

  1   2   3   4   5   >