[GitHub] [flink] flinkbot commented on pull request #12415: [FLINK-17895] Default value of rows-per-second in datagen is changed …

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

[GitHub] [flink] flinkbot commented on pull request #12414: [FLINK-17967][Documentation]Could not find document *** in docs

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

[GitHub] [flink] flinkbot commented on pull request #12415: [FLINK-17895] Default value of rows-per-second in datagen is changed …

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

[GitHub] [flink] pyscala commented on pull request #12415: [FLINK-17895] Default value of rows-per-second in datagen is changed …

pyscala commented on pull request #12415: URL: https://github.com/apache/flink/pull/12415#issuecomment-636285890 @JingsongLi Appreciate for your time to review this PR.thanks This is an automated message from the Apache Git S

[jira] [Updated] (FLINK-17895) Default value of rows-per-second in datagen can be limited

[ https://issues.apache.org/jira/browse/FLINK-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17895: --- Labels: pull-request-available starter (was: starter) > Default value of rows-per-second in

[GitHub] [flink] pyscala opened a new pull request #12415: [FLINK-17895] Default value of rows-per-second in datagen is changed …

pyscala opened a new pull request #12415: URL: https://github.com/apache/flink/pull/12415 Default value of rows-per-second in datagen is changed from Long.MAX_VALUE to 1L. This is an automated message from the Apache

[GitHub] [flink] pnowojski commented on a change in pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceiv

pnowojski commented on a change in pull request #12406: URL: https://github.com/apache/flink/pull/12406#discussion_r432815265 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnalignerTest.java ## @@ -639,4 +673,79 @@ publ

[GitHub] [flink] pnowojski commented on a change in pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceiv

pnowojski commented on a change in pull request #12406: URL: https://github.com/apache/flink/pull/12406#discussion_r432815265 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnalignerTest.java ## @@ -639,4 +673,79 @@ publ

[GitHub] [flink] pnowojski commented on a change in pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceiv

pnowojski commented on a change in pull request #12406: URL: https://github.com/apache/flink/pull/12406#discussion_r432815265 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnalignerTest.java ## @@ -639,4 +673,79 @@ publ

[GitHub] [flink] flinkbot commented on pull request #12414: [FLINK-17967][Documentation]Could not find document *** in docs

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

[jira] [Updated] (FLINK-17967) Could not find document *** in docs

[ https://issues.apache.org/jira/browse/FLINK-17967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17967: --- Labels: pull-request-available (was: ) > Could not find document *** in docs >

[GitHub] [flink] LululuAlu opened a new pull request #12414: [FLINK-17967][Documentation]Could not find document *** in docs

LululuAlu opened a new pull request #12414: URL: https://github.com/apache/flink/pull/12414 ## What is the purpose of the change Fix error when run build_docs.sh -p in docs dir with master Liquid Exception: Could not find document 'concepts/stateful-stream-processing.md'

[GitHub] [flink] flinkbot edited a comment on pull request #12413: [FLINK-16198][core] Fix FileUtilsTest fails on MacOS

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

[GitHub] [flink] becketqin commented on a change in pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

becketqin commented on a change in pull request #12234: URL: https://github.com/apache/flink/pull/12234#discussion_r432805261 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java ## @@ -99,29 +187,110 @@ publi

[jira] [Commented] (FLINK-17091) AvroRow(De)SerializationSchema doesn't support new Timestamp conversion classes

[ https://issues.apache.org/jira/browse/FLINK-17091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120097#comment-17120097 ] Paul Lin commented on FLINK-17091: -- [~jark] I checked AvroRowDataDeserializationSchema,

[jira] [Commented] (FLINK-16085) Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120086#comment-17120086 ] Authuir commented on FLINK-16085: - Hi [~jark], sorry for the delay. Actually it's nearin

[GitHub] [flink] flinkbot edited a comment on pull request #12413: [FLINK-16198][core] Fix FileUtilsTest fails on MacOS

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

[jira] [Commented] (FLINK-17895) Default value of rows-per-second in datagen can be limited

[ https://issues.apache.org/jira/browse/FLINK-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120077#comment-17120077 ] liufangliang commented on FLINK-17895: -- [~lzljs3620320] can you add a description?

[jira] [Commented] (FLINK-17736) Add flink CEP examples

[ https://issues.apache.org/jira/browse/FLINK-17736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120076#comment-17120076 ] liufangliang commented on FLINK-17736: -- [~lzljs3620320] Can you add a description？

[GitHub] [flink] flinkbot commented on pull request #12413: [FLINK-16198][core] Fix FileUtilsTest fails on MacOS

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

[jira] [Created] (FLINK-18039) Change SourceCoordinator to handle resetToCheckpoint() call after started.

Jiangjie Qin created FLINK-18039: Summary: Change SourceCoordinator to handle resetToCheckpoint() call after started. Key: FLINK-18039 URL: https://issues.apache.org/jira/browse/FLINK-18039 Project: F

[GitHub] [flink] flinkbot commented on pull request #12413: [FLINK-16198][core] Fix FileUtilsTest fails on MacOS

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

[jira] [Updated] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16198: --- Labels: pull-request-available starter (was: starter) > FileUtilsTest fails on Mac OS > ---

[GitHub] [flink] fishzhe opened a new pull request #12413: [FLINK-16198][core] Fix FileUtilsTest fails on MacOS

fishzhe opened a new pull request #12413: URL: https://github.com/apache/flink/pull/12413 ## What is the purpose of the change Fix FileUtilsTest fails on MacOS ## Brief change log -*Fix concurrent delete failure on MacOS* -*Fix relative compression path te

[jira] [Commented] (FLINK-18036) Chinese documentation build is broken

[ https://issues.apache.org/jira/browse/FLINK-18036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120005#comment-17120005 ] Jark Wu commented on FLINK-18036: - [~wuxuyang78], do you want to fix this one together?

[GitHub] [flink] AHeise commented on a change in pull request #12353: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

AHeise commented on a change in pull request #12353: URL: https://github.com/apache/flink/pull/12353#discussion_r43276 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/BroadcastRecordWriter.java ## @@ -130,7 +132,7 @@ public BufferBu

[jira] [Created] (FLINK-18038) StateBackendLoader logs application-defined state before it is fully configured

Steve Bairos created FLINK-18038: Summary: StateBackendLoader logs application-defined state before it is fully configured Key: FLINK-18038 URL: https://issues.apache.org/jira/browse/FLINK-18038 Proje

[GitHub] [flink] flinkbot edited a comment on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

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

[GitHub] [flink] flinkbot edited a comment on pull request #12380: [FLINK-17581][docs-zh] Update translation of S3 documentation

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

[GitHub] [flink] flinkbot edited a comment on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

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

[GitHub] [flink] flinkbot edited a comment on pull request #12401: [FLINK-16057] Optimize ContinuousFileReaderOperator

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

[GitHub] [flink] flinkbot edited a comment on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

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

[GitHub] [flink] StephanEwen commented on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

StephanEwen commented on pull request #12234: URL: https://github.com/apache/flink/pull/12234#issuecomment-636172362 Updated the PR to address the issue raised by @becketqin This required a change in the `OperatorCoordinator` interface. To explain why, let's revisit the semantics we

[GitHub] [flink] flinkbot edited a comment on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

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

[GitHub] [flink] flinkbot edited a comment on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

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

[GitHub] [flink] StephanEwen commented on a change in pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

StephanEwen commented on a change in pull request #12234: URL: https://github.com/apache/flink/pull/12234#discussion_r432706623 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorCoordinatorCheckpoints.java ## @@ -58,7 +58,17 @@

[GitHub] [flink] TengHu commented on a change in pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

TengHu commented on a change in pull request #12297: URL: https://github.com/apache/flink/pull/12297#discussion_r432696612 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java ## @@ -46,28 +46,44

[GitHub] [flink] TengHu commented on a change in pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

TengHu commented on a change in pull request #12297: URL: https://github.com/apache/flink/pull/12297#discussion_r432696612 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java ## @@ -46,28 +46,44

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119890#comment-17119890 ] Dian Fu commented on FLINK-17923: - We assume that the Python worker uses task off-heap m

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119883#comment-17119883 ] Stephan Ewen commented on FLINK-17923: -- I think my suggestion from above is not a f

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119880#comment-17119880 ] Stephan Ewen commented on FLINK-17923: -- We could think about making the Python Proc

[GitHub] [flink] flinkbot edited a comment on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

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

[GitHub] [flink] flinkbot edited a comment on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

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

[GitHub] [flink] carp84 commented on pull request #12368: [FLINK-15507][state backends] Activate local recovery by default (on release-1.11)

carp84 commented on pull request #12368: URL: https://github.com/apache/flink/pull/12368#issuecomment-636120661 We've decided to postpone FLINK-15507 to 1.12.0 to have more thorough discussions, thus closing the PR directly (w/o merging). --

[GitHub] [flink] carp84 closed pull request #12368: [FLINK-15507][state backends] Activate local recovery by default (on release-1.11)

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

[jira] [Updated] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15507: -- Fix Version/s: (was: 1.11.0) 1.12.0 Priority: Critical (was: Blocker) Thanks

[GitHub] [flink] carp84 commented on pull request #12312: [FLINK-15507][state backends] Activate local recovery by default

carp84 commented on pull request #12312: URL: https://github.com/apache/flink/pull/12312#issuecomment-636120242 We've decided to postpone FLINK-15507 to 1.12.0 to have more thorough discussions, thus won't merge the PR at the moment. ---

[GitHub] [flink] flinkbot edited a comment on pull request #12146: [FLINK-17968][hbase] Fix Hadoop Configuration is not properly serialized in HBaseRowInputFormat

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

[GitHub] [flink] flinkbot edited a comment on pull request #12380: [FLINK-17581][docs-zh] Update translation of S3 documentation

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

[jira] [Commented] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119803#comment-17119803 ] Yu Li commented on FLINK-17800: --- Thanks for debugging and locating the root cause [~yunta]

[GitHub] [flink] flinkbot edited a comment on pull request #12380: [FLINK-17581][docs-zh] Update translation of S3 documentation

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

[GitHub] [flink] wydhcws commented on pull request #12380: [FLINK-17581][docs-zh] Update translation of S3 documentation

wydhcws commented on pull request #12380: URL: https://github.com/apache/flink/pull/12380#issuecomment-636096206 Thanks for your patience and careful . I've fixed the problem. @klion26 This is an automated message f

[GitHub] [flink] wydhcws commented on a change in pull request #12380: [FLINK-17581][docs-zh] Update translation of S3 documentation

wydhcws commented on a change in pull request #12380: URL: https://github.com/apache/flink/pull/12380#discussion_r432635762 ## File path: docs/ops/filesystems/s3.zh.md ## @@ -58,11 +58,15 @@ env.setStateBackend(new FsStateBackend("s3:///")); Flink 提供两种文件系统用来与 S3 交互：`flink-s3-

[GitHub] [flink] wydhcws commented on a change in pull request #12380: [FLINK-17581][docs-zh] Update translation of S3 documentation

wydhcws commented on a change in pull request #12380: URL: https://github.com/apache/flink/pull/12380#discussion_r432635557 ## File path: docs/ops/filesystems/s3.zh.md ## @@ -58,11 +58,15 @@ env.setStateBackend(new FsStateBackend("s3:///")); Flink 提供两种文件系统用来与 S3 交互：`flink-s3-

[GitHub] [flink] rkhachatryan commented on a change in pull request #12401: [FLINK-16057] Optimize ContinuousFileReaderOperator

rkhachatryan commented on a change in pull request #12401: URL: https://github.com/apache/flink/pull/12401#discussion_r432618358 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.java ## @@ -114,6 +114,7 @@ publi

[GitHub] [flink] flinkbot edited a comment on pull request #12401: [FLINK-16057] Optimize ContinuousFileReaderOperator

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

[GitHub] [flink] flinkbot edited a comment on pull request #12411: [FLINK-18005][table] Implement type inference for CAST

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

[GitHub] [flink] flinkbot edited a comment on pull request #12379: [FLINK-18001][table-planner] Add a new test base for evaluating functions

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

[GitHub] [flink] flinkbot edited a comment on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

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

[GitHub] [flink] flinkbot edited a comment on pull request #12401: [FLINK-16057] Optimize ContinuousFileReaderOperator

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

[GitHub] [flink] flinkbot commented on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

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

[jira] [Created] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status'

ZhuShang created FLINK-18037: Summary: The doc of StreamTaskNetworkInput.java may has a redundant 'status' Key: FLINK-18037 URL: https://issues.apache.org/jira/browse/FLINK-18037 Project: Flink

[GitHub] [flink] walterddr commented on a change in pull request #11586: [FLINK-5552][runtime] make JMXServer static per JVM

walterddr commented on a change in pull request #11586: URL: https://github.com/apache/flink/pull/11586#discussion_r432582640 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JMXServerOptions.java ## @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] walterddr commented on a change in pull request #11586: [FLINK-5552][runtime] make JMXServer static per JVM

walterddr commented on a change in pull request #11586: URL: https://github.com/apache/flink/pull/11586#discussion_r432582640 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JMXServerOptions.java ## @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] walterddr commented on a change in pull request #11586: [FLINK-5552][runtime] make JMXServer static per JVM

walterddr commented on a change in pull request #11586: URL: https://github.com/apache/flink/pull/11586#discussion_r432582640 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JMXServerOptions.java ## @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] walterddr commented on a change in pull request #11586: [FLINK-5552][runtime] make JMXServer static per JVM

walterddr commented on a change in pull request #11586: URL: https://github.com/apache/flink/pull/11586#discussion_r432579859 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/management/JMXServer.java ## @@ -0,0 +1,239 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [flink] zhijiangW commented on a change in pull request #12353: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

zhijiangW commented on a change in pull request #12353: URL: https://github.com/apache/flink/pull/12353#discussion_r432575584 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/BroadcastRecordWriter.java ## @@ -130,7 +132,7 @@ public Buffe

[GitHub] [flink] zhijiangW commented on a change in pull request #12353: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

zhijiangW commented on a change in pull request #12353: URL: https://github.com/apache/flink/pull/12353#discussion_r432575584 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/BroadcastRecordWriter.java ## @@ -130,7 +132,7 @@ public Buffe

[GitHub] [flink] flinkbot commented on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

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

[jira] [Updated] (FLINK-18011) Make WatermarkStrategy/WatermarkStrategies more ergonomic

[ https://issues.apache.org/jira/browse/FLINK-18011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18011: --- Labels: pull-request-available (was: ) > Make WatermarkStrategy/WatermarkStrategies more er

[GitHub] [flink] aljoscha commented on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

aljoscha commented on pull request #12412: URL: https://github.com/apache/flink/pull/12412#issuecomment-636046671 By now I'm wondering wether we should make `WatermarkStrategy` `@PublicEvolving`. This is an automated message

[GitHub] [flink] aljoscha opened a new pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

aljoscha opened a new pull request #12412: URL: https://github.com/apache/flink/pull/12412 ## What is the purpose of the change From the Jira issue: Currently, we have an interface `WatermarkStrategy`, which is a `TimestampAssignerSupplier` and `WatermarkGeneratorSupplier`. The ve

[GitHub] [flink] zhijiangW commented on a change in pull request #12353: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

zhijiangW commented on a change in pull request #12353: URL: https://github.com/apache/flink/pull/12353#discussion_r432575584 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/BroadcastRecordWriter.java ## @@ -130,7 +132,7 @@ public Buffe

[GitHub] [flink] flinkbot edited a comment on pull request #12379: [FLINK-18001][table-planner] Add a new test base for evaluating functions

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

[GitHub] [flink] zhijiangW commented on a change in pull request #12353: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

zhijiangW commented on a change in pull request #12353: URL: https://github.com/apache/flink/pull/12353#discussion_r432575584 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/BroadcastRecordWriter.java ## @@ -130,7 +132,7 @@ public Buffe

[jira] [Commented] (FLINK-18036) Chinese documentation build is broken

[ https://issues.apache.org/jira/browse/FLINK-18036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119714#comment-17119714 ] Aljoscha Krettek commented on FLINK-18036: -- Yes, that's the same issue. > Chin

[GitHub] [flink] flinkbot edited a comment on pull request #12379: [FLINK-18001][table-planner] Add a new test base for evaluating functions

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

[GitHub] [flink] zhijiangW edited a comment on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

zhijiangW edited a comment on pull request #12406: URL: https://github.com/apache/flink/pull/12406#issuecomment-636036676 Thanks for the efficient review @pnowojski ! >As far as I understand it, it's not a full fix, as EndOfPartitionEvents or checkpoint barrier cancellation markers c

[GitHub] [flink] flinkbot edited a comment on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

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

[GitHub] [flink] flinkbot edited a comment on pull request #12408: [FLINK-15547][hive] Add test for avro table

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

[GitHub] [flink] zhijiangW edited a comment on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

zhijiangW edited a comment on pull request #12406: URL: https://github.com/apache/flink/pull/12406#issuecomment-636036676 Thanks for the efficient review @pnowojski ! >As far as I understand it, it's not a full fix, as EndOfPartitionEvents or checkpoint barrier cancellation markers c

[GitHub] [flink] zhijiangW commented on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

zhijiangW commented on pull request #12406: URL: https://github.com/apache/flink/pull/12406#issuecomment-636036676 >As far as I understand it, it's not a full fix, as EndOfPartitionEvents or checkpoint barrier cancellation markers can still cause the same race condition, and you want to fi

[jira] [Commented] (FLINK-17706) Clarify licensing situation for flink-benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119704#comment-17119704 ] Roman Grebennikov commented on FLINK-17706: --- I'm ok with licensing my contribu

[GitHub] [flink] zhijiangW commented on a change in pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceiv

zhijiangW commented on a change in pull request #12406: URL: https://github.com/apache/flink/pull/12406#discussion_r432561333 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner.java ## @@ -164,33 +158,32 @@ public

[GitHub] [flink] zhijiangW commented on a change in pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceiv

zhijiangW commented on a change in pull request #12406: URL: https://github.com/apache/flink/pull/12406#discussion_r432559532 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnalignerTest.java ## @@ -639,4 +673,79 @@ publ

[jira] [Assigned] (FLINK-17918) Jobs with two input operators are loosing data with unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17918: -- Assignee: Arvid Heise (was: Yingjie Cao) > Jobs with two input operators are loosing

[jira] [Closed] (FLINK-17842) Performance regression on 19.05.2020

[ https://issues.apache.org/jira/browse/FLINK-17842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17842. -- Resolution: Fixed 2nd fixed merged to release-1.11 as acb16cbdc3 and to master as 955a683 >

[GitHub] [flink] pnowojski merged pull request #12407: [FLINK-17842][network] Remove NextRecordResponse to improve deserialisation performance

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

[GitHub] [flink] twalthr commented on pull request #12379: [FLINK-18001][table-planner] Add a new test base for evaluating functions

twalthr commented on pull request #12379: URL: https://github.com/apache/flink/pull/12379#issuecomment-636015882 Thanks @dawidwys. I will check what I can do and merge this once I get a green build. This is an automated mess

[GitHub] [flink] flinkbot edited a comment on pull request #12409: [FLINK-18035][runtime] Use fixed thread pool

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

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

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

[GitHub] [flink] flinkbot edited a comment on pull request #12407: [FLINK-17842][network] Remove NextRecordResponse to improve deserialisation performance

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

[GitHub] [flink] flinkbot edited a comment on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

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

[GitHub] [flink] flinkbot edited a comment on pull request #12381: [FLINK-17941][sql-client] Switching catalog or database doesn't work …

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

[GitHub] [flink] flinkbot edited a comment on pull request #12146: [FLINK-17968][hbase] Fix Hadoop Configuration is not properly serialized in HBaseRowInputFormat

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

[jira] [Comment Edited] (FLINK-17500) Deploy JobGraph from file in StandaloneClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119656#comment-17119656 ] Fabian Paul edited comment on FLINK-17500 at 5/29/20, 2:21 PM: ---

[jira] [Comment Edited] (FLINK-17500) Deploy JobGraph from file in StandaloneClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119656#comment-17119656 ] Fabian Paul edited comment on FLINK-17500 at 5/29/20, 2:21 PM: ---

[jira] [Commented] (FLINK-17500) Deploy JobGraph from file in StandaloneClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119656#comment-17119656 ] Fabian Paul commented on FLINK-17500: - Sorry for the late reply and obviously no pro

[GitHub] [flink] flinkbot edited a comment on pull request #12407: [FLINK-17842][network] Remove NextRecordResponse to improve deserialisation performance

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

[GitHub] [flink] flinkbot edited a comment on pull request #12146: [FLINK-17968][hbase] Fix Hadoop Configuration is not properly serialized in HBaseRowInputFormat

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

  1   2   3   4   >