[GitHub] [flink] liming30 commented on pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

liming30 commented on pull request #13109: URL: https://github.com/apache/flink/pull/13109#issuecomment-687535459 Hi, @pnowojski I have rebase the master and reorganized the commit. > Could you restructure first three commits in the following way ([following our coding

[GitHub] [flink] flinkbot edited a comment on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

flinkbot edited a comment on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836 ## CI report: * 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN * ece578a9fdbaee4d815de501187d92a729790c9b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

flinkbot edited a comment on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836 ## CI report: * 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN * ece578a9fdbaee4d815de501187d92a729790c9b Azure:

[GitHub] [flink] miklosgergely commented on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

miklosgergely commented on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-687446541 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #13217: [FLINK-16866] Make job submission non-blocking

flinkbot edited a comment on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678285884 ## CI report: * 3655fcea1966bfbcb85c86d6a159c354f20d6cc7 UNKNOWN * 4d4d6690d8ad282f71e5f3d890e28421aef17766 Azure:

[jira] [Commented] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable

[ https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190870#comment-17190870 ] Kezhu Wang commented on FLINK-18815: [~trohrmann] Your are right, I made mistake. After revise, I

[GitHub] [flink] flinkbot edited a comment on pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

flinkbot edited a comment on pull request #13109: URL: https://github.com/apache/flink/pull/13109#issuecomment-671381707 ## CI report: * b43e9eda0e94696b0563922ecb37b202bca47af5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN * db1607ead33ae1b60634c1162ba8247a9957f0f4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13315: [FLINK-19070][hive] Hive connector should throw a meaningful exception if user reads/writes ACID tables

flinkbot edited a comment on pull request #13315: URL: https://github.com/apache/flink/pull/13315#issuecomment-686398823 ## CI report: * 2ed647fc736a248d536d6f5422e0a50a7119045f UNKNOWN * 6f796f529a1dc3aed87785eaeb251725c4dd17c2 Azure:

[GitHub] [flink] zhuxiaoshang removed a comment on pull request #13329: [hot fix]fix typo in the java doc

zhuxiaoshang removed a comment on pull request #13329: URL: https://github.com/apache/flink/pull/13329#issuecomment-687272049 @libenchao @wuchong This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] zhuxiaoshang commented on pull request #13329: [hot fix]fix typo in the java doc

zhuxiaoshang commented on pull request #13329: URL: https://github.com/apache/flink/pull/13329#issuecomment-687272049 @libenchao @wuchong This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

flinkbot edited a comment on pull request #13228: URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456 ## CI report: * 273cc6bf445b4a44daca0e98d49aa0745a36a534 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

flinkbot edited a comment on pull request #13228: URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456 ## CI report: * 67942d0ea538985ec25cecf7cefdc1bec0c1b53b Azure:

[GitHub] [flink] asfgit closed pull request #13241: [hotfix] Fix a typo in the watermark docs

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

[GitHub] [flink] rmetzger commented on pull request #13270: [hotfix] [javadocs] fix typo in TaskManagerServices

rmetzger commented on pull request #13270: URL: https://github.com/apache/flink/pull/13270#issuecomment-687234365 I agree, this is not a typo. Closing ticket... Please reopen if you disagree. This is an automated message

[GitHub] [flink] rmetzger closed pull request #13218: remove unnecessary integer boxing

rmetzger closed pull request #13218: URL: https://github.com/apache/flink/pull/13218 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] rmetzger commented on pull request #13218: remove unnecessary integer boxing

rmetzger commented on pull request #13218: URL: https://github.com/apache/flink/pull/13218#issuecomment-687234116 Closing ticket... Please reopen if you disagree. This is an automated message from the Apache Git Service. To

[GitHub] [flink] asfgit closed pull request #13324: [hotfix][docs] Fix ExecutionEnvironment.scala doc error

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

[GitHub] [flink] asfgit closed pull request #13329: [hot fix]fix typo in the java doc

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

[GitHub] [flink] asfgit closed pull request #12005: [hotfix][runtime] Remove never thrown IOException in ContinuousFileMnitoringFunction

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

[GitHub] [flink] flinkbot edited a comment on pull request #13216: [FLINK-18999][table-planner-blink][hive] Temporary generic table does…

flinkbot edited a comment on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 167e78ad9d9f8fdb79ce5b2483feed7f120456a3 Azure:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #13320: [FLINK-19035] Remove fold from DataStream API

gaoyunhaii commented on a change in pull request #13320: URL: https://github.com/apache/flink/pull/13320#discussion_r483691287 ## File path: docs/dev/stream/state/queryable_state.md ## @@ -155,7 +150,7 @@ descriptor.setQueryable("query-name"); // queryable state name

[jira] [Commented] (FLINK-10407) Reactive container mode

[ https://issues.apache.org/jira/browse/FLINK-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190775#comment-17190775 ] Antonio Verardi commented on FLINK-10407: - Hi [~trohrmann], I have seen Reactive Scaling in the

[jira] [Updated] (FLINK-19089) Improvement of ClosableBlockingQueue, replace Lock with ReadWriteLock, replace signalAll with signal

[ https://issues.apache.org/jira/browse/FLINK-19089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dugenkui updated FLINK-19089: - Description: 1. Replace ReentrantLock with ReentrantReadWriteLock to improve concurrency; 2. Use

[GitHub] [flink] flinkbot edited a comment on pull request #13330: [FLINK-19004][table-planner-blink] Use FIRST_VALUE when re-write non-…

flinkbot edited a comment on pull request #13330: URL: https://github.com/apache/flink/pull/13330#issuecomment-687094698 ## CI report: * dda51e888c3f58e83346118f03ad55075e990eb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13217: [FLINK-16866] Make job submission non-blocking

flinkbot edited a comment on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678285884 ## CI report: * 3655fcea1966bfbcb85c86d6a159c354f20d6cc7 UNKNOWN * 8036016c752bce433dc65d1c08695377c917836f Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

tillrohrmann commented on a change in pull request #13181: URL: https://github.com/apache/flink/pull/13181#discussion_r483678060 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkCheckerImpl.java ## @@ -0,0 +1,191 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13102: [FLINK-18515][Kinesis] Adding FanOutRecordPublisher for Kinesis EFO support

flinkbot edited a comment on pull request #13102: URL: https://github.com/apache/flink/pull/13102#issuecomment-671238228 ## CI report: * d82d0c6582050aa4364b4c7dda2c3053f3c2d756 Azure:

[jira] [Updated] (FLINK-19089) Improvement of ClosableBlockingQueue, replace Lock with ReadWriteLock, replace signalAll with signal

[ https://issues.apache.org/jira/browse/FLINK-19089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dugenkui updated FLINK-19089: - Summary: Improvement of ClosableBlockingQueue, replace Lock with ReadWriteLock, replace signalAll with

[jira] [Updated] (FLINK-19089) In ClosableBlockingQueue, Replace ReentrantLock with ReentrantReadWriteLock

[ https://issues.apache.org/jira/browse/FLINK-19089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dugenkui updated FLINK-19089: - Summary: In ClosableBlockingQueue, Replace ReentrantLock with ReentrantReadWriteLock (was: Replace

[GitHub] [flink] flinkbot edited a comment on pull request #13295: [FLINK-18598][python][docs] Add instructions for asynchronous execute in PyFlink doc.

flinkbot edited a comment on pull request #13295: URL: https://github.com/apache/flink/pull/13295#issuecomment-684586420 ## CI report: * 00804638850e8cc6779ebb3331ebb42be69f352b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13306: [FLINK-17779][Connectors/ORC]Orc file format support filter push down

flinkbot edited a comment on pull request #13306: URL: https://github.com/apache/flink/pull/13306#issuecomment-685717187 ## CI report: * a7f4abab05ad875bf6acef6510fcec6df7d2dc6c UNKNOWN * c7628fc4b97f68c44d7f5e9cf316814c9f73db18 Azure:

[GitHub] [flink] rmetzger commented on pull request #13324: [hotfix][docs] Fix ExecutionEnvironment.scala doc error

rmetzger commented on pull request #13324: URL: https://github.com/apache/flink/pull/13324#issuecomment-687204426 Thanks for review. Merging ... This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] rmetzger commented on pull request #13241: [hotfix] Fix a typo in the watermark docs

rmetzger commented on pull request #13241: URL: https://github.com/apache/flink/pull/13241#issuecomment-687204523 Thanks for review. Merging ... This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] rmetzger commented on pull request #13329: [hot fix]fix typo in the java doc

rmetzger commented on pull request #13329: URL: https://github.com/apache/flink/pull/13329#issuecomment-687204212 Thanks for review. Merging ... This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] rmetzger commented on pull request #12005: [hotfix][runtime] Remove never thrown IOException in ContinuousFileMnitoringFunction

rmetzger commented on pull request #12005: URL: https://github.com/apache/flink/pull/12005#issuecomment-687204617 Thanks for review. Merging ... This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #13217: [FLINK-16866] Make job submission non-blocking

flinkbot edited a comment on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678285884 ## CI report: * 3655fcea1966bfbcb85c86d6a159c354f20d6cc7 UNKNOWN * 8036016c752bce433dc65d1c08695377c917836f Azure:

[jira] [Updated] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19142: -- Fix Version/s: 1.12.0 > Investigate slot hijacking from preceding pipelined regions after

[GitHub] [flink] azagrebin commented on a change in pull request #13284: [FLINK-17016][runtime] Enable pipelined region scheduling

azagrebin commented on a change in pull request #13284: URL: https://github.com/apache/flink/pull/13284#discussion_r483646625 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionSlotAllocatorFactory.java ## @@ -19,11 +19,39 @@ package

[GitHub] [flink] azagrebin commented on a change in pull request #13284: [FLINK-17016][runtime] Enable pipelined region scheduling

azagrebin commented on a change in pull request #13284: URL: https://github.com/apache/flink/pull/13284#discussion_r483645607 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java ## @@ -300,6 +305,32 @@ public int getNumberOfVertices() {

[jira] [Commented] (FLINK-17554) Add release hooks for user code class loader

[ https://issues.apache.org/jira/browse/FLINK-17554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190743#comment-17190743 ] Robert Metzger commented on FLINK-17554: I confirmed that the leak is gone when using

[jira] [Commented] (FLINK-18858) Kinesis Flink SQL Connector

[ https://issues.apache.org/jira/browse/FLINK-18858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190744#comment-17190744 ] Timo Walther commented on FLINK-18858: -- Feel free to also ping me if you need any help. SQL

[GitHub] [flink] flinkbot edited a comment on pull request #13189: [FLINK-18661][Kinesis] Stream consumer Registration/Deregistration

flinkbot edited a comment on pull request #13189: URL: https://github.com/apache/flink/pull/13189#issuecomment-675350675 ## CI report: * 17ab6b978f786d321781a589867fdd331731 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13102: [FLINK-18515][Kinesis] Adding FanOutRecordPublisher for Kinesis EFO support

flinkbot edited a comment on pull request #13102: URL: https://github.com/apache/flink/pull/13102#issuecomment-671238228 ## CI report: * 2d0fb75c7d741e191192c6647ffeb5a44b155e6f Azure:

[GitHub] [flink] azagrebin commented on a change in pull request #13284: [FLINK-17016][runtime] Enable pipelined region scheduling

azagrebin commented on a change in pull request #13284: URL: https://github.com/apache/flink/pull/13284#discussion_r480166064 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java ## @@ -300,6 +305,32 @@ public int getNumberOfVertices() {

[GitHub] [flink] Tartarus0zm commented on a change in pull request #13319: [FLINK-19022][runtime]Register the TerminationFuture of ResourceManager and Dispatcher with DispatcherResourceManagerComponen

Tartarus0zm commented on a change in pull request #13319: URL: https://github.com/apache/flink/pull/13319#discussion_r483637646 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DispatcherResourceManagerComponent.java ## @@ -88,6 +95,18

[jira] [Commented] (FLINK-19141) Flink Job Submitted on Yarn Does not Work

[ https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190727#comment-17190727 ] Huang Xiao commented on FLINK-19141: Hi, [~yunhui]. According to the log, it seems there's no

[GitHub] [flink] flinkbot edited a comment on pull request #13315: [FLINK-19070][hive] Hive connector should throw a meaningful exception if user reads/writes ACID tables

flinkbot edited a comment on pull request #13315: URL: https://github.com/apache/flink/pull/13315#issuecomment-686398823 ## CI report: * 2e0da845caf6355b898bdcff29e3b7ac56b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13295: [FLINK-18598][python][docs] Add instructions for asynchronous execute in PyFlink doc.

flinkbot edited a comment on pull request #13295: URL: https://github.com/apache/flink/pull/13295#issuecomment-684586420 ## CI report: * 38a9a93bc6f82f321b94390f74c19f89aa7d7eca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

flinkbot edited a comment on pull request #13109: URL: https://github.com/apache/flink/pull/13109#issuecomment-671381707 ## CI report: * 3a7e71c54243a063412da38da4be35c4f3b2d175 Azure:

[GitHub] [flink] haveanote commented on pull request #13324: [hotfix][docs] Fix ExecutionEnvironment.scala doc error

haveanote commented on pull request #13324: URL: https://github.com/apache/flink/pull/13324#issuecomment-687155612 @XComp ,not at all ,i'm happy to do it This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #13315: [FLINK-19070][hive] Hive connector should throw a meaningful exception if user reads/writes ACID tables

flinkbot edited a comment on pull request #13315: URL: https://github.com/apache/flink/pull/13315#issuecomment-686398823 ## CI report: * 2e0da845caf6355b898bdcff29e3b7ac56b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13295: [FLINK-18598][python][docs] Add instructions for asynchronous execute in PyFlink doc.

flinkbot edited a comment on pull request #13295: URL: https://github.com/apache/flink/pull/13295#issuecomment-684586420 ## CI report: * f67e466f192eaecfc167467334d844a571123afe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN * d34648bab5e9a642c97db6e98f80f8059500c145 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

flinkbot edited a comment on pull request #13109: URL: https://github.com/apache/flink/pull/13109#issuecomment-671381707 ## CI report: * 3a7e71c54243a063412da38da4be35c4f3b2d175 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13315: [FLINK-19070][hive] Hive connector should throw a meaningful exception if user reads/writes ACID tables

flinkbot edited a comment on pull request #13315: URL: https://github.com/apache/flink/pull/13315#issuecomment-686398823 ## CI report: * 2e0da845caf6355b898bdcff29e3b7ac56b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13316: [FLINK-14422][runtime] Expose network memory usage to TaskManagerDetailsHandler's endpoint

flinkbot edited a comment on pull request #13316: URL: https://github.com/apache/flink/pull/13316#issuecomment-686398901 ## CI report: * e37cb771c66ed8cab48e0b7abd53132fb15dfca3 UNKNOWN * 194b07dfb332eca1b8d99d0fe1425e117eff9b33 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13295: [FLINK-18598][python][docs] Add instructions for asynchronous execute in PyFlink doc.

flinkbot edited a comment on pull request #13295: URL: https://github.com/apache/flink/pull/13295#issuecomment-684586420 ## CI report: * f67e466f192eaecfc167467334d844a571123afe Azure:

[GitHub] [flink] lirui-apache commented on a change in pull request #13315: [FLINK-19070][hive] Hive connector should throw a meaningful exception if user reads/writes ACID tables

lirui-apache commented on a change in pull request #13315: URL: https://github.com/apache/flink/pull/13315#discussion_r483604044 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java ## @@ -328,4 +330,16 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13274: [FLINK-19061][hive] HiveCatalog fails to get partition column stats i…

flinkbot edited a comment on pull request #13274: URL: https://github.com/apache/flink/pull/13274#issuecomment-682368291 ## CI report: * 6d99f26131d335a4548c7eb7d5c64611d3de8094 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13329: [hot fix]fix typo in the java doc

flinkbot edited a comment on pull request #13329: URL: https://github.com/apache/flink/pull/13329#issuecomment-687023379 ## CI report: * 54964991f6b3ec7b12f2cb045d29a2a33dad1011 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #13320: [FLINK-19035] Remove fold from DataStream API

twalthr commented on a change in pull request #13320: URL: https://github.com/apache/flink/pull/13320#discussion_r483589525 ## File path: flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/AllWindowTranslationTest.scala ## @@ -91,54 +91,10 @@ class

[GitHub] [flink] twalthr commented on a change in pull request #13320: [FLINK-19035] Remove fold from DataStream API

twalthr commented on a change in pull request #13320: URL: https://github.com/apache/flink/pull/13320#discussion_r483589434 ## File path: flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowTranslationTest.scala ## @@ -92,56 +93,10 @@ class

[GitHub] [flink] flinkbot edited a comment on pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

flinkbot edited a comment on pull request #13327: URL: https://github.com/apache/flink/pull/13327#issuecomment-687006937 ## CI report: * 352380e8ab8941541fbc1773bcd29820bcf646c3 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #13320: [FLINK-19035] Remove fold from DataStream API

twalthr commented on a change in pull request #13320: URL: https://github.com/apache/flink/pull/13320#discussion_r483579510 ## File path: flink-streaming-scala/pom.xml ## @@ -262,6 +262,22 @@ under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN * d34648bab5e9a642c97db6e98f80f8059500c145 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13326: [FLINK-19133] Open custom partitioners in KafkaSerializationSchemaWrapper

flinkbot edited a comment on pull request #13326: URL: https://github.com/apache/flink/pull/13326#issuecomment-686943261 ## CI report: * e8a32ce376b09df4766fd6ddd439d8f634210ad7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13321: [FLINK-14870] Remove nullable assumption of task slot sharing group

flinkbot edited a comment on pull request #13321: URL: https://github.com/apache/flink/pull/13321#issuecomment-686567896 ## CI report: * d79f152fa91b8bc555af6fb2a00a8d62b184be5a UNKNOWN * bcd04d78e47e1c3a9b0cb0165d625f424dea4951 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13295: [FLINK-18598][python][docs] Add instructions for asynchronous execute in PyFlink doc.

flinkbot edited a comment on pull request #13295: URL: https://github.com/apache/flink/pull/13295#issuecomment-684586420 ## CI report: * f67e466f192eaecfc167467334d844a571123afe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13314: [FLINK-18913][docs][python] Add a "TableEnvironment" document under the "Python API" -> "Table API User's Guide" section

flinkbot edited a comment on pull request #13314: URL: https://github.com/apache/flink/pull/13314#issuecomment-686373715 ## CI report: * 7566c3c966f7771fc6cb14970c9ccf318c6ba5ce Azure:

[GitHub] [flink] azagrebin commented on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

azagrebin commented on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-687108594 Thanks for the review @tillrohrmann and @zhuzhurk I have addressed comments This is an automated message

[jira] [Closed] (FLINK-19036) Translate page 'Application Profiling & Debugging' of 'Debugging & Monitoring' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19036. --- Resolution: Fixed master: 5cce7652f5afa31c4bd25c2819aadbd58d4c8ce3 > Translate page 'Application Profiling

[jira] [Updated] (FLINK-19036) Translate page 'Application Profiling & Debugging' of 'Debugging & Monitoring' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19036: Fix Version/s: 1.12.0 > Translate page 'Application Profiling & Debugging' of 'Debugging & > Monitoring'

[GitHub] [flink] dianfu closed pull request #13235: [FLINK-19036][docs-zh] Translate page 'Application Profiling & Debugging' of 'Debugging & Monitoring' into Chinese

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

[GitHub] [flink] azagrebin commented on a change in pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

azagrebin commented on a change in pull request #13181: URL: https://github.com/apache/flink/pull/13181#discussion_r483577436 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java ## @@ -108,27 +122,30 @@

[jira] [Updated] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-19142: Affects Version/s: 1.12.0 > Investigate slot hijacking from preceding pipelined regions

[jira] [Updated] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-19142: Component/s: Runtime / Coordination > Investigate slot hijacking from preceding pipelined

[jira] [Created] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

Andrey Zagrebin created FLINK-19142: --- Summary: Investigate slot hijacking from preceding pipelined regions after failover Key: FLINK-19142 URL: https://issues.apache.org/jira/browse/FLINK-19142

[GitHub] [flink] flinkbot edited a comment on pull request #13330: [FLINK-19004][table-planner-blink] Use FIRST_VALUE when re-write non-…

flinkbot edited a comment on pull request #13330: URL: https://github.com/apache/flink/pull/13330#issuecomment-687094698 ## CI report: * dda51e888c3f58e83346118f03ad55075e990eb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13295: [FLINK-18598][python][docs] Add instructions for asynchronous execute in PyFlink doc.

flinkbot edited a comment on pull request #13295: URL: https://github.com/apache/flink/pull/13295#issuecomment-684586420 ## CI report: * f67e466f192eaecfc167467334d844a571123afe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13284: [FLINK-17016][runtime] Enable pipelined region scheduling

flinkbot edited a comment on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000 ## CI report: * c89d0141f4a854bc7deb4512a2b2007fccfb13fd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13216: [FLINK-18999][table-planner-blink][hive] Temporary generic table does…

flinkbot edited a comment on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 31eef5a5d1f413435c3a3ccd9764c185b66c1c08 Azure:

[GitHub] [flink] XComp commented on pull request #13218: remove unnecessary integer boxing

XComp commented on pull request #13218: URL: https://github.com/apache/flink/pull/13218#issuecomment-687098584 Thanks for looking into this. But the issue was fixed already in c34c7e41. This is an automated message from the

[jira] [Commented] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable

[ https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190687#comment-17190687 ] Till Rohrmann commented on FLINK-18815: --- Thanks for the analysis [~kezhuw]. I am not totally

[jira] [Updated] (FLINK-19127) Provide a replacement of StreamExecutionEnvironment.createRemoteEnvironment for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-19127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-19127: - Description: Connecting to a remote cluster from the unified TableEnvironment is neither tested

[GitHub] [flink] shuiqiangchen commented on pull request #13295: [FLINK-18598][python][docs] Add instructions for asynchronous execute in PyFlink doc.

shuiqiangchen commented on pull request #13295: URL: https://github.com/apache/flink/pull/13295#issuecomment-687096968 @dianfu Highly appreciate for your suggestions, I have updated the PR, please have a look. This is an

[GitHub] [flink] XComp commented on pull request #13241: [hotfix] Fix a typo in the watermark docs

XComp commented on pull request #13241: URL: https://github.com/apache/flink/pull/13241#issuecomment-687095970 FYI: The Chinese version of this file is already translated and, therefore, does not need to be changed. This is

[GitHub] [flink] flinkbot commented on pull request #13330: [FLINK-19004][table-planner-blink] Use FIRST_VALUE when re-write non-…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13216: [FLINK-18999][table-planner-blink][hive] Temporary generic table does…

flinkbot edited a comment on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 31eef5a5d1f413435c3a3ccd9764c185b66c1c08 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

flinkbot edited a comment on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836 ## CI report: * 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN * ece578a9fdbaee4d815de501187d92a729790c9b Azure:

[GitHub] [flink] XComp edited a comment on pull request #13270: [hotfix] [javadocs] fix typo in TaskManagerServices

XComp edited a comment on pull request #13270: URL: https://github.com/apache/flink/pull/13270#issuecomment-687094033 Thanks for your contribution. Not sure whether this fix is necessary since the `iff` is also perfectly fine here, though (see

[GitHub] [flink] XComp commented on pull request #13270: [hotfix] [javadocs] fix typo in TaskManagerServices

XComp commented on pull request #13270: URL: https://github.com/apache/flink/pull/13270#issuecomment-687094033 Not sure whether this fix is necessary since the `iff` is also perfectly fine here (see [Wikipedia](https://en.wikipedia.org/wiki/If_and_only_if)).

[GitHub] [flink] dianfu commented on a change in pull request #13292: [FLINK-19097][python] Support add_jars() for Python StreamExecutionEnvironment.

dianfu commented on a change in pull request #13292: URL: https://github.com/apache/flink/pull/13292#discussion_r483563989 ## File path: flink-python/pyflink/datastream/stream_execution_environment.py ## @@ -553,6 +553,33 @@ def set_python_executable(self, python_exec: str):

[jira] [Updated] (FLINK-19135) (Stream)ExecutionEnvironment.execute() should not throw ExecutionException

[ https://issues.apache.org/jira/browse/FLINK-19135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19135: - Affects Version/s: 1.12.0 1.10.0 1.11.0 >

[GitHub] [flink] flinkbot commented on pull request #13330: [FLINK-19004][table-planner-blink] Use FIRST_VALUE when re-write non-…

flinkbot commented on pull request #13330: URL: https://github.com/apache/flink/pull/13330#issuecomment-687087968 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 edited a comment on pull request #13306: [FLINK-17779][Connectors/ORC]Orc file format support filter push down

flinkbot edited a comment on pull request #13306: URL: https://github.com/apache/flink/pull/13306#issuecomment-685717187 ## CI report: * a7f4abab05ad875bf6acef6510fcec6df7d2dc6c UNKNOWN * 8048b8f9ded32203cb0ca0761414ef7186a68e5f Azure:

[jira] [Updated] (FLINK-19004) Fail to call Hive percentile function together with distinct aggregate call

[ https://issues.apache.org/jira/browse/FLINK-19004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19004: --- Labels: pull-request-available (was: ) > Fail to call Hive percentile function together

[GitHub] [flink] lirui-apache opened a new pull request #13330: [FLINK-19004][table-planner-blink] Use FIRST_VALUE when re-write non-…

lirui-apache opened a new pull request #13330: URL: https://github.com/apache/flink/pull/13330 …distinct agg call in FlinkAggregateExpandDistinctAggregatesRule ## What is the purpose of the change Fix the issue that Hive `percentile` UDAF cannot be used together with

[jira] [Closed] (FLINK-18984) Add tutorial documentation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18984. --- Resolution: Resolved > Add tutorial documentation for Python DataStream API >

[jira] [Commented] (FLINK-18984) Add tutorial documentation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190683#comment-17190683 ] Hequn Cheng commented on FLINK-18984: - Resolved in 1.12.0 via

  1   2   3   >