[jira] [Commented] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697677#comment-16697677 ] Zhenqiu Huang commented on FLINK-10868: --- [~suez1224] [~till.rohrmann] Agree with

[jira] [Comment Edited] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697629#comment-16697629 ] ideal-hp edited comment on FLINK-10999 at 11/24/18 6:11 AM:

[jira] [Created] (FLINK-11000) Introduce Resource Blacklist Mechanism

Yingjie Cao created FLINK-11000: --- Summary: Introduce Resource Blacklist Mechanism Key: FLINK-11000 URL: https://issues.apache.org/jira/browse/FLINK-11000 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

ideal-hp created FLINK-10999: Summary: Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long Key: FLINK-10999 URL: https://issues.apache.org/jira/browse/FLINK-10999

[jira] [Commented] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697629#comment-16697629 ] ideal-hp commented on FLINK-10999: -- To reproduce this problem I have provided the follo

[jira] [Comment Edited] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697629#comment-16697629 ] ideal-hp edited comment on FLINK-10999 at 11/24/18 4:03 AM:

[GitHub] Clarkkkkk commented on issue #6628: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase

Clark commented on issue #6628: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase URL: https://github.com/apache/flink/pull/6628#issuecomment-441338045 Hi @burgesschentz , we cannot guarantee the order of different subtask actually. Bu

[jira] [Commented] (FLINK-10245) Add DataStream HBase Sink

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

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

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

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

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

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

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

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

zentol commented on a change in pull request #7165: [FLINK-10990][Metric]Pre-check timespan in meterview to avoid NAN URL: https://github.com/apache/flink/pull/7165#discussion_r236018552 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MeterView

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

zentol commented on a change in pull request #7165: [FLINK-10990][Metric]Pre-check timespan in meterview to avoid NAN URL: https://github.com/apache/flink/pull/7165#discussion_r236019059 ## File path: flink-metrics/flink-metrics-core/src/test/java/org/apache/flink/metrics/MeterView

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

zentol commented on a change in pull request #7165: [FLINK-10990][Metric]Pre-check timespan in meterview to avoid NAN URL: https://github.com/apache/flink/pull/7165#discussion_r236018604 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MeterView

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

zentol commented on a change in pull request #7165: [FLINK-10990][Metric]Pre-check timespan in meterview to avoid NAN URL: https://github.com/apache/flink/pull/7165#discussion_r236019042 ## File path: flink-metrics/flink-metrics-core/src/test/java/org/apache/flink/metrics/MeterView

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

zentol commented on a change in pull request #7165: [FLINK-10990][Metric]Pre-check timespan in meterview to avoid NAN URL: https://github.com/apache/flink/pull/7165#discussion_r236018806 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MeterView

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

zentol commented on a change in pull request #7165: [FLINK-10990][Metric]Pre-check timespan in meterview to avoid NAN URL: https://github.com/apache/flink/pull/7165#discussion_r236019092 ## File path: flink-metrics/flink-metrics-core/src/test/java/org/apache/flink/metrics/MeterView

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

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

[GitHub] HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format

HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-441301540 @fhueske Resolved all of the comments except the one for timestamp rewrite. It is needed for time field of window functions.

[jira] [Commented] (FLINK-10845) Support DISTINCT aggregates for batch

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

[GitHub] xueyumusic commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch

xueyumusic commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch URL: https://github.com/apache/flink/pull/7079#discussion_r23578 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table

[jira] [Commented] (FLINK-10985) Enable multiple Job Submission in distributed Tests

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

[GitHub] GJL commented on a change in pull request #7166: [FLINK-10985][tests] Enable submission of multiple jobs.

GJL commented on a change in pull request #7166: [FLINK-10985][tests] Enable submission of multiple jobs. URL: https://github.com/apache/flink/pull/7166#discussion_r235997963 ## File path: flink-jepsen/docker/run-tests.sh ## @@ -26,6 +28,27 @@ n2 n3 EOF -common_jepsen_

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

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

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

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

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

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

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

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

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

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

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

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

[GitHub] StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state

StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state URL: https://github.com/apache/flink/pull/7153#discussion_r235995783 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/mai

[GitHub] StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state

StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state URL: https://github.com/apache/flink/pull/7153#discussion_r235995727 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/mai

[GitHub] StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state

StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state URL: https://github.com/apache/flink/pull/7153#discussion_r235996032 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/mai

[GitHub] StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state

StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state URL: https://github.com/apache/flink/pull/7153#discussion_r235996153 ## File path: docs/release-notes/flink-1.6.md ## @@ -29,6 +2

[GitHub] StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state

StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state URL: https://github.com/apache/flink/pull/7153#discussion_r235995638 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/mai

[GitHub] StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state

StefanRRichter commented on a change in pull request #7153: FLINK-10918 Fix the checkpoint dir creation error on Window for keyed rocksdb state URL: https://github.com/apache/flink/pull/7153#discussion_r235995974 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/mai

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

[ https://issues.apache.org/jira/browse/FLINK-10946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter resolved FLINK-10946. Resolution: Fixed Fix Version/s: (was: 1.7.1) (was: 1.8.0

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

[ https://issues.apache.org/jira/browse/FLINK-10946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697339#comment-16697339 ] ASF GitHub Bot commented on FLINK-10946: StefanRRichter closed pull request #715

[GitHub] StefanRRichter closed pull request #7154: [FLINK-10946] Silent checkpoint async failures in task executor if job is not runnning

StefanRRichter closed pull request #7154: [FLINK-10946] Silent checkpoint async failures in task executor if job is not runnning URL: https://github.com/apache/flink/pull/7154 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below f

[jira] [Commented] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

[ https://issues.apache.org/jira/browse/FLINK-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697328#comment-16697328 ] ASF GitHub Bot commented on FLINK-10009: XuQianJin-Stars removed a comment on is

[GitHub] XuQianJin-Stars removed a comment on issue #7155: [FLINK-10009] [table] Fix the casting problem for function TIMESTAMPADD in Table

XuQianJin-Stars removed a comment on issue #7155: [FLINK-10009] [table] Fix the casting problem for function TIMESTAMPADD in Table URL: https://github.com/apache/flink/pull/7155#issuecomment-441142981 @twalthr Thank you very much for helping me modify the title of this PR. Could you help m

[jira] [Commented] (FLINK-10245) Add DataStream HBase Sink

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697324#comment-16697324 ] ASF GitHub Bot commented on FLINK-10245: burgesschentz commented on issue #6628:

[GitHub] burgesschentz commented on issue #6628: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase

burgesschentz commented on issue #6628: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase URL: https://github.com/apache/flink/pull/6628#issuecomment-441279266 @Clark Hi Clark. My team is implementing something very similar. We need a

[jira] [Commented] (FLINK-10994) The bug of timestampadd handles time

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

[jira] [Updated] (FLINK-10994) The bug of timestampadd handles time

[ https://issues.apache.org/jira/browse/FLINK-10994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10994: --- Labels: pull-request-available (was: ) > The bug of timestampadd handles time > ---

[GitHub] zentol opened a new pull request #7170: [FLINK-10994][formats] Bundle kafka-scheme-registry-client

zentol opened a new pull request #7170: [FLINK-10994][formats] Bundle kafka-scheme-registry-client URL: https://github.com/apache/flink/pull/7170 ## What is the purpose of the change With this PR `flink-avro-confluent-registry` bundles `kafka-scheme-registry-client` as intended.

[jira] [Commented] (FLINK-10998) flink-metrics-ganglia has LGPL dependency

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

[jira] [Updated] (FLINK-10998) flink-metrics-ganglia has LGPL dependency

[ https://issues.apache.org/jira/browse/FLINK-10998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10998: --- Labels: pull-request-available (was: ) > flink-metrics-ganglia has LGPL dependency > --

[GitHub] zentol opened a new pull request #7169: [FLINK-10998][metrics][ganglia] Remove Ganglia reporter

zentol opened a new pull request #7169: [FLINK-10998][metrics][ganglia] Remove Ganglia reporter URL: https://github.com/apache/flink/pull/7169 The Ganglia reporter has a transitive LGPL dependency and thus has to be removed.

[jira] [Created] (FLINK-10998) flink-metrics-ganglia has LGPL dependency

Chesnay Schepler created FLINK-10998: Summary: flink-metrics-ganglia has LGPL dependency Key: FLINK-10998 URL: https://issues.apache.org/jira/browse/FLINK-10998 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697175#comment-16697175 ] ASF GitHub Bot commented on FLINK-8577: --- hequn8128 commented on issue #6787: [FLINK

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

hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#issuecomment-441249337 @pnowojski @sunjincheng121 @dianfu Thanks for your review and suggestions. I have split and updated the pr.

[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&focusedCommentId=16697162#comment-16697162 ] Dawid Wysakowicz commented on FLINK-10997: -- Yes, the plan was not to include fl

[jira] [Updated] (FLINK-10994) The bug of timestampadd handles time

[ https://issues.apache.org/jira/browse/FLINK-10994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-10994: -- Description: The error occur when {{timestampadd(MINUTE, 1, time '01:00:00')}} is executed: java.lang

[jira] [Updated] (FLINK-10994) The bug of timestampadd handles time

[ https://issues.apache.org/jira/browse/FLINK-10994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-10994: -- Description: The error occur when {{timestampadd(MINUTE, 1, time '01:00:00')}} is executed: java.lang

[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&focusedCommentId=16697099#comment-16697099 ] Chesnay Schepler commented on FLINK-10997: -- [~dawidwys] flink-avro is not suppo

[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&focusedCommentId=16696703#comment-16696703 ] ASF GitHub Bot commented on FLINK-10973: dianfu opened a new pull request #7167:

[jira] [Updated] (FLINK-10540) Remove legacy FlinkMiniCluster

[ https://issues.apache.org/jira/browse/FLINK-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-10540: Affects Version/s: (was: 1.8.0) 1.7.0 > Remove legacy FlinkMiniCluster

[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&focusedCommentId=16697054#comment-16697054 ] Timo Walther edited comment on FLINK-9461 at 11/23/18 12:09 PM: ---

[jira] [Updated] (FLINK-10540) Remove legacy FlinkMiniCluster

[ https://issues.apache.org/jira/browse/FLINK-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-10540: Affects Version/s: (was: 1.7.0) 1.8.0 > Remove legacy FlinkMiniCluster

[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&focusedCommentId=16697054#comment-16697054 ] Timo Walther commented on FLINK-9461: - Yes, this is the way to go. Feel free to start

[GitHub] Clarkkkkk opened a new pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

Clark opened a new pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168 ## What is the purpose of the change Provide Rich AsyncFunction to Scala API suite ## Brief change log - Proivd

[jira] [Updated] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6756: -- Labels: pull-request-available (was: ) > Provide RichAsyncFunction to Scala API suite > --

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

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

[jira] [Commented] (FLINK-10552) Provide RichAsyncFunction for scala API

[ https://issues.apache.org/jira/browse/FLINK-10552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16696751#comment-16696751 ] ASF GitHub Bot commented on FLINK-10552: Clark closed pull request #6878: [F

[GitHub] Clarkkkkk closed pull request #6878: [FLINK-10552][DataStream API]Add supports for RichAsyncFunction in Scala API

Clark closed pull request #6878: [FLINK-10552][DataStream API]Add supports for RichAsyncFunction in Scala API URL: https://github.com/apache/flink/pull/6878 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-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&focusedCommentId=16696704#comment-16696704 ] ASF GitHub Bot commented on FLINK-10924: TisonKun commented on issue #7143: [FLI

[GitHub] TisonKun commented on issue #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in…

TisonKun commented on issue #7143: [FLINK-10924] [javadoc] StreamExecutionEnvironment method javadocs in… URL: https://github.com/apache/flink/pull/7143#issuecomment-441222646 @zentol as a reminder This is an automated messag

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

[ https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10973: --- Labels: pull-request-available (was: ) > Add Map operator to Table API > --

[GitHub] dianfu opened a new pull request #7167: [FLINK-10973] [table] Add support for map to table API

dianfu opened a new pull request #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167 ## What is the purpose of the change *This pull request adds support for map to table API. * ## Brief change log - *Added map

[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&focusedCommentId=16696693#comment-16696693 ] vinoyang commented on FLINK-9461: - hi [~twalthr]  Thank you for your explanation of the c

[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&focusedCommentId=16696693#comment-16696693 ] vinoyang edited comment on FLINK-9461 at 11/23/18 11:44 AM: h

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

Chesnay Schepler created FLINK-10997: Summary: Avro-confluent-registry does not bundle any dependency Key: FLINK-10997 URL: https://issues.apache.org/jira/browse/FLINK-10997 Project: Flink

[jira] [Commented] (FLINK-10845) Support DISTINCT aggregates for batch

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

[GitHub] twalthr commented on issue #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch

twalthr commented on issue #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch URL: https://github.com/apache/flink/pull/7079#issuecomment-441215494 Thanks for the update @xueyumusic. Then let's at least do my other comment.

[jira] [Closed] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-10842. Resolution: Fixed Fix Version/s: (was: 1.8.0) 1.7.0 Fixed in master:

[jira] [Commented] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16696646#comment-16696646 ] ASF GitHub Bot commented on FLINK-10842: asfgit closed pull request #7073: [FLIN

[GitHub] asfgit closed pull request #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh

asfgit closed pull request #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh URL: https://github.com/apache/flink/pull/7073 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As t

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

[ https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16696641#comment-16696641 ] ASF GitHub Bot commented on FLINK-9964: --- twalthr commented on issue #6541: [FLINK-9

[GitHub] twalthr commented on issue #6541: [FLINK-9964] [table] Add a CSV table format factory

twalthr commented on issue #6541: [FLINK-9964] [table] Add a CSV table format factory URL: https://github.com/apache/flink/pull/6541#issuecomment-441204182 Thanks for the update @buptljy. I will take care of merging this. Thi

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16696631#comment-16696631 ] ASF GitHub Bot commented on FLINK-8577: --- hequn8128 commented on issue #6787: [FLINK

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

hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#issuecomment-441202156 @pnowojski thanks for your review. Make sense to me. I will split it into 4 commits according to your sugg

[jira] [Updated] (FLINK-10985) Enable multiple Job Submission in distributed Tests

[ https://issues.apache.org/jira/browse/FLINK-10985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10985: --- Labels: pull-request-available (was: ) > Enable multiple Job Submission in distributed Test

[jira] [Commented] (FLINK-10985) Enable multiple Job Submission in distributed Tests

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

[GitHub] GJL opened a new pull request #7166: [FLINK-10985][tests] Enable submission of multiple jobs.

GJL opened a new pull request #7166: [FLINK-10985][tests] Enable submission of multiple jobs. URL: https://github.com/apache/flink/pull/7166 ## What is the purpose of the change *This enables submission of multiple jobs in the Jepsen tests.* ## Brief change log - *The

[jira] [Commented] (FLINK-10842) Waiting loops are broken in e2e/common.sh

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

[GitHub] twalthr commented on issue #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh

twalthr commented on issue #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh URL: https://github.com/apache/flink/pull/7073#issuecomment-441199627 Thanks for the update @azagrebin. I will merge this... Thi

[jira] [Commented] (FLINK-10842) Waiting loops are broken in e2e/common.sh

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

[GitHub] twalthr commented on a change in pull request #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh

twalthr commented on a change in pull request #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh URL: https://github.com/apache/flink/pull/7073#discussion_r235892506 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -242,30 +245,45 @@ fun

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

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

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

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

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

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

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

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

[GitHub] twalthr commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common

twalthr commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7059#discussion_r235889153 ## File path: flink-libraries/flink-table-common/src/main/java/org/apache/fli

[GitHub] twalthr commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common

twalthr commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7059#discussion_r235889153 ## File path: flink-libraries/flink-table-common/src/main/java/org/apache/fli

[GitHub] twalthr commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common

twalthr commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7059#discussion_r235888670 ## File path: flink-libraries/flink-table-common/src/main/java/org/apache/fli

[GitHub] twalthr commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common

twalthr commented on a change in pull request #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7059#discussion_r23519 ## File path: flink-libraries/flink-table-common/src/main/java/org/apache/fli

[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&focusedCommentId=16696589#comment-16696589 ] Timo Walther commented on FLINK-9461: - [~yanghua] The main work on this issue has alr

  1   2   >