[jira] [Assigned] (FLINK-6344) Migrate from Java serialization for BucketingSink's state

[ https://issues.apache.org/jira/browse/FLINK-6344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-6344: --- Assignee: vinoyang (was: Hai Zhou) > Migrate from Java serialization for BucketingSink's state >

[jira] [Assigned] (FLINK-6347) Migrate from Java serialization for MessageAcknowledgingSourceBase's state

[ https://issues.apache.org/jira/browse/FLINK-6347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-6347: --- Assignee: vinoyang (was: Hai Zhou) > Migrate from Java serialization for

[jira] [Commented] (FLINK-10214) why is job applying as many TMs as default parallelism when starting, each parallelism is 1

[ https://issues.apache.org/jira/browse/FLINK-10214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592461#comment-16592461 ] lzh9 commented on FLINK-10214: -- [~yanghua] , the parallelism is 6*8=48. If it's set 1, the job will apply

[jira] [Assigned] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics

[ https://issues.apache.org/jira/browse/FLINK-7624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-7624: --- Assignee: vinoyang > Add kafka-topic for "KafkaProducer" metrics >

[jira] [Commented] (FLINK-10214) why is job applying as many TMs as default parallelism when starting, each parallelism is 1

[ https://issues.apache.org/jira/browse/FLINK-10214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592449#comment-16592449 ] vinoyang commented on FLINK-10214: -- [~lzh9] What is the parallelism of your job? Since FLIP-6, Flink

[jira] [Commented] (FLINK-10212) REST API for listing all the available save points

[ https://issues.apache.org/jira/browse/FLINK-10212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592436#comment-16592436 ] vinoyang commented on FLINK-10212: -- Hi [~mrooding] good thoughts, I think GET is better for the 

[jira] [Commented] (FLINK-10136) Add REPEAT supported in Table API and SQL

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

[GitHub] yanghua commented on a change in pull request #6597: [FLINK-10136] [table] Add REPEAT supported in Table API and SQL

yanghua commented on a change in pull request #6597: [FLINK-10136] [table] Add REPEAT supported in Table API and SQL URL: https://github.com/apache/flink/pull/6597#discussion_r212788014 ## File path: docs/dev/table/functions.md ## @@ -2614,6 +2626,18 @@ STRING.rtrim()

[jira] [Commented] (FLINK-9610) Add Kafka partitioner that uses the key to partition by

[ https://issues.apache.org/jira/browse/FLINK-9610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592422#comment-16592422 ] ASF GitHub Bot commented on FLINK-9610: --- cricket007 commented on issue #6181: [FLINK-9610]

[GitHub] cricket007 commented on issue #6181: [FLINK-9610] [flink-connector-kafka-base] Add Kafka Partitioner that uses the hash of the provided key.

cricket007 commented on issue #6181: [FLINK-9610] [flink-connector-kafka-base] Add Kafka Partitioner that uses the hash of the provided key. URL: https://github.com/apache/flink/pull/6181#issuecomment-415930190 Kafka uses a Murmur2 Hash, not `Arrays.hashCode`

[jira] [Created] (FLINK-10214) why is job applying as many TMs as default parallelism when starting, each parallelism is 1

lzh9 created FLINK-10214: Summary: why is job applying as many TMs as default parallelism when starting, each parallelism is 1 Key: FLINK-10214 URL: https://issues.apache.org/jira/browse/FLINK-10214 Project:

[jira] [Resolved] (FLINK-10136) Add REPEAT supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-10136. - Resolution: Done Implemented in 1.7.0 505dca174128ebb3bf765778ee36d58f680d6a1e > Add REPEAT

[jira] [Updated] (FLINK-10201) The batchTestUtil was mistakenly used in some stream sql tests

[ https://issues.apache.org/jira/browse/FLINK-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-10201: Fix Version/s: 1.7.0 > The batchTestUtil was mistakenly used in some stream sql tests >

[jira] [Updated] (FLINK-10136) Add REPEAT supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-10136: Fix Version/s: 1.7.0 > Add REPEAT supported in Table API and SQL >

[jira] [Commented] (FLINK-10136) Add REPEAT supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592376#comment-16592376 ] ASF GitHub Bot commented on FLINK-10136: asfgit closed pull request #6597: [FLINK-10136] [table]

[GitHub] asfgit closed pull request #6597: [FLINK-10136] [table] Add REPEAT supported in Table API and SQL

asfgit closed pull request #6597: [FLINK-10136] [table] Add REPEAT supported in Table API and SQL URL: https://github.com/apache/flink/pull/6597 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As

[jira] [Commented] (FLINK-10201) The batchTestUtil was mistakenly used in some stream sql tests

[ https://issues.apache.org/jira/browse/FLINK-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592372#comment-16592372 ] ASF GitHub Bot commented on FLINK-10201: xccui closed pull request #6605: [FLINK-10201] [table]

[jira] [Resolved] (FLINK-10201) The batchTestUtil was mistakenly used in some stream sql tests

[ https://issues.apache.org/jira/browse/FLINK-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-10201. - Resolution: Fixed Fixed in 1.7.0 6d28a65092ffe4a4390fccacb4deb7e403924f51 > The batchTestUtil

[GitHub] xccui closed pull request #6605: [FLINK-10201] [table] [test] The batchTestUtil was mistakenly used in some stream sql tests

xccui closed pull request #6605: [FLINK-10201] [table] [test] The batchTestUtil was mistakenly used in some stream sql tests URL: https://github.com/apache/flink/pull/6605 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[GitHub] fhueske commented on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs

fhueske commented on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs URL: https://github.com/apache/flink/pull/6508#issuecomment-415906486 Hi @tragicjun, sorry for the late reply. I'll have a look at this PR next week. Best, Fabian

[jira] [Commented] (FLINK-9086) Use INTERNAL_HADOOP_CLASSPATHS as classpath for launching Yarn cluster for Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-9086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592298#comment-16592298 ] ASF GitHub Bot commented on FLINK-9086: --- ruankd commented on issue #5768: [FLINK-9086] Use

[jira] [Updated] (FLINK-9086) Use INTERNAL_HADOOP_CLASSPATHS as classpath for launching Yarn cluster for Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-9086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9086: -- Labels: pull-request-available (was: ) > Use INTERNAL_HADOOP_CLASSPATHS as classpath for

[GitHub] ruankd commented on issue #5768: [FLINK-9086] Use INTERNAL_HADOOP_CLASSPATHS as classpath for Yarn Session

ruankd commented on issue #5768: [FLINK-9086] Use INTERNAL_HADOOP_CLASSPATHS as classpath for Yarn Session URL: https://github.com/apache/flink/pull/5768#issuecomment-415904593 Ping. This is an automated message from the

[jira] [Commented] (FLINK-7477) Use "hadoop classpath" to augment classpath when available

[ https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592297#comment-16592297 ] ASF GitHub Bot commented on FLINK-7477: --- ruankd commented on issue #4566: [FLINK-7477] [FLINK-7480]

[GitHub] ruankd commented on issue #4566: [FLINK-7477] [FLINK-7480] Various improvements to Flink scripts

ruankd commented on issue #4566: [FLINK-7477] [FLINK-7480] Various improvements to Flink scripts URL: https://github.com/apache/flink/pull/4566#issuecomment-415904348 Hey, notice that this [commit](https://github.com/apache/flink/commit/0a0f6ed6c3d6cff702e4322293340274bea5e7d9) is part

[jira] [Created] (FLINK-10213) Task managers cache a negative DNS lookup of the blob server indefinitely

Joey Echeverria created FLINK-10213: --- Summary: Task managers cache a negative DNS lookup of the blob server indefinitely Key: FLINK-10213 URL: https://issues.apache.org/jira/browse/FLINK-10213

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592182#comment-16592182 ] Luka Jurukovski commented on FLINK-10195: - [~StephanEwen] For what I can tell no. Although this

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

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

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r212714129 ## File path:

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

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

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r212706499 ## File path:

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

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

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r212704322 ## File path:

[jira] [Updated] (FLINK-10212) REST API for listing all the available save points

[ https://issues.apache.org/jira/browse/FLINK-10212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marc Rooding updated FLINK-10212: - Description: *Background* I'm one of the authors of the open-source Flink job deployer

[jira] [Created] (FLINK-10212) REST API for listing all the available save points

Marc Rooding created FLINK-10212: Summary: REST API for listing all the available save points Key: FLINK-10212 URL: https://issues.apache.org/jira/browse/FLINK-10212 Project: Flink Issue

[jira] [Commented] (FLINK-10153) Add tutorial section to documentation

[ https://issues.apache.org/jira/browse/FLINK-10153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591943#comment-16591943 ] ASF GitHub Bot commented on FLINK-10153: asfgit closed pull request #6565: [FLINK-10153] [docs]

[jira] [Closed] (FLINK-10153) Add tutorial section to documentation

[ https://issues.apache.org/jira/browse/FLINK-10153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-10153. - Resolution: Done Fix Version/s: 1.7.0 Done for 1.7.0 with

[GitHub] asfgit closed pull request #6565: [FLINK-10153] [docs] Add Tutorials section and rework structure.

asfgit closed pull request #6565: [FLINK-10153] [docs] Add Tutorials section and rework structure. URL: https://github.com/apache/flink/pull/6565 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:

[GitHub] fhueske commented on a change in pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client

fhueske commented on a change in pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client URL: https://github.com/apache/flink/pull/6606#discussion_r212621362 ## File path: docs/dev/table/sqlClient.md ## @@ -459,6 +466,50 @@ Web interface:

[jira] [Commented] (FLINK-10163) Support CREATE VIEW in SQL Client

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

[jira] [Commented] (FLINK-10163) Support CREATE VIEW in SQL Client

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

[GitHub] fhueske commented on a change in pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client

fhueske commented on a change in pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client URL: https://github.com/apache/flink/pull/6606#discussion_r212693978 ## File path:

[jira] [Commented] (FLINK-10163) Support CREATE VIEW in SQL Client

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

[jira] [Commented] (FLINK-10163) Support CREATE VIEW in SQL Client

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

[jira] [Commented] (FLINK-10163) Support CREATE VIEW in SQL Client

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

[GitHub] fhueske commented on a change in pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client

fhueske commented on a change in pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client URL: https://github.com/apache/flink/pull/6606#discussion_r212609696 ## File path: docs/dev/table/sqlClient.md ## @@ -459,6 +466,50 @@ Web interface:

[GitHub] fhueske commented on a change in pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client

fhueske commented on a change in pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client URL: https://github.com/apache/flink/pull/6606#discussion_r212622912 ## File path:

[GitHub] fhueske commented on a change in pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client

fhueske commented on a change in pull request #6606: [FLINK-10163] [sql-client] Support views in SQL Client URL: https://github.com/apache/flink/pull/6606#discussion_r212654542 ## File path:

[jira] [Commented] (FLINK-10204) Job is marked as FAILED after serialization exception

[ https://issues.apache.org/jira/browse/FLINK-10204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591852#comment-16591852 ] ASF GitHub Bot commented on FLINK-10204: benlamonica commented on issue #6610: [FLINK-10204] -

[GitHub] benlamonica commented on issue #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records.

benlamonica commented on issue #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records. URL: https://github.com/apache/flink/pull/6610#issuecomment-415805492 @zentol do you want me to squash the commits and force push to this branch so that the history remains clean?

[jira] [Commented] (FLINK-10204) Job is marked as FAILED after serialization exception

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

[GitHub] benlamonica commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records.

benlamonica commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records. URL: https://github.com/apache/flink/pull/6610#discussion_r212666184 ## File path:

[jira] [Commented] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

[ https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591783#comment-16591783 ] ASF GitHub Bot commented on FLINK-9559: --- pnowojski commented on issue #6519: [FLINK-9559] [table]

[GitHub] pnowojski commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR

pnowojski commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR URL: https://github.com/apache/flink/pull/6519#issuecomment-415789873 @hequn8128 I'm pretty sure that what you have just pointed out is bug in Flink SQL. I'm

[jira] [Commented] (FLINK-9391) Support UNNEST in Table API

[ https://issues.apache.org/jira/browse/FLINK-9391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591754#comment-16591754 ] Hequn Cheng commented on FLINK-9391: Hi [~SokolovMS], Thanks for contributing to Flink. You are

[jira] [Commented] (FLINK-10204) Job is marked as FAILED after serialization exception

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

[jira] [Commented] (FLINK-10204) Job is marked as FAILED after serialization exception

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

[GitHub] zentol commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records.

zentol commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records. URL: https://github.com/apache/flink/pull/6610#discussion_r212644961 ## File path:

[GitHub] zentol commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records.

zentol commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records. URL: https://github.com/apache/flink/pull/6610#discussion_r212645193 ## File path:

[GitHub] benlamonica commented on issue #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records.

benlamonica commented on issue #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records. URL: https://github.com/apache/flink/pull/6610#issuecomment-415769746 @StephanEwen and @zentol , I've commented on the PR comments. The reason why LatencyMarker has changes is

[jira] [Commented] (FLINK-10204) Job is marked as FAILED after serialization exception

[ https://issues.apache.org/jira/browse/FLINK-10204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591707#comment-16591707 ] ASF GitHub Bot commented on FLINK-10204: benlamonica commented on issue #6610: [FLINK-10204] -

[jira] [Commented] (FLINK-10204) Job is marked as FAILED after serialization exception

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

[GitHub] benlamonica commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records.

benlamonica commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records. URL: https://github.com/apache/flink/pull/6610#discussion_r212639070 ## File path:

[jira] [Commented] (FLINK-10204) Job is marked as FAILED after serialization exception

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

[GitHub] benlamonica commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records.

benlamonica commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records. URL: https://github.com/apache/flink/pull/6610#discussion_r212626021 ## File path:

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r212625803 ## File path:

[GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r208833159 ## File path:

[jira] [Commented] (FLINK-10204) Job is marked as FAILED after serialization exception

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

[GitHub] benlamonica commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records.

benlamonica commented on a change in pull request #6610: [FLINK-10204] - fix serialization/copy error for LatencyMarker records. URL: https://github.com/apache/flink/pull/6610#discussion_r212623923 ## File path:

[jira] [Commented] (FLINK-10136) Add REPEAT supported in Table API and SQL

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

[GitHub] xccui commented on a change in pull request #6597: [FLINK-10136] [table] Add REPEAT supported in Table API and SQL

xccui commented on a change in pull request #6597: [FLINK-10136] [table] Add REPEAT supported in Table API and SQL URL: https://github.com/apache/flink/pull/6597#discussion_r212618421 ## File path: docs/dev/table/functions.md ## @@ -2614,6 +2626,18 @@ STRING.rtrim()

[jira] [Commented] (FLINK-10211) Time indicators are not always materialised for LogicalJoin

[ https://issues.apache.org/jira/browse/FLINK-10211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591587#comment-16591587 ] Xingcan Cui commented on FLINK-10211: - Hi [~pnowojski], I guess the two tickets you just filed are

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591576#comment-16591576 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on issue #6432: [FLINK-9970] [table] Add

[GitHub] yanghua commented on issue #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

yanghua commented on issue #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#issuecomment-415745275 cc @xccui rebased this PR please review again. This is an

[jira] [Created] (FLINK-10211) Time indicators are not always materialised for LogicalJoin

Piotr Nowojski created FLINK-10211: -- Summary: Time indicators are not always materialised for LogicalJoin Key: FLINK-10211 URL: https://issues.apache.org/jira/browse/FLINK-10211 Project: Flink

[jira] [Created] (FLINK-10210) Time indicators are not always materialised for LogicalCorrelate

Piotr Nowojski created FLINK-10210: -- Summary: Time indicators are not always materialised for LogicalCorrelate Key: FLINK-10210 URL: https://issues.apache.org/jira/browse/FLINK-10210 Project: Flink

[jira] [Assigned] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-10205: - Assignee: JIN SUN > Batch Job: InputSplit Fault tolerant for DataSourceTask >

[jira] [Commented] (FLINK-3875) Add a TableSink for Elasticsearch

[ https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591538#comment-16591538 ] ASF GitHub Bot commented on FLINK-3875: --- twalthr commented on issue #6611: [FLINK-3875]

[GitHub] twalthr commented on issue #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch

twalthr commented on issue #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch URL: https://github.com/apache/flink/pull/6611#issuecomment-415737635 CC @tzulitai @dawidwys This is an

[jira] [Commented] (FLINK-3875) Add a TableSink for Elasticsearch

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

[jira] [Updated] (FLINK-3875) Add a TableSink for Elasticsearch

[ https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3875: -- Labels: pull-request-available (was: ) > Add a TableSink for Elasticsearch >

[GitHub] twalthr opened a new pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch

twalthr opened a new pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch URL: https://github.com/apache/flink/pull/6611 ## What is the purpose of the change This PR adds full support for Elasticsearch to be used with Table & SQL API as

[jira] [Commented] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

[ https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591535#comment-16591535 ] ASF GitHub Bot commented on FLINK-9559: --- hequn8128 edited a comment on issue #6519: [FLINK-9559]

[GitHub] hequn8128 edited a comment on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR

hequn8128 edited a comment on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR URL: https://github.com/apache/flink/pull/6519#issuecomment-415735866 Hi @pnowojski , thanks for your reply. There are many cases need this feature.

[jira] [Commented] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

[ https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591533#comment-16591533 ] ASF GitHub Bot commented on FLINK-9559: --- hequn8128 edited a comment on issue #6519: [FLINK-9559]

[GitHub] hequn8128 edited a comment on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR

hequn8128 edited a comment on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR URL: https://github.com/apache/flink/pull/6519#issuecomment-415735866 Hi @pnowojski , thanks for your reply. There are many cases need this feature.

[GitHub] hequn8128 commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR

hequn8128 commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR URL: https://github.com/apache/flink/pull/6519#issuecomment-415735866 Hi @pnowojski , thanks for your reply. There are many cases need this feature. Not only

[jira] [Commented] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

[ https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591530#comment-16591530 ] ASF GitHub Bot commented on FLINK-9559: --- hequn8128 commented on issue #6519: [FLINK-9559] [table]

[jira] [Comment Edited] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591511#comment-16591511 ] eugen yushin edited comment on FLINK-10050 at 8/24/18 11:31 AM:

[jira] [Comment Edited] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591511#comment-16591511 ] eugen yushin edited comment on FLINK-10050 at 8/24/18 11:30 AM:

[jira] [Comment Edited] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591511#comment-16591511 ] eugen yushin edited comment on FLINK-10050 at 8/24/18 11:29 AM:

[jira] [Commented] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591511#comment-16591511 ] eugen yushin commented on FLINK-10050: -- [~aljoscha] There's no info about windows for any of

[jira] [Commented] (FLINK-7964) Add Apache Kafka 1.0/1.1 connectors

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

[GitHub] yanghua commented on a change in pull request #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1 connectors

yanghua commented on a change in pull request #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1 connectors URL: https://github.com/apache/flink/pull/6577#discussion_r212599001 ## File path:

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591489#comment-16591489 ] JIN SUN commented on FLINK-10205: - In my opinion we need deterministic, especially when a task rerun,

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591484#comment-16591484 ] Fabian Hueske commented on FLINK-10205: --- Oh, I didn't notice that this issue was created in the

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591472#comment-16591472 ] JIN SUN commented on FLINK-10205: - Thanks Vinoyang, I cannot assign the bug to myself, I've send a

[GitHub] tragicjun edited a comment on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs

tragicjun edited a comment on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs URL: https://github.com/apache/flink/pull/6508#issuecomment-415720615 CC @zentol @xccui would you please help review it?

  1   2   >