[jira] [Updated] (FLINK-23567) Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was not found

[ https://issues.apache.org/jira/browse/FLINK-23567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wuyang updated FLINK-23567: --- Attachment: image-2021-08-02-13-55-26-467.png > Hive 1.1.0 failed to write using flink sql 1.13.1 because

[jira] [Resolved] (FLINK-23229) Translate "Timely Stream Processing" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kevin resolved FLINK-23229. --- Resolution: Fixed Translation finished, waiting for code review. > Translate "Timely Stream Processing"

[GitHub] [flink] flinkbot commented on pull request #16663: [FLINK-23229][docs-zh] Translate "Timely Stream Processing" page into Chinese

flinkbot commented on pull request #16663: URL: https://github.com/apache/flink/pull/16663#issuecomment-890736604 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-23229) Translate "Timely Stream Processing" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23229: --- Labels: pull-request-available (was: ) > Translate "Timely Stream Processing" page into

[GitHub] [flink] RollsBean opened a new pull request #16663: [FLINK-23229][docs-zh] Translate "Timely Stream Processing" page into Chinese

RollsBean opened a new pull request #16663: URL: https://github.com/apache/flink/pull/16663 ## What is the purpose of the change *This pull request transalte "Timely Stream Processing" page into Chinese. Doc lInk:

[jira] [Updated] (FLINK-23575) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with AsynchronousException

[ https://issues.apache.org/jira/browse/FLINK-23575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23575: - Priority: Blocker (was: Major) >

[jira] [Updated] (FLINK-23557) 'Resuming Externalized Checkpoint (hashmap, sync, no parallelism change) end-to-end test' fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23557: - Priority: Blocker (was: Major) > 'Resuming Externalized Checkpoint (hashmap, sync, no

[jira] [Updated] (FLINK-22382) ProcessFailureCancelingITCase.testCancelingOnProcessFailure

[ https://issues.apache.org/jira/browse/FLINK-22382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22382: - Priority: Critical (was: Major) > ProcessFailureCancelingITCase.testCancelingOnProcessFailure

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391341#comment-17391341 ] Xintong Song commented on FLINK-22198: --

[jira] [Commented] (FLINK-22971) Initialization of Testcontainers unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-22971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391340#comment-17391340 ] Xintong Song commented on FLINK-22971: --

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391338#comment-17391338 ] Xintong Song commented on FLINK-18634: --

[jira] [Commented] (FLINK-23575) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with AsynchronousException

[ https://issues.apache.org/jira/browse/FLINK-23575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391337#comment-17391337 ] Xintong Song commented on FLINK-23575: --

[jira] [Commented] (FLINK-23518) ZooKeeperLeaderElectionConnectionHandlingTest hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-23518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391336#comment-17391336 ] Xintong Song commented on FLINK-23518: --

[jira] [Commented] (FLINK-23557) 'Resuming Externalized Checkpoint (hashmap, sync, no parallelism change) end-to-end test' fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391334#comment-17391334 ] Xintong Song commented on FLINK-23557: --

[jira] [Commented] (FLINK-23574) test_pandas_udaf hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391335#comment-17391335 ] Xintong Song commented on FLINK-23574: --

[jira] [Created] (FLINK-23577) CoordinatedSourceRescaleITCase.testUpscaling fails with NoSuchFileException

Xintong Song created FLINK-23577: Summary: CoordinatedSourceRescaleITCase.testUpscaling fails with NoSuchFileException Key: FLINK-23577 URL: https://issues.apache.org/jira/browse/FLINK-23577 Project:

[jira] [Commented] (FLINK-23574) test_pandas_udaf hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391332#comment-17391332 ] Xintong Song commented on FLINK-23574: --

[jira] [Commented] (FLINK-22382) ProcessFailureCancelingITCase.testCancelingOnProcessFailure

[ https://issues.apache.org/jira/browse/FLINK-22382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391330#comment-17391330 ] Xintong Song commented on FLINK-22382: --

[jira] [Created] (FLINK-23576) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to Artificial Failure

Xintong Song created FLINK-23576: Summary: JoinITCase.testFullJoinWithEqualPkNonEqui fails due to Artificial Failure Key: FLINK-23576 URL: https://issues.apache.org/jira/browse/FLINK-23576 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * aba5c1f4d84b5ca8dc28b7057dbd092c87c9d932 Azure:

[jira] [Commented] (FLINK-23518) ZooKeeperLeaderElectionConnectionHandlingTest hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-23518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391327#comment-17391327 ] Xintong Song commented on FLINK-23518: --

[jira] [Commented] (FLINK-23575) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with AsynchronousException

[ https://issues.apache.org/jira/browse/FLINK-23575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391326#comment-17391326 ] Xintong Song commented on FLINK-23575: --

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

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

[jira] [Commented] (FLINK-23557) 'Resuming Externalized Checkpoint (hashmap, sync, no parallelism change) end-to-end test' fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391321#comment-17391321 ] Xintong Song commented on FLINK-23557: --

[jira] [Created] (FLINK-23575) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with AsynchronousException

Xintong Song created FLINK-23575: Summary: UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with AsynchronousException Key: FLINK-23575 URL:

[jira] [Updated] (FLINK-23236) FanOutShardSubscriberTest.testTimeoutEnqueuingEvent fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23236: - Affects Version/s: 1.12.4 > FanOutShardSubscriberTest.testTimeoutEnqueuingEvent fails on azure

[jira] [Commented] (FLINK-23236) FanOutShardSubscriberTest.testTimeoutEnqueuingEvent fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391311#comment-17391311 ] Xintong Song commented on FLINK-23236: --

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391309#comment-17391309 ] Xintong Song commented on FLINK-22198: --

[jira] [Commented] (FLINK-23574) test_pandas_udaf hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391307#comment-17391307 ] Xintong Song commented on FLINK-23574: -- cc [~dianfu] > test_pandas_udaf hangs on azure >

[jira] [Created] (FLINK-23574) test_pandas_udaf hangs on azure

Xintong Song created FLINK-23574: Summary: test_pandas_udaf hangs on azure Key: FLINK-23574 URL: https://issues.apache.org/jira/browse/FLINK-23574 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * aba5c1f4d84b5ca8dc28b7057dbd092c87c9d932 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: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * bda4e98be48b7975272bafd63702d844287a7e4a Azure:

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391290#comment-17391290 ] Xintong Song commented on FLINK-15493: --

[jira] [Commented] (FLINK-23573) Tests fail with AdaptiveScheduler due to exceptions in logs trying to offer slots after JobMaster shutdown

[ https://issues.apache.org/jira/browse/FLINK-23573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391288#comment-17391288 ] Xintong Song commented on FLINK-23573: -- The tests can be easily fixed by adding the

[jira] [Created] (FLINK-23573) Tests fail with AdaptiveScheduler due to exceptions in logs trying to offer slots after JobMaster shutdown

Xintong Song created FLINK-23573: Summary: Tests fail with AdaptiveScheduler due to exceptions in logs trying to offer slots after JobMaster shutdown Key: FLINK-23573 URL:

[GitHub] [flink] RocMarshal commented on a change in pull request #16547: [FLINK-23423][docs-zh] Translate the page of "Elasticsearch Connector" into Chinese

RocMarshal commented on a change in pull request #16547: URL: https://github.com/apache/flink/pull/16547#discussion_r680612732 ## File path: docs/content.zh/docs/connectors/datastream/elasticsearch.md ## @@ -51,29 +49,25 @@ of the Elasticsearch installation: {{<

[jira] [Commented] (FLINK-23572) KubernetesSharedInformerITCase JVM crash on azure

[ https://issues.apache.org/jira/browse/FLINK-23572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391287#comment-17391287 ] Xintong Song commented on FLINK-23572: -- cc [~wangyang0918] > KubernetesSharedInformerITCase JVM

[jira] [Commented] (FLINK-23557) 'Resuming Externalized Checkpoint (hashmap, sync, no parallelism change) end-to-end test' fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391286#comment-17391286 ] Xintong Song commented on FLINK-23557: --

[GitHub] [flink] flinkbot edited a comment on pull request #16662: [hotfix][connector][jdbc] Corrected exception variable name

flinkbot edited a comment on pull request #16662: URL: https://github.com/apache/flink/pull/16662#issuecomment-890591363 ## CI report: * 91e19b0ae0c150ca6e4f00cc3e67bf4df8718f92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

flinkbot edited a comment on pull request #16598: URL: https://github.com/apache/flink/pull/16598#issuecomment-886655820 ## CI report: * e6b0b05fadd9d6724a424c313a7b9617a854955f Azure:

[jira] [Created] (FLINK-23572) KubernetesSharedInformerITCase JVM crash on azure

Xintong Song created FLINK-23572: Summary: KubernetesSharedInformerITCase JVM crash on azure Key: FLINK-23572 URL: https://issues.apache.org/jira/browse/FLINK-23572 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4e68f790d4f960bc0e8d9a7557f3f638a4f0ee40 Azure:

[jira] [Updated] (FLINK-23059) Update playgrounds for Flink 1.13

[ https://issues.apache.org/jira/browse/FLINK-23059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23059: - Fix Version/s: (was: 1.13.1) 1.13.3 > Update playgrounds for Flink 1.13 >

[jira] [Updated] (FLINK-22855) Translate the 'Overview of Python API' page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-22855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22855: - Fix Version/s: 1.13.2 1.14.0 > Translate the 'Overview of Python API' page into

[jira] [Updated] (FLINK-21229) Support ssl connection with schema registry format

[ https://issues.apache.org/jira/browse/FLINK-21229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21229: - Fix Version/s: (was: 1.13.3) 1.13.2 > Support ssl connection with schema

[jira] [Updated] (FLINK-23443) LaunchCoordinatorTest fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23443: - Fix Version/s: (was: 1.13.2) 1.13.3 > LaunchCoordinatorTest fails on azure >

[jira] [Updated] (FLINK-23155) Streaming File Sink s3 end-to-end test fail on azure

[ https://issues.apache.org/jira/browse/FLINK-23155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23155: - Fix Version/s: (was: 1.13.2) 1.13.3 > Streaming File Sink s3 end-to-end test

[jira] [Updated] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23391: - Fix Version/s: (was: 1.13.2) 1.13.3 >

[jira] [Updated] (FLINK-23108) KafkaITCase.testCancelingEmptyTopic fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23108: - Fix Version/s: (was: 1.13.2) 1.13.3 > KafkaITCase.testCancelingEmptyTopic fails

[jira] [Updated] (FLINK-22959) Keep the job jar files on JobManager

[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22959: - Fix Version/s: (was: 1.13.2) > Keep the job jar files on JobManager >

[GitHub] [flink] Myasuka commented on pull request #16318: [FLINK-22945][runtime] Avoid StackOverflowException when a large scale job is canceling or failing

Myasuka commented on pull request #16318: URL: https://github.com/apache/flink/pull/16318#issuecomment-890686829 FYI, the JIRA id in the original commit message is not right. The correct JIRA id should be `FLINK-22945` -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-22932) RocksDBStateBackendWindowITCase fails with savepoint timeout

[ https://issues.apache.org/jira/browse/FLINK-22932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22932: - Fix Version/s: (was: 1.13.2) 1.13.3 > RocksDBStateBackendWindowITCase fails with

[GitHub] [flink] flinkbot edited a comment on pull request #16627: [FLINK-23427][chinese-translation] Translate the page of "Blocking Sh…

flinkbot edited a comment on pull request #16627: URL: https://github.com/apache/flink/pull/16627#issuecomment-888439016 ## CI report: * bd5918c2cd6093ef02f1ed77727ccc45dcf450e4 Azure:

[jira] [Updated] (FLINK-22799) Missing documentation: State backwards compatibility is not support for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22799: - Fix Version/s: (was: 1.13.2) (was: 1.12.5) (was:

[jira] [Updated] (FLINK-22203) KafkaChangelogTableITCase.testKafkaCanalChangelogSource fail due to ConcurrentModificationException

[ https://issues.apache.org/jira/browse/FLINK-22203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22203: - Fix Version/s: 1.13.2 > KafkaChangelogTableITCase.testKafkaCanalChangelogSource fail due to >

[jira] [Commented] (FLINK-23567) Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was not found

[ https://issues.apache.org/jira/browse/FLINK-23567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391274#comment-17391274 ] Rui Li commented on FLINK-23567: [~wuyang09] The filter is there because the JSON dependency's license

[jira] [Updated] (FLINK-22589) There are quite a few Python classes doesn't appear in the Python docs

[ https://issues.apache.org/jira/browse/FLINK-22589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22589: - Fix Version/s: (was: 1.13.2) 1.13.3 > There are quite a few Python classes

[jira] [Updated] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22621: - Fix Version/s: (was: 1.13.2) 1.13.3 >

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 15b75b2d1bc5a274ec9040eeb6151eecee9c828b Azure:

[jira] [Commented] (FLINK-22578) deployment configuration page miss content navigate menu

[ https://issues.apache.org/jira/browse/FLINK-22578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391272#comment-17391272 ] Yun Tang commented on FLINK-22578: -- [~hiscat] I think the navigate menu is on the right side, what the

[jira] [Updated] (FLINK-22578) deployment configuration page miss content navigate menu

[ https://issues.apache.org/jira/browse/FLINK-22578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22578: - Fix Version/s: (was: 1.13.2) 1.13.3 > deployment configuration page miss content

[jira] [Updated] (FLINK-22527) Give friendly hint when click FlameGraph without rest.flamegraph.enabled

[ https://issues.apache.org/jira/browse/FLINK-22527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22527: - Fix Version/s: (was: 1.13.2) 1.13.3 1.14.0 > Give friendly

[jira] [Updated] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22387: - Fix Version/s: (was: 1.13.2) 1.13.3 > UpsertKafkaTableITCase hangs when setting

[jira] [Updated] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22480: - Fix Version/s: (was: 1.13.2) 1.13.3 > KafkaChangelogTableITCase hangs on Azure >

[jira] [Updated] (FLINK-22370) ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true

[ https://issues.apache.org/jira/browse/FLINK-22370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22370: - Fix Version/s: (was: 1.13.2) 1.13.3 > ParquetColumnarRowSplitReader#reachedEnd()

[jira] [Updated] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22358: - Fix Version/s: (was: 1.13.2) 1.13.3 > Add missing stability annotation to Split

[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 ] Yun Tang updated FLINK-20431: - Fix Version/s: (was: 1.13.2) 1.13.3 >

[jira] [Updated] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-23449: - Component/s: Connectors / Hive > YarnTaskExecutorRunner does not contains MapReduce classes >

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-15493: - Fix Version/s: (was: 1.13.2) 1.13.3 >

[GitHub] [flink-web] Myasuka commented on a change in pull request #453: Add release 1.13.2

Myasuka commented on a change in pull request #453: URL: https://github.com/apache/flink-web/pull/453#discussion_r680626763 ## File path: _posts/2021-07-01-release-1.13.2.md ## @@ -0,0 +1,348 @@ +--- +layout: post +title: "Apache Flink 1.13.2 Released" +date: 2021-07-14

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * d16b8e7b3a5b1a4c25018c3c560a9b9300505f30 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16627: [FLINK-23427][chinese-translation] Translate the page of "Blocking Sh…

flinkbot edited a comment on pull request #16627: URL: https://github.com/apache/flink/pull/16627#issuecomment-888439016 ## CI report: * a4b275ac26d19b38e9b723ee51532ca3b58b19b8 Azure:

[GitHub] [flink] tsreaper commented on a change in pull request #16650: [FLINK-22405] [Table SQL / API] Support fixed-lengh chars in the Lead…

tsreaper commented on a change in pull request #16650: URL: https://github.com/apache/flink/pull/16650#discussion_r680613521 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala ## @@ -366,7 +366,7 @@

[GitHub] [flink] tsreaper commented on a change in pull request #16650: [FLINK-22405] [Table SQL / API] Support fixed-lengh chars in the Lead…

tsreaper commented on a change in pull request #16650: URL: https://github.com/apache/flink/pull/16650#discussion_r680613521 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala ## @@ -366,7 +366,7 @@

[GitHub] [flink] KarmaGYZ commented on pull request #16640: [FLINK-22891][runtime] Using CompletableFuture to sync the scheduling…

KarmaGYZ commented on pull request #16640: URL: https://github.com/apache/flink/pull/16640#issuecomment-890655634 cc @wangyang0918 -- 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

[GitHub] [flink-web] dianfu commented on a change in pull request #453: Add release 1.13.2

dianfu commented on a change in pull request #453: URL: https://github.com/apache/flink-web/pull/453#discussion_r680608694 ## File path: _posts/2021-07-01-release-1.13.2.md ## @@ -0,0 +1,348 @@ +--- +layout: post +title: "Apache Flink 1.13.2 Released" +date: 2021-07-14

[jira] [Commented] (FLINK-23567) Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was not found

[ https://issues.apache.org/jira/browse/FLINK-23567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391263#comment-17391263 ] wuyang commented on FLINK-23567: [~lirui] Please explain this filter comment,thanks > Hive 1.1.0 failed

[GitHub] [flink] flinkbot edited a comment on pull request #16627: [FLINK-23427][chinese-translation] Translate the page of "Blocking Sh…

flinkbot edited a comment on pull request #16627: URL: https://github.com/apache/flink/pull/16627#issuecomment-888439016 ## CI report: * a4b275ac26d19b38e9b723ee51532ca3b58b19b8 Azure:

[jira] [Updated] (FLINK-23567) Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was not found

[ https://issues.apache.org/jira/browse/FLINK-23567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wuyang updated FLINK-23567: --- Summary: Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was not found (was: Hive

[GitHub] [flink-web] dianfu commented on a change in pull request #455: Add release 1.12.5

dianfu commented on a change in pull request #455: URL: https://github.com/apache/flink-web/pull/455#discussion_r680605809 ## File path: _config.yml ## @@ -161,6 +161,10 @@ release_archive: version_short: "1.13" version_long: 1.13.0 release_date:

[GitHub] [flink] GOODBOY008 commented on pull request #16627: [FLINK-23427][chinese-translation] Translate the page of "Blocking Sh…

GOODBOY008 commented on pull request #16627: URL: https://github.com/apache/flink/pull/16627#issuecomment-890643484 @gaoyunhaii Please review my pr again.Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[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: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 3996ed01171c5a55e2d786472221a37b558bb55d 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: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 3996ed01171c5a55e2d786472221a37b558bb55d Azure:

[GitHub] [flink] tweise commented on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-890599075 @AHeise @StephanEwen thank you for the review! Comments are addressed. I also resolved the underlying enumerator restore TODO. If there are no more comments I'm going to merge

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r680576567 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,251

[GitHub] [flink] flinkbot edited a comment on pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

flinkbot edited a comment on pull request #16598: URL: https://github.com/apache/flink/pull/16598#issuecomment-886655820 ## CI report: * 65f256e785b3ac499d38eee63d177f6a6059b609 Azure:

[jira] [Updated] (FLINK-23323) HAQueryableStateRocksDBBackendITCase failed due to heap OOM

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

[jira] [Updated] (FLINK-9389) Improve error message when cancelling job in state canceled via REST API

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

[GitHub] [flink] flinkbot edited a comment on pull request #16662: [hotfix][connector][jdbc] Corrected exception variable name

flinkbot edited a comment on pull request #16662: URL: https://github.com/apache/flink/pull/16662#issuecomment-890591363 ## CI report: * 91e19b0ae0c150ca6e4f00cc3e67bf4df8718f92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

flinkbot edited a comment on pull request #16598: URL: https://github.com/apache/flink/pull/16598#issuecomment-886655820 ## CI report: * 65f256e785b3ac499d38eee63d177f6a6059b609 Azure:

[GitHub] [flink] flinkbot commented on pull request #16662: [hotfix][connector][jdbc] Corrected exception variable name

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

[GitHub] [flink] brachi-wernick commented on a change in pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

brachi-wernick commented on a change in pull request #16598: URL: https://github.com/apache/flink/pull/16598#discussion_r680569542 ## File path:

[GitHub] [flink] flinkbot commented on pull request #16662: [hotfix][connector][jdbc] Corrected exception variable name

flinkbot commented on pull request #16662: URL: https://github.com/apache/flink/pull/16662#issuecomment-890589029 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] mans2singh opened a new pull request #16662: [hotfix][connector][jdbc] Corrected exception variable name

mans2singh opened a new pull request #16662: URL: https://github.com/apache/flink/pull/16662 ## What is the purpose of the change * Corrected exception variable name ## Brief change log * Corrected variable name ## Verifying this change This change is a

[GitHub] [flink] Airblader commented on a change in pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

Airblader commented on a change in pull request #16598: URL: https://github.com/apache/flink/pull/16598#discussion_r680563823 ## File path: flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/table/PubSubTableSourceFactory.java

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * aba5c1f4d84b5ca8dc28b7057dbd092c87c9d932 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16661: Revert "[FLINK-22054][dist] Suppress the verbose log in kubernetes in…

flinkbot edited a comment on pull request #16661: URL: https://github.com/apache/flink/pull/16661#issuecomment-890515153 ## CI report: * bbc707a8804f2bd65d0747db61a466f9bb15d5ee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * ef821b8e200eefad94af21a530408c7bb59f915c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * ef821b8e200eefad94af21a530408c7bb59f915c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16661: Revert "[FLINK-22054][dist] Suppress the verbose log in kubernetes in…

flinkbot edited a comment on pull request #16661: URL: https://github.com/apache/flink/pull/16661#issuecomment-890515153 ## CI report: * bbc707a8804f2bd65d0747db61a466f9bb15d5ee Azure:

  1   2   >