[jira] [Updated] (FLINK-16206) Support JSON_ARRAYAGG

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

[jira] [Updated] (FLINK-23349) GroupWindowITCase JVM crash on azure

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

[jira] [Updated] (FLINK-18822) [umbrella] Improve and complete Change Data Capture formats

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

[jira] [Updated] (FLINK-22739) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException

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

[GitHub] [flink] flinkbot edited a comment on pull request #17322: [FLINK-24336][python] Fix the issue that jar url may be a empty string.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17322: [FLINK-24336][python] Fix the issue that jar url may be a empty string.

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

[GitHub] [flink] flinkbot commented on pull request #17322: [FLINK-24336][python] Fix the issue that jar url may be a empty string.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17321: [FLINK-24315][k8s] Throw exception in failing watching pods

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

[jira] [Resolved] (FLINK-24277) Offset commit should be disabled if consumer group ID is not specified in KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-24277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-24277. -- Fix Version/s: 1.13.3 1.12.6 Assignee: Qingsheng Ren Resolut

[GitHub] [flink] flinkbot commented on pull request #17322: [FLINK-24336][python] Fix the issue that jar url may be a empty string.

flinkbot commented on pull request #17322: URL: https://github.com/apache/flink/pull/17322#issuecomment-922279880 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24336: --- Labels: pull-request-available (was: ) > PyFlink TableEnvironment executes the SQL randomly

[GitHub] [flink] is opened a new pull request #17322: [FLINK-24336][python] Fix the issue that jar url may be a empty string.

is opened a new pull request #17322: URL: https://github.com/apache/flink/pull/17322 ## What is the purpose of the change Fix FLINK-24336, avoid empty string be inserted into classpaths, resolve randomly MalformedURLException when PyFlink TableEnvironment executes the SQL.

[GitHub] [flink] becketqin merged pull request #17307: [BP-1.12][FLINK-24277][connector/kafka] Add configuration for committing offset on checkpoint and disable it if group ID is not specified

becketqin merged pull request #17307: URL: https://github.com/apache/flink/pull/17307 -- 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. To unsubscribe, e-mail: issues-unsub

[GitHub] [flink] becketqin merged pull request #17306: [BP-1.13][FLINK-24277][connector/kafka] Add configuration for committing offset on checkpoint and disable it if group ID is not specified

becketqin merged pull request #17306: URL: https://github.com/apache/flink/pull/17306 -- 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. To unsubscribe, e-mail: issues-unsub

[GitHub] [flink] flinkbot edited a comment on pull request #17319: [FLINK-24329][connector/pulsar] Fix PulsarSourceITCase fails due to port conflict

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

[GitHub] [flink] flinkbot edited a comment on pull request #17320: [FLINK-24319][Tests] Fix invalid surefire work directory for flink-tests

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

[GitHub] [flink] flinkbot edited a comment on pull request #17318: [hotfix][tests] Azure tests fail prematurely because timeout watchdog fails to sleep

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

[jira] [Assigned] (FLINK-16504) Add a AWS DynamoDB sink

[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-16504: -- Assignee: Yuri Gusev > Add a AWS DynamoDB sink > --- > >

[jira] [Updated] (FLINK-16504) Add a AWS DynamoDB sink

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

[jira] [Commented] (FLINK-15816) Limit the maximum length of the value of kubernetes.cluster-id configuration option

[ https://issues.apache.org/jira/browse/FLINK-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417129#comment-17417129 ] Robert Metzger commented on FLINK-15816: Oh, you are right! I misread the error

[GitHub] [flink] flinkbot edited a comment on pull request #17321: [FLINK-24315][k8s] Throw exception in failing watching pods

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

[jira] [Assigned] (FLINK-23559) Enable periodic materialisation in tests

[ https://issues.apache.org/jira/browse/FLINK-23559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-23559: - Assignee: (was: Roman Khachatryan) > Enable periodic materialisation in tes

[jira] [Resolved] (FLINK-22944) Optimize writing state changes

[ https://issues.apache.org/jira/browse/FLINK-22944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-22944. --- Resolution: Fixed Merged into master as  032f467edb825e18bdd08f51af26cb8bb3e87ad4..b

[jira] [Closed] (FLINK-22944) Optimize writing state changes

[ https://issues.apache.org/jira/browse/FLINK-22944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-22944. - > Optimize writing state changes > -- > > Key: F

[GitHub] [flink] rkhachatryan merged pull request #17203: [FLINK-22944][state] Optimize writing state changelog

rkhachatryan merged pull request #17203: URL: https://github.com/apache/flink/pull/17203 -- 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. To unsubscribe, e-mail: issues-un

[GitHub] [flink] flinkbot commented on pull request #17321: [FLINK-24315][k8s] Throw exception in failing watching pods

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

[jira] [Commented] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417115#comment-17417115 ] Yun Tang commented on FLINK-23949: -- merged in release-1.12: b84223034a55a16df4d977f5be1

[GitHub] [flink] flinkbot commented on pull request #17321: [FLINK-24315][k8s] Throw exception in failing watching pods

flinkbot commented on pull request #17321: URL: https://github.com/apache/flink/pull/17321#issuecomment-922255806 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] Myasuka merged pull request #17233: FLINK-23949 adapt to Flink1.12

Myasuka merged pull request #17233: URL: https://github.com/apache/flink/pull/17233 -- 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. To unsubscribe, e-mail: issues-unsubsc

[jira] [Closed] (FLINK-16088) Translate "Query Configuration" page of "Streaming Concepts" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16088. --- Resolution: Invalid > Translate "Query Configuration" page of "Streaming Concepts" into Chinese > -

[jira] [Commented] (FLINK-16088) Translate "Query Configuration" page of "Streaming Concepts" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417112#comment-17417112 ] Jark Wu commented on FLINK-16088: - [~monster#12], sorry, this page can be removed after

[jira] [Updated] (FLINK-24315) Cannot rebuild watcher thread while the K8S API server is unavailable

[ https://issues.apache.org/jira/browse/FLINK-24315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24315: --- Labels: pull-request-available (was: ) > Cannot rebuild watcher thread while the K8S API se

[GitHub] [flink] KarmaGYZ opened a new pull request #17321: [FLINK-24315][k8s] Throw exception in failing watching pods

KarmaGYZ opened a new pull request #17321: URL: https://github.com/apache/flink/pull/17321 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[GitHub] [flink] flinkbot edited a comment on pull request #17318: [hotfix][tests] Azure tests fail prematurely because timeout watchdog fails to sleep

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

[GitHub] [flink] flinkbot edited a comment on pull request #17319: [FLINK-24329][connector/pulsar] Fix PulsarSourceITCase fails due to port conflict

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

[GitHub] [flink] flinkbot edited a comment on pull request #17320: [FLINK-24319][Tests] Fix invalid surefire work directory for flink-tests

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

[GitHub] [flink] flinkbot commented on pull request #17319: [FLINK-24329][connector/pulsar] Fix PulsarSourceITCase fails due to port conflict

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

[GitHub] [flink] flinkbot commented on pull request #17320: [FLINK-24319][Tests] Fix invalid surefire work directory for flink-tests

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

[GitHub] [flink] flinkbot commented on pull request #17318: [hotfix][tests] Azure tests fail prematurely because timeout watchdog fails to sleep

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

[GitHub] [flink] zicat commented on a change in pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

zicat commented on a change in pull request #14916: URL: https://github.com/apache/flink/pull/14916#discussion_r711489339 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalCorrelateToJoinFromTemporalTableFunctionRule.

[GitHub] [flink] flinkbot commented on pull request #17320: [FLINK-24319][Tests] Fix invalid surefire work directory for flink-tests

flinkbot commented on pull request #17320: URL: https://github.com/apache/flink/pull/17320#issuecomment-922245796 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-24336) PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417100#comment-17417100 ] Dian Fu commented on FLINK-24336: - [~is] Thanks, have assigned it to you~ > PyFlink Tab

[jira] [Assigned] (FLINK-24336) PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-24336: --- Assignee: Xin Yu > PyFlink TableEnvironment executes the SQL randomly MalformedURLException with >

[jira] [Commented] (FLINK-24336) PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417099#comment-17417099 ] Xin Yu commented on FLINK-24336: i will submit a PR ASAP. > PyFlink TableEnvironment ex

[jira] [Updated] (FLINK-24319) Jar not found in ClassLoaderITCase

[ https://issues.apache.org/jira/browse/FLINK-24319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24319: --- Labels: pull-request-available (was: ) > Jar not found in ClassLoaderITCase > -

[GitHub] [flink] link3280 opened a new pull request #17320: [FLINK-24319][Tests] Fix invalid surefire work directory for flink-tests

link3280 opened a new pull request #17320: URL: https://github.com/apache/flink/pull/17320 ## What is the purpose of the change Commit https://github.com/apache/flink/commit/7aa510c9e5dad2f0d2bcdcf1abc6b4f9e0374470#diff-9c5fb3d1b7e3b0f54bc5c4182965c4fe1f9023d449017cece3005d3f90e8e4d8

[jira] [Closed] (FLINK-24335) Get java.net.MalformedURLException when submit job from python by pyflink table api.

[ https://issues.apache.org/jira/browse/FLINK-24335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang closed FLINK-24335. -- Resolution: Duplicate > Get java.net.MalformedURLException when submit job from python by pyfl

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24336: --- Description: When I run flink client to submit a python based workflow, I got the Malformed

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24336: --- Summary: PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the c

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment execute SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24336: --- Affects Version/s: 1.14.1 1.14.0 1.13.2 > PyFl

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment execute SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24336: --- Component/s: API / Python > PyFlink TableEnvironment execute SQL randomly MalformedURLExcept

[jira] [Updated] (FLINK-24335) Get java.net.MalformedURLException when submit job from python by pyflink table api.

[ https://issues.apache.org/jira/browse/FLINK-24335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Yu updated FLINK-24335: --- Description: When I run flink client to submit a python based workflow, I got the  MalformedURLException lik

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment execute SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24336: --- Summary: PyFlink TableEnvironment execute SQL randomly MalformedURLException with the config

[jira] [Created] (FLINK-24336) PyFlink

Nicholas Jiang created FLINK-24336: -- Summary: PyFlink Key: FLINK-24336 URL: https://issues.apache.org/jira/browse/FLINK-24336 Project: Flink Issue Type: Bug Reporter: Nicholas Ji

[jira] [Created] (FLINK-24335) Get java.net.MalformedURLException when submit job from python by pyflink table api.

Xin Yu created FLINK-24335: -- Summary: Get java.net.MalformedURLException when submit job from python by pyflink table api. Key: FLINK-24335 URL: https://issues.apache.org/jira/browse/FLINK-24335 Project: Fli

[GitHub] [flink] flinkbot commented on pull request #17319: [FLINK-24329][connector/pulsar] Fix PulsarSourceITCase fails due to port conflict

flinkbot commented on pull request #17319: URL: https://github.com/apache/flink/pull/17319#issuecomment-922243751 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

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

[jira] [Commented] (FLINK-15816) Limit the maximum length of the value of kubernetes.cluster-id configuration option

[ https://issues.apache.org/jira/browse/FLINK-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417096#comment-17417096 ] Yang Wang commented on FLINK-15816: --- [~rmetzger] Thanks for sharing your concerns. But

[jira] [Updated] (FLINK-24329) PulsarSourceITCase fails due to port conflict

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

[GitHub] [flink] xmarker opened a new pull request #17319: [FLINK-24329][connector/pulsar] Fix PulsarSourceITCase fails due to port conflict

xmarker opened a new pull request #17319: URL: https://github.com/apache/flink/pull/17319 ## What is the purpose of the change *Fix PulsarSourceITCase fails due to port conflict* ## Brief change log - *PulsarMockRuntime use runtime dynamic port*

[GitHub] [flink] flinkbot commented on pull request #17318: [hotfix][tests] Fix command not found error in azure watchdog script

flinkbot commented on pull request #17318: URL: https://github.com/apache/flink/pull/17318#issuecomment-922243179 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] link3280 opened a new pull request #17318: [hotfix][tests] Fix command not found error in azure watchdog script

link3280 opened a new pull request #17318: URL: https://github.com/apache/flink/pull/17318 ## What is the purpose of the change The `secondsToKill` variable is executed as a command by mistake, which makes e2e tests fail if the build takes too long. ## Brief change log

[jira] [Commented] (FLINK-24329) PulsarSourceITCase fails due to port conflict

[ https://issues.apache.org/jira/browse/FLINK-24329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417085#comment-17417085 ] xmarker commented on FLINK-24329: - I can help fix the issue,maybe we should use dynamic

[jira] [Created] (FLINK-24334) Configuration kubernetes.flink.log.dir not working

Yang Wang created FLINK-24334: - Summary: Configuration kubernetes.flink.log.dir not working Key: FLINK-24334 URL: https://issues.apache.org/jira/browse/FLINK-24334 Project: Flink Issue Type: Bug

[GitHub] [flink] zhouaoe commented on pull request #7798: [FLINK-11388][fs] Add Aliyun OSS recoverable writer

zhouaoe commented on pull request #7798: URL: https://github.com/apache/flink/pull/7798#issuecomment-922237555 ”flink-oss-fs-hadoop-XXX.jar“ built from source code can‘t support streaming file sink. It 's a common error when Flink users use FileSink/StreamingFileSink to upload objet

[GitHub] [flink] flinkbot edited a comment on pull request #17233: FLINK-23949 adapt to Flink1.12

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

[GitHub] [flink] xuyangzhong commented on a change in pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

xuyangzhong commented on a change in pull request #17308: URL: https://github.com/apache/flink/pull/17308#discussion_r711525214 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/FileSystemITCaseBase.scala ## @@ -95,6 +95,60 @@