[jira] [Commented] (FLINK-11070) Add stream-stream non-window cross join

[ https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712454#comment-16712454 ] Fabian Hueske commented on FLINK-11070: --- Thanks for this issue [~hequn8128]! I think we

[jira] [Commented] (FLINK-10932) Initial flink-kubernetes module with empty implementation

[ https://issues.apache.org/jira/browse/FLINK-10932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712451#comment-16712451 ] Chunhui Shi commented on FLINK-10932: - This work is interesting. When can we make progress to pull

[GitHub] KarmaGYZ commented on issue #7260: [hotfix][docs] Fix typo and make improvement in Kafka Connectors doc

KarmaGYZ commented on issue #7260: [hotfix][docs] Fix typo and make improvement in Kafka Connectors doc URL: https://github.com/apache/flink/pull/7260#issuecomment-445148910 cc @yanghua @pnowojski This is an automated

[GitHub] KarmaGYZ opened a new pull request #7260: [hotfix][docs] Fix typo and make improvement in Kafka Connectors doc

KarmaGYZ opened a new pull request #7260: [hotfix][docs] Fix typo and make improvement in Kafka Connectors doc URL: https://github.com/apache/flink/pull/7260 ## What is the purpose of the change This pull request fix typo and make improvement in Kafka Connectors doc ##

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in

[GitHub] maqingxiang opened a new pull request #7259: [hotfix][Table API & SQL] fix example in connect.md table docs

maqingxiang opened a new pull request #7259: [hotfix][Table API & SQL] fix example in connect.md table docs URL: https://github.com/apache/flink/pull/7259 This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Summary: Restored state in RocksDBStateBackend that has not been accessed in

[jira] [Created] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in new execution causes NPE on snapshot

Tzu-Li (Gordon) Tai created FLINK-11094: --- Summary: Restored state in RocksDBStateBackend that has not been accessed in new execution causes NPE on snapshot Key: FLINK-11094 URL:

[jira] [Assigned] (FLINK-10478) Kafka Producer wrongly formats "%" for transaction ID

[ https://issues.apache.org/jira/browse/FLINK-10478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-10478: - Assignee: leesf (was: vinoyang) > Kafka Producer wrongly formats "%" for transaction ID >

[jira] [Commented] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712349#comment-16712349 ] xuqianjin commented on FLINK-9740: -- hi [~twalthr] I have resubmitted this design thanks qianjin >

[GitHub] KarmaGYZ commented on a change in pull request #7211: [hotfix][docs] Add and update description of local-recovery config op…

KarmaGYZ commented on a change in pull request #7211: [hotfix][docs] Add and update description of local-recovery config op… URL: https://github.com/apache/flink/pull/7211#discussion_r239697454 ## File path: docs/_includes/generated/checkpointing_configuration.html ## @@

[jira] [Created] (FLINK-11093) Migrate flink-table runtime Function classes

xueyu created FLINK-11093: - Summary: Migrate flink-table runtime Function classes Key: FLINK-11093 URL: https://issues.apache.org/jira/browse/FLINK-11093 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11092) Migrate flink-table runtime Selector and Collector classes

xueyu created FLINK-11092: - Summary: Migrate flink-table runtime Selector and Collector classes Key: FLINK-11092 URL: https://issues.apache.org/jira/browse/FLINK-11092 Project: Flink Issue Type: New

[jira] [Closed] (FLINK-10792) Extend SQL client end-to-end to test KafkaTableSink for kafka 0.11 connector

[ https://issues.apache.org/jira/browse/FLINK-10792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-10792. Resolution: Duplicate > Extend SQL client end-to-end to test KafkaTableSink for kafka 0.11 connector >

[GitHub] yanghua commented on a change in pull request #7211: [hotfix][docs] Add and update description of local-recovery config op…

yanghua commented on a change in pull request #7211: [hotfix][docs] Add and update description of local-recovery config op… URL: https://github.com/apache/flink/pull/7211#discussion_r239695031 ## File path: docs/_includes/generated/checkpointing_configuration.html ## @@

[GitHub] yanghua commented on a change in pull request #7211: [hotfix][docs] Add and update description of local-recovery config op…

yanghua commented on a change in pull request #7211: [hotfix][docs] Add and update description of local-recovery config op… URL: https://github.com/apache/flink/pull/7211#discussion_r239695031 ## File path: docs/_includes/generated/checkpointing_configuration.html ## @@

[jira] [Assigned] (FLINK-11091) Clear the use of deprecated methods of KeyedStream in table operators

[ https://issues.apache.org/jira/browse/FLINK-11091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-11091: --- Assignee: sunjincheng > Clear the use of deprecated methods of KeyedStream in table

[jira] [Updated] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-9740: - Attachment: Discuss [FLINK-9740] Support group windows over intervals of months.pdf > Support group

[jira] [Created] (FLINK-11091) Clear the use of deprecated methods of KeyedStream in table operators

sunjincheng created FLINK-11091: --- Summary: Clear the use of deprecated methods of KeyedStream in table operators Key: FLINK-11091 URL: https://issues.apache.org/jira/browse/FLINK-11091 Project: Flink

[jira] [Created] (FLINK-11090) Unused parameter in WindowedStream.aggregate()

Hequn Cheng created FLINK-11090: --- Summary: Unused parameter in WindowedStream.aggregate() Key: FLINK-11090 URL: https://issues.apache.org/jira/browse/FLINK-11090 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712306#comment-16712306 ] xueyu commented on FLINK-11065: --- hi, [~hequn8128], I totally agree with you. Last time when I port UDF

[jira] [Commented] (FLINK-10974) Add FlatMap to TableAPI

[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712304#comment-16712304 ] ASF GitHub Bot commented on FLINK-10974: dianfu commented on a change in pull request #7196:

[GitHub] dianfu commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API

dianfu commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196#discussion_r239688529 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala

[GitHub] Clarkkkkk opened a new pull request #7258: Flink 11084

Clark opened a new pull request #7258: Flink 11084 URL: https://github.com/apache/flink/pull/7258 ## What is the purpose of the change This PR fix the incorrect output when there are consecutive split and select. ## Brief change log - Add a OutputSelectorWrapper

[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=16712292#comment-16712292 ] ASF GitHub Bot commented on FLINK-11010: lamber-ken commented on issue #7180: [FLINK-11010]

[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-445109507 @walterddr, you are welcome. flink sql use `CodeGenerator#generateProctimeTimestamp` method

[jira] [Commented] (FLINK-11069) Remove FutureUtil

[ https://issues.apache.org/jira/browse/FLINK-11069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712288#comment-16712288 ] ASF GitHub Bot commented on FLINK-11069: TisonKun edited a comment on issue #7245: [FLINK-11069]

[GitHub] TisonKun edited a comment on issue #7245: [FLINK-11069] [utils] Remove FutureUtil

TisonKun edited a comment on issue #7245: [FLINK-11069] [utils] Remove FutureUtil URL: https://github.com/apache/flink/pull/7245#issuecomment-445107203 Thanks @yanghua. I notice the inconsistent among `util.function`. With 1e6a91a3bf7e734eccdb034ce505b3775b709265 @StephanEwen mark the

[jira] [Commented] (FLINK-11024) Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-11024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712286#comment-16712286 ] ASF GitHub Bot commented on FLINK-11024: liu-zhaokun commented on issue #7193:

[jira] [Commented] (FLINK-11069) Remove FutureUtil

[ https://issues.apache.org/jira/browse/FLINK-11069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712287#comment-16712287 ] ASF GitHub Bot commented on FLINK-11069: TisonKun edited a comment on issue #7245: [FLINK-11069]

[GitHub] TisonKun edited a comment on issue #7245: [FLINK-11069] [utils] Remove FutureUtil

TisonKun edited a comment on issue #7245: [FLINK-11069] [utils] Remove FutureUtil URL: https://github.com/apache/flink/pull/7245#issuecomment-445107203 Thanks @yanghua. I notice the inconsistent among `util.function`. With 1e6a91a3bf7e734eccdb034ce505b3775b709265 @StephanEwen mark the

[GitHub] liu-zhaokun commented on issue #7193: [FLINK-11024]Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml

liu-zhaokun commented on issue #7193: [FLINK-11024]Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml URL: https://github.com/apache/flink/pull/7193#issuecomment-445108043 @tillrohrmann Hi,I dont think this failing check related to me.Are

[jira] [Created] (FLINK-11089) Log filecache directory removed messages

liuzhaokun created FLINK-11089: -- Summary: Log filecache directory removed messages Key: FLINK-11089 URL: https://issues.apache.org/jira/browse/FLINK-11089 Project: Flink Issue Type:

[jira] [Commented] (FLINK-11069) Remove FutureUtil

[ https://issues.apache.org/jira/browse/FLINK-11069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712284#comment-16712284 ] ASF GitHub Bot commented on FLINK-11069: TisonKun commented on issue #7245: [FLINK-11069]

[GitHub] TisonKun commented on issue #7245: [FLINK-11069] [utils] Remove FutureUtil

TisonKun commented on issue #7245: [FLINK-11069] [utils] Remove FutureUtil URL: https://github.com/apache/flink/pull/7245#issuecomment-445107203 Thanks @yanghua. I notice the inconsistent among `util.function`. With 1e6a91a3bf7e734eccdb034ce505b3775b709265 @StephanEwen mark the

[GitHub] liu-zhaokun opened a new pull request #7257: [FLINK-11089]Log filecache directory removed messages

liu-zhaokun opened a new pull request #7257: [FLINK-11089]Log filecache directory removed messages URL: https://github.com/apache/flink/pull/7257 [https://issues.apache.org/jira/browse/FLINK-11089](https://issues.apache.org/jira/browse/FLINK-11089) When taskmanager exit or shutdown,the

[jira] [Commented] (FLINK-11089) Log filecache directory removed messages

[ https://issues.apache.org/jira/browse/FLINK-11089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712280#comment-16712280 ] ASF GitHub Bot commented on FLINK-11089: liu-zhaokun opened a new pull request #7257:

[jira] [Updated] (FLINK-11089) Log filecache directory removed messages

[ https://issues.apache.org/jira/browse/FLINK-11089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11089: --- Labels: pull-request-available (was: ) > Log filecache directory removed messages >

[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=16712272#comment-16712272 ] ASF GitHub Bot commented on FLINK-11010: walterddr commented on issue #7180: [FLINK-11010]

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

walterddr commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-445103065 Hi @lamber-ken sorry for the late response. I am a bit confuse with the JIRA ticket description

[jira] [Commented] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

[ https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712265#comment-16712265 ] ASF GitHub Bot commented on FLINK-11050: Myracle commented on issue #7226: FLINK-11050 add

[GitHub] Myracle commented on issue #7226: FLINK-11050 add lowerBound and upperBound for optimizing RocksDBMapState's entries

Myracle commented on issue #7226: FLINK-11050 add lowerBound and upperBound for optimizing RocksDBMapState's entries URL: https://github.com/apache/flink/pull/7226#issuecomment-445098945 > Hi @Myracle, thanks for the PR. I think we should either support the new API for all `MapState`

[jira] [Commented] (FLINK-11069) Remove FutureUtil

[ https://issues.apache.org/jira/browse/FLINK-11069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712262#comment-16712262 ] ASF GitHub Bot commented on FLINK-11069: yanghua commented on issue #7245: [FLINK-11069] [utils]

[GitHub] yanghua commented on issue #7245: [FLINK-11069] [utils] Remove FutureUtil

yanghua commented on issue #7245: [FLINK-11069] [utils] Remove FutureUtil URL: https://github.com/apache/flink/pull/7245#issuecomment-445098606 Hi @TisonKun ``` 18:26:28.316 [ERROR] Failed to execute goal com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp (default) on

[jira] [Commented] (FLINK-11084) Incorrect ouput after two consecutive split and select

[ https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712255#comment-16712255 ] Shimin Yang commented on FLINK-11084: - Hi [~aljoscha], I don't agree on that. From the view of

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

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712251#comment-16712251 ] Hequn Cheng commented on FLINK-11065: - [~twalthr] Sounds great. Smaller PRs are better and easier to

[GitHub] link3280 closed pull request #6887: [FLINK-10601] [YARN] Make user home dir consistent with Flink default filesystem

link3280 closed pull request #6887: [FLINK-10601] [YARN] Make user home dir consistent with Flink default filesystem URL: https://github.com/apache/flink/pull/6887 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[jira] [Commented] (FLINK-10601) Make user home dir consistent with Flink default filesystem

[ https://issues.apache.org/jira/browse/FLINK-10601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712245#comment-16712245 ] ASF GitHub Bot commented on FLINK-10601: link3280 commented on issue #6887: [FLINK-10601] [YARN]

[jira] [Commented] (FLINK-10601) Make user home dir consistent with Flink default filesystem

[ https://issues.apache.org/jira/browse/FLINK-10601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712246#comment-16712246 ] ASF GitHub Bot commented on FLINK-10601: link3280 closed pull request #6887: [FLINK-10601]

[GitHub] link3280 commented on issue #6887: [FLINK-10601] [YARN] Make user home dir consistent with Flink default filesystem

link3280 commented on issue #6887: [FLINK-10601] [YARN] Make user home dir consistent with Flink default filesystem URL: https://github.com/apache/flink/pull/6887#issuecomment-445095013 This may break [FLINK-6376] for the application probably will not apply for the HDFS delegation that

[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=16712232#comment-16712232 ] ASF GitHub Bot commented on FLINK-11010: Jennifer-sarah commented on issue #7180: [FLINK-11010]

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

Jennifer-sarah commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-445092699 +1, from my side. I had the [same

[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=16712224#comment-16712224 ] ASF GitHub Bot commented on FLINK-7208: --- sunjincheng121 commented on issue #7201: [FLINK-7208]

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

sunjincheng121 commented on issue #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#issuecomment-445091806 Hi @twalthr @walterddr @dianfu I totally agree that any changes will be covered by the test case！Thanks

[jira] [Commented] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712219#comment-16712219 ] xuqianjin commented on FLINK-9740: -- hi [~twalthr] I'm sorry that I found some details need to be

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712208#comment-16712208 ] ASF GitHub Bot commented on FLINK-11074: walterddr commented on a change in pull request #7253:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712209#comment-16712209 ] ASF GitHub Bot commented on FLINK-11074: walterddr commented on a change in pull request #7253:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712211#comment-16712211 ] ASF GitHub Bot commented on FLINK-11074: walterddr commented on a change in pull request #7253:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712210#comment-16712210 ] ASF GitHub Bot commented on FLINK-11074: walterddr commented on a change in pull request #7253:

[GitHub] walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r239669171 ## File path:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712206#comment-16712206 ] ASF GitHub Bot commented on FLINK-11074: walterddr commented on a change in pull request #7253:

[GitHub] walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r239668845 ## File path:

[GitHub] walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r239668845 ## File path:

[GitHub] walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r239669171 ## File path:

[GitHub] walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r239669171 ## File path:

[GitHub] walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r239668705 ## File path:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712207#comment-16712207 ] ASF GitHub Bot commented on FLINK-11074: walterddr commented on a change in pull request #7253:

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

[ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712183#comment-16712183 ] ASF GitHub Bot commented on FLINK-11048: tweise commented on a change in pull request #7249:

[GitHub] tweise commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

tweise commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239665450 ## File path:

[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=16712177#comment-16712177 ] ASF GitHub Bot commented on FLINK-7208: --- sunjincheng121 commented on a change in pull request

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

sunjincheng121 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_r239663677 ## File path:

[jira] [Commented] (FLINK-10973) Add Map operator to Table API

[ https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712156#comment-16712156 ] ASF GitHub Bot commented on FLINK-10973: sunjincheng121 commented on issue #7167: [FLINK-10973]

[GitHub] sunjincheng121 commented on issue #7167: [FLINK-10973] [table] Add support for map to table API

sunjincheng121 commented on issue #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#issuecomment-445072642 Here a minor suggestion： In the java example we use `RowTypeInfo.java` instead of `Types.scala` to create getResultType.

[jira] [Assigned] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11088: - Assignee: Rong Rong > Improve Kerberos Authentication using Keytab in YARN proxy user mode >

[jira] [Updated] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Component/s: Security > Improve Kerberos Authentication using Keytab in YARN proxy user mode >

[jira] [Created] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode

Rong Rong created FLINK-11088: - Summary: Improve Kerberos Authentication using Keytab in YARN proxy user mode Key: FLINK-11088 URL: https://issues.apache.org/jira/browse/FLINK-11088 Project: Flink

[jira] [Commented] (FLINK-10974) Add FlatMap to TableAPI

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

[jira] [Commented] (FLINK-10974) Add FlatMap to TableAPI

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

[GitHub] sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API

sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196#discussion_r239653799 ## File path:

[GitHub] sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API

sunjincheng121 commented on a change in pull request #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196#discussion_r239654833 ## File path:

[jira] [Commented] (FLINK-11077) Make subtask aware of the timeout of checkpoint and abort the current ongoing asynccheckpoint

[ https://issues.apache.org/jira/browse/FLINK-11077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712021#comment-16712021 ] Stephan Ewen commented on FLINK-11077: -- There are plans that the checkpoint coordinator sends

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

[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712017#comment-16712017 ] Stephan Ewen edited comment on FLINK-10930 at 12/6/18 8:53 PM: --- [~yunta]

[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=16712017#comment-16712017 ] Stephan Ewen commented on FLINK-10930: -- [~yunta] Better exception handling is definitely always a

[jira] [Commented] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711900#comment-16711900 ] Stephan Ewen commented on FLINK-11085: -- [~Zentol] The class is not filtered out, the filter defines

[jira] [Comment Edited] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711803#comment-16711803 ] Arnaud Linz edited comment on FLINK-10832 at 12/6/18 6:22 PM: -- Okay, it

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711803#comment-16711803 ] Arnaud Linz commented on FLINK-10832: - Which jdk are you using? >

[jira] [Updated] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11087: --- Labels: Migration State broadcast pull-request-available (was: Migration State broadcast)

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711678#comment-16711678 ] ASF GitHub Bot commented on FLINK-11087: tzulitai opened a new pull request #7256: [FLINK-11087]

[GitHub] tzulitai opened a new pull request #7256: [FLINK-11087] [state] Incorrect K/V serializer association when reading broadcast from 1.5.x snapshots

tzulitai opened a new pull request #7256: [FLINK-11087] [state] Incorrect K/V serializer association when reading broadcast from 1.5.x snapshots URL: https://github.com/apache/flink/pull/7256 ## What is the purpose of the change This is a bug that prevents Flink versions 1.6.x (up

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

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711649#comment-16711649 ] Timo Walther commented on FLINK-11065: -- [~hequn8128] Yes, I think runner classes are straight

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711638#comment-16711638 ] Tzu-Li (Gordon) Tai commented on FLINK-11087: - Yes, will do. > Broadcast state migration

[jira] [Updated] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11087: Affects Version/s: 1.6.2 > Broadcast state migration Incompatibility from 1.5.3

[jira] [Updated] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11087: Priority: Blocker (was: Major) > Broadcast state migration Incompatibility from

  1   2   3   >