[GitHub] [flink] flinkbot edited a comment on pull request #15332: [FLINK-21701][sql-client] Extend the "RESET" syntax in the SQL Client

flinkbot edited a comment on pull request #15332: URL: https://github.com/apache/flink/pull/15332#issuecomment-804297721 ## CI report: * c5dbec469fa3f073138b1f15dd7c3b966b369cfd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

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

[GitHub] [flink] flinkbot edited a comment on pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

flinkbot edited a comment on pull request #15337: URL: https://github.com/apache/flink/pull/15337#issuecomment-804610022 ## CI report: * fe8a261ff73f5e252902403d8d7c3e396420d6db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15319: [FLINK-21751] Eagerly issue release calls from RM if JM disconnects for terminal job

flinkbot edited a comment on pull request #15319: URL: https://github.com/apache/flink/pull/15319#issuecomment-803982383 ## CI report: * eb2822af636368eaa734582d260dc9d629d0ed78 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 225c8fe92a5db0965de7934f945bd56a86966ad9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

flinkbot edited a comment on pull request #15133: URL: https://github.com/apache/flink/pull/15133#issuecomment-795031750 ## CI report: * 492393d5c044fa6e940cf086368eb060035cf07d 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: * daaafe6b7f398f863b36b09a0b681b9c80a17d60 Azure:

[GitHub] [flink] zentol commented on a change in pull request #15227: [hotfix][checkpoint] Incorrect calculation of timeInQueue

zentol commented on a change in pull request #15227: URL: https://github.com/apache/flink/pull/15227#discussion_r599429925 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -218,7 +218,7 @@ int

[jira] [Comment Edited] (FLINK-17752) Align the timestamp format with Flink SQL types in JSON format

[ https://issues.apache.org/jira/browse/FLINK-17752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306942#comment-17306942 ] jiamo edited comment on FLINK-17752 at 3/23/21, 10:00 AM: -- Why not offer format

[jira] [Commented] (FLINK-17752) Align the timestamp format with Flink SQL types in JSON format

[ https://issues.apache.org/jira/browse/FLINK-17752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306942#comment-17306942 ] jiamo commented on FLINK-17752: --- Why not offer format in 

[GitHub] [flink-statefun-playground] asfgit closed pull request #6: [hotfix] fix docker-compose command

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

[GitHub] [flink-statefun-playground] tzulitai commented on pull request #6: [hotfix] fix docker-compose command

tzulitai commented on pull request #6: URL: https://github.com/apache/flink-statefun-playground/pull/6#issuecomment-804764115 LGTM, thanks @afedulov. -- 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

[jira] [Updated] (FLINK-21871) Support watermark for Hive and Filesystem streaming source

[ https://issues.apache.org/jira/browse/FLINK-21871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21871: Fix Version/s: (was: 1.13.0) > Support watermark for Hive and Filesystem streaming source >

[jira] [Closed] (FLINK-21904) parseJmJvmArgsAndExportLogs: command not found warning when starting StateFun

[ https://issues.apache.org/jira/browse/FLINK-21904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21904. --- Resolution: Fixed flink-statefun/master: 7005f6a75e0a24445dd9b59fda6162cce8018b48

[jira] [Closed] (FLINK-21901) Update StateFun version to 3.0-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-21901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21901. --- Resolution: Fixed flink-statefun/master: 929872ab0c29c71e9bd0072de4ac954841ca54fe

[GitHub] [flink-statefun] tzulitai closed pull request #216: [FLINK-21901] Update version to 3.0-SNAPSHOT

tzulitai closed pull request #216: URL: https://github.com/apache/flink-statefun/pull/216 -- 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-statefun] tzulitai closed pull request #217: [FLINK-21904] Sync standalone-job.sh with recent Flink 1.12.x changes

tzulitai closed pull request #217: URL: https://github.com/apache/flink-statefun/pull/217 -- 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 commented on pull request #15341: [FLINK-21923][table-planner-blink] Fix SplitAggregateRule not support both filter, count/sum, avg

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

[GitHub] [flink] flinkbot edited a comment on pull request #15339: [FLINK-21448] Randomize ITTests for delegating state backend

flinkbot edited a comment on pull request #15339: URL: https://github.com/apache/flink/pull/15339#issuecomment-804687609 ## CI report: * 61bac18cf324bf4b282471ec37cc6ea05a41ad05 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

flinkbot edited a comment on pull request #15337: URL: https://github.com/apache/flink/pull/15337#issuecomment-804610022 ## CI report: * fe8a261ff73f5e252902403d8d7c3e396420d6db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15332: [FLINK-21701][sql-client] Extend the "RESET" syntax in the SQL Client

flinkbot edited a comment on pull request #15332: URL: https://github.com/apache/flink/pull/15332#issuecomment-804297721 ## CI report: * c5dbec469fa3f073138b1f15dd7c3b966b369cfd Azure:

[jira] [Commented] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

[ https://issues.apache.org/jira/browse/FLINK-21108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306926#comment-17306926 ] Xiaoguang Sun commented on FLINK-21108: --- Sorry for the late reply, let me rebase the PR agains the

[GitHub] [flink] flinkbot edited a comment on pull request #15212: [FLINK-21628][python] Support Python UDAF in Tumbling Window

flinkbot edited a comment on pull request #15212: URL: https://github.com/apache/flink/pull/15212#issuecomment-799172540 ## CI report: * 55bf3a050d7c3d1c49914d3942e900da3eb39eb1 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: * daaafe6b7f398f863b36b09a0b681b9c80a17d60 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15117: [FLINK-21655] [table-planner-blink] Fix incorrect simplification for coalesce call on a groupingsets' result

flinkbot edited a comment on pull request #15117: URL: https://github.com/apache/flink/pull/15117#issuecomment-792736135 ## CI report: * d4a0523eed71bd99b6514303c484242bbab4f753 Azure:

[jira] [Closed] (FLINK-21922) The method partition_by in Over doesn't work for expression dsl

[ https://issues.apache.org/jira/browse/FLINK-21922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-21922. --- Resolution: Fixed Fixed in - master via 1892a24d4096d531847cca5267243ce588f90f6e - release-1.12 via 

[jira] [Updated] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-21923: - Description: SplitAggregateRule optimizes one-layer aggregation to two-layer aggregation to improve

[jira] [Updated] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-21923: - Description: SplitAggregateRule optimizes one-layer aggregation to two-layer aggregation to improve

[jira] [Updated] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-21923: - Description: SplitAggregateRule optimizes one-layer aggregation to two-layer aggregation to improve

[GitHub] [flink] dianfu closed pull request #15338: [FLINK-21922][python] Fix partition_by in Over which doesn't work for expression DSL

dianfu closed pull request #15338: URL: https://github.com/apache/flink/pull/15338 -- 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] xiangtao commented on a change in pull request #15332: [FLINK-21701][sql-client] Extend the "RESET" syntax in the SQL Client

xiangtao commented on a change in pull request #15332: URL: https://github.com/apache/flink/pull/15332#discussion_r599292000 ## File path: flink-table/flink-sql-client/src/test/resources/sql/set.q ## @@ -104,3 +104,70 @@ Was expecting one of: "," ... !error + +# test

[GitHub] [flink] dianfu commented on pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

dianfu commented on pull request #15337: URL: https://github.com/apache/flink/pull/15337#issuecomment-804751939 @xintongsong Thanks for the review. Updated the PR accordingly~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-21927) ExpressionReducer compile fail when running long term

[ https://issues.apache.org/jira/browse/FLINK-21927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306922#comment-17306922 ] MaChengLong commented on FLINK-21927: - This issue seems easy, let me resolve it?  :D >

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

gaoyunhaii commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r599399255 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,264 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot commented on pull request #15341: [FLINK-21923][table-planner-blink] Fix SplitAggregateRule not support both filter, count/sum, avg

flinkbot commented on pull request #15341: URL: https://github.com/apache/flink/pull/15341#issuecomment-804749646 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] Tartarus0zm commented on pull request #15341: [FLINK-21923][table-planner-blink] Fix SplitAggregateRule not support both filter, count/sum, avg

Tartarus0zm commented on pull request #15341: URL: https://github.com/apache/flink/pull/15341#issuecomment-804749011 @wuchong please take a look, if you have time, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21923: --- Labels: pull-request-available (was: ) > SplitAggregateRule will be abnormal, when the

[GitHub] [flink] flinkbot edited a comment on pull request #15340: [FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

flinkbot edited a comment on pull request #15340: URL: https://github.com/apache/flink/pull/15340#issuecomment-804732503 ## CI report: * bd59806ebbb919d248ed5a7d024313f035431726 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15339: [FLINK-21448] Randomize ITTests for delegating state backend

flinkbot edited a comment on pull request #15339: URL: https://github.com/apache/flink/pull/15339#issuecomment-804687609 ## CI report: * 61bac18cf324bf4b282471ec37cc6ea05a41ad05 Azure:

[GitHub] [flink] Tartarus0zm opened a new pull request #15341: [FLINK-21923][table-planner-blink] Fix SplitAggregateRule not support both filter, count/sum, avg

Tartarus0zm opened a new pull request #15341: URL: https://github.com/apache/flink/pull/15341 ## What is the purpose of the change Fix SplitAggregateRule not support both filter, count/sum, avg. Avoid ClassCastException in SplitAggregateRule ## Brief change log * Fix

[GitHub] [flink] flinkbot edited a comment on pull request #15336: [FLINK-20547][network] Fix inconsistent availability issue of LocalBufferPool

flinkbot edited a comment on pull request #15336: URL: https://github.com/apache/flink/pull/15336#issuecomment-804609978 ## CI report: * 295036f53219c05b7ed3b662a95034dddb56f3b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15310: [FLINK-21330] Optimize the performance of PipelinedRegionSchedulingStrategy

flinkbot edited a comment on pull request #15310: URL: https://github.com/apache/flink/pull/15310#issuecomment-803836704 ## CI report: * dcbc4d6f9efcd5e5d70f224862be38963e1fab63 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15212: [FLINK-21628][python] Support Python UDAF in Tumbling Window

flinkbot edited a comment on pull request #15212: URL: https://github.com/apache/flink/pull/15212#issuecomment-799172540 ## CI report: * 55bf3a050d7c3d1c49914d3942e900da3eb39eb1 Azure:

[jira] [Commented] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306915#comment-17306915 ] Leonard Xu commented on FLINK-20254: I think this is another bug in `collecting result` after some

[GitHub] [flink] flinkbot edited a comment on pull request #15149: [FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams

flinkbot edited a comment on pull request #15149: URL: https://github.com/apache/flink/pull/15149#issuecomment-796635889 ## CI report: * 6314c86f14c23f286d9c2e3d8d711da8f786 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #15132: [FLINK-21698][table-planner] Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

wuchong commented on a change in pull request #15132: URL: https://github.com/apache/flink/pull/15132#discussion_r599333669 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala ## @@ -1203,72

[GitHub] [flink] flinkbot edited a comment on pull request #15117: [FLINK-21655] [table-planner-blink] Fix incorrect simplification for coalesce call on a groupingsets' result

flinkbot edited a comment on pull request #15117: URL: https://github.com/apache/flink/pull/15117#issuecomment-792736135 ## CI report: * d4a0523eed71bd99b6514303c484242bbab4f753 Azure:

[GitHub] [flink] xintongsong commented on a change in pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

xintongsong commented on a change in pull request #15337: URL: https://github.com/apache/flink/pull/15337#discussion_r599389303 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/ManagedMemoryUtils.java ## @@ -155,4 +155,19 @@ public static

[jira] [Assigned] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reassigned FLINK-21416: - Assignee: Yun Gao (was: Guo Weijie) > FileBufferReaderITCase.testSequentialReading fails on

[jira] [Commented] (FLINK-21817) New Kafka Source might break subtask and split assignment upon rescale

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306912#comment-17306912 ] Qingsheng Ren commented on FLINK-21817: --- Thanks for the inspiring discussion! About

[jira] [Commented] (FLINK-21468) ParquetTableSource: where clause on integer does not work

[ https://issues.apache.org/jira/browse/FLINK-21468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306911#comment-17306911 ] Etienne Chauchot commented on FLINK-21468: -- [~ZhenqiuHuang] would you be interested in working

[GitHub] [flink] WeiZhong94 commented on pull request #15149: [FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams

WeiZhong94 commented on pull request #15149: URL: https://github.com/apache/flink/pull/15149#issuecomment-804736470 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot commented on pull request #15340: [FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #15320: [FLINK-21903][docs-zh] Translate "Importing Flink into an IDE" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

flinkbot edited a comment on pull request #15337: URL: https://github.com/apache/flink/pull/15337#issuecomment-804610022 ## CI report: * fe8a261ff73f5e252902403d8d7c3e396420d6db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15318: [FLINK-21868][table-planner-blink]Support StreamExecLookupJoin json serialization/deserialization

flinkbot edited a comment on pull request #15318: URL: https://github.com/apache/flink/pull/15318#issuecomment-803958618 ## CI report: * c915f87ec63410214cfa1a0cc09f812bf59f2e48 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15228: [Flink-21910][resourcemanager] fix the check that whether JobLeaderIdService has been stated

flinkbot edited a comment on pull request #15228: URL: https://github.com/apache/flink/pull/15228#issuecomment-82897 ## CI report: * 46ae634688c94f205f50a741aaa9148526f49b44 Azure:

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306896#comment-17306896 ] Kezhu Wang commented on FLINK-21564: A small improvement is still a good. I will open a pr in days.

[jira] [Created] (FLINK-21928) DuplicateJobSubmissionException after JobManager failover

Ufuk Celebi created FLINK-21928: --- Summary: DuplicateJobSubmissionException after JobManager failover Key: FLINK-21928 URL: https://issues.apache.org/jira/browse/FLINK-21928 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15320: [FLINK-21903][docs-zh] Translate "Importing Flink into an IDE" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #15149: [FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams

flinkbot edited a comment on pull request #15149: URL: https://github.com/apache/flink/pull/15149#issuecomment-796635889 ## CI report: * 6314c86f14c23f286d9c2e3d8d711da8f786 Azure:

[GitHub] [flink] flinkbot commented on pull request #15340: [FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

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

[jira] [Commented] (FLINK-21626) Consider shaping newly introduced RuntimeContext.getJobId to return JobID with no Optional wrapper

[ https://issues.apache.org/jira/browse/FLINK-21626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306885#comment-17306885 ] Stephan Ewen commented on FLINK-21626: -- Thanks for picking this up so quickly. > Consider shaping

[jira] [Updated] (FLINK-21669) Support "table.dml-sync" option to execute DML statements synchronizely in TableEnvironment and SQL Client

[ https://issues.apache.org/jira/browse/FLINK-21669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21669: --- Labels: pull-request-available (was: ) > Support "table.dml-sync" option to execute DML

[jira] [Closed] (FLINK-21506) Option for setting mesos task user

[ https://issues.apache.org/jira/browse/FLINK-21506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21506. Fix Version/s: 1.13.0 Resolution: Fixed master:

[GitHub] [flink] fsk119 opened a new pull request #15340: [FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

fsk119 opened a new pull request #15340: URL: https://github.com/apache/flink/pull/15340 ## What is the purpose of the change *Introduce the option `table.dml-sync`. This option allow users to execute sql in sync.* *This option doesn't work in old planner and batch

[GitHub] [flink] zentol merged pull request #15097: [FLINK-21506] [mesos] Option for mesos task user

zentol merged pull request #15097: URL: https://github.com/apache/flink/pull/15097 -- 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] [Commented] (FLINK-20723) testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed due to NoHostAvailableException

[ https://issues.apache.org/jira/browse/FLINK-20723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306884#comment-17306884 ] Chesnay Schepler commented on FLINK-20723: -- Let's just increase the timeouts. We can see from

[jira] [Comment Edited] (FLINK-20723) testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed due to NoHostAvailableException

[ https://issues.apache.org/jira/browse/FLINK-20723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306884#comment-17306884 ] Chesnay Schepler edited comment on FLINK-20723 at 3/23/21, 8:28 AM:

[jira] [Commented] (FLINK-21921) Unreasonable ADDED event ignoring in callback handler in KubernetesLeaderRetrievalDriver

[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306879#comment-17306879 ] Yang Wang commented on FLINK-21921: --- [~yittg] Thanks for raising this concern. I think maybe it is not

[jira] [Assigned] (FLINK-21032) JsonFileCompactionITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21032: --- Assignee: Leonard Xu > JsonFileCompactionITCase fails on azure >

[jira] [Created] (FLINK-21927) ExpressionReducer compile fail when running long term

runsun created FLINK-21927: -- Summary: ExpressionReducer compile fail when running long term Key: FLINK-21927 URL: https://issues.apache.org/jira/browse/FLINK-21927 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #15339: [FLINK-21448] Randomize ITTests for delegating state backend

flinkbot edited a comment on pull request #15339: URL: https://github.com/apache/flink/pull/15339#issuecomment-804687609 ## CI report: * 61bac18cf324bf4b282471ec37cc6ea05a41ad05 Azure:

[jira] [Updated] (FLINK-21008) Residual HA related Kubernetes ConfigMaps and ZooKeeper nodes when cluster entrypoint received SIGTERM in shutdown

[ https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-21008: -- Fix Version/s: (was: 1.13.0) > Residual HA related Kubernetes ConfigMaps and ZooKeeper nodes when

[GitHub] [flink] flinkbot edited a comment on pull request #15303: [FLINK-21713][table-api/table-planner] Correct function CURRENT_TIMESTAMP/CURRENT_TIME/CURRENT_DATE/NOW/LOCALTIME/LOCALTIMESTAMP

flinkbot edited a comment on pull request #15303: URL: https://github.com/apache/flink/pull/15303#issuecomment-803399784 ## CI report: * 48542f4cd216994de0722a8d2458ee6b26618ad1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15248: [FLINK-21382][doc] Update documentation for standalone Flink on Kubernetes with standby JobManagers

flinkbot edited a comment on pull request #15248: URL: https://github.com/apache/flink/pull/15248#issuecomment-800773858 ## CI report: * 291ea8b8adc0092b87258ba4c2bc4c8e27eceaf8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15212: [FLINK-21628][python] Support Python UDAF in Tumbling Window

flinkbot edited a comment on pull request #15212: URL: https://github.com/apache/flink/pull/15212#issuecomment-799172540 ## CI report: * 55bf3a050d7c3d1c49914d3942e900da3eb39eb1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15149: [FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams

flinkbot edited a comment on pull request #15149: URL: https://github.com/apache/flink/pull/15149#issuecomment-796635889 ## CI report: * 6314c86f14c23f286d9c2e3d8d711da8f786 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15148: [FLINK-21731] Add benchmarks for DefaultScheduler#startScheduling

flinkbot edited a comment on pull request #15148: URL: https://github.com/apache/flink/pull/15148#issuecomment-796572621 ## CI report: * 25e912512943d29b15c8fa5a22adc5cf0e2294a1 Azure:

[jira] [Updated] (FLINK-21926) Document Fine Grained Resource Management

[ https://issues.apache.org/jira/browse/FLINK-21926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21926: - Component/s: Documentation > Document Fine Grained Resource Management >

[jira] [Created] (FLINK-21926) Document Fine Grained Resource Management

Xintong Song created FLINK-21926: Summary: Document Fine Grained Resource Management Key: FLINK-21926 URL: https://issues.apache.org/jira/browse/FLINK-21926 Project: Flink Issue Type:

[jira] [Created] (FLINK-21925) Support configuring fine grained resource requirements via DataStream API

Xintong Song created FLINK-21925: Summary: Support configuring fine grained resource requirements via DataStream API Key: FLINK-21925 URL: https://issues.apache.org/jira/browse/FLINK-21925 Project:

[jira] [Closed] (FLINK-14194) Clean-up of legacy mode.

[ https://issues.apache.org/jira/browse/FLINK-14194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-14194. Resolution: Won't Do With the current implementation, there's not much legacy codes to clean.

[jira] [Updated] (FLINK-14194) Clean-up of legacy mode.

[ https://issues.apache.org/jira/browse/FLINK-14194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14194: - Fix Version/s: (was: 1.13.0) > Clean-up of legacy mode. > > >

[jira] [Updated] (FLINK-14193) Update Web UI for fine grained TM/Slot resources

[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14193: - Fix Version/s: (was: 1.13.0) > Update Web UI for fine grained TM/Slot resources >

[jira] [Updated] (FLINK-14193) Update Web UI fine grained TM/Slot resources

[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14193: - Summary: Update Web UI fine grained TM/Slot resources (was: Update RestAPI / Web UI) > Update

[jira] [Updated] (FLINK-14193) Update Web UI for fine grained TM/Slot resources

[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14193: - Summary: Update Web UI for fine grained TM/Slot resources (was: Update Web UI fine grained

[jira] [Updated] (FLINK-21921) Unreasonable ADDED event ignoring in callback handler in KubernetesLeaderRetrievalDriver

[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-21921: Summary: Unreasonable ADDED event ignoring in callback handler in KubernetesLeaderRetrievalDriver (was:

[jira] [Updated] (FLINK-21794) Support retrieving slot details via rest api

[ https://issues.apache.org/jira/browse/FLINK-21794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21794: - Parent: FLINK-21924 Issue Type: Sub-task (was: Improvement) > Support retrieving slot

[jira] [Closed] (FLINK-14187) FLIP-56 Dynamic Slot Allocation

[ https://issues.apache.org/jira/browse/FLINK-14187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-14187. Resolution: Fixed > FLIP-56 Dynamic Slot Allocation > --- > >

[jira] [Updated] (FLINK-14194) Clean-up of legacy mode.

[ https://issues.apache.org/jira/browse/FLINK-14194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14194: - Parent: FLINK-21924 Issue Type: Sub-task (was: Task) > Clean-up of legacy mode. >

[jira] [Updated] (FLINK-14194) Clean-up of legacy mode.

[ https://issues.apache.org/jira/browse/FLINK-14194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14194: - Parent: (was: FLINK-14187) Issue Type: Task (was: Sub-task) > Clean-up of legacy

[jira] [Updated] (FLINK-21288) Support redundant task managers for fine grained resource management

[ https://issues.apache.org/jira/browse/FLINK-21288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21288: - Parent: FLINK-21924 Issue Type: Sub-task (was: Task) > Support redundant task managers

[jira] [Updated] (FLINK-20838) Implement SlotRequestAdapter for the FineGrainedSlotManager

[ https://issues.apache.org/jira/browse/FLINK-20838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20838: - Parent: FLINK-21924 Issue Type: Sub-task (was: Task) > Implement SlotRequestAdapter

[jira] [Updated] (FLINK-20838) Implement SlotRequestAdapter for the FineGrainedSlotManager

[ https://issues.apache.org/jira/browse/FLINK-20838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20838: - Parent: (was: FLINK-14187) Issue Type: Task (was: Sub-task) > Implement

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

Myasuka commented on a change in pull request #15119: URL: https://github.com/apache/flink/pull/15119#discussion_r599338577 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingStateConfig.java ## @@ -0,0 +1,117 @@ +/* + * Licensed

[jira] [Updated] (FLINK-21174) Optimize the performance of ResourceAllocationStrategy

[ https://issues.apache.org/jira/browse/FLINK-21174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21174: - Parent: FLINK-21924 Issue Type: Sub-task (was: Task) > Optimize the performance of

[jira] [Updated] (FLINK-14193) Update RestAPI / Web UI

[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14193: - Parent: FLINK-21924 Issue Type: Sub-task (was: Task) > Update RestAPI / Web UI >

[jira] [Updated] (FLINK-21288) Support redundant task managers for fine grained resource management

[ https://issues.apache.org/jira/browse/FLINK-21288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21288: - Parent: (was: FLINK-14187) Issue Type: Task (was: Sub-task) > Support redundant

[jira] [Updated] (FLINK-14193) Update RestAPI / Web UI

[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14193: - Parent: (was: FLINK-14187) Issue Type: Task (was: Sub-task) > Update RestAPI / Web

<    1   2   3   4   5   6   >