[jira] [Commented] (FLINK-21986) taskmanager native memory not release timely after restart

[ https://issues.apache.org/jira/browse/FLINK-21986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312920#comment-17312920 ] Yun Tang commented on FLINK-21986: -- [~Feifan Wang] I think this is really weird after l

[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: * 5f2a1ada2fd1124bc6950fdbfea8747fecf0ab1d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge RowDa

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

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][rest][ui] Vertex 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 * a682564bcc9fe670b70fd526258b799f7143

[jira] [Commented] (FLINK-21823) RocksDB on FreeBSD

[ https://issues.apache.org/jira/browse/FLINK-21823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312909#comment-17312909 ] Yun Tang commented on FLINK-21823: -- It seems like a RocksDB bug to detect platform, do

[jira] [Commented] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312906#comment-17312906 ] Yun Tang commented on FLINK-21321: -- [~legojoey17] I think we can leverage this once we

[GitHub] [flink] flinkbot edited a comment on pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge RowDa

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

[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: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-21439) Add support for exception history

[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312898#comment-17312898 ] John Phelan commented on FLINK-21439: - hi [~mapohl] [~rmetzger] It seems like the {

[GitHub] [flink] Myasuka closed pull request #15091: [FLINK-16444][state] Count the get/put/seek/next/writeBatch latency of RocksDB as metrics

Myasuka closed pull request #15091: URL: https://github.com/apache/flink/pull/15091 -- 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] Myasuka commented on pull request #15091: [FLINK-16444][state] Count the get/put/seek/next/writeBatch latency of RocksDB as metrics

Myasuka commented on pull request #15091: URL: https://github.com/apache/flink/pull/15091#issuecomment-811674251 Aborted by more general PR https://github.com/apache/flink/pull/15119 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[jira] [Resolved] (FLINK-16444) Count the read/write/seek/next latency of RocksDB as metrics

[ https://issues.apache.org/jira/browse/FLINK-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-16444. -- Resolution: Fixed > Count the read/write/seek/next latency of RocksDB as metrics > ---

[jira] [Commented] (FLINK-16444) Count the read/write/seek/next latency of RocksDB as metrics

[ https://issues.apache.org/jira/browse/FLINK-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312895#comment-17312895 ] Yun Tang commented on FLINK-16444: -- This ticket has been subsumed by FLINK-21736 and me

[jira] [Commented] (FLINK-21736) Introduce latency tracking state

[ https://issues.apache.org/jira/browse/FLINK-21736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312894#comment-17312894 ] Yun Tang commented on FLINK-21736: -- Merged into master f4b6fe2ce5fccee69518a5ac8cd29f8c

[jira] [Resolved] (FLINK-22053) NumberSequenceSource causes fatal exception when less splits than parallelism.

[ https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22053. - Fix Version/s: 1.12.3 1.13.0 Resolution: Fixed > NumberSequenceSource

[jira] [Resolved] (FLINK-21736) Introduce latency tracking state

[ https://issues.apache.org/jira/browse/FLINK-21736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-21736. -- Resolution: Fixed > Introduce latency tracking state > > >

[jira] [Commented] (FLINK-22053) NumberSequenceSource causes fatal exception when less splits than parallelism.

[ https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312892#comment-17312892 ] Arvid Heise commented on FLINK-22053: - Merged into master as a93251b4599e7c7d77ec6f0

[GitHub] [flink] Myasuka merged pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

Myasuka merged pull request #15119: URL: https://github.com/apache/flink/pull/15119 -- 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] Myasuka commented on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

Myasuka commented on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-811672401 Thanks for your review, merging -- 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

[GitHub] [flink] AHeise merged pull request #15454: [FLINK-22053][core] Allow NumberSequenceSource to have less splits than parallelism. [1.12]

AHeise merged pull request #15454: URL: https://github.com/apache/flink/pull/15454 -- 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] AHeise commented on a change in pull request #15442: [FLINK-22081][flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

AHeise commented on a change in pull request #15442: URL: https://github.com/apache/flink/pull/15442#discussion_r605399943 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/EntropyInjector.java ## @@ -93,25 +93,18 @@ public static boolean isEntropyInjecting(FileS

[jira] [Issue Comment Deleted] (FLINK-22057) Client submit job remotely to Flink cluster through Loadbalancer rest service --failed

[ https://issues.apache.org/jira/browse/FLINK-22057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22057: -- Comment: was deleted (was: Okay.. I will look into it.. When i am excuting flink job, why file is not able to

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

[ https://issues.apache.org/jira/browse/FLINK-22079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22079. -- Resolution: Duplicate > ReactiveModeITCase stack with fine grained resource manager. > ---

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (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 ] Arvid Heise reassigned FLINK-22081: --- Assignee: Chen Qin (was: Prem Santosh) > Entropy key not resolved if flink-s3-fs-hadoop is

[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&focusedCommentId=17312887#comment-17312887 ] Robert Metzger commented on FLINK-22079: This is a known issue, which is tracked

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

becketqin commented on pull request #15461: URL: https://github.com/apache/flink/pull/15461#issuecomment-811668592 I share the same concerns as @StephanEwen. `TopicListSubscriber` is probably by far the most used subscriber, so improving the performance there is rewarding. Maybe we

[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&focusedCommentId=17312880#comment-17312880 ] Dian Fu commented on FLINK-22082: - Does kafka source support nested projection pushdown?

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

[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&focusedCommentId=17312872#comment-17312872 ] Jark Wu commented on FLINK-22082: - {{FileSystemTableSource}} doesn't support nested proj

[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 MetricRegistry

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 l

[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&focusedCommentId=17312868#comment-17312868 ] Dian Fu commented on FLINK-22082: - cc [~fsk119] > Nested projection push down doesn't w

[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 projectio

[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 Iss

[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&focusedCommentId=17312867#comment-17312867 ] Chen Qin commented on FLINK-22081: -- [~AHeise] could you assign this Jira to me and help

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 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: - 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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 disconne

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 ConsumedPartit

[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 ConsumedPartit

[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 ConsumedPartit

[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 bug-fix

[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&focusedCommentId=17312850#comment-17312850 ] Xintong Song commented on FLINK-22079: -- cc [~rmetzger] > ReactiveModeITCase stack

[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 Project:

[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&focusedCommentId=17312849#comment-17312849 ] Zhilong Hong commented on FLINK-22077: -- cc [~trohrmann] I personally think it's nec

[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 ConsumedPartit

[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 ConsumedPartit

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17312831#comment-17312831 ] Yun Tang commented on FLINK-20816: -- >From the comparison of success and failure logs, I

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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... 04bbf03a0cdb2f455c1b06569dea

[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, please

[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 Apac

[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&focusedCommentId=17312812#comment-17312812 ] Jark Wu edited comment on FLINK-20558 at 4/1/21, 2:28 AM: -- http

[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&focusedCommentId=17312812#comment-17312812 ] Jark Wu commented on FLINK-20558: - https://dev.azure.com/apache-flink/apache-flink/_buil

[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 u

[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, please

[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 * a682564bcc9fe670b70fd526258b799f7143

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 * a682564bcc9fe670b70fd526258b799f7143

[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&focusedCommentId=17312789#comment-17312789 ] Dian Fu commented on FLINK-21976: - Removed flink-ml from Flink repo via 60b3895db28c2270

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   4   5   6   7   >