[jira] [Created] (FLINK-10957) Adapt documents about DataStream to Table conversion

Hequn Cheng created FLINK-10957: --- Summary: Adapt documents about DataStream to Table conversion Key: FLINK-10957 URL: https://issues.apache.org/jira/browse/FLINK-10957 Project: Flink Issue Type

[jira] [Created] (FLINK-10958) Add overload support for user defined function

Dian Fu created FLINK-10958: --- Summary: Add overload support for user defined function Key: FLINK-10958 URL: https://issues.apache.org/jira/browse/FLINK-10958 Project: Flink Issue Type: Task

[jira] [Issue Comment Deleted] (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: Comment: was deleted (was: Sorry for the long reply, I did not get the post notification. Your qu

[GitHub] dianfu opened a new pull request #7152: [FLINK-10958] [table] Add overload support for user defined function

dianfu opened a new pull request #7152: [FLINK-10958] [table] Add overload support for user defined function URL: https://github.com/apache/flink/pull/7152 ## What is the purpose of the change *This pull request adds the overload support for user defined function.* ## Brie

[jira] [Commented] (FLINK-10958) Add overload support for user defined function

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

[jira] [Updated] (FLINK-10958) Add overload support for user defined function

[ https://issues.apache.org/jira/browse/FLINK-10958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10958: --- Labels: pull-request-available (was: ) > Add overload support for user defined function >

[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&focusedCommentId=16694375#comment-16694375 ] Arnaud Linz commented on FLINK-10832: - Sorry for the long reply, I did not get the p

[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] [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 source

[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: (was: pom.xml) > StreamExecutionEnvironment.execute() does not return when all sou

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

[jira] [Commented] (FLINK-7022) Flink Job Manager Scheduler & Web Frontend out of sync when Zookeeper is unavailable on startup

[ https://issues.apache.org/jira/browse/FLINK-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694398#comment-16694398 ] Sander Ploegsma commented on FLINK-7022: I can confirm that this issue is still p

[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 ## @

[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 #

[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&focusedCommentId=16694413#comment-16694413 ] ASF GitHub Bot commented on FLINK-9574: --- dawidwys commented on a change in pull req

[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&focusedCommentId=16694415#comment-16694415 ] ASF GitHub Bot commented on FLINK-9574: --- dawidwys commented on a change in pull req

[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&focusedCommentId=16694414#comment-16694414 ] ASF GitHub Bot commented on FLINK-9574: --- dawidwys commented on a change in pull req

[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&focusedCommentId=16694418#comment-16694418 ] ASF GitHub Bot commented on FLINK-9574: --- dawidwys commented on a change in pull req

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

dawidwys 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_r235301974 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/ce

[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=16694422#comment-16694422 ] ASF GitHub Bot commented on FLINK-8159: --- dawidwys commented on a change in pull req

[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&focusedCommentId=16694417#comment-16694417 ] ASF GitHub Bot commented on FLINK-9574: --- dawidwys commented on a change in pull req

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

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

[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] [https://api.travis-c

[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.

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

[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. ---

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

[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] [https://api.travis-c

[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] [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=16694472#comment-16694472 ] ASF GitHub Bot commented on FLINK-8577: --- hequn8128 commented on issue #6787: [FLINK

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

Yee created FLINK-10959: --- Summary: most taskmanger in the same node Key: FLINK-10959 URL: https://issues.apache.org/jira/browse/FLINK-10959 Project: Flink Issue Type: Bug Reporter: Yee 8*

[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

[jira] [Updated] (FLINK-10959) sometimes 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: Summary: sometimes most taskmanger in the same node (was: most taskmanger in the same node) > sometimes most t

[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: The test failed 3 times in total during the overall night build, but succeede

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

[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=16694513#comment-16694513 ] 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=16694516#comment-16694516 ] 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_r235324507 ## File path: docs/release-notes/flink-1.7.md ## @@ -37,6 +120,15 @@ You should only use this

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

[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&focusedCommentId=16694517#comment-16694517 ] Arnaud Linz commented on FLINK-10832: - The main thread hangs in the MiniCluster.clos

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

[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&focusedCommentId=16694517#comment-16694517 ] Arnaud Linz edited comment on FLINK-10832 at 11/21/18 10:24 AM: --

[GitHub] XuQianJin-Stars closed pull request #7092: [FLINK-10134] UTF-16 support for TextInputFormat bug

XuQianJin-Stars closed pull request #7092: [FLINK-10134] UTF-16 support for TextInputFormat bug URL: https://github.com/apache/flink/pull/7092 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As th

[GitHub] zhijiangW commented on issue #6829: [FLINK-10367][network] Introduce NotificationResult for BufferListener to solve recursive stack overflow

zhijiangW commented on issue #6829: [FLINK-10367][network] Introduce NotificationResult for BufferListener to solve recursive stack overflow URL: https://github.com/apache/flink/pull/6829#issuecomment-440616620 cc @pnowojski @NicoK -

[jira] [Commented] (FLINK-10367) Avoid recursion stack overflow during releasing SingleInputGate

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

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694539#comment-16694539 ] ASF GitHub Bot commented on FLINK-10134: XuQianJin-Stars closed pull request #70

[GitHub] asfgit closed pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support

asfgit closed pull request #6980: [FLINK-5697] [kinesis] Add periodic per-shard watermark support URL: https://github.com/apache/flink/pull/6980 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As

[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=16694552#comment-16694552 ] ASF GitHub Bot commented on FLINK-5697: --- asfgit closed pull request #6980: [FLINK-5

[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] [Closed] (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 closed FLINK-10138. Resolution: Duplicate Fix Version/s: (was: 1.7.0) > Queryable state (rocksdb) e

[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&focusedCommentId=16694568#comment-16694568 ] Chesnay Schepler commented on FLINK-10862: -- This issue is related to FLINK-1086

[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 T

[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] [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] [Updated] (FLINK-10367) Avoid recursion stack overflow during releasing SingleInputGate

[ https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10367: - Issue Type: Sub-task (was: Improvement) Parent: FLINK-7282 > Avoid recursion stack overflow dur

[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&focusedCommentId=16694593#comment-16694593 ] Timo Walther commented on FLINK-10956: -- [~hequn8128] Yes, this is a known limitatio

[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' ins

[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 > - > >

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

[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694596#comment-16694596 ] Till Rohrmann commented on FLINK-10368: --- The test seems still to be unstable. It f

[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&focusedCommentId=16694605#comment-16694605 ] Dawid Wysakowicz commented on FLINK-10960: -- Hi [~Jamalarm] Could you provide u

[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 use

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

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

[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 Ty

[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: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calc

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runt

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan

[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: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environmen

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calc

[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: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runt

[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: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environmen

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calc

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runt

[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: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environmen

[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: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environmen

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/

[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: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environmen

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runt

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runt

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runt

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calc

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

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

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

  1   2   3   4   >