[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

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

[GitHub] sunjincheng121 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

sunjincheng121 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#issuecomment-440561427 @hequn8128 Thanks for the PR. I am glad to review the changes after you rebase the code! Best,

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[GitHub] sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235268470 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/fl

[jira] [Commented] (FLINK-10941) Slots prematurely released which still contain unconsumed data

[ https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694247#comment-16694247 ] Qi commented on FLINK-10941: Thanks [~zjwang]! We will keep an eye on that. > Slots prematu

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[GitHub] dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235254991 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/

[GitHub] dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235254880 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[jira] [Commented] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable

[ https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694199#comment-16694199 ] Hequn Cheng commented on FLINK-10873: - [~fhueske] Thanks for your information. I hav

[GitHub] sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235247291 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/fl

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[GitHub] sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235247496 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/fl

[jira] [Commented] (FLINK-10662) Refactor the ChannelSelector interface for single selected channel

[ https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694190#comment-16694190 ] zhijiang commented on FLINK-10662: -- Thanks for all the suggestions!  I think we all re

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[GitHub] sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235246730 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/fl

[jira] [Comment Edited] (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=16694177#comment-16694177 ] zhijiang edited comment on FLINK-10884 at 11/21/18 3:47 AM:

[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=16694177#comment-16694177 ] zhijiang commented on FLINK-10884: -- I just quickly reviewed the related codes. In my an

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[GitHub] dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235244088 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[GitHub] dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235243736 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[GitHub] dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235243602 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[GitHub] dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235243458 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/

[GitHub] dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

dianfu commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r235243458 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/

[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks

[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694160#comment-16694160 ] Jiayi Liao commented on FLINK-5601: --- [~icshuo] Sorry it's a mistake... Thanks for poin

[jira] [Comment Edited] (FLINK-5601) Window operator does not checkpoint watermarks

[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694096#comment-16694096 ] Shuo Cheng edited comment on FLINK-5601 at 11/21/18 3:16 AM: -

[jira] [Commented] (FLINK-10914) Prefer notifying status changed to waiting and checking in ExecutionGraph tests

[ https://issues.apache.org/jira/browse/FLINK-10914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694152#comment-16694152 ] TisonKun commented on FLINK-10914: -- [~till.rohrmann] [~StephanEwen] do you mean, as you

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

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

[GitHub] tweise commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

tweise commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#discussion_r235234375 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/watermark/SourceWater

[jira] [Commented] (FLINK-10834) TableAPI flatten() calculated value error

[ https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694115#comment-16694115 ] Hequn Cheng commented on FLINK-10834: - Hi, thanks for your discussion and suggestion

[jira] [Updated] (FLINK-10956) Reuse same rexCall during codegen

[ https://issues.apache.org/jira/browse/FLINK-10956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-10956: Description: Currently, same rexCalls have not been reused during codegen. I think we can add som

[jira] [Created] (FLINK-10956) Reuse same rexCall during codegen

Hequn Cheng created FLINK-10956: --- Summary: Reuse same rexCall during codegen Key: FLINK-10956 URL: https://issues.apache.org/jira/browse/FLINK-10956 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-10945: Description: Currently *resource deadlocks* can happen to finite stream jobs(or batch jobs) when resource

[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks

[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694096#comment-16694096 ] Shuo Cheng commented on FLINK-5601: --- Hi, JiaYi, You say that the watermark restored is

[jira] [Commented] (FLINK-10955) Extend release notes for Flink 1.7

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

[GitHub] hequn8128 commented on a change in pull request #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0

hequn8128 commented on a change in pull request #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0 URL: https://github.com/apache/flink/pull/7150#discussion_r235222632 ## File path: docs/release-notes/flink-1.7.md ## @@ -22,6 +22,89 @@ under the License. T

[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&focusedCommentId=16693894#comment-16693894 ] ASF GitHub Bot commented on FLINK-10932: isunjin commented on a change in pull r

[GitHub] isunjin commented on a change in pull request #7144: [FLINK-10932] [ResourceManager] Initial flink-kubernetes module with empty implementation

isunjin commented on a change in pull request #7144: [FLINK-10932] [ResourceManager] Initial flink-kubernetes module with empty implementation URL: https://github.com/apache/flink/pull/7144#discussion_r235208074 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernet

[jira] [Commented] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693835#comment-16693835 ] Shuyi Chen commented on FLINK-10848: [~till.rohrmann], can you help take a look at t

[jira] [Commented] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693833#comment-16693833 ] Shuyi Chen commented on FLINK-10868: Hi [~till.rohrmann], the following describes th

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

[GitHub] tweise commented on a change in pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

tweise commented on a change in pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980#discussion_r235154450 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/c

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

[GitHub] tweise commented on a change in pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

tweise commented on a change in pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980#discussion_r235149642 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/c

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

[GitHub] tweise commented on a change in pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

tweise commented on a change in pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980#discussion_r235149070 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/c

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235147078 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/or

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235146538 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/or

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235146282 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/or

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235145995 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/or

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235145345 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/or

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235144945 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/or

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235143376 ## File path: flink-connectors/flink-connector-cassandra/src/main/java/or

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235143059 ## File path: flink-connectors/flink-connector-cassandra/src/main/java/or

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235142979 ## File path: flink-connectors/flink-connector-cassandra/src/main/java/or

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235142071 ## File path: flink-connectors/flink-connector-cassandra/src/main/java/or

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[GitHub] zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

zentol commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r235141641 ## File path: flink-connectors/flink-connector-cassandra/src/main/java/or

[jira] [Commented] (FLINK-10955) Extend release notes for Flink 1.7

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

[jira] [Commented] (FLINK-10955) Extend release notes for Flink 1.7

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

[jira] [Commented] (FLINK-10955) Extend release notes for Flink 1.7

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

[GitHub] zentol commented on a change in pull request #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0

zentol commented on a change in pull request #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0 URL: https://github.com/apache/flink/pull/7150#discussion_r235135547 ## File path: docs/release-notes/flink-1.7.md ## @@ -22,6 +22,89 @@ under the License. Thes

[GitHub] zentol commented on a change in pull request #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0

zentol commented on a change in pull request #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0 URL: https://github.com/apache/flink/pull/7150#discussion_r235134511 ## File path: docs/release-notes/flink-1.7.md ## @@ -22,6 +22,89 @@ under the License. Thes

[GitHub] zentol commented on a change in pull request #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0

zentol commented on a change in pull request #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0 URL: https://github.com/apache/flink/pull/7150#discussion_r235134684 ## File path: docs/release-notes/flink-1.7.md ## @@ -22,6 +22,89 @@ under the License. Thes

[jira] [Commented] (FLINK-10952) How to stream MySQl data and Store in Flink Dataset

[ https://issues.apache.org/jira/browse/FLINK-10952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693678#comment-16693678 ] Ken Krugler commented on FLINK-10952: - Hi [~vinothmahalingam] - for problems with Fl

[jira] [Updated] (FLINK-10951) Disable enforcing of YARN container virtual memory limits in tests

[ https://issues.apache.org/jira/browse/FLINK-10951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10951: - Fix Version/s: 1.7.1 1.6.3 > Disable enforcing of YARN container virtual memory limit

[jira] [Commented] (FLINK-10903) Shade Internal Akka Dependencies

[ https://issues.apache.org/jira/browse/FLINK-10903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693574#comment-16693574 ] Luka Jurukovski commented on FLINK-10903: - Thanks for the in depth response! *A

[jira] [Commented] (FLINK-10904) Expose Classloader before Pipeline execution

[ https://issues.apache.org/jira/browse/FLINK-10904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693591#comment-16693591 ] Luka Jurukovski commented on FLINK-10904: - I have a shaded jar with a `main` ent

[jira] [Commented] (FLINK-10955) Extend release notes for Flink 1.7

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

[GitHub] tillrohrmann opened a new pull request #7151: [BP-1.7][FLINK-10955] Extend release notes for Apache Flink 1.7.0

tillrohrmann opened a new pull request #7151: [BP-1.7][FLINK-10955] Extend release notes for Apache Flink 1.7.0 URL: https://github.com/apache/flink/pull/7151 Backport of #7150 for `release-1.7`. This is an automated message

[jira] [Updated] (FLINK-10955) Extend release notes for Flink 1.7

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

[GitHub] tillrohrmann opened a new pull request #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0

tillrohrmann opened a new pull request #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0 URL: https://github.com/apache/flink/pull/7150 ## What is the purpose of the change Extend release notes for Apache Flink 1.7.0. This includes all the release notes of issues fixe

[jira] [Commented] (FLINK-10952) How to stream MySQl data and Store in Flink Dataset

[ https://issues.apache.org/jira/browse/FLINK-10952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693546#comment-16693546 ] vinoth commented on FLINK-10952: thanks for your response, But this link its not workin

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

[jira] [Closed] (FLINK-10256) Port legacy jobmanager test to FILP-6

[ https://issues.apache.org/jira/browse/FLINK-10256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10256. - Resolution: Duplicate Fix Version/s: (was: 1.7.0) Release Note: (was: The purpo

[jira] [Created] (FLINK-10955) Extend release notes for Flink 1.7

Till Rohrmann created FLINK-10955: - Summary: Extend release notes for Flink 1.7 Key: FLINK-10955 URL: https://issues.apache.org/jira/browse/FLINK-10955 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693531#comment-16693531 ] Yun Tang commented on FLINK-10954: -- First of all, I plan to handle the exception after

[jira] [Assigned] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-10954: Assignee: Yun Tang > Hardlink from files of previous local stored state might cross devices > ---

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

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

  1   2   3   >