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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * b14f97d8b614ae1bc318f8c4e8ddcdf1eb232095 Azure:

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

2022-02-15 Thread GitBox
tillrohrmann opened a new pull request #26: URL: https://github.com/apache/flink-statefun-playground/pull/26 This PR is based on #25. It updates the playground to use the newly introduced playground ingress/egress. By using the curl based ingress/egresses we can simplify the overall setup

[jira] [Commented] (FLINK-24550) Can not access job information from a standby jobmanager UI

2022-02-15 Thread stuxnet (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492640#comment-17492640 ] stuxnet commented on FLINK-24550: - Hello, is this issue really resolved ? We're still experiencing the

[GitHub] [flink] flinkbot edited a comment on pull request #18746: [docs]revamp security pages

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18746: URL: https://github.com/apache/flink/pull/18746#issuecomment-1038829702 ## CI report: * 91c09fb42686497a7e80405effd8fe474c24d4df Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18738: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18738: URL: https://github.com/apache/flink/pull/18738#issuecomment-1037051889 ## CI report: * 8cfabce2c4953a63dfdf9e27b3231445c77d7821 Azure:

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * aab3087762ad1405ff910b1573f7307317a3ccd4 Azure:

[jira] [Closed] (FLINK-26161) Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning

2022-02-15 Thread Yufei Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufei Zhang closed FLINK-26161. --- Resolution: Invalid When I look back at this issue, I think I had some misunderstanding at the

[jira] [Commented] (FLINK-26161) Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning

2022-02-15 Thread Yufei Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492635#comment-17492635 ] Yufei Zhang commented on FLINK-26161: - When I look back at this issue, I think I had some

[GitHub] [flink] nyingping commented on pull request #18722: [hotfix][docs]fixed some causing ambiguities including the 'shit' comment

2022-02-15 Thread GitBox
nyingping commented on pull request #18722: URL: https://github.com/apache/flink/pull/18722#issuecomment-1040329157 > @RyanSkraba thank you! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18782: URL: https://github.com/apache/flink/pull/18782#issuecomment-1040321537 ## CI report: * 67cc675ef6caf816e4ee71f61b407f5fc8ae9fa1 Azure:

[GitHub] [flink] XComp commented on a change in pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

2022-02-15 Thread GitBox
XComp commented on a change in pull request #18749: URL: https://github.com/apache/flink/pull/18749#discussion_r806878952 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DispatcherResourceCleanerFactory.java ## @@ -101,13 +101,13 @@

[GitHub] [flink] leonardBang commented on a change in pull request #18738: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2022-02-15 Thread GitBox
leonardBang commented on a change in pull request #18738: URL: https://github.com/apache/flink/pull/18738#discussion_r806721189 ## File path: docs/content.zh/docs/connectors/table/formats/ogg.md ## @@ -0,0 +1,256 @@ +--- +title: Ogg +weight: 8 +type: docs +aliases: +-

[GitHub] [flink] flinkbot edited a comment on pull request #18417: [FLINK-15455][network] Enabled tcp connection reuse across multi jobs.

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18417: URL: https://github.com/apache/flink/pull/18417#issuecomment-1017267306 ## CI report: * 4a8fa799e58150ba888bd1384aaa4ed196d6aefd Azure:

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

2022-02-15 Thread GitBox
flinkbot commented on pull request #18782: URL: https://github.com/apache/flink/pull/18782#issuecomment-1040321537 ## CI report: * 67cc675ef6caf816e4ee71f61b407f5fc8ae9fa1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18774: [FLINK-25701][kafka] Add Flink API annotation to all connector classes based on the new Source/Sink design

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18774: URL: https://github.com/apache/flink/pull/18774#issuecomment-1040091754 ## CI report: * d3dd674e0494238ad2b1a96613067dd18a01370c Azure:

[GitHub] [flink] XComp edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-15 Thread GitBox
XComp edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1040317952 > I'm wondering if that isn't yet again a minio issue. From everything I have read presto assumes that everything is an empty directory by default (hence why mkdirs

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

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

[GitHub] [flink] XComp commented on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-15 Thread GitBox
XComp commented on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1040317952 > Did you step through PrestoS3FileSystem to see which call fails? How does the test (FileSystemBehaviorTestSuite.testMkdirsCreatesParentDirectories) actually fail? Is the

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

2022-02-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26148: --- Labels: pull-request-available (was: ) > Change the format of adaptive batch scheduler

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

2022-02-15 Thread GitBox
wanglijie95 opened a new pull request #18782: URL: https://github.com/apache/flink/pull/18782 ## What is the purpose of the change Change the format of adaptive batch scheduler config option to jobmanager.adaptive-batch-scheduler.XXX to align the format with the existing scheduler

[GitHub] [flink] flinkbot edited a comment on pull request #18781: [FLINK-26159][doc] add description for MAX_FETCH_RECORD related question

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18781: URL: https://github.com/apache/flink/pull/18781#issuecomment-1040309374 ## CI report: * af3a899250856878183ca1df8c31a395b42d46a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18774: [FLINK-25701][kafka] Add Flink API annotation to all connector classes based on the new Source/Sink design

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18774: URL: https://github.com/apache/flink/pull/18774#issuecomment-1040091754 ## CI report: * d3dd674e0494238ad2b1a96613067dd18a01370c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18761: URL: https://github.com/apache/flink/pull/18761#issuecomment-1039202980 ## CI report: * 6b2a762f6922fdaf46a8f12f7aa071dac95074fc Azure:

[jira] [Updated] (FLINK-26061) FileSystem.getFileStatus fails for empty directories on Presto S3 FS

2022-02-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26061: -- Description: {{FileSystem.getFileStatus}} -or {{FileSystem.exists}}- are not supported for

[GitHub] [flink] flinkbot commented on pull request #18781: [FLINK-26159][doc] add description for MAX_FETCH_RECORD related question

2022-02-15 Thread GitBox
flinkbot commented on pull request #18781: URL: https://github.com/apache/flink/pull/18781#issuecomment-1040309374 ## CI report: * af3a899250856878183ca1df8c31a395b42d46a3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18761: URL: https://github.com/apache/flink/pull/18761#issuecomment-1039202980 ## CI report: * 6b2a762f6922fdaf46a8f12f7aa071dac95074fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18755: [FLINK-26089][table-planner] Introduce TablePipeline

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18755: URL: https://github.com/apache/flink/pull/18755#issuecomment-1039066287 ## CI report: * b133c7767bd5e2e453241acf093e24965df4727b Azure:

[GitHub] [flink] zentol commented on a change in pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

2022-02-15 Thread GitBox
zentol commented on a change in pull request #18749: URL: https://github.com/apache/flink/pull/18749#discussion_r806855733 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DispatcherResourceCleanerFactory.java ## @@ -101,13 +101,13 @@

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-15 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r806857666 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java ## @@ -155,18 +155,15 @@ public boolean

[GitHub] [flink] zentol commented on a change in pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

2022-02-15 Thread GitBox
zentol commented on a change in pull request #18749: URL: https://github.com/apache/flink/pull/18749#discussion_r806855733 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DispatcherResourceCleanerFactory.java ## @@ -101,13 +101,13 @@

[GitHub] [flink] zentol commented on a change in pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

2022-02-15 Thread GitBox
zentol commented on a change in pull request #18749: URL: https://github.com/apache/flink/pull/18749#discussion_r806855733 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DispatcherResourceCleanerFactory.java ## @@ -101,13 +101,13 @@

[GitHub] [flink] zentol commented on a change in pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

2022-02-15 Thread GitBox
zentol commented on a change in pull request #18749: URL: https://github.com/apache/flink/pull/18749#discussion_r806855733 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DispatcherResourceCleanerFactory.java ## @@ -101,13 +101,13 @@

[GitHub] [flink] dmvk commented on pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-15 Thread GitBox
dmvk commented on pull request #18761: URL: https://github.com/apache/flink/pull/18761#issuecomment-1040303242 @zentol I've addressed your comment. The last change is done in a separate commit as it also contains migration to junit5 so we don't introduce too much noise into the actual

[GitHub] [flink] flinkbot commented on pull request #18781: [FLINK-26159][doc] add description for MAX_FETCH_RECORD related question

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

[GitHub] [flink] zentol commented on a change in pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

2022-02-15 Thread GitBox
zentol commented on a change in pull request #18749: URL: https://github.com/apache/flink/pull/18749#discussion_r806852636 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/LocallyCleanableResource.java ## @@ -24,12 +24,11 @@ import

[GitHub] [flink] imaffe opened a new pull request #18781: [FLINK-26159][doc] add description for MAX_FETCH_RECORD related question

2022-02-15 Thread GitBox
imaffe opened a new pull request #18781: URL: https://github.com/apache/flink/pull/18781 ## 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 on

[jira] [Updated] (FLINK-26159) Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain slow consumption

2022-02-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26159: --- Labels: Pulsar pull-request-available (was: Pulsar) > Pulsar Connector: should add

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-15 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804187457 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java ## @@ -155,18 +155,15 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #18721: [FLINK-24474] Bind Jobmanager and Taskmanager RPC host addresses to localhost by default

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18721: URL: https://github.com/apache/flink/pull/18721#issuecomment-1035971992 ## CI report: * 3eb94c01df59300d070b30aafc8bbd4bee8f6948 Azure:

[GitHub] [flink] dmvk commented on a change in pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-15 Thread GitBox
dmvk commented on a change in pull request #18761: URL: https://github.com/apache/flink/pull/18761#discussion_r806844044 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.java ## @@ -155,6 +179,60 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18721: [FLINK-24474] Bind Jobmanager and Taskmanager RPC host addresses to localhost by default

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18721: URL: https://github.com/apache/flink/pull/18721#issuecomment-1035971992 ## CI report: * 3eb94c01df59300d070b30aafc8bbd4bee8f6948 Azure:

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * b14f97d8b614ae1bc318f8c4e8ddcdf1eb232095 Azure:

[GitHub] [flink] dawidwys commented on pull request #18726: [FLINK-25983] Add API for configuring maximal watermark drift

2022-02-15 Thread GitBox
dawidwys commented on pull request #18726: URL: https://github.com/apache/flink/pull/18726#issuecomment-1040285690 @JingGe @Airblader May you take a look at [282dae5](https://github.com/apache/flink/pull/18726/commits/282dae5d491e53b842098c763924b863ce20dd0b) if it makes sense for you.

[GitHub] [flink] gaborgsomogyi commented on pull request #18687: [FLINK-24169][tests] Add TimeBased rolling policy and delete OnStartupTriggeringPolicy

2022-02-15 Thread GitBox
gaborgsomogyi commented on pull request #18687: URL: https://github.com/apache/flink/pull/18687#issuecomment-1040284738 I still don't know what is the exception what I need to see at the initial point. Please answer it in order to be in sync. -- This is an automated message from the

[GitHub] [flink] gaborgsomogyi commented on pull request #18687: [FLINK-24169][tests] Add TimeBased rolling policy and delete OnStartupTriggeringPolicy

2022-02-15 Thread GitBox
gaborgsomogyi commented on pull request #18687: URL: https://github.com/apache/flink/pull/18687#issuecomment-1040283835 I've just checked out the latest PR code and it constantly fails the following way: ``` /Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/bin/java

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18771: URL: https://github.com/apache/flink/pull/18771#issuecomment-1039998775 ## CI report: * 1294b28e3e3e814893541b421923972e1470f1a0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18770: [FLINK-26132][table-planner] Now anonymous tables serialization won't use the flag CatalogPlanCompilation anymore

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18770: URL: https://github.com/apache/flink/pull/18770#issuecomment-1039994674 ## CI report: * 8c69c97fef80bf29ee3eaab3f6b2f72540c33bd6 Azure:

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * b14f97d8b614ae1bc318f8c4e8ddcdf1eb232095 Azure:

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * b14f97d8b614ae1bc318f8c4e8ddcdf1eb232095 Azure:

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * b14f97d8b614ae1bc318f8c4e8ddcdf1eb232095 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18780: [FLINK-26160][pulsar][doc] update the doc of setUnboundedStopCursor()

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18780: URL: https://github.com/apache/flink/pull/18780#issuecomment-1040253405 ## CI report: * da76073dfc386e3159e933945d3bdb0ab8c824a9 Azure:

[GitHub] [flink] zentol commented on a change in pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-15 Thread GitBox
zentol commented on a change in pull request #18761: URL: https://github.com/apache/flink/pull/18761#discussion_r806819042 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.java ## @@ -155,6 +179,60 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18763: .[FLINK-26133][docus] Fixed Kafka Connector deserializer demo code error

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18763: URL: https://github.com/apache/flink/pull/18763#issuecomment-1039250899 ## CI report: * c7f4bdedb22c2fa9d96f2f6adfe8e08a061cdc91 Azure:

[GitHub] [flink] zentol commented on a change in pull request #18761: [FLINK-26107][runtime] AdaptiveScheduler: OperatorCoordinator should …

2022-02-15 Thread GitBox
zentol commented on a change in pull request #18761: URL: https://github.com/apache/flink/pull/18761#discussion_r806819042 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.java ## @@ -155,6 +179,60 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18496: URL: https://github.com/apache/flink/pull/18496#issuecomment-1020867632 ## CI report: * da588603a577a2b26bcf90fcd38653f7ec8a3a74 Azure:

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * b14f97d8b614ae1bc318f8c4e8ddcdf1eb232095 Azure:

[GitHub] [flink] flinkbot commented on pull request #18780: [FLINK-26160][pulsar][doc] update the doc of setUnboundedStopCursor()

2022-02-15 Thread GitBox
flinkbot commented on pull request #18780: URL: https://github.com/apache/flink/pull/18780#issuecomment-1040253405 ## CI report: * da76073dfc386e3159e933945d3bdb0ab8c824a9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zentol edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-15 Thread GitBox
zentol edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1040251026 > We do. The Presto S3 Filesystem requires it. That's what [FLINK-26061](https://issues.apache.org/jira/browse/FLINK-26061) is about. I'm wondering if that isn't

[GitHub] [flink] flinkbot edited a comment on pull request #18763: .[FLINK-26133][docus] Fixed Kafka Connector deserializer demo code error

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18763: URL: https://github.com/apache/flink/pull/18763#issuecomment-1039250899 ## CI report: * c7f4bdedb22c2fa9d96f2f6adfe8e08a061cdc91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18496: URL: https://github.com/apache/flink/pull/18496#issuecomment-1020867632 ## CI report: * da588603a577a2b26bcf90fcd38653f7ec8a3a74 Azure:

[GitHub] [flink] zentol commented on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-15 Thread GitBox
zentol commented on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1040251026 > We do. The Presto S3 Filesystem requires it. That's what [FLINK-26061](https://issues.apache.org/jira/browse/FLINK-26061) is about. I'm wondering if that isn't yet

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * b14f97d8b614ae1bc318f8c4e8ddcdf1eb232095 Azure:

[GitHub] [flink] flinkbot commented on pull request #18780: [FLINK-26160][pulsar][doc] update the doc of setUnboundedStopCursor()

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

[jira] [Commented] (FLINK-25981) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers failed

2022-02-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492602#comment-17492602 ] Matthias Pohl commented on FLINK-25981: --- I created a

[jira] [Assigned] (FLINK-25981) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers failed

2022-02-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-25981: - Assignee: Matthias Pohl >

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-02-15 Thread GitBox
ruanhang1993 commented on a change in pull request #18496: URL: https://github.com/apache/flink/pull/18496#discussion_r806806902 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/source/FromElementsSource.java

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-02-15 Thread GitBox
ruanhang1993 commented on a change in pull request #18496: URL: https://github.com/apache/flink/pull/18496#discussion_r806806442 ## File path:

[jira] [Updated] (FLINK-26160) Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled.

2022-02-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26160: --- Labels: Pulsar pull-request-available (was: Pulsar) > Pulsar Connector: stopCursor

[GitHub] [flink] imaffe opened a new pull request #18780: [FLINK-26160][pulsar][doc] update the doc of setUnboundedStopCursor()

2022-02-15 Thread GitBox
imaffe opened a new pull request #18780: URL: https://github.com/apache/flink/pull/18780 ## What is the purpose of the change Modify the documentation of Bounded StopCursor ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on

[GitHub] [flink] flinkbot edited a comment on pull request #18779: Misprint in javadoc at QuadFunction.java

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18779: URL: https://github.com/apache/flink/pull/18779#issuecomment-1040236268 ## CI report: * 08617e15a0482d984e7fccd5ed591acd74a8e6dc Azure:

[jira] [Commented] (FLINK-25699) Use HashMap for MAP value constructors

2022-02-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492601#comment-17492601 ] Sergey Nuyanzin commented on FLINK-25699: - By the way I submitted a PR once you have time please

[GitHub] [flink] flinkbot commented on pull request #18779: Misprint in javadoc at QuadFunction.java

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

[GitHub] [flink] flinkbot commented on pull request #18779: Misprint in javadoc at QuadFunction.java

2022-02-15 Thread GitBox
flinkbot commented on pull request #18779: URL: https://github.com/apache/flink/pull/18779#issuecomment-1040236268 ## CI report: * 08617e15a0482d984e7fccd5ed591acd74a8e6dc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1039977246 ## CI report: * 360431b93439bbb3f16aed0b326063a7594b8e50 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310 ## CI report: * 6453c87094bd1515d5eb80ff016123da5a0887dc Azure:

[GitHub] [flink] snuyanzin opened a new pull request #18779: Misprint in javadoc at QuadFunction.java

2022-02-15 Thread GitBox
snuyanzin opened a new pull request #18779: URL: https://github.com/apache/flink/pull/18779 ## What is the purpose of the change This is a trivial PR fixing a misprint at `flink-core/src/main/java/org/apache/flink/util/function/QuadFunction.java` `@oaram` => `@param`

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

2022-02-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492592#comment-17492592 ] Matthias Pohl commented on FLINK-26121: --- Linking FLINK-25120 because we observed similar behavior

[GitHub] [flink] flinkbot edited a comment on pull request #18755: [FLINK-26089][table-planner] Introduce TablePipeline

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18755: URL: https://github.com/apache/flink/pull/18755#issuecomment-1039066287 ## CI report: * cbd78cd85cfd9d2791fba1c255cad43fe0857738 Azure:

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * b14f97d8b614ae1bc318f8c4e8ddcdf1eb232095 Azure:

[GitHub] [flink-ml] lindong28 commented on pull request #57: [FLINK-26100][docs] Set up Flink ML Document Website

2022-02-15 Thread GitBox
lindong28 commented on pull request #57: URL: https://github.com/apache/flink-ml/pull/57#issuecomment-1040224761 Thanks for the update. LGTM. -- 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-ml] lindong28 merged pull request #57: [FLINK-26100][docs] Set up Flink ML Document Website

2022-02-15 Thread GitBox
lindong28 merged pull request #57: URL: https://github.com/apache/flink-ml/pull/57 -- 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:

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

2022-02-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492584#comment-17492584 ] Chesnay Schepler commented on FLINK-26121: -- FYI, in FLINK-25120 we also have an issue because

[jira] [Updated] (FLINK-24370) [FLIP-171] Documentation for Generic AsyncSinkBase

2022-02-15 Thread Zichen Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-24370: --- Fix Version/s: (was: 1.15.0) > [FLIP-171] Documentation for Generic AsyncSinkBase >

[GitHub] [flink] flinkbot edited a comment on pull request #18755: [FLINK-26089][table-planner] Introduce TablePipeline

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18755: URL: https://github.com/apache/flink/pull/18755#issuecomment-1039066287 ## CI report: * cbd78cd85cfd9d2791fba1c255cad43fe0857738 Azure:

[jira] [Commented] (FLINK-26154) SavepointFormatITCase times out on azure

2022-02-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492583#comment-17492583 ] Roman Khachatryan commented on FLINK-26154: --- Probably a separate issue:

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0c99c5916b0cc11caaf237c667c6ed4df6e7ac4b Azure:

[jira] [Created] (FLINK-26161) Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning

2022-02-15 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-26161: --- Summary: Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning Key: FLINK-26161 URL: https://issues.apache.org/jira/browse/FLINK-26161

[jira] [Resolved] (FLINK-25821) Add the doc of execution mode in PyFlink

2022-02-15 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-25821. -- Resolution: Done merged into master via eb80d55e760e83108a841d254c132edb859ed209 > Add the

[jira] [Created] (FLINK-26160) Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled.

2022-02-15 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-26160: --- Summary: Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled. Key: FLINK-26160 URL:

[GitHub] [flink] HuangXingBo closed pull request #18748: [FLINK-25821][python][doc] Add the doc of execution mode in PyFlink

2022-02-15 Thread GitBox
HuangXingBo closed pull request #18748: URL: https://github.com/apache/flink/pull/18748 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #18755: [FLINK-26089][table-planner] Introduce TablePipeline

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18755: URL: https://github.com/apache/flink/pull/18755#issuecomment-1039066287 ## CI report: * cbd78cd85cfd9d2791fba1c255cad43fe0857738 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18754: [FLINK-26130][docs] Expanded the reason to increase network buffer si…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18754: URL: https://github.com/apache/flink/pull/18754#issuecomment-1039015814 ## CI report: * 1952f6b22246d43449dd83835427a1d91e72dc87 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18748: [FLINK-25821][python][doc] Add the doc of execution mode in PyFlink

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18748: URL: https://github.com/apache/flink/pull/18748#issuecomment-1038986841 ## CI report: * 8169fd6cbb3b5383c8be2dc836b9f519d945b017 Azure:

[jira] [Created] (FLINK-26159) Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain slow consumption

2022-02-15 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-26159: --- Summary: Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain slow consumption Key: FLINK-26159 URL: https://issues.apache.org/jira/browse/FLINK-26159

[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * bef54d7fb6c5025829a29722892350a4a8e4c585 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 1dbd224db334939fc5337ac994d1b24efdf99657 Azure:

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

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0c99c5916b0cc11caaf237c667c6ed4df6e7ac4b Azure:

[GitHub] [flink] dianfu commented on a change in pull request #18748: [FLINK-25821][python][doc] Add the doc of execution mode in PyFlink

2022-02-15 Thread GitBox
dianfu commented on a change in pull request #18748: URL: https://github.com/apache/flink/pull/18748#discussion_r806768683 ## File path: docs/content.zh/docs/dev/python/python_execution_mode.md ## @@ -0,0 +1,101 @@ +--- +title: "执行模式" +weight: 40 +type: docs +--- + + +#

[GitHub] [flink] RocMarshal commented on a change in pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
RocMarshal commented on a change in pull request #18718: URL: https://github.com/apache/flink/pull/18718#discussion_r806733589 ## File path: docs/content.zh/docs/connectors/datastream/filesystem.md ## @@ -27,61 +27,58 @@ KIND, either express or implied. See the License for

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

2022-02-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492574#comment-17492574 ] Matthias Pohl commented on FLINK-26121: --- I wasn't able to reproduce it locally. But it looks like

<    3   4   5   6   7   8   9   10   11   12   >