[jira] [Created] (FLINK-26176) Scala savepoint migration tests don't run as configured (not testing RocksDB savepoints)

Sebastian Mattheis created FLINK-26176: -- Summary: Scala savepoint migration tests don't run as configured (not testing RocksDB savepoints) Key: FLINK-26176 URL: https://issues.apache.org/jira/browse/FLINK-261

[GitHub] [flink-statefun-playground] tillrohrmann closed pull request #25: [FLINK-26155] Add Playground ingress/egress that allows to ingest and consume messages via curl

tillrohrmann closed pull request #25: URL: https://github.com/apache/flink-statefun-playground/pull/25 -- 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-m

[jira] [Updated] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26177: -- Component/s: Connectors / Pulsar > PulsarSourceITCase.testScaleDown fails with timeout > -

[jira] [Comment Edited] (FLINK-25290) Add table source and sink test suite in connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493045#comment-17493045 ] Hang Ruan edited comment on FLINK-25290 at 2/16/22, 8:00 AM: -

[jira] [Created] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout

Matthias Pohl created FLINK-26177: - Summary: PulsarSourceITCase.testScaleDown fails with timeout Key: FLINK-26177 URL: https://issues.apache.org/jira/browse/FLINK-26177 Project: Flink Issue T

[jira] [Updated] (FLINK-26176) Scala savepoint migration tests don't run as configured (not testing RocksDB savepoints)

[ https://issues.apache.org/jira/browse/FLINK-26176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Mattheis updated FLINK-26176: --- Description: The following Scala integration test cases in flink-tests: * flink-te

[jira] [Closed] (FLINK-26155) Add playground ingress/egress for curl interaction

[ https://issues.apache.org/jira/browse/FLINK-26155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26155. - Fix Version/s: statefun-3.3.0 statefun-3.2.1 Resolution: Fixed Fixed v

[jira] [Updated] (FLINK-26176) Scala savepoint migration tests don't run as configured (not testing RocksDB savepoints)

[ https://issues.apache.org/jira/browse/FLINK-26176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Mattheis updated FLINK-26176: --- Priority: Minor (was: Major) > Scala savepoint migration tests don't run as configu

[GitHub] [flink] flinkbot edited a comment on pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

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

[GitHub] [flink-statefun-playground] tillrohrmann commented on pull request #26: [FLINK-26158] Update the playground examples to use the playground ingress/egress

tillrohrmann commented on pull request #26: URL: https://github.com/apache/flink-statefun-playground/pull/26#issuecomment-1041217623 Merging this PR now. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18778: [FLINK-26150][connector/pulsar] enable requestTimeoutMs configuration.

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

[GitHub] [flink] fapaul opened a new pull request #18795: [FLINK-26174][kinesis] Add Internal annotation to KinesisDataStreamsSink#restore

fapaul opened a new pull request #18795: URL: https://github.com/apache/flink/pull/18795 ## What is the purpose of the change Add Internal annotation to KinesisDataStreamsSink#restore to fix the arch unit violations. The method returns an internal aws sdk object and therefore

[jira] [Updated] (FLINK-26174) KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation

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

[GitHub] [flink] gaborgsomogyi opened a new pull request #18796: [FLINK-26166][runtime-web] Add auto newline detection to prettier formatter

gaborgsomogyi opened a new pull request #18796: URL: https://github.com/apache/flink/pull/18796 ## What is the purpose of the change Normally I'm developing on linux based system but sometimes reviewing on Windows based machines. Compile blows up in the following way: ``` [INFO

[jira] [Updated] (FLINK-26166) flink-runtime-web fails to compile if newline is cr lf

[ https://issues.apache.org/jira/browse/FLINK-26166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26166: --- Labels: pull-request-available (was: ) > flink-runtime-web fails to compile if newline is c

[GitHub] [flink] flinkbot edited a comment on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

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

[GitHub] [flink] flinkbot commented on pull request #18795: [FLINK-26174][kinesis] Add Internal annotation to KinesisDataStreamsSink#restore

flinkbot commented on pull request #18795: URL: https://github.com/apache/flink/pull/18795#issuecomment-1041223968 ## CI report: * 56e5c3cf71abe9e7d035eb89eec3dbf99bf3e281 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18796: [FLINK-26166][runtime-web] Add auto newline detection to prettier formatter

flinkbot commented on pull request #18796: URL: https://github.com/apache/flink/pull/18796#issuecomment-1041224101 ## CI report: * 39c86af3f4ab34c03537f845a90a4f3f78e0b835 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18796: [FLINK-26166][runtime-web] Add auto newline detection to prettier formatter

flinkbot commented on pull request #18796: URL: https://github.com/apache/flink/pull/18796#issuecomment-1041224632 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] flinkbot commented on pull request #18795: [FLINK-26174][kinesis] Add Internal annotation to KinesisDataStreamsSink#restore

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

[jira] [Assigned] (FLINK-26142) Integrate flink-kubernetes-operator repo with CI/CD

[ https://issues.apache.org/jira/browse/FLINK-26142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26142: -- Assignee: Yang Wang > Integrate flink-kubernetes-operator repo with CI/CD > -

[GitHub] [flink-statefun-playground] tillrohrmann merged pull request #26: [FLINK-26158] Update the playground examples to use the playground ingress/egress

tillrohrmann merged pull request #26: URL: https://github.com/apache/flink-statefun-playground/pull/26 -- 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-m

[jira] [Created] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

Gyula Fora created FLINK-26178: -- Summary: Use the same enum for expected and observed jobstate (JobState / JobStatus.state) Key: FLINK-26178 URL: https://issues.apache.org/jira/browse/FLINK-26178 Project

[jira] [Created] (FLINK-26179) Support periodic savepointing in the operator

Gyula Fora created FLINK-26179: -- Summary: Support periodic savepointing in the operator Key: FLINK-26179 URL: https://issues.apache.org/jira/browse/FLINK-26179 Project: Flink Issue Type: Sub-tas

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

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

[GitHub] [flink] gaoyunhaii commented on pull request #18795: [FLINK-26174][kinesis] Add Internal annotation to KinesisDataStreamsSink#restore

gaoyunhaii commented on pull request #18795: URL: https://github.com/apache/flink/pull/18795#issuecomment-1041229079 I'll directly merge this PR since currently the CI pipeline is busy before code freeze and the fix should be not large. -- This is an automated message from the Apache Gi

[GitHub] [flink] flinkbot edited a comment on pull request #18766: [FLINK-25490][checkpoint] Complete the Chinese document regarding final checkpoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #18795: [FLINK-26174][kinesis] Add Internal annotation to KinesisDataStreamsSink#restore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18796: [FLINK-26166][runtime-web] Add auto newline detection to prettier formatter

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

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18363: [FLINK-25600][table-planner] Support new statement set syntax in sql client and update docs

slinkydeveloper commented on a change in pull request #18363: URL: https://github.com/apache/flink/pull/18363#discussion_r807633757 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/delegation/Parser.java ## @@ -44,7 +45,7 @@ * * @

[jira] [Closed] (FLINK-26158) Update statefun-playground examples to use playground ingress/egress

[ https://issues.apache.org/jira/browse/FLINK-26158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26158. - Fix Version/s: statefun-3.3.0 statefun-3.2.1 Resolution: Fixed Fixed v

[GitHub] [flink] gaoyunhaii closed pull request #18795: [FLINK-26174][kinesis] Add Internal annotation to KinesisDataStreamsSink#restore

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

[jira] [Created] (FLINK-26180) Update docs to introduce the compaction for FileSink

Gen Luo created FLINK-26180: --- Summary: Update docs to introduce the compaction for FileSink Key: FLINK-26180 URL: https://issues.apache.org/jira/browse/FLINK-26180 Project: Flink Issue Type: Sub-ta

[jira] [Commented] (FLINK-26174) KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation

[ https://issues.apache.org/jira/browse/FLINK-26174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493061#comment-17493061 ] Yun Gao commented on FLINK-26174: - Merged on master via 70ee694c62d6762de4a909988c6399bf

[jira] [Updated] (FLINK-26180) Update docs to introduce the compaction for FileSink

[ https://issues.apache.org/jira/browse/FLINK-26180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26180: Affects Version/s: 1.15.0 > Update docs to introduce the compaction for FileSink > ---

[jira] [Assigned] (FLINK-26180) Update docs to introduce the compaction for FileSink

[ https://issues.apache.org/jira/browse/FLINK-26180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-26180: --- Assignee: Gen Luo > Update docs to introduce the compaction for FileSink >

[GitHub] [flink] gaborgsomogyi commented on pull request #18796: [FLINK-26166][runtime-web] Add auto newline detection to prettier formatter

gaborgsomogyi commented on pull request #18796: URL: https://github.com/apache/flink/pull/18796#issuecomment-1041232393 cc @gyfora @mbalassi -- 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

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18363: [FLINK-25600][table-planner] Support new statement set syntax in sql client and update docs

slinkydeveloper commented on a change in pull request #18363: URL: https://github.com/apache/flink/pull/18363#discussion_r807660282 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlMultiLineParser.java ## @@ -31,18 +37,61 @@ */ p

[jira] [Created] (FLINK-26181) Support manual savepoint triggering in the operator

Gyula Fora created FLINK-26181: -- Summary: Support manual savepoint triggering in the operator Key: FLINK-26181 URL: https://issues.apache.org/jira/browse/FLINK-26181 Project: Flink Issue Type: S

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

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

[GitHub] [flink] flinkbot edited a comment on pull request #18766: [FLINK-25490][checkpoint] Complete the Chinese document regarding final checkpoint

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

[GitHub] [flink] pltbkd opened a new pull request #18797: [FLINK-26180] Update docs to introduce the compaction for FileSink.

pltbkd opened a new pull request #18797: URL: https://github.com/apache/flink/pull/18797 ## What is the purpose of the change This pull request update docs to introduce the compaction for FileSink. ## Brief change log - docs/connectors/datastream/filesystem is updated

[jira] [Updated] (FLINK-26180) Update docs to introduce the compaction for FileSink

[ https://issues.apache.org/jira/browse/FLINK-26180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26180: --- Labels: pull-request-available (was: ) > Update docs to introduce the compaction for FileSi

[GitHub] [flink] flinkbot commented on pull request #18797: [FLINK-26180] Update docs to introduce the compaction for FileSink.

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

[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493062#comment-17493062 ] Dawid Wysakowicz commented on FLINK-26177: -- I see the test (actually {{testScal

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 9b9e4dc96990436cb5684646ed801b84f2357848 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Updated] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26177: - Priority: Blocker (was: Major) > PulsarSourceITCase.testScaleDown fails with timeout >

[GitHub] [flink] flinkbot commented on pull request #18797: [FLINK-26180] Update docs to introduce the compaction for FileSink.

flinkbot commented on pull request #18797: URL: https://github.com/apache/flink/pull/18797#issuecomment-1041240844 ## CI report: * 716d8eb657299bd7243957443128ae3935cb3e31 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

[ https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493063#comment-17493063 ] Chesnay Schepler commented on FLINK-26178: -- Side question: Can we add a dedicat

[jira] [Commented] (FLINK-26166) flink-runtime-web fails to compile if newline is cr lf

[ https://issues.apache.org/jira/browse/FLINK-26166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493064#comment-17493064 ] Chesnay Schepler commented on FLINK-26166: -- I can see where you're coming from

[GitHub] [flink] alpreu commented on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu commented on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-1041244714 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18759: [FLINK-25698][connectors/elasticsearch] Enable logging for Elasticsearch containers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 9b9e4dc96990436cb5684646ed801b84f2357848 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Closed] (FLINK-24629) Sorting start-time/duration/end-time not working under pages of vertex taskManagers and sub-tasks

[ https://issues.apache.org/jira/browse/FLINK-24629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junhan Yang closed FLINK-24629. --- Resolution: Fixed > Sorting start-time/duration/end-time not working under pages of vertex > taskMa

[GitHub] [flink] flinkbot edited a comment on pull request #18797: [FLINK-26180] Update docs to introduce the compaction for FileSink.

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

[GitHub] [flink] XComp merged pull request #18750: [FLINK-25973][FLINK-25978][FLINK-26017] Applies minor code changes that didn't make it in any of the other JRS-related PRS

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

[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493070#comment-17493070 ] Roman Khachatryan commented on FLINK-26177: --- [https://dev.azure.com/khachatrya

[jira] [Resolved] (FLINK-26017) Add debug log message when marking a job result as dirty

[ https://issues.apache.org/jira/browse/FLINK-26017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26017. --- Fix Version/s: 1.15.0 Resolution: Fixed master: [540d876946d42619cdc2c5be31c9f6f5b76

[jira] [Resolved] (FLINK-25973) Rename ArchivedExecutionGraph.createFromInitializingJob into more generic createSparseArchivedExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-25973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-25973. --- Fix Version/s: 1.15.0 Resolution: Fixed master: [5575c9ad29623745875ef2fea4cc86a9361

[jira] [Resolved] (FLINK-25978) DispatcherTest.testJobDataAreCleanedUpInCorrectOrderOn*Job can be removed

[ https://issues.apache.org/jira/browse/FLINK-25978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-25978. --- Fix Version/s: 1.15.0 Resolution: Fixed master: [f1e7d12bd91b1439a23c1faecb1c74911af

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

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

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 9b9e4dc96990436cb5684646ed801b84f2357848 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18772: [FLINK-25992][Runtime/Coordination, Tests] For stability, wait until the latest restored checkpoint is not null to avoid race condit

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

[GitHub] [flink] zentol merged pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

zentol merged pull request #18761: URL: https://github.com/apache/flink/pull/18761 -- 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] XComp merged pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

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

[jira] [Closed] (FLINK-26107) CoordinatorEventsExactlyOnceITCase.test failed on azure

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

[jira] [Resolved] (FLINK-26117) JobManagerMetricGroup needs to implement GloballyCleanableResource as well

[ https://issues.apache.org/jira/browse/FLINK-26117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26117. --- Fix Version/s: 1.15.0 Resolution: Fixed master: * [5b06297c9d27e57de7d96999615f6c7b

[jira] [Reopened] (FLINK-20200) SQL Hints are not supported in "Create View" syntax

[ https://issues.apache.org/jira/browse/FLINK-20200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reopened FLINK-20200: Assignee: godfrey he (was: Danny Chen) > SQL Hints are not supported in "Create View" syntax >

[GitHub] [flink] rkhachatryan opened a new pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

rkhachatryan opened a new pull request #18798: URL: https://github.com/apache/flink/pull/18798 ## What is the purpose of the change Temporarily disable scale up/down tests to unblock CI. ## Verifying this change This change is a trivial rework without any test coverage.

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

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

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [FLINK-25600][table-planner] Support new statement set syntax in sql client and update docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 9b9e4dc96990436cb5684646ed801b84f2357848 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Updated] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout

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

[jira] [Updated] (FLINK-26026) Unit test for PulsarSink on FLIP-191

[ https://issues.apache.org/jira/browse/FLINK-26026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-26026: Summary: Unit test for PulsarSink on FLIP-191 (was: Test FLIP-191 PulsarSink) > Unit test for Pu

[GitHub] [flink] flinkbot edited a comment on pull request #18771: [FLINK-26119][connectors/common] AsyncSinkWriterStateSerializer to @PublicEvolving

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

[GitHub] [flink] flinkbot edited a comment on pull request #18773: [FLINK-26118][connectors/common] Add support for AsyncSink to downscale with state

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

[jira] [Created] (FLINK-26182) E2E test for PulsarSink on new Flink sink testing tools

Yufan Sheng created FLINK-26182: --- Summary: E2E test for PulsarSink on new Flink sink testing tools Key: FLINK-26182 URL: https://issues.apache.org/jira/browse/FLINK-26182 Project: Flink Issue T

[GitHub] [flink] flinkbot edited a comment on pull request #18782: [FLINK-26148][runtime] Change the format of adaptive batch scheduler config option to jobmanager.adaptive-batch-scheduler.XXX

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

[jira] [Commented] (FLINK-26015) FileSystemJobResultStore fails to access Minio

[ https://issues.apache.org/jira/browse/FLINK-26015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493083#comment-17493083 ] Matthias Pohl commented on FLINK-26015: --- FYI: I created https://github.com/prestod

[GitHub] [flink] flinkbot commented on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

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

[jira] [Created] (FLINK-26183) Support kubernetes-operator metrics using the Flink metric system

Gyula Fora created FLINK-26183: -- Summary: Support kubernetes-operator metrics using the Flink metric system Key: FLINK-26183 URL: https://issues.apache.org/jira/browse/FLINK-26183 Project: Flink

[jira] [Assigned] (FLINK-26182) E2E test for PulsarSink on new Flink sink testing tools

[ https://issues.apache.org/jira/browse/FLINK-26182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-26182: --- Assignee: Yufan Sheng > E2E test for PulsarSink on new Flink sink testing tools > -

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 9b9e4dc96990436cb5684646ed801b84f2357848 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18771: [FLINK-26119][connectors/common] AsyncSinkWriterStateSerializer to @PublicEvolving

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

[GitHub] [flink] flinkbot edited a comment on pull request #18773: [FLINK-26118][connectors/common] Add support for AsyncSink to downscale with state

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

[GitHub] [flink] flinkbot commented on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

flinkbot commented on pull request #18798: URL: https://github.com/apache/flink/pull/18798#issuecomment-1041265347 ## CI report: * 7b3b53570a9ac3f4b7159e7b1bf24eb7d29b2649 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-24474) Standalone clusters should bind to localhost by default

[ https://issues.apache.org/jira/browse/FLINK-24474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493087#comment-17493087 ] Robert Metzger commented on FLINK-24474: Thanks a lot for the fix, this is very

[GitHub] [flink] knaufk commented on a change in pull request #18725: [FLINK-25532] Improve Documentation of Flink Docker-Compose

knaufk commented on a change in pull request #18725: URL: https://github.com/apache/flink/pull/18725#discussion_r807700065 ## File path: docs/content/docs/deployment/resource-providers/standalone/docker.md ## @@ -96,7 +96,6 @@ This allows you to deploy a standalone cluster (Ses

[GitHub] [flink] rmetzger commented on pull request #18746: [FLINK-26162][docs]revamp security pages

rmetzger commented on pull request #18746: URL: https://github.com/apache/flink/pull/18746#issuecomment-1041269302 Since https://issues.apache.org/jira/browse/FLINK-24474, the one thing I wanted to mention in the docs seems to be resolved ;) So in the future https://flink.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 9b9e4dc96990436cb5684646ed801b84f2357848 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

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

[GitHub] [flink] knaufk commented on a change in pull request #18725: [FLINK-25532] Improve Documentation of Flink Docker-Compose

knaufk commented on a change in pull request #18725: URL: https://github.com/apache/flink/pull/18725#discussion_r807701590 ## File path: docs/content/docs/deployment/resource-providers/standalone/docker.md ## @@ -247,68 +246,175 @@ You can see that certain tags include the vers

[GitHub] [flink] knaufk commented on a change in pull request #18725: [FLINK-25532] Improve Documentation of Flink Docker-Compose

knaufk commented on a change in pull request #18725: URL: https://github.com/apache/flink/pull/18725#discussion_r807701936 ## File path: docs/content/docs/deployment/resource-providers/standalone/docker.md ## @@ -247,68 +246,175 @@ You can see that certain tags include the vers

[GitHub] [flink] zhuzhurk closed pull request #18782: [FLINK-26148][runtime] Change the format of adaptive batch scheduler config option to jobmanager.adaptive-batch-scheduler.XXX

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

[jira] [Closed] (FLINK-26148) Change the format of adaptive batch scheduler config option to "jobmanager.adaptive-batch-scheduler.XXX"

[ https://issues.apache.org/jira/browse/FLINK-26148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-26148. --- Resolution: Done master/release-1.15: 4f20772ca2e36358f51d656b78e45a3e966d6f9e > Change the format of adapt

[jira] [Assigned] (FLINK-26174) KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation

[ https://issues.apache.org/jira/browse/FLINK-26174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-26174: --- Assignee: Fabian Paul (was: Jing Ge) > KinesisDataStreamsSink.restoreWriter failed due to Architec

[jira] (FLINK-26121) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26121 ] Matthias Pohl deleted comment on FLINK-26121: --- was (Author: mapohl): Linking FLINK-25120 because we observed similar behavior there > ZooKeeperLeaderRetrievalConnectionHandlingTest.testNew

[GitHub] [flink] flinkbot edited a comment on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

flinkbot edited a comment on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1036101042 ## CI report: * 9b9e4dc96990436cb5684646ed801b84f2357848 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18793: [FLINK-23240][runtime] Master process supports living through multiple leader sessions.

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

  1   2   3   4   5   6   7   8   9   >