[GitHub] [flink] aljoscha commented on a change in pull request #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API

aljoscha commented on a change in pull request #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API URL: https://github.com/apache/flink/pull/11061#discussion_r382586616 ## File path:

[jira] [Updated] (FLINK-15948) Resource will be wasted when the task manager memory is not a multiple of Yarn minimum allocation

[ https://issues.apache.org/jira/browse/FLINK-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15948: --- Labels: pull-request-available (was: ) > Resource will be wasted when the task manager

[GitHub] [flink] wangyang0918 opened a new pull request #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory

wangyang0918 opened a new pull request #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory URL: https://github.com/apache/flink/pull/11176 ## What is the purpose of the change Currently, we just check whether the JobManager/TaskManager is

[jira] [Updated] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-16198: Description: The following tests fail if run on Mac OS (IDE/maven).  

[jira] [Commented] (FLINK-16215) Start redundant TaskExecutor when JM failed

[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041869#comment-17041869 ] Andrey Zagrebin commented on FLINK-16215: - I assume it is about some active RM integration, e.g.

[jira] [Created] (FLINK-16217) SQL Client crashed when any uncatched exception is thrown

Jark Wu created FLINK-16217: --- Summary: SQL Client crashed when any uncatched exception is thrown Key: FLINK-16217 URL: https://issues.apache.org/jira/browse/FLINK-16217 Project: Flink Issue Type:

[GitHub] [flink] aljoscha commented on a change in pull request #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API

aljoscha commented on a change in pull request #11061: [FLINK-15782] [connectors/jdbc] JDBC sink DataStream API URL: https://github.com/apache/flink/pull/11061#discussion_r382585012 ## File path: docs/redirects/jdbc.md ## @@ -0,0 +1,24 @@ +--- Review comment: The

[GitHub] [flink] lirui-apache commented on issue #11175: [FLINK-16197][hive] Failed to query partitioned table when partition …

lirui-apache commented on issue #11175: [FLINK-16197][hive] Failed to query partitioned table when partition … URL: https://github.com/apache/flink/pull/11175#issuecomment-589655266 @JingsongLi @bowenli86 Let me know if you think the change makes sense. Thanks,

[GitHub] [flink] flinkbot commented on issue #11175: [FLINK-16197][hive] Failed to query partitioned table when partition …

flinkbot commented on issue #11175: [FLINK-16197][hive] Failed to query partitioned table when partition … URL: https://github.com/apache/flink/pull/11175#issuecomment-589653458 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query

flinkbot edited a comment on issue #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query URL: https://github.com/apache/flink/pull/11172#issuecomment-589618638 ## CI report: * 7031e428e2c08f96a7e9ef69afd6680c91cdd2bc Travis:

[GitHub] [flink] flinkbot commented on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

flinkbot commented on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#issuecomment-589653271 ## CI report: * e7a2eaa529eca12790f7a4ddb28b6acf7bef88be UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] flinkbot edited a comment on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

flinkbot edited a comment on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173#issuecomment-589629527 ## CI report: * 80755e8c69c712ebc1a2216f4b38bf23939deeea Travis:

[jira] [Updated] (FLINK-16197) Failed to query partitioned table when partition folder is removed

[ https://issues.apache.org/jira/browse/FLINK-16197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16197: --- Labels: pull-request-available (was: ) > Failed to query partitioned table when partition

[GitHub] [flink] lirui-apache opened a new pull request #11175: [FLINK-16197][hive] Failed to query partitioned table when partition …

lirui-apache opened a new pull request #11175: [FLINK-16197][hive] Failed to query partitioned table when partition … URL: https://github.com/apache/flink/pull/11175 …folder is removed ## What is the purpose of the change To fix the issue of querying a table whose

[GitHub] [flink] zentol edited a comment on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

zentol edited a comment on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173#issuecomment-589651425 @StephanEwen you still want to use zk 3.5 during IT cases / tests, and having the logic in the build system is more

[GitHub] [flink] flinkbot edited a comment on issue #11143: [FLINK-16163][build] Migrate to flink-shaded-zookeeper

flinkbot edited a comment on issue #11143: [FLINK-16163][build] Migrate to flink-shaded-zookeeper URL: https://github.com/apache/flink/pull/11143#issuecomment-588270028 ## CI report: * cc722b6e4c4c0ba9725a3424bff4a6c8c0e7d2c5 Travis:

[GitHub] [flink] zentol commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

zentol commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173#issuecomment-589651735 @TisonKun As noted in the PR description, `curator.version` is only used for curator-test, nothing else. It does not affect the

[GitHub] [flink] zentol commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

zentol commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173#issuecomment-589651425 @StephanEwen you still want to use zk 3.5 during IT cases / tests.

[GitHub] [flink] TisonKun merged pull request #11053: [FLINK-15977][docs] Update pull request template to include Kubernetes as deployment candidates

TisonKun merged pull request #11053: [FLINK-15977][docs] Update pull request template to include Kubernetes as deployment candidates URL: https://github.com/apache/flink/pull/11053 This is an automated message from the

[jira] [Commented] (FLINK-16192) Remove "Legacy State" and Checkpoint Compatibility with Flink 1.2

[ https://issues.apache.org/jira/browse/FLINK-16192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041855#comment-17041855 ] Chesnay Schepler commented on FLINK-16192: -- But doesn't this mean that in this issue we are

[jira] [Closed] (FLINK-15977) Update pull request template to include Kubernetes as deployment candidates

[ https://issues.apache.org/jira/browse/FLINK-15977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-15977. - Resolution: Fixed master via a50b666fde5d71f3c74635ab1d14c12bf50595fa > Update pull request template

[GitHub] [flink] flinkbot edited a comment on issue #11073: [FLINK-15672][build] Migrate to log4j2

flinkbot edited a comment on issue #11073: [FLINK-15672][build] Migrate to log4j2 URL: https://github.com/apache/flink/pull/11073#issuecomment-585286222 ## CI report: * 29034cb85769cd69b09b121c4b88f54b4483aafe Travis:

[jira] [Commented] (FLINK-15992) Incorrect classloader when finding TableFactory

[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041844#comment-17041844 ] Jark Wu commented on FLINK-15992: - Reverted in master (1.11.0): aacf0792bc1a39f3953724d2387ee668572b4b22

[jira] [Closed] (FLINK-15999) Extract “Concepts” material from API/Library sections and start proper concepts section

[ https://issues.apache.org/jira/browse/FLINK-15999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15999. Fix Version/s: 1.11.0 Resolution: Fixed master: 

[GitHub] [flink] rmetzger commented on issue #11164: [hotfix][build system] Do not trigger dependent jobs if predecessor fails

rmetzger commented on issue #11164: [hotfix][build system] Do not trigger dependent jobs if predecessor fails URL: https://github.com/apache/flink/pull/11164#issuecomment-589644505 @zentol: looks like there's a bug in CI bot. it says "success" for Azure, even though the build failed.

[GitHub] [flink] aljoscha commented on issue #9836: [FLINK-14317] make hadoop history server logs accessible through flink ui

aljoscha commented on issue #9836: [FLINK-14317] make hadoop history server logs accessible through flink ui URL: https://github.com/apache/flink/pull/9836#issuecomment-589644324 I'll close this for now because there's no consensus on the Jira Issue and there's a discussion ongoing on the

[GitHub] [flink] aljoscha closed pull request #9836: [FLINK-14317] make hadoop history server logs accessible through flink ui

aljoscha closed pull request #9836: [FLINK-14317] make hadoop history server logs accessible through flink ui URL: https://github.com/apache/flink/pull/9836 This is an automated message from the Apache Git Service. To

[GitHub] [flink] aljoscha closed pull request #11092: [FLINK-15999] Extract “Concepts” material from API/Library sections and start proper concepts section

aljoscha closed pull request #11092: [FLINK-15999] Extract “Concepts” material from API/Library sections and start proper concepts section URL: https://github.com/apache/flink/pull/11092 This is an automated message from

[GitHub] [flink] aljoscha commented on issue #11092: [FLINK-15999] Extract “Concepts” material from API/Library sections and start proper concepts section

aljoscha commented on issue #11092: [FLINK-15999] Extract “Concepts” material from API/Library sections and start proper concepts section URL: https://github.com/apache/flink/pull/11092#issuecomment-589643739 Thanks for the reviews! I created new subtasks for the `TODOs` and for things

[GitHub] [flink] TisonKun edited a comment on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

TisonKun edited a comment on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173#issuecomment-589643407 LGTM. A possible follow-up is separating `curator.version` & `curator.test.version`. zk 3.4 works well with curator

[GitHub] [flink] TisonKun commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

TisonKun commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173#issuecomment-589643407 LGTM. A possible follow-up is separating `curator.version` & `curator.test.version`. zk 3.4 works well with curator 4.x

[jira] [Created] (FLINK-16216) Describe end-to-end exactly once programs in stateful stream processing concepts documentation

Aljoscha Krettek created FLINK-16216: Summary: Describe end-to-end exactly once programs in stateful stream processing concepts documentation Key: FLINK-16216 URL:

[jira] [Created] (FLINK-16215) Start redundant TaskExecutor when JM failed

YufeiLiu created FLINK-16215: Summary: Start redundant TaskExecutor when JM failed Key: FLINK-16215 URL: https://issues.apache.org/jira/browse/FLINK-16215 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-16213) Add "What Is State" section in concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041834#comment-17041834 ] Aljoscha Krettek commented on FLINK-16213: -- This should go into

[jira] [Commented] (FLINK-16208) Add introduction to timely stream processing concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041830#comment-17041830 ] Aljoscha Krettek commented on FLINK-16208: -- This should go into

[jira] [Commented] (FLINK-16211) Add introduction to stream processing concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041832#comment-17041832 ] Aljoscha Krettek commented on FLINK-16211: -- This should go into {{stream-processing.md}}. >

[jira] [Commented] (FLINK-16209) Add Latency and Completeness section in timely stream processing concepts

[ https://issues.apache.org/jira/browse/FLINK-16209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041831#comment-17041831 ] Aljoscha Krettek commented on FLINK-16209: -- This should go into

[jira] [Commented] (FLINK-16212) Describe how Flink is a unified batch/stream processing system in concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041833#comment-17041833 ] Aljoscha Krettek commented on FLINK-16212: -- This should go into {{stream-processing.md}}. >

[jira] [Created] (FLINK-16214) Describe how state is different for stream/batch programs in concepts documentation

Aljoscha Krettek created FLINK-16214: Summary: Describe how state is different for stream/batch programs in concepts documentation Key: FLINK-16214 URL: https://issues.apache.org/jira/browse/FLINK-16214

[jira] [Commented] (FLINK-16207) In stream processing concepts section, rework distribution patterns description

[ https://issues.apache.org/jira/browse/FLINK-16207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041829#comment-17041829 ] Aljoscha Krettek commented on FLINK-16207: -- This should go into {{stream-processing.md}}. > In

[jira] [Created] (FLINK-16213) Add "What Is State" section in concepts documentation

Aljoscha Krettek created FLINK-16213: Summary: Add "What Is State" section in concepts documentation Key: FLINK-16213 URL: https://issues.apache.org/jira/browse/FLINK-16213 Project: Flink

[GitHub] [flink] TisonKun commented on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

TisonKun commented on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#issuecomment-589641231 Hi @wuchong please give it a review when you have spare time. Besides, I'll appreciate it if anyone can guide me

[jira] [Assigned] (FLINK-16210) Add section about applications and clusters/session in concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marta Paes Moreira reassigned FLINK-16210: -- Assignee: Marta Paes Moreira > Add section about applications and

[GitHub] [flink] flinkbot edited a comment on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

flinkbot edited a comment on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173#issuecomment-589629527 ## CI report: * 80755e8c69c712ebc1a2216f4b38bf23939deeea Travis:

[GitHub] [flink] flinkbot commented on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

flinkbot commented on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#issuecomment-589641033 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] flinkbot edited a comment on issue #11164: [hotfix][build system] Do not trigger dependent jobs if predecessor fails

flinkbot edited a comment on issue #11164: [hotfix][build system] Do not trigger dependent jobs if predecessor fails URL: https://github.com/apache/flink/pull/11164#issuecomment-589179847 ## CI report: * 54afc31acb5e8b57a72442e39282c89252fb38fe Travis:

[jira] [Updated] (FLINK-16199) Support IS JSON predicate for blink planner

[ https://issues.apache.org/jira/browse/FLINK-16199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16199: --- Labels: pull-request-available (was: ) > Support IS JSON predicate for blink planner >

[GitHub] [flink] TisonKun opened a new pull request #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

TisonKun opened a new pull request #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174 ## What is the purpose of the change Support IS JSON predicate for blink planner IS_JSON_VALUE IS_JSON_OBJECT

[jira] [Updated] (FLINK-16210) Add section about applications and clusters/session in concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16210: - Component/s: Documentation > Add section about applications and clusters/session in

[jira] [Created] (FLINK-16212) Describe how Flink is a unified batch/stream processing system in concepts documentation

Aljoscha Krettek created FLINK-16212: Summary: Describe how Flink is a unified batch/stream processing system in concepts documentation Key: FLINK-16212 URL: https://issues.apache.org/jira/browse/FLINK-16212

[jira] [Created] (FLINK-16211) Add introduction to stream processing concepts documentation

Aljoscha Krettek created FLINK-16211: Summary: Add introduction to stream processing concepts documentation Key: FLINK-16211 URL: https://issues.apache.org/jira/browse/FLINK-16211 Project: Flink

[jira] [Comment Edited] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041816#comment-17041816 ] Thomas Wozniakowski edited comment on FLINK-16142 at 2/21/20 12:48 PM:

[jira] [Created] (FLINK-16210) Add section about applications and clusters/session in concepts documentation

Aljoscha Krettek created FLINK-16210: Summary: Add section about applications and clusters/session in concepts documentation Key: FLINK-16210 URL: https://issues.apache.org/jira/browse/FLINK-16210

[jira] [Commented] (FLINK-15927) TaskExecutor should treat it as a fatal error is Task cannot be failed

[ https://issues.apache.org/jira/browse/FLINK-15927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041819#comment-17041819 ] Stephan Ewen commented on FLINK-15927: -- [~Khairy] yes, this is not really a beginner issue, I

[jira] [Updated] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-16142: Attachment: java_pid1.hprof > Memory Leak causes Metaspace OOM error on repeated

[jira] [Created] (FLINK-16209) Add Latency and Completeness section in timely stream processing concepts

Aljoscha Krettek created FLINK-16209: Summary: Add Latency and Completeness section in timely stream processing concepts Key: FLINK-16209 URL: https://issues.apache.org/jira/browse/FLINK-16209

[jira] [Created] (FLINK-16208) Add introduction to timely stream processing concepts documentation

Aljoscha Krettek created FLINK-16208: Summary: Add introduction to timely stream processing concepts documentation Key: FLINK-16208 URL: https://issues.apache.org/jira/browse/FLINK-16208 Project:

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041816#comment-17041816 ] Thomas Wozniakowski commented on FLINK-16142: - Hi [~sewen] I've attached the heap dump. It

[GitHub] [flink] flinkbot edited a comment on issue #11081: [FLINK-16033][table-api] Introduced Java Table API Expression DSL

flinkbot edited a comment on issue #11081: [FLINK-16033][table-api] Introduced Java Table API Expression DSL URL: https://github.com/apache/flink/pull/11081#issuecomment-585639356 ## CI report: * 16d4e9e6fbeb230b8aa05976e4909299ebc929bf Travis:

[GitHub] [flink] StephanEwen commented on issue #11052: FLINK-15975 : Making test assertion more stable.

StephanEwen commented on issue #11052: FLINK-15975 : Making test assertion more stable. URL: https://github.com/apache/flink/pull/11052#issuecomment-589638075 A bit nicer version would be `assertThat(Arrays.asList(result), containsInAnyOrder("1", "2", "3"))`

[jira] [Created] (FLINK-16207) In stream processing concepts section, rework distribution patterns description

Aljoscha Krettek created FLINK-16207: Summary: In stream processing concepts section, rework distribution patterns description Key: FLINK-16207 URL: https://issues.apache.org/jira/browse/FLINK-16207

[GitHub] [flink] StephanEwen commented on issue #11048: [FLINK-15966][runtime] Capture callstacks for RPC ask() calls to improve exceptions.

StephanEwen commented on issue #11048: [FLINK-15966][runtime] Capture callstacks for RPC ask() calls to improve exceptions. URL: https://github.com/apache/flink/pull/11048#issuecomment-589637121 Should we backport this to 1.10, switched off by default? The one caveat is that it changes

[jira] [Commented] (FLINK-16001) Avoid using Java Streams in construction of ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041813#comment-17041813 ] Stephan Ewen commented on FLINK-16001: -- As a heuristic, it makes sense to avoid Java Streams when

[GitHub] [flink] StephanEwen commented on issue #11159: [FLINK-16188][e2e] AutoClosableProcess constructor now private

StephanEwen commented on issue #11159: [FLINK-16188][e2e] AutoClosableProcess constructor now private URL: https://github.com/apache/flink/pull/11159#issuecomment-589635289 Looks good, +1 This is an automated message from

[GitHub] [flink] rkhachatryan commented on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

rkhachatryan commented on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-589634942 Thanks for the contribution @sunhaibotb

[jira] [Commented] (FLINK-16069) Creation of TaskDeploymentDescriptor can block main thread for long time

[ https://issues.apache.org/jira/browse/FLINK-16069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041812#comment-17041812 ] Stephan Ewen commented on FLINK-16069: -- It it possible to make more of the deployment descriptor

[jira] [Commented] (FLINK-16193) Improve error messaging when a key is assigned to the wrong key group range

[ https://issues.apache.org/jira/browse/FLINK-16193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041808#comment-17041808 ] Stephan Ewen commented on FLINK-16193: -- There is a discussion as part of "unaligned checkpoints"

[jira] [Commented] (FLINK-16192) Remove "Legacy State" and Checkpoint Compatibility with Flink 1.2

[ https://issues.apache.org/jira/browse/FLINK-16192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041807#comment-17041807 ] Stephan Ewen commented on FLINK-16192: -- Legacy state was usable in Flink 1.3, despite the interface

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #29: [FLINK-16063] Add simple backpressure

tzulitai commented on a change in pull request #29: [FLINK-16063] Add simple backpressure URL: https://github.com/apache/flink-statefun/pull/29#discussion_r382552029 ## File path:

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #29: [FLINK-16063] Add simple backpressure

tzulitai commented on a change in pull request #29: [FLINK-16063] Add simple backpressure URL: https://github.com/apache/flink-statefun/pull/29#discussion_r382551837 ## File path:

[jira] [Commented] (FLINK-12548) FlinkKafkaConsumer issues configuring underlying KafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-12548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041799#comment-17041799 ] Aljoscha Krettek commented on FLINK-12548: -- [~sjwiesman] Do you maybe have an opinion on this?

[GitHub] [flink] flinkbot commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

flinkbot commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173#issuecomment-589629527 ## CI report: * 80755e8c69c712ebc1a2216f4b38bf23939deeea UNKNOWN Bot commands The @flinkbot bot supports

[GitHub] [flink] flinkbot edited a comment on issue #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query

flinkbot edited a comment on issue #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query URL: https://github.com/apache/flink/pull/11172#issuecomment-589618638 ## CI report: * 7031e428e2c08f96a7e9ef69afd6680c91cdd2bc Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11171: [FLINK-15722] Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint

flinkbot edited a comment on issue #11171: [FLINK-15722] Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11171#issuecomment-589604347 ## CI report: * 29acf2322ddd57b6309ae87bfa9fc1747886449d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process

flinkbot edited a comment on issue #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process URL: https://github.com/apache/flink/pull/11169#issuecomment-589576991 ## CI report: * 6187e51e301c2c81d6e2fb9446747a2e5265e99a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl.

flinkbot edited a comment on issue #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl. URL: https://github.com/apache/flink/pull/11170#issuecomment-589590759 ## CI report: * 2c85988d5f5074372ff5363164ebfe0244d0dc57 UNKNOWN *

[GitHub] [flink] StephanEwen commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

StephanEwen commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173#issuecomment-589629392 Looks good in general. I am wondering if we could avoid the extra maven profile. With each additional profile, it becomes

[jira] [Commented] (FLINK-16193) Improve error messaging when a key is assigned to the wrong key group range

[ https://issues.apache.org/jira/browse/FLINK-16193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041794#comment-17041794 ] Aljoscha Krettek commented on FLINK-16193: -- I think it's good to improve that error message. I

[jira] [Commented] (FLINK-15722) Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041793#comment-17041793 ] Aljoscha Krettek commented on FLINK-15722: -- I don't think so, please refer to the class-level

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041792#comment-17041792 ] Stephan Ewen commented on FLINK-16142: -- Thank you. The JVM is using G1GC, so class unloading

[GitHub] [flink] flinkbot edited a comment on issue #11143: [FLINK-16163][build] Migrate to flink-shaded-zookeeper

flinkbot edited a comment on issue #11143: [FLINK-16163][build] Migrate to flink-shaded-zookeeper URL: https://github.com/apache/flink/pull/11143#issuecomment-588270028 ## CI report: * cc722b6e4c4c0ba9725a3424bff4a6c8c0e7d2c5 Travis:

[jira] [Assigned] (FLINK-16193) Improve error messaging when a key is assigned to the wrong key group range

[ https://issues.apache.org/jira/browse/FLINK-16193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-16193: Assignee: Seth Wiesman > Improve error messaging when a key is assigned to the

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #29: [FLINK-16063] Add simple backpressure

igalshilman commented on a change in pull request #29: [FLINK-16063] Add simple backpressure URL: https://github.com/apache/flink-statefun/pull/29#discussion_r382549046 ## File path:

[jira] [Commented] (FLINK-15718) Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041789#comment-17041789 ] Aljoscha Krettek commented on FLINK-15718: -- We don't need to update that one because it's

[GitHub] [flink] flinkbot edited a comment on issue #11073: [FLINK-15672][build] Migrate to log4j2

flinkbot edited a comment on issue #11073: [FLINK-15672][build] Migrate to log4j2 URL: https://github.com/apache/flink/pull/11073#issuecomment-585286222 ## CI report: * 29034cb85769cd69b09b121c4b88f54b4483aafe Travis:

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #29: [FLINK-16063] Add simple backpressure

igalshilman commented on a change in pull request #29: [FLINK-16063] Add simple backpressure URL: https://github.com/apache/flink-statefun/pull/29#discussion_r382544542 ## File path:

[jira] [Created] (FLINK-16206) Support JSON_ARRAYAGG for blink planner

Zili Chen created FLINK-16206: - Summary: Support JSON_ARRAYAGG for blink planner Key: FLINK-16206 URL: https://issues.apache.org/jira/browse/FLINK-16206 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16205) Support JSON_OBJECTAGG for blink planner

Zili Chen created FLINK-16205: - Summary: Support JSON_OBJECTAGG for blink planner Key: FLINK-16205 URL: https://issues.apache.org/jira/browse/FLINK-16205 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16202) Support JSON_QUERY for blink planner

Zili Chen created FLINK-16202: - Summary: Support JSON_QUERY for blink planner Key: FLINK-16202 URL: https://issues.apache.org/jira/browse/FLINK-16202 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16203) Support JSON_OBJECT for blink planner

Zili Chen created FLINK-16203: - Summary: Support JSON_OBJECT for blink planner Key: FLINK-16203 URL: https://issues.apache.org/jira/browse/FLINK-16203 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16204) Support JSON_ARRAY for blink planner

Zili Chen created FLINK-16204: - Summary: Support JSON_ARRAY for blink planner Key: FLINK-16204 URL: https://issues.apache.org/jira/browse/FLINK-16204 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16201) Support JSON_VALUE for blink planner

Zili Chen created FLINK-16201: - Summary: Support JSON_VALUE for blink planner Key: FLINK-16201 URL: https://issues.apache.org/jira/browse/FLINK-16201 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16200) Support JSON_EXISTS for blink planner

Zili Chen created FLINK-16200: - Summary: Support JSON_EXISTS for blink planner Key: FLINK-16200 URL: https://issues.apache.org/jira/browse/FLINK-16200 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16199) Support IS JSON predicate for blink planner

Zili Chen created FLINK-16199: - Summary: Support IS JSON predicate for blink planner Key: FLINK-16199 URL: https://issues.apache.org/jira/browse/FLINK-16199 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on issue #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query

flinkbot commented on issue #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query URL: https://github.com/apache/flink/pull/11172#issuecomment-589618638 ## CI report: * 7031e428e2c08f96a7e9ef69afd6680c91cdd2bc UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #11171: [FLINK-15722] Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint

flinkbot edited a comment on issue #11171: [FLINK-15722] Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11171#issuecomment-589604347 ## CI report: * 29acf2322ddd57b6309ae87bfa9fc1747886449d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl.

flinkbot edited a comment on issue #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl. URL: https://github.com/apache/flink/pull/11170#issuecomment-589590759 ## CI report: * 2c85988d5f5074372ff5363164ebfe0244d0dc57 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese

flinkbot edited a comment on issue #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese URL: https://github.com/apache/flink/pull/11168#issuecomment-589576910 ## CI report: * 8e08bdefc8f3a02ffdba8591620b4fea59889cc2 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11164: [hotfix][build system] Do not trigger dependent jobs if predecessor fails

flinkbot edited a comment on issue #11164: [hotfix][build system] Do not trigger dependent jobs if predecessor fails URL: https://github.com/apache/flink/pull/11164#issuecomment-589179847 ## CI report: * 54afc31acb5e8b57a72442e39282c89252fb38fe Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11143: [FLINK-16163][build] Migrate to flink-shaded-zookeeper

flinkbot edited a comment on issue #11143: [FLINK-16163][build] Migrate to flink-shaded-zookeeper URL: https://github.com/apache/flink/pull/11143#issuecomment-588270028 ## CI report: * cc722b6e4c4c0ba9725a3424bff4a6c8c0e7d2c5 Travis:

<    1   2   3   4   5   6   >