[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701495#comment-16701495 ] Xiaogang Shi commented on FLINK-10333: -- Hi [~till.rohrmann] Our cluster is suffering from unstable

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

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

[GitHub] TisonKun closed pull request #7183: [hotfix] Prefer compact all exception to just throw last exception

TisonKun closed pull request #7183: [hotfix] Prefer compact all exception to just throw last exception URL: https://github.com/apache/flink/pull/7183 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

[jira] [Commented] (FLINK-11013) Fix distinct aggregates for group window in Table API

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

[GitHub] sunjincheng121 commented on issue #7181: [FLINK-11013] [table] Fix distinct aggregates for group window in Table API

sunjincheng121 commented on issue #7181: [FLINK-11013] [table] Fix distinct aggregates for group window in Table API URL: https://github.com/apache/flink/pull/7181#issuecomment-442346412 @dianfu Thanks for the PR! Good catch! I'll merge the commit after travis gives green. Best,

[GitHub] dianfu commented on a change in pull request #7167: [FLINK-10973] [table] Add support for map to table API

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

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

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

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

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

[GitHub] dianfu commented on a change in pull request #7167: [FLINK-10973] [table] Add support for map to table API

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

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

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

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

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

[GitHub] TisonKun commented on issue #7183: [hotfix] Prefer compact all exception to just throw last exception

TisonKun commented on issue #7183: [hotfix] Prefer compact all exception to just throw last exception URL: https://github.com/apache/flink/pull/7183#issuecomment-442353809 @zhijiangW thanks for your review! Yes this code snip is about multi attempts and things go like you said. I must be

[GitHub] yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182#issuecomment-442345726 @twalthr Can you review this PR? It blocks FLINK-9461.

[GitHub] dianfu commented on a change in pull request #7167: [FLINK-10973] [table] Add support for map to table API

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

[GitHub] sunjincheng121 commented on a change in pull request #7167: [FLINK-10973] [table] Add support for map to table API

sunjincheng121 commented on a change in pull request #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#discussion_r236970144 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala

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

sunjincheng121 commented on issue #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#issuecomment-442352308 @dianfu Thanks for the quick update ! LGTM ! +1 Wait a minute to see if there are other committer that will leave

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701477#comment-16701477 ] ASF GitHub Bot commented on FLINK-10820: zhijiangW commented on issue #7051:

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701478#comment-16701478 ] ASF GitHub Bot commented on FLINK-11015: yanghua commented on issue #7182: [FLINK-11015] Remove

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

dianfu commented on issue #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#issuecomment-442350798 @sunjincheng121 Thanks a lot for the latest review. Have updated the PR accordingly.

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

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

[jira] [Commented] (FLINK-10997) Avro-confluent-registry does not bundle any dependency

[ https://issues.apache.org/jira/browse/FLINK-10997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700521#comment-16700521 ] ASF GitHub Bot commented on FLINK-10997: StephanEwen commented on issue #7170:

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700567#comment-16700567 ] Stephan Ewen commented on FLINK-9461: - I think it would be great to have a section in either the wiki

[jira] [Commented] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700591#comment-16700591 ] Stephan Ewen commented on FLINK-10966: -- I need some clarification to help understand this: - In

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700603#comment-16700603 ] Stephan Ewen commented on FLINK-10993: -- I would suggest to focus on what the behavior should be in

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700597#comment-16700597 ] ASF GitHub Bot commented on FLINK-10820: zhijiangW commented on issue #7051:

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700607#comment-16700607 ] vinoyang commented on FLINK-10993: -- Oh, [~StephanEwen]  I need to clarify, of course, I mainly focus on

[GitHub] zentol commented on a change in pull request #7174: [FLINK-11003][docs] Fix mistake in java_lambda doc

zentol commented on a change in pull request #7174: [FLINK-11003][docs] Fix mistake in java_lambda doc URL: https://github.com/apache/flink/pull/7174#discussion_r236729601 ## File path: docs/dev/java_lambdas.md ## @@ -135,4 +135,4 @@ public static class DoubleTuple

[jira] [Commented] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700660#comment-16700660 ] vinoyang commented on FLINK-10966: -- [~StephanEwen]  This scenario is in the standalone environment of

[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-442104761 Thanks for merging @pnowojski .

[GitHub] zentol commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client

zentol commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client URL: https://github.com/apache/flink/pull/7170#issuecomment-442106543 Ive changed the configuration to use inclusions. Additionally covered FLINK-10987 for this module.

[jira] [Updated] (FLINK-10990) Enforce minimum timespan in MeterView

[ https://issues.apache.org/jira/browse/FLINK-10990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10990: - Fix Version/s: 1.6.3 1.5.6 > Enforce minimum timespan in MeterView >

[jira] [Commented] (FLINK-10990) Pre-check timespan in meterview to avoid NAN

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

[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=16700650#comment-16700650 ] ASF GitHub Bot commented on FLINK-10924: zentol closed pull request #7143: [FLINK-10924]

[GitHub] zentol closed pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in…

zentol closed pull request #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in… URL: https://github.com/apache/flink/pull/7143 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

[GitHub] yanghua opened a new pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

yanghua opened a new pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182 ## What is the purpose of the change *This pull request removes deprecated methods and classes about

[GitHub] StephanEwen commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client

StephanEwen commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client URL: https://github.com/apache/flink/pull/7170#issuecomment-442082770 Keeping a "compile" dependency is good for user dependency management. Let's got with the list of includes then, because

[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=16700598#comment-16700598 ] ASF GitHub Bot commented on FLINK-10367: zhijiangW commented on issue #6829:

[jira] [Commented] (FLINK-10997) Avro-confluent-registry does not bundle any dependency

[ https://issues.apache.org/jira/browse/FLINK-10997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700612#comment-16700612 ] ASF GitHub Bot commented on FLINK-10997: StephanEwen commented on issue #7170:

[GitHub] StephanEwen commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client

StephanEwen commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client URL: https://github.com/apache/flink/pull/7170#issuecomment-442109065 Looks good, +1 This is an automated message from the

[jira] [Commented] (FLINK-11003) Document of Java Lambda Expressions has a mistake

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

[jira] [Assigned] (FLINK-11012) Introduce abstract superclass for filesystem IT cases

[ https://issues.apache.org/jira/browse/FLINK-11012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wujinhu reassigned FLINK-11012: --- Assignee: wujinhu > Introduce abstract superclass for filesystem IT cases >

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700562#comment-16700562 ] Timo Walther commented on FLINK-9461: - [~StephanEwen] What do you mean with "handle connectors"? The

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700574#comment-16700574 ] vinoyang commented on FLINK-10993: -- [~StephanEwen] Yes, I believe that it is not just about the state,

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700596#comment-16700596 ] Timo Walther commented on FLINK-9461: - I'm about to create a FLIP for the new module structure of

[jira] [Updated] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11015: - Summary: Remove deprecated methods and classes about table from all the Kafka connectors (was: Remove

[jira] [Updated] (FLINK-11003) Document of Java Lambda Expressions has a mistake

[ https://issues.apache.org/jira/browse/FLINK-11003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11003: - Affects Version/s: 1.7.0 1.5.5 1.6.2 >

[jira] [Updated] (FLINK-11003) Document of Java Lambda Expressions has a mistake

[ https://issues.apache.org/jira/browse/FLINK-11003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11003: - Fix Version/s: 1.8.0 > Document of Java Lambda Expressions has a mistake >

[jira] [Updated] (FLINK-10990) Enforce minimum timespan in MeterView

[ https://issues.apache.org/jira/browse/FLINK-10990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10990: - Summary: Enforce minimum timespan in MeterView (was: Pre-check timespan in meterview

[GitHub] zentol closed pull request #7165: [FLINK-10990][Metric]Pre-check timespan in meterview to avoid NAN

zentol closed pull request #7165: [FLINK-10990][Metric]Pre-check timespan in meterview to avoid NAN URL: https://github.com/apache/flink/pull/7165 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:

[jira] [Closed] (FLINK-10990) Enforce minimum timespan in MeterView

[ https://issues.apache.org/jira/browse/FLINK-10990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10990. Resolution: Fixed master: 4cc9479805f422433ceeaa9ba6eb1ef8c5456aa1 1.7:

[jira] [Closed] (FLINK-10924) readTextFile methods javadoc incorrect in regards to used charset

[ https://issues.apache.org/jira/browse/FLINK-10924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10924. Resolution: Fixed Fix Version/s: 1.8.0 master:

[jira] [Updated] (FLINK-10924) readTextFile methods javadoc incorrect in regards to used charset

[ https://issues.apache.org/jira/browse/FLINK-10924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10924: - Summary: readTextFile methods javadoc incorrect in regards to used charset (was:

[jira] [Comment Edited] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700660#comment-16700660 ] vinoyang edited comment on FLINK-10966 at 11/27/18 4:39 PM: [~StephanEwen]  

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

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

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700506#comment-16700506 ] Stephan Ewen commented on FLINK-10993: -- If I understand the feature proposal correctly, the use of

[jira] [Comment Edited] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700596#comment-16700596 ] Timo Walther edited comment on FLINK-9461 at 11/27/18 3:37 PM: --- I'm about

[jira] [Updated] (FLINK-10990) Enforce minimum timespan in MeterView

[ https://issues.apache.org/jira/browse/FLINK-10990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10990: - Affects Version/s: 1.5.5 1.6.2 > Enforce minimum timespan in

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700534#comment-16700534 ] Stephan Ewen commented on FLINK-9461: - [~twalthr] Is there a plan on how to handle connectors across

[jira] [Comment Edited] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700591#comment-16700591 ] Stephan Ewen edited comment on FLINK-10966 at 11/27/18 3:32 PM: I need

[GitHub] zhijiangW commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

zhijiangW commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#issuecomment-442104312 @pnowojski , I have updated the codes in the hotfix commit.

[jira] [Created] (FLINK-11015) Remove deprecated methods and classes from all the Kafka connectors

vinoyang created FLINK-11015: Summary: Remove deprecated methods and classes from all the Kafka connectors Key: FLINK-11015 URL: https://issues.apache.org/jira/browse/FLINK-11015 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700528#comment-16700528 ] Stephan Ewen commented on FLINK-10930: -- The layout refactoring is not the right solution to this

[jira] [Assigned] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

[ https://issues.apache.org/jira/browse/FLINK-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wujinhu reassigned FLINK-10865: --- Assignee: wujinhu > Implement Flink's own Aliyun OSS filesystem >

[jira] [Commented] (FLINK-10997) Avro-confluent-registry does not bundle any dependency

[ https://issues.apache.org/jira/browse/FLINK-10997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700604#comment-16700604 ] ASF GitHub Bot commented on FLINK-10997: zentol commented on issue #7170: [FLINK-10997][formats]

[jira] [Assigned] (FLINK-11003) Document of Java Lambda Expressions has a mistake

[ https://issues.apache.org/jira/browse/FLINK-11003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11003: Assignee: Yangze Guo > Document of Java Lambda Expressions has a mistake >

[jira] [Updated] (FLINK-10924) readTextFile methods javadoc incorrect in regards to used charset

[ https://issues.apache.org/jira/browse/FLINK-10924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10924: - Component/s: (was: Streaming) DataStream API

[jira] [Updated] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11015: --- Labels: pull-request-available (was: ) > Remove deprecated methods and classes about table

[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=16700744#comment-16700744 ] ASF GitHub Bot commented on FLINK-9574: --- tzulitai commented on a change in pull request #7124:

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

tzulitai 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_r236764367 ## File path: docs/dev/stream/state/schema_evolution.md ##

[jira] [Commented] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700759#comment-16700759 ] Stephan Ewen commented on FLINK-10966: -- Okay, so you are suggesting to add a timeout to the barrier

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

tzulitai 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_r236763803 ## 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=16700742#comment-16700742 ] ASF GitHub Bot commented on FLINK-9574: --- tzulitai commented on a change in pull request #7124:

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

[ https://issues.apache.org/jira/browse/FLINK-10968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700812#comment-16700812 ] JIN SUN commented on FLINK-10968: - Yes, it will extend from TaskManagerRunner and handle

[jira] [Commented] (FLINK-10923) Make SlotPool Status Machine-Readable

[ https://issues.apache.org/jira/browse/FLINK-10923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700884#comment-16700884 ] Konstantin Knauf commented on FLINK-10923: -- [~till.rohrmann] I think you are right. Let's put

[jira] [Commented] (FLINK-10997) Avro-confluent-registry does not bundle any dependency

[ https://issues.apache.org/jira/browse/FLINK-10997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701101#comment-16701101 ] ASF GitHub Bot commented on FLINK-10997: zentol commented on issue #7170: [FLINK-10997][formats]

[GitHub] zentol commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client

zentol commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client URL: https://github.com/apache/flink/pull/7170#issuecomment-442233922 ```18:26:31.504 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-shade-plugin:3.0.0:shade (shade-flink) on

[GitHub] TisonKun opened a new pull request #7183: [hotfix] Prefer compact all exception to just throw last exception

TisonKun opened a new pull request #7183: [hotfix] Prefer compact all exception to just throw last exception URL: https://github.com/apache/flink/pull/7183 ## What is the purpose of the change Prefer compact all exception to just throw last exception. Help user diagnostic

[GitHub] TisonKun opened a new pull request #7184: [hotfix] Remove unused class OneTimeLeaderListenerFuture and LeaderAd…

TisonKun opened a new pull request #7184: [hotfix] Remove unused class OneTimeLeaderListenerFuture and LeaderAd… URL: https://github.com/apache/flink/pull/7184 …dressAndId ## What is the purpose of the change These two class were introduced by

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

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

hequn8128 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_r236909228 ## File path:

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

hequn8128 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_r236909214 ## File path:

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

hequn8128 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_r236914923 ## File path:

[jira] [Commented] (FLINK-11003) Document of Java Lambda Expressions has a mistake

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

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

sunjincheng121 commented on issue #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#issuecomment-442279595 @wuchong, Yes, we are plan to bring up a discuss in mail list about Column operation, such as short cut: `*`, `_`

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

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

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

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

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

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

hequn8128 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_r236911934 ## File path:

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

hequn8128 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_r236912969 ## 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=16701274#comment-16701274 ] ASF GitHub Bot commented on FLINK-8577: --- hequn8128 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=16701276#comment-16701276 ] ASF GitHub Bot commented on FLINK-8577: --- hequn8128 commented on a change in pull request #6787:

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

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

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

dianfu commented on issue #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#issuecomment-442294091 @wuchong Thanks a lot for your review. As @sunjincheng121 said, the column operation still needs discussion and so the support of

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

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

hequn8128 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_r236914923 ## File path:

[GitHub] KarmaGYZ commented on a change in pull request #7174: [FLINK-11003][docs] Fix mistake in java_lambda doc

KarmaGYZ commented on a change in pull request #7174: [FLINK-11003][docs] Fix mistake in java_lambda doc URL: https://github.com/apache/flink/pull/7174#discussion_r236917645 ## File path: docs/dev/java_lambdas.md ## @@ -135,4 +135,4 @@ public static class DoubleTuple

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

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

  1   2   3   >