[jira] [Created] (FLINK-11035) Notify data available to network stack immediately after finishing BufferBuilder

zhijiang created FLINK-11035: Summary: Notify data available to network stack immediately after finishing BufferBuilder Key: FLINK-11035 URL: https://issues.apache.org/jira/browse/FLINK-11035 Project: Fli

[jira] [Commented] (FLINK-11034) Provide "rewriting config” to file system factory

[ https://issues.apache.org/jira/browse/FLINK-11034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704369#comment-16704369 ] Tony Xintong Song commented on FLINK-11034: --- I agree with you that we should a

[jira] [Commented] (FLINK-8739) Optimize runtime support for distinct filter

[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704356#comment-16704356 ] Dian Fu commented on FLINK-8739: Hi [~walterddr], are you still working on this ticket? I

[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&focusedCommentId=16704340#comment-16704340 ] vinoyang commented on FLINK-10993: -- [~fhueske] yes, I looked the design document attach

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

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

[GitHub] Clarkkkkk commented on issue #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

Clark commented on issue #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#issuecomment-443109202 Hi @StefanRRichter , I am just wondering why make SlotPool no longer to be an RpcEndpoint?

[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&focusedCommentId=16704325#comment-16704325 ] ASF GitHub Bot commented on FLINK-11015: yanghua commented on issue #7182: [FLIN

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704326#comment-16704326 ] ASF GitHub Bot commented on FLINK-10252: yanghua commented on issue #6850: [FLIN

[GitHub] yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges

yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#issuecomment-443107471 @zentol This is an automated message from the Apache Git Service. To respon

[jira] [Commented] (FLINK-10798) Add the version number of Flink 1.7 to MigrationVersion

[ https://issues.apache.org/jira/browse/FLINK-10798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704324#comment-16704324 ] ASF GitHub Bot commented on FLINK-10798: yanghua commented on issue #7026: [FLIN

[GitHub] yanghua commented on issue #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion

yanghua commented on issue #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion URL: https://github.com/apache/flink/pull/7026#issuecomment-443107105 Since Flink 1.7 has released, shall we merge this PR? --

[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-443107227 @twalthr Let's merge this PR? thanks. --

[jira] [Commented] (FLINK-11017) Time interval for window aggregations in SQL is wrongly translated if specified with YEAR_MONTH resolution

[ https://issues.apache.org/jira/browse/FLINK-11017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704307#comment-16704307 ] xuqianjin commented on FLINK-11017: --- [~dawidwys] I want to try to solve it. > Time in

[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&focusedCommentId=16704286#comment-16704286 ] Yun Tang commented on FLINK-10930: -- [~StephanEwen] I think your opinion to refactor the

[jira] [Commented] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704290#comment-16704290 ] ASF GitHub Bot commented on FLINK-10712: Myasuka commented on issue #7009: [FLIN

[GitHub] Myasuka commented on issue #7009: [FLINK-10712] Support to restore state when using RestartPipelinedRegionStrategy

Myasuka commented on issue #7009: [FLINK-10712] Support to restore state when using RestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/7009#issuecomment-443096765 @StefanRRichter Thanks for your comments, I would refactor this PR. BTW, I found region failover withou

[GitHub] zhijiangW commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel

zhijiangW commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7197#issuecomment-443095850 lgtm! This is an automated

[GitHub] zhijiangW commented on a change in pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory

zhijiangW commented on a change in pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory URL: https://github.com/apache/flink/pull/7185#discussion_r237743628 ## File path: flink-runtime/src/main/java/org/apache/fli

[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237724165 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237726170 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237737335 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237738914 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237737176 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237472659 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237727039 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237739790 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237472868 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237731718 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[GitHub] dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237466962 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCodeG

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704215#comment-16704215 ] ASF GitHub Bot commented on FLINK-10461: klion26 commented on issue #6777: [FLIN

[GitHub] klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#issuecomment-443079619 Thanks a lot for your reviews, I learnt a lot from them. @azagrebin I fixed the java doc, a

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[jira] [Created] (FLINK-11034) Provide "rewriting config” to file system factory

Wei-Che Wei created FLINK-11034: --- Summary: Provide "rewriting config” to file system factory Key: FLINK-11034 URL: https://issues.apache.org/jira/browse/FLINK-11034 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[GitHub] zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r237735988 ## File path: flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala ## @@ -16

[GitHub] zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r237736038 ## File path: flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala ## @@ -16

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[GitHub] zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r237735688 ## File path: flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala ## @@ -16

[GitHub] zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r237735688 ## File path: flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala ## @@ -16

[GitHub] maqingxiang commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel

maqingxiang commented on issue #7197: [hotfix][flink-runtime] add try catch when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7197#issuecomment-443067252 @zhijiangW thanks for your review. Sorry, I will create a jira ticket next time . :)

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

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

[GitHub] dianfu commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

dianfu commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237722370 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/match/Patter

[jira] [Commented] (FLINK-10986) Jepsen: Deploy Kafka Broker on DB Nodes

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

[GitHub] GJL commented on a change in pull request #7173: [FLINK-10986][tests] Implement DB to setup Apache Kafka

GJL commented on a change in pull request #7173: [FLINK-10986][tests] Implement DB to setup Apache Kafka URL: https://github.com/apache/flink/pull/7173#discussion_r237573167 ## File path: flink-jepsen/docker/test-specs/mesos-session.edn ## @@ -0,0 +1,19 @@ +;; Licensed to

[jira] [Closed] (FLINK-11033) Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-11033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11033. Resolution: Duplicate Duplicate of FLINK-11011. > Elasticsearch (v6.3.1) sink end-to-end test uns

[jira] [Updated] (FLINK-11011) Elasticsearch 6 sink end-to-end test unstable

[ https://issues.apache.org/jira/browse/FLINK-11011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11011: - Priority: Critical (was: Major) > Elasticsearch 6 sink end-to-end test unstable > -

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237569734 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -211,6 +211,66 @@ If a

[jira] [Created] (FLINK-11033) Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis

Till Rohrmann created FLINK-11033: - Summary: Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis Key: FLINK-11033 URL: https://issues.apache.org/jira/browse/FLINK-11033 Project: Flink

[jira] [Closed] (FLINK-11032) Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-11032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11032. Resolution: Duplicate Duplicate of FLINK-11011. > Elasticsearch (v6.3.1) sink end-to-end test uns

[jira] [Updated] (FLINK-11011) Elasticsearch 6 sink end-to-end test unstable

[ https://issues.apache.org/jira/browse/FLINK-11011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11011: - Affects Version/s: 1.7.1 1.8.0 > Elasticsearch 6 sink end-to-end test uns

[jira] [Updated] (FLINK-11030) Cannot use Avro logical types with ConfluentRegistryAvroDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-11030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-11030: --- Description: I created Specific class for Kafka topic. Avro schema includes logicalTypes.

[jira] [Created] (FLINK-11032) Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis

Till Rohrmann created FLINK-11032: - Summary: Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis Key: FLINK-11032 URL: https://issues.apache.org/jira/browse/FLINK-11032 Project: Flink

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237544327 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237544327 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

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

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r237538899 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237533224 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCod

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237529902 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCod

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237529378 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCod

[GitHub] dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237529378 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCod

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237526604 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCod

[GitHub] dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

dawidwys commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237526604 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCod

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

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

[GitHub] kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237520314 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/jo

[jira] [Created] (FLINK-11031) How to consume the Hive data in Flink using Scala

Preethi.C created FLINK-11031: - Summary: How to consume the Hive data in Flink using Scala Key: FLINK-11031 URL: https://issues.apache.org/jira/browse/FLINK-11031 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-11021) ZoneOffset objects don't appear to be serialized correctly

[ https://issues.apache.org/jira/browse/FLINK-11021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703290#comment-16703290 ] Christina commented on FLINK-11021: --- Looks like the root cause of this issue is that k

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[GitHub] kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237515137 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/ha

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[GitHub] kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237509884 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/ha

[GitHub] kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237509724 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/ha

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[GitHub] kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237509459 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/ha

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

  1   2   3   >