[jira] [Created] (FLINK-10968) Implement TaskManager Entrypoint

JIN SUN created FLINK-10968: --- Summary: Implement TaskManager Entrypoint Key: FLINK-10968 URL: https://issues.apache.org/jira/browse/FLINK-10968 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-10971) Dependency convergence issue when building flink-s3-fs-presto

[ https://issues.apache.org/jira/browse/FLINK-10971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-10971: Attachment: FLINK-10971-build_output_flink-s3-fs-presto FLINK-10971-build_output

[jira] [Created] (FLINK-10971) Dependency convergence issue when building flink-s3-fs-presto

Ufuk Celebi created FLINK-10971: --- Summary: Dependency convergence issue when building flink-s3-fs-presto Key: FLINK-10971 URL: https://issues.apache.org/jira/browse/FLINK-10971 Project: Flink

[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=16695089#comment-16695089 ] ASF GitHub Bot commented on FLINK-9083: --- azagrebin commented on a change in pull request #6782:

[jira] [Commented] (FLINK-10946) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695166#comment-16695166 ] ASF GitHub Bot commented on FLINK-10946: azagrebin commented on issue #7154: [FLINK-10946]

[GitHub] azagrebin commented on issue #7154: [FLINK-10946] Silent checkpoint async failures in task executor if job is not runnning

azagrebin commented on issue #7154: [FLINK-10946] Silent checkpoint async failures in task executor if job is not runnning URL: https://github.com/apache/flink/pull/7154#issuecomment-440785486 passed in my CI: https://travis-ci.org/azagrebin/flink/builds/458023830

[jira] [Created] (FLINK-10970) expose metric for total state size in terms of bytes

Steven Zhen Wu created FLINK-10970: -- Summary: expose metric for total state size in terms of bytes Key: FLINK-10970 URL: https://issues.apache.org/jira/browse/FLINK-10970 Project: Flink

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

azagrebin 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_r234920560 ## File path:

[jira] [Commented] (FLINK-10959) sometimes most taskmanger in the same node

[ https://issues.apache.org/jira/browse/FLINK-10959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695163#comment-16695163 ] Ken Krugler commented on FLINK-10959: - Hi [~luyee] - this is something that would be best to first

[jira] [Commented] (FLINK-10971) Dependency convergence issue when building flink-s3-fs-presto

[ https://issues.apache.org/jira/browse/FLINK-10971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695304#comment-16695304 ] Ufuk Celebi commented on FLINK-10971: - *Note*: I verified that the actual RC binaries don't have

[jira] [Created] (FLINK-10969) expose API or metric for total number of keys stored in state backend

Steven Zhen Wu created FLINK-10969: -- Summary: expose API or metric for total number of keys stored in state backend Key: FLINK-10969 URL: https://issues.apache.org/jira/browse/FLINK-10969 Project:

[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=16695332#comment-16695332 ] ASF GitHub Bot commented on FLINK-10887: jgrier commented on a change in pull request #7099:

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

jgrier 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_r235559380 ## File path:

[jira] [Updated] (FLINK-10969) expose API or metric for total number of keys stored in state backend

[ https://issues.apache.org/jira/browse/FLINK-10969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-10969: --- Description: [~srichter] mentioned it might make sense to provide two versions: exact count

[jira] [Reopened] (FLINK-10138) Queryable state (rocksdb) end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-10138: -- > Queryable state (rocksdb) end-to-end test failed on Travis >

[jira] [Commented] (FLINK-10862) REST API does not show program descriptions of "simple" ProgramDescription

[ https://issues.apache.org/jira/browse/FLINK-10862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694568#comment-16694568 ] Chesnay Schepler commented on FLINK-10862: -- This issue is related to FLINK-10864 in that it

[jira] [Updated] (FLINK-10368) 'Kerberized YARN on Docker test' unstable

[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10368: -- Summary: 'Kerberized YARN on Docker test' unstable (was: 'Kerberized YARN on Docker test'

[jira] [Reopened] (FLINK-10368) 'Kerberized YARN on Docker test' instable

[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-10368: --- > 'Kerberized YARN on Docker test' instable > - > >

[GitHub] tillrohrmann commented on issue #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0

tillrohrmann commented on issue #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0 URL: https://github.com/apache/flink/pull/7150#issuecomment-440639380 Good point @zentol. I've replaced all config options with their respective links now.

[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=16694607#comment-16694607 ] ASF GitHub Bot commented on FLINK-10955: tillrohrmann commented on issue #7150: [FLINK-10955]

[jira] [Created] (FLINK-10961) RuntimeException: Could not extract key when using closure

Avi Levi created FLINK-10961: Summary: RuntimeException: Could not extract key when using closure Key: FLINK-10961 URL: https://issues.apache.org/jira/browse/FLINK-10961 Project: Flink Issue

[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=16694630#comment-16694630 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[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=16694622#comment-16694622 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[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=16694625#comment-16694625 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[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=16694619#comment-16694619 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[jira] [Commented] (FLINK-10924) StreamExecutionEnvironment method javadocs incorrect in regards to used charset

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

[jira] [Commented] (FLINK-10924) StreamExecutionEnvironment method javadocs incorrect in regards to used charset

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

[jira] [Commented] (FLINK-10924) StreamExecutionEnvironment method javadocs incorrect in regards to used charset

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

[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=16694624#comment-16694624 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[GitHub] zentol commented on a change in pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in…

zentol commented on a change in pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in… URL: https://github.com/apache/flink/pull/7143#discussion_r235362367 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235318373 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235321744 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235361226 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235316850 ## File path:

[jira] [Commented] (FLINK-10924) StreamExecutionEnvironment method javadocs incorrect in regards to used charset

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

[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=16694620#comment-16694620 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235315365 ## File path:

[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=16694628#comment-16694628 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[jira] [Commented] (FLINK-10924) StreamExecutionEnvironment method javadocs incorrect in regards to used charset

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

[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=16694626#comment-16694626 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[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=16694623#comment-16694623 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[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=16694618#comment-16694618 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[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=16694629#comment-16694629 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235361188 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235313379 ## File path:

[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=16694407#comment-16694407 ] Arnaud Linz commented on FLINK-10832: - Sorry for the long delay, I did not get the notification,

[jira] [Updated] (FLINK-10946) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10946: Description: [https://travis-ci.org/azagrebin/flink/jobs/456972759]

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

tillrohrmann 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_r235304865 ## File path: docs/release-notes/flink-1.7.md ## @@ -22,6 +22,89 @@ under the License.

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

hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#issuecomment-440596555 @sunjincheng121 thanks for your attention. I have rebased to the master.

[jira] [Updated] (FLINK-10960) CEP: Job Failure when .times(2) is used

[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10960: Description: Hi Guys, Encountered a strange one today. We use the CEP library in

[jira] [Created] (FLINK-10960) CEP: Job Failure when .times(2) is used

Thomas Wozniakowski created FLINK-10960: --- Summary: CEP: Job Failure when .times(2) is used Key: FLINK-10960 URL: https://issues.apache.org/jira/browse/FLINK-10960 Project: Flink Issue

[jira] [Updated] (FLINK-10960) CEP: Job Failure when .times(2) is used

[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10960: Description: Hi Guys, Encountered a strange one today. We use the CEP library in

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

[ https://issues.apache.org/jira/browse/FLINK-10956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694593#comment-16694593 ] Timo Walther commented on FLINK-10956: -- [~hequn8128] Yes, this is a known limitation that could be

[jira] [Commented] (FLINK-10960) CEP: Job Failure when .times(2) is used

[ https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694605#comment-16694605 ] Dawid Wysakowicz commented on FLINK-10960: -- Hi [~Jamalarm] Could you provide us with a

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

tillrohrmann 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_r235359939 ## File path: docs/release-notes/flink-1.7.md ## @@ -37,6 +120,15 @@ You should only

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

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235362084 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235312380 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235317112 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235320988 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235346023 ## File path:

[GitHub] zentol commented on a change in pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in…

zentol commented on a change in pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in… URL: https://github.com/apache/flink/pull/7143#discussion_r235362604 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235313039 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235361617 ## File path:

[GitHub] zentol commented on a change in pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in…

zentol commented on a change in pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in… URL: https://github.com/apache/flink/pull/7143#discussion_r235362545 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235315365 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235360525 ## File path:

[GitHub] zentol commented on a change in pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in…

zentol commented on a change in pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in… URL: https://github.com/apache/flink/pull/7143#discussion_r235362522 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235316296 ## File path:

[GitHub] dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

dianfu commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r235351015 ## File path:

[GitHub] zentol commented on a change in pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in…

zentol commented on a change in pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in… URL: https://github.com/apache/flink/pull/7143#discussion_r235362402 ## File path:

[jira] [Updated] (FLINK-10961) RuntimeException: Could not extract key when using closure

[ https://issues.apache.org/jira/browse/FLINK-10961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10961: - Component/s: (was: Kafka Connector) Scala API > RuntimeException:

[jira] [Updated] (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:all-tabpanel ] Arnaud Linz updated FLINK-10832: Attachment: (was: pom.xml) > StreamExecutionEnvironment.execute() does not return when all

[jira] [Updated] (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:all-tabpanel ] Arnaud Linz updated FLINK-10832: Attachment: log.txt > StreamExecutionEnvironment.execute() does not return when all sources end >

[jira] [Updated] (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:all-tabpanel ] Arnaud Linz updated FLINK-10832: Attachment: flink-10832.zip > StreamExecutionEnvironment.execute() does not return when all

[jira] [Commented] (FLINK-9574) Add a dedicated documentation page for state evolution

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

[jira] [Commented] (FLINK-9574) Add a dedicated documentation page for state evolution

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

[GitHub] dawidwys commented on a change in pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution

dawidwys commented on a change in pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution URL: https://github.com/apache/flink/pull/7124#discussion_r235290652 ## File path: docs/dev/stream/state/schema_evolution.md ##

[GitHub] dawidwys commented on a change in pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution

dawidwys commented on a change in pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution URL: https://github.com/apache/flink/pull/7124#discussion_r235298883 ## File path: docs/dev/stream/state/custom_serialization.md

[GitHub] dawidwys commented on a change in pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution

dawidwys commented on a change in pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution URL: https://github.com/apache/flink/pull/7124#discussion_r235299684 ## File path: docs/dev/stream/state/custom_serialization.md

[GitHub] dawidwys commented on a change in pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution

dawidwys commented on a change in pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution URL: https://github.com/apache/flink/pull/7124#discussion_r235294163 ## File path: docs/dev/stream/state/custom_serialization.md

[GitHub] dawidwys commented on a change in pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution

dawidwys commented on a change in pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution URL: https://github.com/apache/flink/pull/7124#discussion_r235296908 ## File path: docs/dev/stream/state/schema_evolution.md ##

[jira] [Commented] (FLINK-9574) Add a dedicated documentation page for state evolution

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

[jira] [Commented] (FLINK-9574) Add a dedicated documentation page for state evolution

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

[GitHub] tillrohrmann commented on issue #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0

tillrohrmann commented on issue #7150: [FLINK-10955] Extend release notes for Apache Flink 1.7.0 URL: https://github.com/apache/flink/pull/7150#issuecomment-440592622 Thanks for the review @hequn8128 and @zentol. I've addressed your comments.

[GitHub] imamitsehgal opened a new pull request #7153: Hotfix/flink 10918

imamitsehgal opened a new pull request #7153: Hotfix/flink 10918 URL: https://github.com/apache/flink/pull/7153 FLINK-10918 Fix issue with running Flink on windows with RocksDB keyed state enabled and check pointing. This

[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=16694631#comment-16694631 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[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=16694617#comment-16694617 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[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=16694627#comment-16694627 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[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=16694615#comment-16694615 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[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=16694616#comment-16694616 ] ASF GitHub Bot commented on FLINK-8577: --- dianfu commented on a change in pull request #6787:

[jira] [Updated] (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:all-tabpanel ] Arnaud Linz updated FLINK-10832: Attachment: pom.xml > StreamExecutionEnvironment.execute() does not return when all sources end >

[jira] [Commented] (FLINK-9574) Add a dedicated documentation page for state evolution

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

[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=16694438#comment-16694438 ] ASF GitHub Bot commented on FLINK-10955: tillrohrmann commented on issue #7150: [FLINK-10955]

[jira] [Updated] (FLINK-10959) most taskmanger in the same node

[ https://issues.apache.org/jira/browse/FLINK-10959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yee updated FLINK-10959: Description: flink on yarn first: 8* taskmanger ( 7 in node A, 1in node B) after restart flink 8*taskmanger

[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_r235324386 ## File path: docs/release-notes/flink-1.7.md ## @@ -22,6 +22,89 @@ under the License.

[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_r235324410 ## File path: docs/release-notes/flink-1.7.md ## @@ -22,6 +22,89 @@ under the License.

[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_r235324439 ## File path: docs/release-notes/flink-1.7.md ## @@ -22,6 +22,89 @@ under the License.

[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=16694515#comment-16694515 ] ASF GitHub Bot commented on FLINK-10955: zentol commented on a change in pull request #7150:

[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_r235324470 ## File path: docs/release-notes/flink-1.7.md ## @@ -22,6 +22,89 @@ under the License.

  1   2   3   4   >