[GitHub] [flink] flinkbot edited a comment on pull request #15458: [FLINK-22064][table] Don't submit statement set when no insert is added in the sql client

flinkbot edited a comment on pull request #15458: URL: https://github.com/apache/flink/pull/15458#issuecomment-811149954 ## CI report: * e97c9b4bc77bb3842f3fb72396dcee2acac9fb5d Azure:

[jira] [Commented] (FLINK-22003) UnalignedCheckpointITCase fail

[ https://issues.apache.org/jira/browse/FLINK-22003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312877#comment-17312877 ] Yun Gao commented on FLINK-22003: - Hi, I think [~roman_khachatryan] is exactly right for the conditions

[GitHub] [flink] wangyang0918 commented on a change in pull request #15396: [FLINK-21008][coordination] Register a shutdown supplier in the SignalHandler for ClusterEntrypoint

wangyang0918 commented on a change in pull request #15396: URL: https://github.com/apache/flink/pull/15396#discussion_r605389503 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/SignalHandler.java ## @@ -53,6 +63,13 @@ public void handle(Signal signal)

[GitHub] [flink] wangyang0918 commented on a change in pull request #15396: [FLINK-21008][coordination] Register a shutdown supplier in the SignalHandler for ClusterEntrypoint

wangyang0918 commented on a change in pull request #15396: URL: https://github.com/apache/flink/pull/15396#discussion_r605388703 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/SignalHandler.java ## @@ -53,6 +63,13 @@ public void handle(Signal signal)

[jira] [Commented] (FLINK-22082) Nested projection push down doesn't work for data such as row(array(row))

[ https://issues.apache.org/jira/browse/FLINK-22082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312872#comment-17312872 ] Jark Wu commented on FLINK-22082: - {{FileSystemTableSource}} doesn't support nested projection pushdown

[GitHub] [flink] wangyang0918 commented on a change in pull request #15396: [FLINK-21008][coordination] Register a shutdown supplier in the SignalHandler for ClusterEntrypoint

wangyang0918 commented on a change in pull request #15396: URL: https://github.com/apache/flink/pull/15396#discussion_r605386244 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java ## @@ -366,7 +366,7 @@ protected

[GitHub] [flink] flinkbot edited a comment on pull request #15442: [FLINK-22081][flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

flinkbot edited a comment on pull request #15442: URL: https://github.com/apache/flink/pull/15442#issuecomment-810703449 ## CI report: * 35f4bea03e4bfd96ca125d9980bc3fcdced52d79 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15407: [FLINK-21942][coordination] Remove job from LeaderIdService when disconnecting JobManager with globally terminal state

flinkbot edited a comment on pull request #15407: URL: https://github.com/apache/flink/pull/15407#issuecomment-809165650 ## CI report: * 5611a9d38557ba108df1e64b9f306f5cf98268d5 Azure:

[GitHub] [flink] wangyang0918 commented on pull request #15407: [FLINK-21942][coordination] Remove job from LeaderIdService when disconnecting JobManager with globally terminal state

wangyang0918 commented on pull request #15407: URL: https://github.com/apache/flink/pull/15407#issuecomment-811652456 @tillrohrmann Thanks for your review. Comments addressed and force pushed. -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-22082) Nested projection push down doesn't work for data: row(array(row))

[ https://issues.apache.org/jira/browse/FLINK-22082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312868#comment-17312868 ] Dian Fu commented on FLINK-22082: - cc [~fsk119] > Nested projection push down doesn't work for data:

[jira] [Updated] (FLINK-22082) Nested projection push down doesn't work for data such as row(array(row))

[ https://issues.apache.org/jira/browse/FLINK-22082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22082: Summary: Nested projection push down doesn't work for data such as row(array(row)) (was: Nested

[jira] [Created] (FLINK-22082) Nested projection push down doesn't work for data: row(array(row))

Dian Fu created FLINK-22082: --- Summary: Nested projection push down doesn't work for data: row(array(row)) Key: FLINK-22082 URL: https://issues.apache.org/jira/browse/FLINK-22082 Project: Flink

[jira] [Commented] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312867#comment-17312867 ] Chen Qin commented on FLINK-22081: -- [~AHeise] could you assign this Jira to me and help review pr? >

[jira] [Updated] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-22081: - Description: Using flink 1.11.2 I added the flink-s3-fs-hadoop jar in plugins dir but I am seeing the

[jira] [Updated] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-22081: - Description: Using flink 1.11.2 I added the flink-s3-fs-hadoop jar in plugins dir but I am seeing the

[jira] [Updated] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-22081: - Attachment: image (13).png > Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin >

[jira] [Updated] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-22081: - Description: Using flink 1.11.2 I added the flink-s3-fs-hadoop jar in plugins dir but I am seeing the

[GitHub] [flink] flinkbot edited a comment on pull request #15458: [FLINK-22064][table] Don't submit statement set when no insert is added in the sql client

flinkbot edited a comment on pull request #15458: URL: https://github.com/apache/flink/pull/15458#issuecomment-811149954 ## CI report: * e97c9b4bc77bb3842f3fb72396dcee2acac9fb5d Azure:

[jira] [Updated] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-22081: - Description: Using flink 1.11.2 I added the flink-s3-fs-hadoop jar in plugins dir but I am seeing the

[GitHub] [flink] flinkbot edited a comment on pull request #15442: [FLINK-22081][flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

flinkbot edited a comment on pull request #15442: URL: https://github.com/apache/flink/pull/15442#issuecomment-810703449 ## CI report: * 35f4bea03e4bfd96ca125d9980bc3fcdced52d79 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15407: [FLINK-21942][coordination] Remove job from LeaderIdService when disconnecting JobManager with globally terminal state

flinkbot edited a comment on pull request #15407: URL: https://github.com/apache/flink/pull/15407#issuecomment-809165650 ## CI report: * 5611a9d38557ba108df1e64b9f306f5cf98268d5 Azure:

[GitHub] [flink] chenqin commented on pull request #15442: [FLINK-22081][flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

chenqin commented on pull request #15442: URL: https://github.com/apache/flink/pull/15442#issuecomment-811641843 > I just noticed that you recycled a rather old ticket. Could you please create a new one that I can assign to you? FLINK-22081 -- This is an automated message from

[jira] [Updated] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-22081: - Fix Version/s: 1.10.2 1.10.3 1.11.1 1.11.2

[GitHub] [flink] flinkbot edited a comment on pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

flinkbot edited a comment on pull request #15411: URL: https://github.com/apache/flink/pull/15411#issuecomment-809191175 ## CI report: * 386a106bff7eda5396dc95f088c7121bbb55a73f Azure:

[jira] [Created] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

Chen Qin created FLINK-22081: Summary: Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin Key: FLINK-22081 URL: https://issues.apache.org/jira/browse/FLINK-22081 Project: Flink

[GitHub] [flink] wangyang0918 commented on a change in pull request #15407: [FLINK-21942][coordination] Remove job from LeaderIdService when disconnecting JobManager with globally terminal state

wangyang0918 commented on a change in pull request #15407: URL: https://github.com/apache/flink/pull/15407#discussion_r605371557 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -509,6 +509,11 @@ public void

[jira] [Created] (FLINK-22080) Refactor SqlClient for better testing

Jark Wu created FLINK-22080: --- Summary: Refactor SqlClient for better testing Key: FLINK-22080 URL: https://issues.apache.org/jira/browse/FLINK-22080 Project: Flink Issue Type: Improvement

[GitHub] [flink] wuchong commented on a change in pull request #15458: [FLINK-22064][table] Don't submit statement set when no insert is added in the sql client

wuchong commented on a change in pull request #15458: URL: https://github.com/apache/flink/pull/15458#discussion_r605364874 ## File path: flink-table/flink-sql-client/src/test/resources/sql/statement_set.q ## @@ -152,3 +152,10 @@ SELECT * FROM BatchTable;

[GitHub] [flink] flinkbot edited a comment on pull request #15437: [FLINK-20320][sql-client] support init sql file in sql client

flinkbot edited a comment on pull request #15437: URL: https://github.com/apache/flink/pull/15437#issuecomment-810431644 ## CI report: * 71c1edd98caa64cc1fe447f878f8cbc1321eb40b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

flinkbot edited a comment on pull request #15411: URL: https://github.com/apache/flink/pull/15411#issuecomment-809191175 ## CI report: * 386a106bff7eda5396dc95f088c7121bbb55a73f Azure:

[jira] [Updated] (FLINK-22077) Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-22077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22077: - Description: h3. Introduction We implement a wrong way to calculate cross-region

[jira] [Updated] (FLINK-22077) Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-22077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22077: - Description: h3. Introduction We implement a wrong way to calculate cross-region

[GitHub] [flink] wuchong commented on a change in pull request #15458: [FLINK-22064][table] Don't submit statement set when no insert is added in the sql client

wuchong commented on a change in pull request #15458: URL: https://github.com/apache/flink/pull/15458#discussion_r605363528 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStrings.java ## @@ -212,6 +212,9 @@ private CliStrings() {

[jira] [Updated] (FLINK-22077) Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-22077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22077: - Description: h3. Introduction We implement a wrong way to calculate cross-region

[jira] [Issue Comment Deleted] (FLINK-22077) Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-22077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22077: - Comment: was deleted (was: cc [~trohrmann] I personally think it's necessary to add this

[jira] [Commented] (FLINK-22079) ReactiveModeITCase stack with fine grained resource manager.

[ https://issues.apache.org/jira/browse/FLINK-22079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312850#comment-17312850 ] Xintong Song commented on FLINK-22079: -- cc [~rmetzger] > ReactiveModeITCase stack with fine

[jira] [Created] (FLINK-22078) Introduce a Printer interface to rederict the output to the desired stream

Shengkai Fang created FLINK-22078: - Summary: Introduce a Printer interface to rederict the output to the desired stream Key: FLINK-22078 URL: https://issues.apache.org/jira/browse/FLINK-22078

[jira] [Created] (FLINK-22079) ReactiveModeITCase stack with fine grained resource manager.

Xintong Song created FLINK-22079: Summary: ReactiveModeITCase stack with fine grained resource manager. Key: FLINK-22079 URL: https://issues.apache.org/jira/browse/FLINK-22079 Project: Flink

[jira] [Commented] (FLINK-22077) Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-22077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312849#comment-17312849 ] Zhilong Hong commented on FLINK-22077: -- cc [~trohrmann] I personally think it's necessary to add

[jira] [Updated] (FLINK-22077) Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-22077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22077: - Description: h3. Introduction We implement a wrong way to calculate cross-region

[jira] [Updated] (FLINK-22077) Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

[ https://issues.apache.org/jira/browse/FLINK-22077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22077: - Description: h3. Introduction We implement a wrong way to calculate cross-region

[GitHub] [flink] flinkbot edited a comment on pull request #15437: [FLINK-20320][sql-client] support init sql file in sql client

flinkbot edited a comment on pull request #15437: URL: https://github.com/apache/flink/pull/15437#issuecomment-810431644 ## CI report: * 71c1edd98caa64cc1fe447f878f8cbc1321eb40b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15280: [FLINK-21714][table-api] Use TIMESTAMP_LTZ as return type for function PROCTIME()

flinkbot edited a comment on pull request #15280: URL: https://github.com/apache/flink/pull/15280#issuecomment-802654466 ## CI report: * 3b4b5fcd9d8108b51e0bf62a0bee888b4fdb5186 UNKNOWN * f80daf3fbf6f5f5ce1d39813fbecf9866eb50efb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * 0cfa410c4bfa324f1fab08032f3992833fb4ceb7 Azure:

[GitHub] [flink] xintongsong commented on a change in pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

xintongsong commented on a change in pull request #15411: URL: https://github.com/apache/flink/pull/15411#discussion_r605325307 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java ## @@ -262,4 +269,268 @@ protected ExtendedEndpoint(

[jira] [Commented] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312831#comment-17312831 ] Yun Tang commented on FLINK-20816: -- >From the comparison of success and failure logs, I think the root

[jira] [Created] (FLINK-22077) Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy

Zhilong Hong created FLINK-22077: Summary: Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy Key: FLINK-22077 URL: https://issues.apache.org/jira/browse/FLINK-22077

[GitHub] [flink] flinkbot edited a comment on pull request #15280: [FLINK-21714][table-api] Use TIMESTAMP_LTZ as return type for function PROCTIME()

flinkbot edited a comment on pull request #15280: URL: https://github.com/apache/flink/pull/15280#issuecomment-802654466 ## CI report: * 3b4b5fcd9d8108b51e0bf62a0bee888b4fdb5186 UNKNOWN * f80daf3fbf6f5f5ce1d39813fbecf9866eb50efb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * 0cfa410c4bfa324f1fab08032f3992833fb4ceb7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15456: [BP-1.12][FLINK-21685][k8s] Use dedicated thread pool for Kubernetes client IO operations

flinkbot edited a comment on pull request #15456: URL: https://github.com/apache/flink/pull/15456#issuecomment-811085523 ## CI report: * 4f07860cd382e6e188ac739b4aa9262e1a9da7bf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15456: [BP-1.12][FLINK-21685][k8s] Use dedicated thread pool for Kubernetes client IO operations

flinkbot edited a comment on pull request #15456: URL: https://github.com/apache/flink/pull/15456#issuecomment-811085523 ## CI report: * 4f07860cd382e6e188ac739b4aa9262e1a9da7bf Azure:

[jira] [Assigned] (FLINK-21808) Support DQL/DML in HiveParser

[ https://issues.apache.org/jira/browse/FLINK-21808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21808: --- Assignee: Rui Li > Support DQL/DML in HiveParser > - > >

[jira] [Closed] (FLINK-21808) Support DQL/DML in HiveParser

[ https://issues.apache.org/jira/browse/FLINK-21808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21808. --- Resolution: Fixed Fixed in master: 9222c55da340d4e5fa1dbfe67286df3bc90665cb...

[GitHub] [flink] wuchong closed pull request #15253: [FLINK-21808][hive] Support DQL/DML in HiveParser

wuchong closed pull request #15253: URL: https://github.com/apache/flink/pull/15253 -- 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. For queries about this service,

[GitHub] [flink] wangyang0918 commented on a change in pull request #15385: [FLINK-21685][k8s] Introduce dedicated thread pool and cache for Kubernetes client

wangyang0918 commented on a change in pull request #15385: URL: https://github.com/apache/flink/pull/15385#discussion_r605336670 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java ## @@ -75,12 +77,12 @@ private

[GitHub] [flink] wangyang0918 commented on pull request #15456: [BP-1.12][FLINK-21685][k8s] Use dedicated thread pool for Kubernetes client IO operations

wangyang0918 commented on pull request #15456: URL: https://github.com/apache/flink/pull/15456#issuecomment-811592529 The azure pipeline failed because something is wrong with the alicloud-mvn-mirror. Trigger again. @flinkbot run azure -- This is an automated message from the

[GitHub] [flink] wuchong commented on pull request #15253: [FLINK-21808][hive] Support DQL/DML in HiveParser

wuchong commented on pull request #15253: URL: https://github.com/apache/flink/pull/15253#issuecomment-811591878 I will merge this for now. The failed test should be related to FLINK-20558. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Comment Edited] (FLINK-20558) ParquetAvroStreamingFileSinkITCase.testWriteParquetAvroSpecific test failure

[ https://issues.apache.org/jira/browse/FLINK-20558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312812#comment-17312812 ] Jark Wu edited comment on FLINK-20558 at 4/1/21, 2:28 AM: --

[jira] [Commented] (FLINK-20558) ParquetAvroStreamingFileSinkITCase.testWriteParquetAvroSpecific test failure

[ https://issues.apache.org/jira/browse/FLINK-20558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312812#comment-17312812 ] Jark Wu commented on FLINK-20558: -

[jira] [Closed] (FLINK-21191) Support reducing buffer for upsert-kafka sink

[ https://issues.apache.org/jira/browse/FLINK-21191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21191. --- Resolution: Fixed Fixed in master: ec9b0c5b60290697769415eb3e1b1ed2052460ac > Support reducing buffer for

[GitHub] [flink] wuchong closed pull request #15434: [FLINK-21191][upsert-kafka] Support buffered sink function for upsert…

wuchong closed pull request #15434: URL: https://github.com/apache/flink/pull/15434 -- 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. For queries about this service,

[jira] [Created] (FLINK-22076) Python Test failed with "OSError: [Errno 12] Cannot allocate memory"

Huang Xingbo created FLINK-22076: Summary: Python Test failed with "OSError: [Errno 12] Cannot allocate memory" Key: FLINK-22076 URL: https://issues.apache.org/jira/browse/FLINK-22076 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 0b5aaf42f2861a38e26a80e25cf2324e7cf06bb7 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15461: [FLINK-21817][connector/kafka] Remove split assignment tracking and make worker thread stateless in Kafka enumerator

flinkbot edited a comment on pull request #15461: URL: https://github.com/apache/flink/pull/15461#issuecomment-811315471 ## CI report: * 610bda77e51cd92403f69ac09ae73c3d9a463386 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15434: [FLINK-21191][upsert-kafka] Support buffered sink function for upsert…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15460: [FLINK-22050][runtime] Don't release StreamTask network resources from TaskCanceller

flinkbot edited a comment on pull request #15460: URL: https://github.com/apache/flink/pull/15460#issuecomment-811196253 ## CI report: * 76187017457341aae886aa4a3180b61ae2fa93de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 0b5aaf42f2861a38e26a80e25cf2324e7cf06bb7 UNKNOWN *

[jira] [Commented] (FLINK-21976) Move Flink ML pipeline API and library code to a separate repository named flink-ml

[ https://issues.apache.org/jira/browse/FLINK-21976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312789#comment-17312789 ] Dian Fu commented on FLINK-21976: - Removed flink-ml from Flink repo via 

[GitHub] [flink] dianfu closed pull request #15405: [Flink-21976] Remove Flink ML pipeline API and library code from the Flink repo

dianfu closed pull request #15405: URL: https://github.com/apache/flink/pull/15405 -- 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. For queries about this service, please

[GitHub] [flink] flinkbot edited a comment on pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

flinkbot edited a comment on pull request #15411: URL: https://github.com/apache/flink/pull/15411#issuecomment-809191175 ## CI report: * 386a106bff7eda5396dc95f088c7121bbb55a73f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15458: [FLINK-22064][table] Don't submit statement set when no insert is added in the sql client

flinkbot edited a comment on pull request #15458: URL: https://github.com/apache/flink/pull/15458#issuecomment-811149954 ## CI report: * e97c9b4bc77bb3842f3fb72396dcee2acac9fb5d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15437: [FLINK-20320][sql-client] support init sql file in sql client

flinkbot edited a comment on pull request #15437: URL: https://github.com/apache/flink/pull/15437#issuecomment-810431644 ## CI report: * 71c1edd98caa64cc1fe447f878f8cbc1321eb40b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

flinkbot edited a comment on pull request #15411: URL: https://github.com/apache/flink/pull/15411#issuecomment-809191175 ## CI report: * 386a106bff7eda5396dc95f088c7121bbb55a73f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 0b5aaf42f2861a38e26a80e25cf2324e7cf06bb7 UNKNOWN *

[GitHub] [flink] StephanEwen commented on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

StephanEwen commented on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-811513817 Looks good to me, +1 to merge after rebasing. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] est08zw commented on a change in pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

est08zw commented on a change in pull request #15411: URL: https://github.com/apache/flink/pull/15411#discussion_r605263050 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java ## @@ -262,4 +267,136 @@ protected ExtendedEndpoint(

[GitHub] [flink] est08zw commented on a change in pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

est08zw commented on a change in pull request #15411: URL: https://github.com/apache/flink/pull/15411#discussion_r605262390 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java ## @@ -262,4 +267,136 @@ protected ExtendedEndpoint(

[GitHub] [flink] est08zw commented on a change in pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

est08zw commented on a change in pull request #15411: URL: https://github.com/apache/flink/pull/15411#discussion_r605261249 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java ## @@ -262,4 +267,136 @@ protected ExtendedEndpoint(

[GitHub] [flink] est08zw commented on a change in pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

est08zw commented on a change in pull request #15411: URL: https://github.com/apache/flink/pull/15411#discussion_r605260386 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java ## @@ -262,4 +267,136 @@ protected ExtendedEndpoint(

[GitHub] [flink] est08zw commented on a change in pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

est08zw commented on a change in pull request #15411: URL: https://github.com/apache/flink/pull/15411#discussion_r605259670 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java ## @@ -262,4 +267,136 @@ protected ExtendedEndpoint(

[GitHub] [flink] StephanEwen commented on pull request #15397: [FLINK-21817][connector/common] Remove split assignment tracker from coordinator state

StephanEwen commented on pull request #15397: URL: https://github.com/apache/flink/pull/15397#issuecomment-811503088 Sorry, had to abort the merge because the compile failed with a checkstyle issue... -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] StephanEwen closed pull request #15429: [FLINK-21935] Remove 'state.backend.async' option

StephanEwen closed pull request #15429: URL: https://github.com/apache/flink/pull/15429 -- 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. For queries about this service,

[GitHub] [flink] StephanEwen closed pull request #15449: [FLINK-22053][core] Allow NumberSequenceSource to have less splits than parallelism.

StephanEwen closed pull request #15449: URL: https://github.com/apache/flink/pull/15449 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

flinkbot edited a comment on pull request #15441: URL: https://github.com/apache/flink/pull/15441#issuecomment-810695518 ## CI report: * ca1680265a1fd5b1049d597202efbb992f71fb95 Azure:

[GitHub] [flink] StephanEwen commented on a change in pull request #15461: [FLINK-21817][connector/kafka] Remove split assignment tracking and make worker thread stateless in Kafka enumerator

StephanEwen commented on a change in pull request #15461: URL: https://github.com/apache/flink/pull/15461#discussion_r605201241 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #15456: [BP-1.12][FLINK-21685][k8s] Use dedicated thread pool for Kubernetes client IO operations

flinkbot edited a comment on pull request #15456: URL: https://github.com/apache/flink/pull/15456#issuecomment-811085523 ## CI report: * 4f07860cd382e6e188ac739b4aa9262e1a9da7bf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

flinkbot edited a comment on pull request #15441: URL: https://github.com/apache/flink/pull/15441#issuecomment-810695518 ## CI report: * ca1680265a1fd5b1049d597202efbb992f71fb95 Azure:

[jira] [Closed] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17012. -- Fix Version/s: 1.13.0 Release Note: Task's RUNNING state was split into two states:

[GitHub] [flink] pnowojski closed pull request #15375: [FLINK-17012][streaming] Implemented the separated 'restore' method for StreamTask

pnowojski closed pull request #15375: URL: https://github.com/apache/flink/pull/15375 -- 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. For queries about this service,

[GitHub] [flink] pnowojski commented on pull request #15375: [FLINK-17012][streaming] Implemented the separated 'restore' method for StreamTask

pnowojski commented on pull request #15375: URL: https://github.com/apache/flink/pull/15375#issuecomment-811465586 The final build is almost done, except of e2e tests. Compared to previous builds there were no significant changes (java docs vs the previous build or renames vs the build

[GitHub] [flink] sjwiesman commented on pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

sjwiesman commented on pull request #15441: URL: https://github.com/apache/flink/pull/15441#issuecomment-811465353 Thanks @dianfu. I've made the final fix. Since this is based #15429 I will wait on that PR to finish before merging. -- This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

flinkbot edited a comment on pull request #15441: URL: https://github.com/apache/flink/pull/15441#issuecomment-810695518 ## CI report: * ca1680265a1fd5b1049d597202efbb992f71fb95 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15434: [FLINK-21191][upsert-kafka] Support buffered sink function for upsert…

flinkbot edited a comment on pull request #15434: URL: https://github.com/apache/flink/pull/15434#issuecomment-810339027 ## CI report: * 7c32b2a7767dc356df8f7949646e4e586c65ed8a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15405: [Flink-21976] Remove Flink ML pipeline API and library code from the Flink repo

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

[GitHub] [flink] flinkbot edited a comment on pull request #15385: [FLINK-21685][k8s] Introduce dedicated thread pool and cache for Kubernetes client

flinkbot edited a comment on pull request #15385: URL: https://github.com/apache/flink/pull/15385#issuecomment-808104280 ## CI report: * c628943d4da91fddf19f7c47cb8c9120f61c3ce5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15397: [FLINK-21817][connector/common] Remove split assignment tracker from coordinator state

flinkbot edited a comment on pull request #15397: URL: https://github.com/apache/flink/pull/15397#issuecomment-808916074 ## CI report: * 3ff767f2f01190feee3c93c09048f92e977d8b8f UNKNOWN * ca1e7a3bfb2f8fada3699e84d12eddb17aef2a87 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15375: [FLINK-17012][streaming] Implemented the separated 'restore' method for StreamTask

flinkbot edited a comment on pull request #15375: URL: https://github.com/apache/flink/pull/15375#issuecomment-807081996 ## CI report: * 6366c66172146c943ef8dda07f3c044c87379ef1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 619fedb31ed33e3501be115fc618aa41f5dab8bc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 0b5aaf42f2861a38e26a80e25cf2324e7cf06bb7 UNKNOWN *

[GitHub] [flink] StephanEwen commented on pull request #15461: [FLINK-21817][connector/kafka] Remove split assignment tracking and make worker thread stateless in Kafka enumerator

StephanEwen commented on pull request #15461: URL: https://github.com/apache/flink/pull/15461#issuecomment-811445749 Thanks for picking up these changes and taking the initiative to change the bookkeeping of splits, in addition to the bugfix. I originally meant to postpone the

  1   2   3   4   5   6   7   >