[GitHub] [flink] twalthr closed pull request #18370: [hotfix][table-common] Introduce ObjectIdentifier.ofAnonymous to allow storing anonymous, but still uniquely identified, names in ObjectIdentifier

twalthr closed pull request #18370: URL: https://github.com/apache/flink/pull/18370 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 3faae958e3d607e85dced19c9483891e7dc

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18349: [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

slinkydeveloper commented on a change in pull request #18349: URL: https://github.com/apache/flink/pull/18349#discussion_r785793354 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SourceQueryOperation.java ## @@ -19,40 +19,45 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

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

[jira] [Updated] (FLINK-25664) Notify will be not triggered for PipelinedSubpartition if more than one buffer is added during isBlocked == true

[ https://issues.apache.org/jira/browse/FLINK-25664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25664: --- Labels: pull-request-available (was: ) > Notify will be not triggered for PipelinedSubparti

[jira] [Commented] (FLINK-25674) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477074#comment-17477074 ] Etienne Chauchot commented on FLINK-25674: -- ouch, bad news ! [~trohrmann] thank

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18349: [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

slinkydeveloper commented on a change in pull request #18349: URL: https://github.com/apache/flink/pull/18349#discussion_r785791932 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SinkModifyOperation.java ## @@ -84,7 +90,7 @@ publ

[GitHub] [flink] LoveHeat opened a new pull request #18377: [FLINK-25664][runtime] Notify will be not triggered for PipelinedSubpartition if more than one buffer is added during isBlocked == true

LoveHeat opened a new pull request #18377: URL: https://github.com/apache/flink/pull/18377 ## What is the purpose of the change Fix notify lost for pipelinedSubpartition if more than one buffer is added during isBlocked == true see jira [FLINK-25664](https://issues.apa

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477072#comment-17477072 ] Zhu Zhu commented on FLINK-25649: - >From your description, it's possible that your clust

[jira] [Commented] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

[ https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477073#comment-17477073 ] Jark Wu commented on FLINK-25614: - Currently, we only support TIMESTAMP(<=3) as the rowt

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18349: [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

slinkydeveloper commented on a change in pull request #18349: URL: https://github.com/apache/flink/pull/18349#discussion_r785791088 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/ContextResolvedTable.java ## @@ -0,0 +1,152 @@ +/* +

[jira] [Commented] (FLINK-25648) Redundant to querying deployment when creating task manager pod

[ https://issues.apache.org/jira/browse/FLINK-25648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477070#comment-17477070 ] Yuan Huang commented on FLINK-25648: - Yes. I think it will reduce about half of the

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 3faae958e3d607e85dced19c9483891e7dc

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[jira] [Commented] (FLINK-23946) Application mode fails fatally when being shut down

[ https://issues.apache.org/jira/browse/FLINK-23946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477068#comment-17477068 ] David Morávek commented on FLINK-23946: --- I'll still try to do a backport for 1.13,

[GitHub] [flink] dannycranmer commented on a change in pull request #18367: [FLINK-25657][Kinesis] Upgrade com.amazonaws:amazon-kinesis-client dependency from 1.14.1 to 1.14.7

dannycranmer commented on a change in pull request #18367: URL: https://github.com/apache/flink/pull/18367#discussion_r785788247 ## File path: flink-connectors/flink-connector-kinesis/src/main/resources/META-INF/NOTICE ## @@ -6,7 +6,7 @@ The Apache Software Foundation (http://

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

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

[GitHub] [flink] XComp commented on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

XComp commented on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1014322211 FYI: I didn't squash the initial commits, yet. The commits can be reviewed starting from `386d700c` (the first commit having the `[review]` label in its commit message). -- Th

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 3faae958e3d607e85dced19c9483891e7dc

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

tillrohrmann commented on a change in pull request #18083: URL: https://github.com/apache/flink/pull/18083#discussion_r785782146 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java ## @@ -507,9 +530,15 @@ private Configuration

[GitHub] [flink] tillrohrmann commented on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

tillrohrmann commented on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-1014316856 Quick comment because I see a merge commit: The Flink community uses rebasing to have a linear history. -- This is an automated message from the Apache Git Service. To r

[GitHub] [flink] tillrohrmann commented on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

tillrohrmann commented on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-1014316372 You could take a look at `AbstractTaskManagerProcessFailureRecoveryTest`. I think what could work is to start a `StandaloneSessionClusterEntrypoint` that starts a `RM`. Th

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * cc0ef7b3c9f391a389117dc33107cd9f3d77d708 UNKNOWN * 3faae958e3d607e85dced19c9483891e7dc

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477060#comment-17477060 ] Till Rohrmann commented on FLINK-25649: --- Are you configuring non-default slot shar

[GitHub] [flink] flinkbot edited a comment on pull request #18306: [FLINK-25445] No need to create local recovery dirs when disabled loc…

flinkbot edited a comment on pull request #18306: URL: https://github.com/apache/flink/pull/18306#issuecomment-1008234006 ## CI report: * 3efa1bed35ddcfcf74e1de739ebc355e404eb73b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

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

[jira] [Commented] (FLINK-25224) Upgrade the minimal supported hadoop version to 2.8.5

[ https://issues.apache.org/jira/browse/FLINK-25224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477059#comment-17477059 ] Chesnay Schepler commented on FLINK-25224: -- [~trohrmann] Those were already rem

[jira] [Comment Edited] (FLINK-25224) Upgrade the minimal supported hadoop version to 2.8.5

[ https://issues.apache.org/jira/browse/FLINK-25224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477059#comment-17477059 ] Chesnay Schepler edited comment on FLINK-25224 at 1/17/22, 9:25 AM: --

[jira] [Commented] (FLINK-25500) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477057#comment-17477057 ] Till Rohrmann commented on FLINK-25500: --- Test has been disabled in {{1.14}} and {{

[GitHub] [flink] zentol merged pull request #18356: [hotfix][flink-annotations] Add v1.15 as the next Flink version to master

zentol merged pull request #18356: URL: https://github.com/apache/flink/pull/18356 -- 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-unsubscr

[GitHub] [flink] flinkbot edited a comment on pull request #18124: [FLINK-24824][coordination] Use CREATED for WaitingForResources/CreatingEG

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

[GitHub] [flink] flinkbot edited a comment on pull request #18306: [FLINK-25445] No need to create local recovery dirs when disabled loc…

flinkbot edited a comment on pull request #18306: URL: https://github.com/apache/flink/pull/18306#issuecomment-1008234006 ## CI report: * 3efa1bed35ddcfcf74e1de739ebc355e404eb73b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25500) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477056#comment-17477056 ] Till Rohrmann commented on FLINK-25500: --- https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-25500) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25500: -- Affects Version/s: 1.13.5 (was: 1.15.0) > ZooKeeperLeaderElectionIT

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

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

[jira] [Reopened] (FLINK-25500) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-25500: --- > ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange > failed on azure > -

[jira] [Commented] (FLINK-25500) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477055#comment-17477055 ] Till Rohrmann commented on FLINK-25500: --- The test has not been disabled for {{1.13

[jira] [Commented] (FLINK-23946) Application mode fails fatally when being shut down

[ https://issues.apache.org/jira/browse/FLINK-23946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477054#comment-17477054 ] Till Rohrmann commented on FLINK-23946: --- Yes, it is missing backports to {{1.13}}

[jira] [Commented] (FLINK-25635) Using sql client create hive catalog throw exception

[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477053#comment-17477053 ] Ingo Bürk commented on FLINK-25635: --- {quote}When call TableFactoryService.java#L207, i

[GitHub] [flink] flinkbot edited a comment on pull request #18373: [FLINK-20188][BP 1.14][Connectors][Docs][FileSystem] Added documentation for FileSource

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

[GitHub] [flink] flinkbot edited a comment on pull request #18124: [FLINK-24824][coordination] Use CREATED for WaitingForResources/CreatingEG

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

[GitHub] [flink] flinkbot edited a comment on pull request #18322: [FLINK-25589][docs][connectors] Update Chinese version of Elasticsearch connector docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

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

[jira] [Created] (FLINK-25675) UnalignedCheckpointCompatibilityITCase.test hangs on AZP

Till Rohrmann created FLINK-25675: - Summary: UnalignedCheckpointCompatibilityITCase.test hangs on AZP Key: FLINK-25675 URL: https://issues.apache.org/jira/browse/FLINK-25675 Project: Flink Is

[jira] [Comment Edited] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

[ https://issues.apache.org/jira/browse/FLINK-25667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477040#comment-17477040 ] Till Rohrmann edited comment on FLINK-25667 at 1/17/22, 9:10 AM: -

[jira] [Commented] (FLINK-25635) Using sql client create hive catalog throw exception

[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477047#comment-17477047 ] Jing Zhang commented on FLINK-25635: [~airblader]  Thanks a lot for reply. > Are y

[GitHub] [flink] flinkbot edited a comment on pull request #18373: [FLINK-20188][BP 1.14][Connectors][Docs][FileSystem] Added documentation for FileSource

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

[GitHub] [flink] flinkbot edited a comment on pull request #18364: [FLINK-25654][network] Remove the redundant locks in SortMergeResultPartition

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

[GitHub] [flink] flinkbot edited a comment on pull request #18322: [FLINK-25589][docs][connectors] Update Chinese version of Elasticsearch connector docs

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

[jira] [Updated] (FLINK-25635) Using sql client create hive catalog throw exception

[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25635: --- Attachment: screenshot-1.png > Using sql client create hive catalog throw exception > --

[jira] [Updated] (FLINK-25674) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25674: -- Affects Version/s: 1.14.0 (was: 1.15.0) > CassandraConnectorITCase.

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN * 7ab509701de219f77feaa3e1ac44a59dee7a

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

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

[jira] [Created] (FLINK-25674) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP

Till Rohrmann created FLINK-25674: - Summary: CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP Key: FLINK-25674 URL: https://issues.apache.org/jira/browse/FLINK-25674

[jira] [Commented] (FLINK-25674) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477046#comment-17477046 ] Till Rohrmann commented on FLINK-25674: --- [~echauchot], there seems to be another C

[GitHub] [flink] MartijnVisser commented on pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

MartijnVisser commented on pull request #18288: URL: https://github.com/apache/flink/pull/18288#issuecomment-1014291236 > Overall it looks great thanks for doing this effort. I am only wondering if we have any plans to split the documentation between user perspective and developer perspect

[jira] [Updated] (FLINK-24858) TypeSerializer version mismatch during eagerly restore

[ https://issues.apache.org/jira/browse/FLINK-24858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24858: Release Note: This ticket resolves an issue that during state migration between Flink versions th

[GitHub] [flink] mingwayXue commented on pull request #18362: [hotfix][Apache Kafka Connector][docs] Fixed kafka.md sink example error

mingwayXue commented on pull request #18362: URL: https://github.com/apache/flink/pull/18362#issuecomment-1014288785 @MartijnVisser Hi, MartijnVisser. Could you help to confirm this document fix? Chinese documentation is not contain this same code. -- This is an automated message from th

[jira] [Closed] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

[ https://issues.apache.org/jira/browse/FLINK-25667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25667. Fix Version/s: 1.15.0 Resolution: Fixed master: 556ef5ddc4ff0306e8b43cbd30865c148b8

[GitHub] [flink] JingGe commented on pull request #18322: [FLINK-25589][docs][connectors] Update Chinese version of Elasticsearch connector docs

JingGe commented on pull request #18322: URL: https://github.com/apache/flink/pull/18322#issuecomment-1014288944 @flinkbot run azure -- 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

[jira] [Updated] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

[ https://issues.apache.org/jira/browse/FLINK-25667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25667: - Issue Type: Technical Debt (was: Bug) > AdaptiveSchedulerTest.testStatusMetrics is not

[GitHub] [flink] flinkbot edited a comment on pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

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

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN * 7ab509701de219f77feaa3e1ac44a59dee7a

[jira] [Commented] (FLINK-25224) Upgrade the minimal supported hadoop version to 2.8.5

[ https://issues.apache.org/jira/browse/FLINK-25224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477042#comment-17477042 ] Till Rohrmann commented on FLINK-25224: --- Once we have dropped the lower Hadoop ver

[GitHub] [flink] akalash commented on a change in pull request #18332: [FLINK-25427] Fix SavepointITCase.testTriggerSavepointAndResumeWithNo…

akalash commented on a change in pull request #18332: URL: https://github.com/apache/flink/pull/18332#discussion_r785754167 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java ## @@ -431,36 +430,48 @@ public void invoke(Long value)

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477041#comment-17477041 ] Till Rohrmann commented on FLINK-24119: --- Another instance for the {{KafkaITCase.te

[jira] [Updated] (FLINK-25635) Using sql client create hive catalog throw exception

[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25635: --- Attachment: image-2022-01-17-17-00-41-223.png > Using sql client create hive catalog throw exception

[jira] [Updated] (FLINK-25635) Using sql client create hive catalog throw exception

[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25635: --- Attachment: image-2022-01-17-17-00-18-160.png > Using sql client create hive catalog throw exception

[jira] [Updated] (FLINK-25635) Using sql client create hive catalog throw exception

[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25635: --- Attachment: image-2022-01-17-16-59-25-147.png > Using sql client create hive catalog throw exception

[jira] [Updated] (FLINK-25673) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25673: -- Fix Version/s: (was: 1.15.0) > AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSav

[GitHub] [flink] flinkbot edited a comment on pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

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

[GitHub] [flink] flinkbot edited a comment on pull request #18196: [FLINK-24270][checkpoint] Refactor the tests related to the VertexFinishedStateChecker

flinkbot edited a comment on pull request #18196: URL: https://github.com/apache/flink/pull/18196#issuecomment-1000619056 ## CI report: * 2af5225d59633854c7a5ed23cddf913d88c73b75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN * 7ab509701de219f77feaa3e1ac44a59dee7a

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

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

[jira] [Created] (FLINK-25673) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP

Till Rohrmann created FLINK-25673: - Summary: AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP Key: FLINK-25673 URL: https://issues.apache.org/jira/browse/FLINK-25673

[jira] [Closed] (FLINK-25671) npm ci failed with code EPROTO when downloading stylelint-config-prettier-8.0.2.tgz

[ https://issues.apache.org/jira/browse/FLINK-25671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25671. Resolution: Invalid This was from a testing branch of mine. > npm ci failed with code EPR

[jira] [Assigned] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

[ https://issues.apache.org/jira/browse/FLINK-25667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-25667: Assignee: Chesnay Schepler > AdaptiveSchedulerTest.testStatusMetrics is not stabl

[GitHub] [flink] flinkbot edited a comment on pull request #18196: [FLINK-24270][checkpoint] Refactor the tests related to the VertexFinishedStateChecker

flinkbot edited a comment on pull request #18196: URL: https://github.com/apache/flink/pull/18196#issuecomment-1000619056 ## CI report: * 2af5225d59633854c7a5ed23cddf913d88c73b75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN * 7ab509701de219f77feaa3e1ac44a59dee7a

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

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

[GitHub] [flink] MartijnVisser commented on a change in pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

MartijnVisser commented on a change in pull request #18288: URL: https://github.com/apache/flink/pull/18288#discussion_r785749360 ## File path: docs/content/docs/connectors/datastream/filesystem.md ## @@ -25,12 +27,243 @@ specific language governing permissions and limitations

[jira] [Created] (FLINK-25672) FileSource enumerator remembers paths of all already processed files which can result in large state

Martijn Visser created FLINK-25672: -- Summary: FileSource enumerator remembers paths of all already processed files which can result in large state Key: FLINK-25672 URL: https://issues.apache.org/jira/browse/FLINK

[GitHub] [flink] flinkbot edited a comment on pull request #18368: [FLINK-18356][Azure] Enforce memory limits for docker containers

flinkbot edited a comment on pull request #18368: URL: https://github.com/apache/flink/pull/18368#issuecomment-1013194055 ## CI report: * 85f29ae74ca544e58ec6c46ba2bad95e0abf861e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN * 7ab509701de219f77feaa3e1ac44a59dee7a

[GitHub] [flink] flinkbot edited a comment on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

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

[GitHub] [flink] MartijnVisser commented on a change in pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

MartijnVisser commented on a change in pull request #18288: URL: https://github.com/apache/flink/pull/18288#discussion_r785742437 ## File path: docs/content/docs/connectors/datastream/filesystem.md ## @@ -25,12 +27,243 @@ specific language governing permissions and limitations

[GitHub] [flink] MartijnVisser commented on a change in pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

MartijnVisser commented on a change in pull request #18288: URL: https://github.com/apache/flink/pull/18288#discussion_r785741849 ## File path: docs/content/docs/connectors/datastream/filesystem.md ## @@ -25,12 +27,243 @@ specific language governing permissions and limitations

[GitHub] [flink] flinkbot edited a comment on pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

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

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN * 7ab509701de219f77feaa3e1ac44a59dee7a

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

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

[jira] [Commented] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477033#comment-17477033 ] Yun Gao commented on FLINK-25374: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477031#comment-17477031 ] Gil De Grove commented on FLINK-25649: -- Hello [~zhuzh] , To add to this issue: 1

[GitHub] [flink] MartijnVisser commented on a change in pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

MartijnVisser commented on a change in pull request #18288: URL: https://github.com/apache/flink/pull/18288#discussion_r785739924 ## File path: docs/content/docs/connectors/datastream/filesystem.md ## @@ -25,12 +27,243 @@ specific language governing permissions and limitations

[GitHub] [flink] flinkbot commented on pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

flinkbot commented on pull request #18376: URL: https://github.com/apache/flink/pull/18376#issuecomment-1014267921 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 pr

[GitHub] [flink] metaswirl commented on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

metaswirl commented on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-1014267066 > Thanks for updating this PR @metaswirl. Concerning the test I was more thinking about a test where we kill a TM process via `SIGTERM` and check that it shuts down (e.g. der

[jira] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

[ https://issues.apache.org/jira/browse/FLINK-23956 ] Yun Gao deleted comment on FLINK-23956: - was (Author: gaoyunhaii): https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=29443&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=

[GitHub] [flink] MartijnVisser commented on a change in pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

MartijnVisser commented on a change in pull request #18288: URL: https://github.com/apache/flink/pull/18288#discussion_r785738308 ## File path: docs/content/docs/connectors/datastream/filesystem.md ## @@ -25,12 +27,243 @@ specific language governing permissions and limitations

<    1   2   3   4   5   6   7   >