[
https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592501#comment-16592501
]
Shimin Yang commented on FLINK-10206:
-
Our streaming job heavily relied on hbase as
tragicjun commented on a change in pull request #6508: [Flink-10079] [table]
Automatically register sink table from external catalogs
URL: https://github.com/apache/flink/pull/6508#discussion_r210471287
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/tabl
[
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
> --
[
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 MessageAcknowledgingSource
[
https://issues.apache.org/jira/browse/FLINK-10214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592461#comment-16592461
]
lzh9 commented on FLINK-10214:
--
[~yanghua] , the parallelism is 6*8=48. If it's set 1, the
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-10214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592449#comment-16592449
]
vinoyang commented on FLINK-10214:
--
[~lzh9] What is the parallelism of your job? Since
[
https://issues.apache.org/jira/browse/FLINK-10212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592436#comment-16592436
]
vinoyang commented on FLINK-10212:
--
Hi [~mrooding] good thoughts, I think GET is better
[
https://issues.apache.org/jira/browse/FLINK-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592433#comment-16592433
]
ASF GitHub Bot commented on FLINK-10136:
yanghua commented on a change in pull r
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()
[
https://issues.apache.org/jira/browse/FLINK-9610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592422#comment-16592422
]
ASF GitHub Bot commented on FLINK-9610:
---
cricket007 commented on issue #6181: [FLIN
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`
https://github.com/apac
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:
[
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 sup
[
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
> --
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592376#comment-16592376
]
ASF GitHub Bot commented on FLINK-10136:
asfgit closed pull request #6597: [FLIN
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
[
https://issues.apache.org/jira/browse/FLINK-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592372#comment-16592372
]
ASF GitHub Bot commented on FLINK-10201:
xccui closed pull request #6605: [FLINK
[
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 w
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
t
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
---
[
https://issues.apache.org/jira/browse/FLINK-9086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592298#comment-16592298
]
ASF GitHub Bot commented on FLINK-9086:
---
ruankd commented on issue #5768: [FLINK-90
[
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 launc
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 Apac
[
https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592297#comment-16592297
]
ASF GitHub Bot commented on FLINK-7477:
---
ruankd commented on issue #4566: [FLINK-74
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 of
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
Proje
[
https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592182#comment-16592182
]
Luka Jurukovski commented on FLINK-10195:
-
[~StephanEwen]
For what I can tell no
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592021#comment-16592021
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull
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:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetInputF
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591984#comment-16591984
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull
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:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/Parquet
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591977#comment-16591977
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull
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:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetRowInp
[
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
([https
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 Type
[
https://issues.apache.org/jira/browse/FLINK-10153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591943#comment-16591943
]
ASF GitHub Bot commented on FLINK-10153:
asfgit closed pull request #6565: [FLIN
[
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 52cbe07ba7a367880475af59596adc2
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:
As
[
https://issues.apache.org/jira/browse/FLINK-10163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591933#comment-16591933
]
ASF GitHub Bot commented on FLINK-10163:
fhueske commented on a change in pull r
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:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.
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: http://localhos
[
https://issues.apache.org/jira/browse/FLINK-10163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591932#comment-16591932
]
ASF GitHub Bot commented on FLINK-10163:
fhueske commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-10163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591934#comment-16591934
]
ASF GitHub Bot commented on FLINK-10163:
fhueske commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-10163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591930#comment-16591930
]
ASF GitHub Bot commented on FLINK-10163:
fhueske commented on a change in pull r
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: http://localhos
[
https://issues.apache.org/jira/browse/FLINK-10163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591931#comment-16591931
]
ASF GitHub Bot commented on FLINK-10163:
fhueske commented on a change in pull r
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:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommand
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:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environ
[
https://issues.apache.org/jira/browse/FLINK-10204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591852#comment-16591852
]
ASF GitHub Bot commented on FLINK-10204:
benlamonica commented on issue #6610: [
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?
[
https://issues.apache.org/jira/browse/FLINK-10204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591804#comment-16591804
]
ASF GitHub Bot commented on FLINK-10204:
benlamonica commented on a change in pu
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:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/
[
https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591783#comment-16591783
]
ASF GitHub Bot commented on FLINK-9559:
---
pnowojski commented on issue #6519: [FLINK
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
[
https://issues.apache.org/jira/browse/FLINK-9391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591754#comment-16591754
]
Hequn Cheng commented on FLINK-9391:
Hi [~SokolovMS], Thanks for contributing to Flin
[
https://issues.apache.org/jira/browse/FLINK-10204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591737#comment-16591737
]
ASF GitHub Bot commented on FLINK-10204:
zentol commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-10204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591736#comment-16591736
]
ASF GitHub Bot commented on FLINK-10204:
zentol commented on a change in pull re
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:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/strea
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:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/strea
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 beca
[
https://issues.apache.org/jira/browse/FLINK-10204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591707#comment-16591707
]
ASF GitHub Bot commented on FLINK-10204:
benlamonica commented on issue #6610: [
[
https://issues.apache.org/jira/browse/FLINK-10204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591702#comment-16591702
]
ASF GitHub Bot commented on FLINK-10204:
benlamonica commented on a change in pu
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:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/
[
https://issues.apache.org/jira/browse/FLINK-10204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591641#comment-16591641
]
ASF GitHub Bot commented on FLINK-10204:
benlamonica commented on a change in pu
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:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591639#comment-16591639
]
ASF GitHub Bot commented on FLINK-9713:
---
pnowojski commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591638#comment-16591638
]
ASF GitHub Bot commented on FLINK-9713:
---
pnowojski commented on a change in pull re
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:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/
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:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/lo
[
https://issues.apache.org/jira/browse/FLINK-10204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591630#comment-16591630
]
ASF GitHub Bot commented on FLINK-10204:
benlamonica commented on a change in pu
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:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/
[
https://issues.apache.org/jira/browse/FLINK-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591597#comment-16591597
]
ASF GitHub Bot commented on FLINK-10136:
xccui commented on a change in pull req
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()
[
https://issues.apache.org/jira/browse/FLINK-10211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591587#comment-16591587
]
Xingcan Cui commented on FLINK-10211:
-
Hi [~pnowojski], I guess the two tickets you
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591576#comment-16591576
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on issue #6432: [FLINK-9
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 a
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
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
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591538#comment-16591538
]
ASF GitHub Bot commented on FLINK-3875:
---
twalthr commented on issue #6611: [FLINK-3
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 automated
[
https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591537#comment-16591537
]
ASF GitHub Bot commented on FLINK-3875:
---
twalthr opened a new pull request #6611: [
[
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
> -
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 we
[
https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591535#comment-16591535
]
ASF GitHub Bot commented on FLINK-9559:
---
hequn8128 edited a comment on issue #6519:
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. No
[
https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591533#comment-16591533
]
ASF GitHub Bot commented on FLINK-9559:
---
hequn8128 edited a comment on issue #6519:
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. No
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
[
https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591530#comment-16591530
]
ASF GitHub Bot commented on FLINK-9559:
---
hequn8128 commented on issue #6519: [FLINK
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591511#comment-16591511
]
eugen yushin edited comment on FLINK-10050 at 8/24/18 11:31 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591511#comment-16591511
]
eugen yushin edited comment on FLINK-10050 at 8/24/18 11:30 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591511#comment-16591511
]
eugen yushin edited comment on FLINK-10050 at 8/24/18 11:29 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591511#comment-16591511
]
eugen yushin commented on FLINK-10050:
--
[~aljoscha] There's no info about windows f
[
https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591513#comment-16591513
]
ASF GitHub Bot commented on FLINK-7964:
---
yanghua commented on a change in pull requ
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:
flink-connectors/flink-connector-kafka-1.0/src/test/java/org/apache/flink/streaming/connectors/ka
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591489#comment-16591489
]
JIN SUN commented on FLINK-10205:
-
In my opinion we need deterministic, especially when
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591484#comment-16591484
]
Fabian Hueske commented on FLINK-10205:
---
Oh, I didn't notice that this issue was c
1 - 100 of 137 matches
Mail list logo