[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644488#comment-16644488
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644487#comment-16644487
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
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_r223942389
##
File path:
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_r223942328
##
File path:
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_r223941595
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644486#comment-16644486
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644483#comment-16644483
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
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_r223941595
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644481#comment-16644481
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644480#comment-16644480
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
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_r223940956
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644479#comment-16644479
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
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_r223940919
##
File path:
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_r223940936
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644476#comment-16644476
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
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_r223940551
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644465#comment-16644465
]
ASF GitHub Bot commented on FLINK-9377:
---
tzulitai commented on issue #6711: [FLINK-9377] [core,
tzulitai commented on issue #6711: [FLINK-9377] [core, state backends] Remove
serializers from checkpoints
URL: https://github.com/apache/flink/pull/6711#issuecomment-428440460
Thanks @dawidwys.
I'll address your last comments, rebase on master and after Travis gives
green, proceed to
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644460#comment-16644460
]
huangjiatian commented on FLINK-10464:
--
[~twalthr] supplement to picture
>
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huangjiatian updated FLINK-10464:
-
Description:
I met a strange question when i use Flink SQL API.
I found two difference type
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huangjiatian updated FLINK-10464:
-
Attachment: 3.png
> TimeIndicatorRelDataType: digest can not describe a type completely.
>
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huangjiatian updated FLINK-10464:
-
Description:
I met a strange question when i use Flink SQL API.
I found two difference type
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huangjiatian updated FLINK-10464:
-
Attachment: 2.png
> TimeIndicatorRelDataType: digest can not describe a type completely.
>
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huangjiatian updated FLINK-10464:
-
Description:
I met a strange question when i use Flink SQL API.
I found two difference type
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huangjiatian updated FLINK-10464:
-
Description:
I met a strange question when i use Flink SQL API.
I found two difference type
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huangjiatian updated FLINK-10464:
-
Description:
I met a strange question when i use Flink SQL API.
I found two difference type
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huangjiatian updated FLINK-10464:
-
Attachment: 1.png
> TimeIndicatorRelDataType: digest can not describe a type completely.
>
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644450#comment-16644450
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huangjiatian updated FLINK-10464:
-
Description:
I met a strange question when i use Flink SQL API.
I found two difference type
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_r223935440
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huangjiatian updated FLINK-10464:
-
Description:
I met a strange question when i use Flink SQL API.
I found two difference type
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1663#comment-1663
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
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_r223934091
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644432#comment-16644432
]
ASF GitHub Bot commented on FLINK-10491:
zhijiangW commented on issue #6809:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644433#comment-16644433
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
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_r223932565
##
File path:
zhijiangW commented on issue #6809: [FLINK-10491][network] Pass BufferPoolOwner
in the constructor of LocalBufferPool
URL: https://github.com/apache/flink/pull/6809#issuecomment-428432627
Thanks for efficient reviews! @NicoK @pnowojski
I already updated the codes based on above
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644425#comment-16644425
]
ASF GitHub Bot commented on FLINK-10491:
zhijiangW commented on a change in pull request #6809:
zhijiangW commented on a change in pull request #6809: [FLINK-10491][network]
Pass BufferPoolOwner in the constructor of LocalBufferPool
URL: https://github.com/apache/flink/pull/6809#discussion_r223931343
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644421#comment-16644421
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
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_r223930910
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644407#comment-16644407
]
ASF GitHub Bot commented on FLINK-10491:
zhijiangW commented on a change in pull request #6809:
zhijiangW commented on a change in pull request #6809: [FLINK-10491][network]
Pass BufferPoolOwner in the constructor of LocalBufferPool
URL: https://github.com/apache/flink/pull/6809#discussion_r223929542
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644406#comment-16644406
]
ASF GitHub Bot commented on FLINK-10134:
XuQianJin-Stars commented on a change in pull request
XuQianJin-Stars commented on a change in pull request #6710: [FLINK-10134]
UTF-16 support for TextInputFormat bug fixed
URL: https://github.com/apache/flink/pull/6710#discussion_r223929236
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644401#comment-16644401
]
ASF GitHub Bot commented on FLINK-10491:
zhijiangW commented on a change in pull request #6809:
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644403#comment-16644403
]
ASF GitHub Bot commented on FLINK-10491:
zhijiangW commented on a change in pull request #6809:
zhijiangW commented on a change in pull request #6809: [FLINK-10491][network]
Pass BufferPoolOwner in the constructor of LocalBufferPool
URL: https://github.com/apache/flink/pull/6809#discussion_r223929096
##
File path:
zhijiangW commented on a change in pull request #6809: [FLINK-10491][network]
Pass BufferPoolOwner in the constructor of LocalBufferPool
URL: https://github.com/apache/flink/pull/6809#discussion_r223929018
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644347#comment-16644347
]
Hequn Cheng commented on FLINK-10474:
-
Hi all,
Thanks for your comments. I think there are two
[
https://issues.apache.org/jira/browse/FLINK-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644337#comment-16644337
]
ASF GitHub Bot commented on FLINK-9990:
---
yanghua commented on issue #6448: [FLINK-9990] [table] Add
yanghua commented on issue #6448: [FLINK-9990] [table] Add regexp_extract
supported in TableAPI and SQL
URL: https://github.com/apache/flink/pull/6448#issuecomment-428410089
@xccui Thank you very much for your time and effort. I also have a PR #6432
about `ASCII/CHR`. When you have time,
[
https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644320#comment-16644320
]
ASF GitHub Bot commented on FLINK-10423:
sjwiesman commented on a change in pull request #6814:
sjwiesman commented on a change in pull request #6814:
[FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor
URL: https://github.com/apache/flink/pull/6814#discussion_r223912317
##
File path:
Elias Levy created FLINK-10520:
--
Summary: Job save points REST API fails unless parameters are
specified
Key: FLINK-10520
URL: https://issues.apache.org/jira/browse/FLINK-10520
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644150#comment-16644150
]
Shuyi Chen commented on FLINK-10516:
Hi [~till.rohrmann], how do you want to proceed? I can either
[
https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644138#comment-16644138
]
ASF GitHub Bot commented on FLINK-10423:
zentol commented on a change in pull request #6814:
[
https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644136#comment-16644136
]
ASF GitHub Bot commented on FLINK-10423:
zentol commented on a change in pull request #6814:
[
https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644137#comment-16644137
]
ASF GitHub Bot commented on FLINK-10423:
zentol commented on a change in pull request #6814:
[
https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644139#comment-16644139
]
ASF GitHub Bot commented on FLINK-10423:
zentol commented on a change in pull request #6814:
zentol commented on a change in pull request #6814:
[FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor
URL: https://github.com/apache/flink/pull/6814#discussion_r223873328
##
File path:
zentol commented on a change in pull request #6814:
[FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor
URL: https://github.com/apache/flink/pull/6814#discussion_r223872847
##
File path:
zentol commented on a change in pull request #6814:
[FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor
URL: https://github.com/apache/flink/pull/6814#discussion_r223873851
##
File path:
zentol commented on a change in pull request #6814:
[FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor
URL: https://github.com/apache/flink/pull/6814#discussion_r223872647
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644127#comment-16644127
]
ASF GitHub Bot commented on FLINK-9990:
---
asfgit closed pull request #6448: [FLINK-9990] [table] Add
asfgit closed pull request #6448: [FLINK-9990] [table] Add regexp_extract
supported in TableAPI and SQL
URL: https://github.com/apache/flink/pull/6448
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
[
https://issues.apache.org/jira/browse/FLINK-10465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643266#comment-16643266
]
Gary Yao edited comment on FLINK-10465 at 10/9/18 7:46 PM:
---
fixed via
1.6:
[
https://issues.apache.org/jira/browse/FLINK-10465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-10465.
Resolution: Fixed
> Jepsen: runit supervised sshd is stopped on tear down
>
[
https://issues.apache.org/jira/browse/FLINK-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-5542.
---
Resolution: Fixed
fixed via
1.5: 5fb67abd51aca277d1140c274001e89f4bd7cf9a
1.6:
[
https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florian Schmidt updated FLINK-10519:
Description:
The flink-parent:1.6.1 artifact can't be found on maven central:
[
https://issues.apache.org/jira/browse/FLINK-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-5542:
Fix Version/s: 1.5.5
1.6.2
> YARN client incorrectly uses local YARN config to check
[
https://issues.apache.org/jira/browse/FLINK-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643990#comment-16643990
]
ASF GitHub Bot commented on FLINK-5542:
---
asfgit closed pull request #6775: [FLINK-5542] use
asfgit closed pull request #6775: [FLINK-5542] use YarnCluster vcores setting
to do MaxVCore validation
URL: https://github.com/apache/flink/pull/6775
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
[
https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629155#comment-16629155
]
Seth Wiesman edited comment on FLINK-10423 at 10/9/18 7:34 PM:
---
-I have a
[
https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-10423:
-
Summary: Forward RocksDB native metrics to Flink metrics reporter (was:
Forward RocksDB
[
https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643978#comment-16643978
]
ASF GitHub Bot commented on FLINK-10423:
sjwiesman opened a new pull request #6814:
[
https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10423:
---
Labels: pull-request-available (was: )
> Forward RocksDB memory metrics to Flink metrics
sjwiesman opened a new pull request #6814: [FLINK-10423][rocksdb][metrics]
rocksdb native metrics monitor
URL: https://github.com/apache/flink/pull/6814
## What is the purpose of the change
Optionally expose RocksDB native metrics to Flink metrics reporter. All
metrics are optionally
Florian Schmidt created FLINK-10519:
---
Summary: flink-parent:1.6.1 artifact can't be found on maven
central
Key: FLINK-10519
URL: https://issues.apache.org/jira/browse/FLINK-10519
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643912#comment-16643912
]
ASF GitHub Bot commented on FLINK-10440:
bmeriaux edited a comment on issue #6813: [FLINK-10440]
[
https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643911#comment-16643911
]
ASF GitHub Bot commented on FLINK-10440:
bmeriaux commented on issue #6813: [FLINK-10440] Add a
bmeriaux edited a comment on issue #6813: [FLINK-10440] Add a new
CassandraPojoOutputFormat
URL: https://github.com/apache/flink/pull/6813#issuecomment-428299042
Hi,
I need you advice on the inheritance with `CassandraOutputFormatBase`,
because `CassandraOutputFormatBase` constructor
bmeriaux commented on issue #6813: [FLINK-10440] Add a new
CassandraPojoOutputFormat
URL: https://github.com/apache/flink/pull/6813#issuecomment-428299042
Hi,
I need you advice on the inheritance with `CassandraOutputFormatBase`,
because `CassandraOutputFormatBase` constructor need an
[
https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10440:
---
Labels: pull-request-available (was: )
> Add a CassandraPojoOutputFormat to write Pojo in
[
https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643872#comment-16643872
]
ASF GitHub Bot commented on FLINK-10440:
bmeriaux opened a new pull request #6813: [FLINK-10440]
bmeriaux opened a new pull request #6813: [FLINK-10440] Add a new
CassandraPojoOutputFormat
URL: https://github.com/apache/flink/pull/6813
## What is the purpose of the change
*Create a new CassandraPojoOutputFormat to write Pojo in Cassandra in Batch*
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643840#comment-16643840
]
Benoit MERIAUX commented on FLINK-10440:
Hi,
could you assign this to me ?
I have code ready
[
https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benoit MERIAUX updated FLINK-10440:
---
Fix Version/s: 1.7.0
> Add a CassandraPojoOutputFormat to write Pojo in Cassandra from
[
https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643757#comment-16643757
]
JIN SUN commented on FLINK-9953:
Thanks Till.
> Active Kubernetes integration
>
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643752#comment-16643752
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483:
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-428274826
@fhueske
Thanks for reviewing this PR. I can't agree more on offering a similar
experience for both input formats (Parquet
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643744#comment-16643744
]
ASF GitHub Bot commented on FLINK-9697:
---
eliaslevy commented on a change in pull request #6703:
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643745#comment-16643745
]
ASF GitHub Bot commented on FLINK-9697:
---
eliaslevy commented on a change in pull request #6703:
eliaslevy commented on a change in pull request #6703: [FLINK-9697] Provide
connector for Kafka 2.0.0
URL: https://github.com/apache/flink/pull/6703#discussion_r223779984
##
File path: flink-connectors/flink-connector-kafka-2.0/pom.xml
##
@@ -0,0 +1,312 @@
+
+
eliaslevy commented on a change in pull request #6703: [FLINK-9697] Provide
connector for Kafka 2.0.0
URL: https://github.com/apache/flink/pull/6703#discussion_r223781101
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-10469.
-
Resolution: Fixed
Fixed via:
- master: 1e0a77959d27031048c1c4079a504274c82cc173
- release-1.6:
[
https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643685#comment-16643685
]
ASF GitHub Bot commented on FLINK-10469:
NicoK closed pull request #6788: [FLINK-10469][core]
NicoK closed pull request #6788: [FLINK-10469][core] make sure to always write
the whole buffer to FileChannel
URL: https://github.com/apache/flink/pull/6788
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
[
https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643673#comment-16643673
]
Nico Kruber commented on FLINK-10367:
-
As a rough sketch for option 3 (maybe this can be optimised):
[
https://issues.apache.org/jira/browse/FLINK-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643667#comment-16643667
]
Guibo Pan commented on FLINK-10441:
---
In RestServerEndpoint#createUploadDir, it seems that the
1 - 100 of 423 matches
Mail list logo