yanghua commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1
connectors
URL: https://github.com/apache/flink/pull/6577#issuecomment-430308313
As the PR #6703 is merged and closed, this PR seems to be able to close
directly. @aljoscha what do you think?
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652041#comment-16652041
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on issue #6703: [FLINK-9697] Provide
yanghua commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-430307620
@aljoscha Yes, I am happy to follow up on the documentation and strengthen
the testing of it. Considering that 1.7 is released soon, I
TisonKun created FLINK-10569:
Summary: Clean up uses of Scheduler and Instance in valid tests
Key: FLINK-10569
URL: https://issues.apache.org/jira/browse/FLINK-10569
Project: Flink
Issue Type:
xccui opened a new pull request #6861: [hotfix] [javadocs] Fix some single
quote problems
URL: https://github.com/apache/flink/pull/6861
## What is the purpose of the change
This PR fixed some Chinese single quote problems in docs.
[
https://issues.apache.org/jira/browse/FLINK-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652003#comment-16652003
]
ASF GitHub Bot commented on FLINK-9715:
---
kl0u commented on a change in pull request #6776:
kl0u commented on a change in pull request #6776: [FLINK-9715][table] Support
temporal join with event time
URL: https://github.com/apache/flink/pull/6776#discussion_r225606620
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651999#comment-16651999
]
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=16651997#comment-16651997
]
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=16651998#comment-16651998
]
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_r225604086
##
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_r225605353
##
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_r225604644
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651981#comment-16651981
]
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_r225603693
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651980#comment-16651980
]
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_r225603575
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651978#comment-16651978
]
ASF GitHub Bot commented on FLINK-9697:
---
aljoscha commented on issue #6703: [FLINK-9697] Provide
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651975#comment-16651975
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on a change in pull request #6483:
aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-430293083
I merged manually to master.
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651976#comment-16651976
]
ASF GitHub Bot commented on FLINK-9697:
---
aljoscha commented on issue #6703: [FLINK-9697] Provide
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651974#comment-16651974
]
Aljoscha Krettek commented on FLINK-9697:
-
Merged to master in
aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-430292958
Thanks a lot for iterating on this and coming up with a good solution in the
end, @yanghua!
And also thanks a lot to @eliaslevy
[
https://issues.apache.org/jira/browse/FLINK-10567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10567:
---
Labels: pull-request-available (was: )
> Lost serialize fields when ttl state store with
[
https://issues.apache.org/jira/browse/FLINK-10567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651971#comment-16651971
]
ASF GitHub Bot commented on FLINK-10567:
Aitozi opened a new pull request #6860:
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_r225602641
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9697.
---
Resolution: Fixed
Fix Version/s: 1.7.0
> Provide connector for modern Kafka
>
Aitozi opened a new pull request #6860: [FLINK-10567]Fix TtlStateSerializer
lost field during duplicate()
URL: https://github.com/apache/flink/pull/6860
## What is the purpose of the change
This PR is to fix the exception caused by the `TtlStateSerializer` lost the
fieldSerializer
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651966#comment-16651966
]
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_r225601083
##
File path:
Timo Walther created FLINK-10568:
Summary: Show correct time attributes when calling
Table.getSchema()
Key: FLINK-10568
URL: https://issues.apache.org/jira/browse/FLINK-10568
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651932#comment-16651932
]
ASF GitHub Bot commented on FLINK-4052:
---
asfgit closed pull request #6853: [FLINK-4052] using
[
https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-4052.
-
Resolution: Fixed
Merged in:
master: f195a6ed5c
> Unstable test ConnectionUtilsTest
>
asfgit closed pull request #6853: [FLINK-4052] using non-local unreachable
ip:port to fix unstable Test testReturnLocalHostAddressUsingHeuristics
URL: https://github.com/apache/flink/pull/6853
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is
aitozi created FLINK-10567:
--
Summary: Lost serialize fields when ttl state store with the
mutable serializer
Key: FLINK-10567
URL: https://issues.apache.org/jira/browse/FLINK-10567
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651871#comment-16651871
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10565.
--
Resolution: Fixed
Merged in:
master: 05a4789042
> Refactor SchedulerTestBase
>
[
https://issues.apache.org/jira/browse/FLINK-10565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651896#comment-16651896
]
ASF GitHub Bot commented on FLINK-10565:
asfgit closed pull request #6856: [FLINK-10565] [tests]
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651887#comment-16651887
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651891#comment-16651891
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651888#comment-16651888
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651880#comment-16651880
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651884#comment-16651884
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651889#comment-16651889
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651892#comment-16651892
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651885#comment-16651885
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651875#comment-16651875
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651876#comment-16651876
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651890#comment-16651890
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651867#comment-16651867
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651869#comment-16651869
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651886#comment-16651886
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651868#comment-16651868
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651893#comment-16651893
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua edited a comment on issue #6703: [FLINK-9697]
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651883#comment-16651883
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651873#comment-16651873
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651881#comment-16651881
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651879#comment-16651879
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651882#comment-16651882
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651874#comment-16651874
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651877#comment-16651877
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651872#comment-16651872
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651878#comment-16651878
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651870#comment-16651870
]
ASF GitHub Bot commented on FLINK-10134:
fhueske commented on a change in pull request #6823:
asfgit closed pull request #6856: [FLINK-10565] [tests] Refactor
SchedulerTestBase
URL: https://github.com/apache/flink/pull/6856
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 this is a
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225577966
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225581316
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225573745
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225580979
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
yanghua edited a comment on issue #6703: [FLINK-9697] Provide connector for
modern Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-430275036
Maybe we can create an umbrella issue on JIRA to track the unfinished work
around this PR. After it will be merged, I am also
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225548099
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225547565
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225534152
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225533378
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225543780
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225577009
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225534279
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225539582
##
File path:
flink-java/src/main/java/org/apache/flink/api/java/io/TextInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225479771
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225531993
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225574255
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225578428
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225577541
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225547062
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225543679
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225553146
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225567131
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225549931
##
File path:
flink-java/src/main/java/org/apache/flink/api/java/io/TextInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225568282
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225553773
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225579332
##
File path:
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java
fhueske commented on a change in pull request #6823: [FLINK-10134] UTF-16
support for TextInputFormat bug refixed
URL: https://github.com/apache/flink/pull/6823#discussion_r225532403
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651865#comment-16651865
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on issue #6703: [FLINK-9697] Provide
yanghua commented on issue #6703: [FLINK-9697] Provide connector for modern
Kafka
URL: https://github.com/apache/flink/pull/6703#issuecomment-430275036
Maybe we can create an umbrella issue on JIRA to track the unfinished work
around this PR. After it will be merged, I am also happy to
[
https://issues.apache.org/jira/browse/FLINK-10565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651864#comment-16651864
]
ASF GitHub Bot commented on FLINK-10565:
StefanRRichter commented on issue #6856: [FLINK-10565]
[
https://issues.apache.org/jira/browse/FLINK-10565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651863#comment-16651863
]
ASF GitHub Bot commented on FLINK-10565:
TisonKun commented on issue #6856: [FLINK-10565]
StefanRRichter commented on issue #6856: [FLINK-10565] [tests] Refactor
SchedulerTestBase
URL: https://github.com/apache/flink/pull/6856#issuecomment-430273752
Merging.
This is an automated message from the Apache Git
TisonKun commented on issue #6856: [FLINK-10565] [tests] Refactor
SchedulerTestBase
URL: https://github.com/apache/flink/pull/6856#issuecomment-430273615
The revert done. Thanks for your review @StefanRRichter !
This is an
[
https://issues.apache.org/jira/browse/FLINK-10565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651856#comment-16651856
]
ASF GitHub Bot commented on FLINK-10565:
StefanRRichter commented on issue #6856: [FLINK-10565]
StefanRRichter commented on issue #6856: [FLINK-10565] [tests] Refactor
SchedulerTestBase
URL: https://github.com/apache/flink/pull/6856#issuecomment-430271725
Ok, then I would suggest to just split that extraction for a later time and
take it stepwise. Thanks for your work!
101 - 200 of 452 matches
Mail list logo
