[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709707#comment-16709707 ] ASF GitHub Bot commented on FLINK-7208: --- twalthr commented on a change in pull requ

[GitHub] twalthr commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

twalthr commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238959968 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtim

[GitHub] KarmaGYZ opened a new pull request #7238: [hotfix][docs] Fix typo in Windows documentation

KarmaGYZ opened a new pull request #7238: [hotfix][docs] Fix typo in Windows documentation URL: https://github.com/apache/flink/pull/7238 ## What is the purpose of the change This pr is to Fix typo in Windows documentation ## Brief change log - Fix typo in Windo

[GitHub] zhijiangW commented on a change in pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory

zhijiangW commented on a change in pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory URL: https://github.com/apache/flink/pull/7185#discussion_r238955332 ## File path: flink-runtime/src/main/java/org/apache/fli

[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709685#comment-16709685 ] ASF GitHub Bot commented on FLINK-10884: zhijiangW commented on a change in pull

[jira] [Commented] (FLINK-7209) Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself

[ https://issues.apache.org/jira/browse/FLINK-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709683#comment-16709683 ] ASF GitHub Bot commented on FLINK-7209: --- dianfu opened a new pull request #7237: [F

[jira] [Updated] (FLINK-7209) Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself

[ https://issues.apache.org/jira/browse/FLINK-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7209: -- Labels: pull-request-available (was: ) > Support DataView in Java and Scala Tuples and case cl

[GitHub] dianfu opened a new pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction

dianfu opened a new pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction URL: https://github.com/apache/flink/pull/7237 ## What is the purpose of the change *This pull request adds support of DataView in Tuple and Case

[jira] [Created] (FLINK-11073) Make serializers immutable / provide option TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer

Tzu-Li (Gordon) Tai created FLINK-11073: --- Summary: Make serializers immutable / provide option TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer Key: FLINK-11073 URL: https://issues.apac

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709654#comment-16709654 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu commented on a change in pull reque

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709670#comment-16709670 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu commented on a change in pull reque

[GitHub] dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238942732 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime

[GitHub] dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238940699 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709669#comment-16709669 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu commented on a change in pull reque

[GitHub] dianfu commented on issue #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

dianfu commented on issue #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#issuecomment-444376385 @walterddr Thanks a lot for your comments. Please take a look at if my reply makes sense to you. Thanks a lot. -

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709668#comment-16709668 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu commented on issue #7201: [FLINK-72

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709662#comment-16709662 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu commented on a change in pull reque

[jira] [Commented] (FLINK-10785) Update FlinkKinesisConsumerMigrationTest for 1.7

[ https://issues.apache.org/jira/browse/FLINK-10785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709660#comment-16709660 ] vinoyang commented on FLINK-10785: -- [~tzulitai] and [~till.rohrmann] The general way of

[GitHub] dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238943868 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functio

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709656#comment-16709656 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu commented on a change in pull reque

[GitHub] dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238942732 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime

[GitHub] dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238942732 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709644#comment-16709644 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu commented on a change in pull reque

[GitHub] dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238940699 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime

[jira] [Commented] (FLINK-11002) Trigger.clear() will not be called after purged window

[ https://issues.apache.org/jira/browse/FLINK-11002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709642#comment-16709642 ] Yuan Yifan commented on FLINK-11002: Yes, but `clear` didn't be called normally afte

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709634#comment-16709634 ] ASF GitHub Bot commented on FLINK-10543: hequn8128 commented on issue #6918: [FL

[jira] [Commented] (FLINK-10786) Update CEPMigrationTest for 1.7

[ https://issues.apache.org/jira/browse/FLINK-10786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709631#comment-16709631 ] ASF GitHub Bot commented on FLINK-10786: yanghua opened a new pull request #7236

[GitHub] hequn8128 commented on issue #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

hequn8128 commented on issue #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#issuecomment-444367228 @sunjincheng121 Hi, thanks a lot for your great suggestions. I updated the pr accordingly. Would be great

[jira] [Updated] (FLINK-10786) Update CEPMigrationTest for 1.7

[ https://issues.apache.org/jira/browse/FLINK-10786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10786: --- Labels: pull-request-available (was: ) > Update CEPMigrationTest for 1.7 >

[GitHub] yanghua opened a new pull request #7236: [FLINK-10786] Update CEPMigrationTest for 1.7

yanghua opened a new pull request #7236: [FLINK-10786] Update CEPMigrationTest for 1.7 URL: https://github.com/apache/flink/pull/7236 ## What is the purpose of the change *This pull request updates CEPMigrationTest for 1.7* ## Brief change log - *Update CEPMigrati

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709623#comment-16709623 ] ASF GitHub Bot commented on FLINK-9555: --- sunjincheng121 commented on a change in pu

[GitHub] sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

sunjincheng121 commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r238935139 ## File path: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ## @@ -

[jira] [Commented] (FLINK-10776) Update migration tests for Flink 1.7

[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709612#comment-16709612 ] Hequn Cheng commented on FLINK-10776: - [~yanghua] Hi, thanks for your contribution.

[jira] [Updated] (FLINK-10976) Add Aggregate operator to Table API

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10976: --- Labels: pull-request-available (was: ) > Add Aggregate operator to Table API >

[jira] [Commented] (FLINK-10976) Add Aggregate operator to Table API

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709611#comment-16709611 ] ASF GitHub Bot commented on FLINK-10976: dianfu opened a new pull request #7235:

[GitHub] dianfu opened a new pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

dianfu opened a new pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235 ## What is the purpose of the change *This pull request adds the aggregate operation to table API.* ## Brief change log

[jira] [Updated] (FLINK-10787) Update AbstractNonKeyedOperatorRestoreTestBase for 1.7

[ https://issues.apache.org/jira/browse/FLINK-10787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10787: --- Labels: pull-request-available (was: ) > Update AbstractNonKeyedOperatorRestoreTestBase for

[GitHub] yanghua opened a new pull request #7234: [FLINK-10787] Update AbstractNonKeyedOperatorRestoreTestBase for 1.7

yanghua opened a new pull request #7234: [FLINK-10787] Update AbstractNonKeyedOperatorRestoreTestBase for 1.7 URL: https://github.com/apache/flink/pull/7234 ## What is the purpose of the change *This pull request updates AbstractNonKeyedOperatorRestoreTestBase for 1.7* ## Brie

[jira] [Commented] (FLINK-10787) Update AbstractNonKeyedOperatorRestoreTestBase for 1.7

[ https://issues.apache.org/jira/browse/FLINK-10787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709603#comment-16709603 ] ASF GitHub Bot commented on FLINK-10787: yanghua opened a new pull request #7234

[jira] [Created] (FLINK-11072) KafkaITCase.testKeyValueSupport failure

Bowen Li created FLINK-11072: Summary: KafkaITCase.testKeyValueSupport failure Key: FLINK-11072 URL: https://issues.apache.org/jira/browse/FLINK-11072 Project: Flink Issue Type: Bug Com

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709582#comment-16709582 ] ASF GitHub Bot commented on FLINK-9555: --- shuiqiangchen commented on issue #7121: [F

[GitHub] shuiqiangchen commented on issue #7121: [FLINK-9555]Support table api in scala shell

shuiqiangchen commented on issue #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#issuecomment-444350634 Hi all, I have updated some codes following your suggestions. Please review it in your convenience. --

[jira] [Commented] (FLINK-10782) Update AbstractKeyedOperatorRestoreTestBase for 1.7

[ https://issues.apache.org/jira/browse/FLINK-10782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709581#comment-16709581 ] ASF GitHub Bot commented on FLINK-10782: yanghua opened a new pull request #7233

[jira] [Updated] (FLINK-10782) Update AbstractKeyedOperatorRestoreTestBase for 1.7

[ https://issues.apache.org/jira/browse/FLINK-10782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10782: --- Labels: pull-request-available (was: ) > Update AbstractKeyedOperatorRestoreTestBase for 1.

[GitHub] yanghua opened a new pull request #7233: [FLINK-10782] Update AbstractKeyedOperatorRestoreTestBase for 1.7

yanghua opened a new pull request #7233: [FLINK-10782] Update AbstractKeyedOperatorRestoreTestBase for 1.7 URL: https://github.com/apache/flink/pull/7233 ## What is the purpose of the change *This pull request updates AbstractKeyedOperatorRestoreTestBase for 1.7* ## Brief

[jira] [Commented] (FLINK-10776) Update migration tests for Flink 1.7

[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709578#comment-16709578 ] vinoyang commented on FLINK-10776: -- Hi [~tzulitai]  because FLINK-10777 is in the `flin

[jira] [Commented] (FLINK-10776) Update migration tests for Flink 1.7

[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709574#comment-16709574 ] vinoyang commented on FLINK-10776: -- Hi [~hequn8128] , because FLINK-10779, FLINK-10780

[jira] [Assigned] (FLINK-10785) Update FlinkKinesisConsumerMigrationTest for 1.7

[ https://issues.apache.org/jira/browse/FLINK-10785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10785: Assignee: vinoyang > Update FlinkKinesisConsumerMigrationTest for 1.7 > -

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709534#comment-16709534 ] ASF GitHub Bot commented on FLINK-10461: klion26 commented on a change in pull r

[GitHub] klion26 commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

klion26 commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r238908481 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/ma

[jira] [Assigned] (FLINK-11065) Migrate flink-table runtime classes

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11065: Assignee: (was: vinoyang) > Migrate flink-table runtime classes > ---

[jira] [Assigned] (FLINK-11065) Migrate flink-table runtime classes

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11065: Assignee: vinoyang > Migrate flink-table runtime classes > --- >

[jira] [Assigned] (FLINK-11066) Migrate main Table API classes to flink-table-api-base

[ https://issues.apache.org/jira/browse/FLINK-11066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11066: Assignee: (was: vinoyang) > Migrate main Table API classes to flink-table-api-base >

[jira] [Assigned] (FLINK-11066) Migrate main Table API classes to flink-table-api-base

[ https://issues.apache.org/jira/browse/FLINK-11066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11066: Assignee: vinoyang > Migrate main Table API classes to flink-table-api-base > ---

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709461#comment-16709461 ] ASF GitHub Bot commented on FLINK-7208: --- walterddr commented on a change in pull re

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709462#comment-16709462 ] ASF GitHub Bot commented on FLINK-7208: --- walterddr commented on a change in pull re

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709463#comment-16709463 ] ASF GitHub Bot commented on FLINK-7208: --- walterddr commented on a change in pull re

[GitHub] walterddr commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

walterddr commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238894594 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runt

[GitHub] walterddr commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

walterddr commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238895763 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runt

[GitHub] walterddr commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

walterddr commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238895578 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/func

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709420#comment-16709420 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238886892 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238882703 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709419#comment-16709419 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709421#comment-16709421 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238885237 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238885825 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238882633 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[GitHub] sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators

sunjincheng121 commented on a change in pull request #6918: [FLINK-10543][table] Leverage efficient timer deletion in relational operators URL: https://github.com/apache/flink/pull/6918#discussion_r238884712 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709418#comment-16709418 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709423#comment-16709423 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709422#comment-16709422 ] ASF GitHub Bot commented on FLINK-10543: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709039#comment-16709039 ] ASF GitHub Bot commented on FLINK-11010: lamber-ken commented on issue #7180: [F

[GitHub] tweise commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink

tweise commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink URL: https://github.com/apache/flink/pull/6968#discussion_r238817945 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/stream

[jira] [Commented] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams

[ https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709203#comment-16709203 ] ASF GitHub Bot commented on FLINK-4582: --- tweise commented on a change in pull reque

[jira] [Created] (FLINK-11071) Dynamic proxy classes cannot be resolved when deserializing job graph

Oleg Zhukov created FLINK-11071: --- Summary: Dynamic proxy classes cannot be resolved when deserializing job graph Key: FLINK-11071 URL: https://issues.apache.org/jira/browse/FLINK-11071 Project: Flink

[jira] [Commented] (FLINK-10907) Job recovery on the same JobManager causes JobManager metrics to report stale values

[ https://issues.apache.org/jira/browse/FLINK-10907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709116#comment-16709116 ] Mark Cho commented on FLINK-10907: -- [~Zentol] I think we can close this one out as it l

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709044#comment-16709044 ] ASF GitHub Bot commented on FLINK-11010: lamber-ken edited a comment on issue #7

[GitHub] lamber-ken edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

lamber-ken edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-444193677 hi, @tillrohrmann, the ci build failed, but I can't find something helpful for me from lo

[GitHub] lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-444193677 hi, @tillrohrmann, the ci build failed, but I can't find something helpful for me from log, how

[jira] [Commented] (FLINK-10930) Refactor checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708978#comment-16708978 ] Yun Tang commented on FLINK-10930: -- Speaking of eager and proper discarding useless sta

[jira] [Commented] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

[ https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708951#comment-16708951 ] ASF GitHub Bot commented on FLINK-10963: asfgit closed pull request #7161: [FLIN

[jira] [Closed] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

[ https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-10963. -- Resolution: Fixed Merged to master with bf5dc6c8bac73e7f8d54e983be2080cf6ce48a94 and to releas

[jira] [Commented] (FLINK-9002) Add operators with input type that goes through Avro serialization (with schema/generic)

[ https://issues.apache.org/jira/browse/FLINK-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708948#comment-16708948 ] ASF GitHub Bot commented on FLINK-9002: --- twalthr commented on issue #7041: [FLINK-9

[jira] [Commented] (FLINK-9001) Add operators with input type that goes through Kryo serialization (registered/generic/custom)

[ https://issues.apache.org/jira/browse/FLINK-9001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708947#comment-16708947 ] ASF GitHub Bot commented on FLINK-9001: --- twalthr commented on issue #7042: [FLINK-

[GitHub] asfgit closed pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

asfgit closed pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files. URL: https://github.com/apache/flink/pull/7161 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below

[GitHub] twalthr commented on issue #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization

twalthr commented on issue #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization URL: https://github.com/apache/flink/pull/7041#issuecomment-444160970 @tzulitai any news here? This is an

[GitHub] twalthr commented on issue #7042: [FLINK-9001] [e2e] Add operators with input type that goes through Kryo serialization

twalthr commented on issue #7042: [FLINK-9001] [e2e] Add operators with input type that goes through Kryo serialization URL: https://github.com/apache/flink/pull/7042#issuecomment-444160815 @tzulitai any news here? This is a

[GitHub] twalthr commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch

twalthr commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch URL: https://github.com/apache/flink/pull/7079#discussion_r238731972 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/co

[jira] [Commented] (FLINK-10845) Support DISTINCT aggregates for batch

[ https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708943#comment-16708943 ] ASF GitHub Bot commented on FLINK-10845: twalthr commented on a change in pull r

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708927#comment-16708927 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[GitHub] igalshilman opened a new pull request #7232: [hotfix][docs] Fix StreamingFileSink examples

igalshilman opened a new pull request #7232: [hotfix][docs] Fix StreamingFileSink examples URL: https://github.com/apache/flink/pull/7232 ## What is the purpose of the change The code examples for Scala and Java are both syntactically broken, and set a bad example in terms of effici

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708929#comment-16708929 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708926#comment-16708926 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708924#comment-16708924 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708928#comment-16708928 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r238718548 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r238706596 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708925#comment-16708925 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r238718086 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

  1   2   3   >