[
https://issues.apache.org/jira/browse/FLINK-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621519#comment-16621519
]
Kostas Kloudas commented on FLINK-10373:
Hi [~zhenhua]. Isn't this the same as
[
https://issues.apache.org/jira/browse/FLINK-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9924:
--
Description:
zookeeper 3.4.13 is being released.
ZOOKEEPER-2959 fixes data loss when observer is used
huangzhenhua created FLINK-10373:
Summary: CoGroup Window support lateness
Key: FLINK-10373
URL: https://issues.apache.org/jira/browse/FLINK-10373
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621468#comment-16621468
]
Shimin Yang commented on FLINK-10245:
-
Hi [~hequn8128], I have updated the document, we can discuss
Elias Levy created FLINK-10372:
--
Summary: There is no API to configure the timer state backend
Key: FLINK-10372
URL: https://issues.apache.org/jira/browse/FLINK-10372
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621229#comment-16621229
]
ASF GitHub Bot commented on FLINK-8424:
---
bmeriaux commented on a change in pull request #6715:
bmeriaux commented on a change in pull request #6715: FLINK-8424: update
cassandra and driver version to latest
URL: https://github.com/apache/flink/pull/6715#discussion_r218969992
##
File path: flink-connectors/flink-connector-cassandra/pom.xml
##
@@ -37,8 +37,8 @@ under
[
https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16619847#comment-16619847
]
Fabian Hueske edited comment on FLINK-10079 at 9/19/18 8:01 PM:
Fixed
[
https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reopened FLINK-10079:
---
> Automatically register sink table from external catalogs
>
[
https://issues.apache.org/jira/browse/FLINK-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16619867#comment-16619867
]
Fabian Hueske edited comment on FLINK-10259 at 9/19/18 8:00 PM:
Fixed
[
https://issues.apache.org/jira/browse/FLINK-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reopened FLINK-10259:
---
> Key validation for GroupWindowAggregate is broken
>
[
https://issues.apache.org/jira/browse/FLINK-10332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-10332.
-
Resolution: Fixed
Fix Version/s: 1.5.5
1.6.2
1.7.0
[
https://issues.apache.org/jira/browse/FLINK-10331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-10331.
-
Resolution: Fixed
Fix Version/s: 1.5.5
1.6.2
1.7.0
TisonKun commented on issue #6716: [hotfix] [yarn-test] Clean up inactive test
URL: https://github.com/apache/flink/pull/6716#issuecomment-422914196
FYI, Travis fails on legacy test `JobManagerFailsTest`.
This is an automated
satybald commented on a change in pull request #6706: [hotfix][doc] Fix curl
example in upload jar example
URL: https://github.com/apache/flink/pull/6706#discussion_r218899758
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620859#comment-16620859
]
ASF GitHub Bot commented on FLINK-10134:
XuQianJin-Stars commented on issue #6710: [FLINK-10134]
XuQianJin-Stars commented on issue #6710: [FLINK-10134] UTF-16 support for
TextInputFormat bug fixed
URL: https://github.com/apache/flink/pull/6710#issuecomment-422881621
> Hi @XuQianJin-Stars , thanks for your PR. Could you rebase your commits?
@Clark Thank you. I have re
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620832#comment-16620832
]
ASF GitHub Bot commented on FLINK-10358:
yxu-valleytider commented on issue #6708:
yxu-valleytider commented on issue #6708: [FLINK-10358][Kinesis-connector] fix
NPE in case millisBehindLatest is null
URL: https://github.com/apache/flink/pull/6708#issuecomment-422874733
@mxm We do plan to contribute the efforts of consuming from dynamodb
streams (Flink-4582) back to
[
https://issues.apache.org/jira/browse/FLINK-10265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620773#comment-16620773
]
vinoyang commented on FLINK-10265:
--
[~twalthr] any opinion and suggestion?
> Configure checkpointing
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620770#comment-16620770
]
ASF GitHub Bot commented on FLINK-9891:
---
GJL commented on a change in pull request #6718:
GJL commented on a change in pull request #6718: [FLINK-9891] Add optional hook
to shutdown cluster if a session was created in per-job mode in attached mode
URL: https://github.com/apache/flink/pull/6718#discussion_r218859953
##
File path: docs/ops/cli.md
##
@@ -265,6
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620758#comment-16620758
]
ASF GitHub Bot commented on FLINK-9891:
---
GJL commented on a change in pull request #6718:
[
https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620756#comment-16620756
]
ASF GitHub Bot commented on FLINK-10157:
azagrebin commented on a change in pull request #6707:
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620755#comment-16620755
]
ASF GitHub Bot commented on FLINK-9891:
---
GJL commented on a change in pull request #6718:
GJL commented on a change in pull request #6718: [FLINK-9891] Add optional hook
to shutdown cluster if a session was created in per-job mode in attached mode
URL: https://github.com/apache/flink/pull/6718#discussion_r218853732
##
File path:
azagrebin commented on a change in pull request #6707: [FLINK-10157] [State
TTL] Allow `null` user values in map state with TTL
URL: https://github.com/apache/flink/pull/6707#discussion_r218853515
##
File path:
GJL commented on a change in pull request #6718: [FLINK-9891] Add optional hook
to shutdown cluster if a session was created in per-job mode in attached mode
URL: https://github.com/apache/flink/pull/6718#discussion_r218853427
##
File path: docs/ops/cli.md
##
@@ -257,6
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620750#comment-16620750
]
ASF GitHub Bot commented on FLINK-9891:
---
azagrebin commented on issue #6718: [FLINK-9891] Add
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620752#comment-16620752
]
ASF GitHub Bot commented on FLINK-9891:
---
azagrebin edited a comment on issue #6718: [FLINK-9891]
azagrebin edited a comment on issue #6718: [FLINK-9891] Add optional hook to
shutdown cluster if a session was created in per-job mode in attached mode
URL: https://github.com/apache/flink/pull/6718#issuecomment-422847652
cc @tillrohrmann @GJL @packet23
azagrebin commented on issue #6718: [FLINK-9891] Add optional hook to shutdown
cluster if a session was created in per-job mode in attached mode
URL: https://github.com/apache/flink/pull/6718#issuecomment-422847652
cc @tillrohrmann @GJL
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620749#comment-16620749
]
ASF GitHub Bot commented on FLINK-9891:
---
azagrebin opened a new pull request #6718: [FLINK-9891]
[
https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-10309:
Assignee: Gary Yao
> Cancel flink job occurs java.net.ConnectException
>
azagrebin opened a new pull request #6718: [FLINK-9891] Add optional hook to
shutdown cluster if a session was created in per-job mode in attached mode
URL: https://github.com/apache/flink/pull/6718
## What is the purpose of the change
This PR picks up #6540, adds a cli option to
[
https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620743#comment-16620743
]
Pierre Zemb commented on FLINK-10225:
-
Hi! I've been reading the code a bit, and I have a question.
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620643#comment-16620643
]
lihongli commented on FLINK-10355:
--
[~hequn8128] I insert a wrong row into oracle.It prints the whole
[
https://issues.apache.org/jira/browse/FLINK-10369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620635#comment-16620635
]
ASF GitHub Bot commented on FLINK-10369:
TisonKun commented on issue #6717: [FLINK-10369][tests]
TisonKun commented on issue #6717: [FLINK-10369][tests] Enable YARNITCase to
test per job mode deployment
URL: https://github.com/apache/flink/pull/6717#issuecomment-422816984
Attach the NoDataSource solution.
[patch.txt](https://github.com/apache/flink/files/2397364/patch.txt) diff
Johannes Dillmann created FLINK-10371:
-
Summary: Allow to enable SSL mutual authentication on REST
endpoints by configuration
Key: FLINK-10371
URL: https://issues.apache.org/jira/browse/FLINK-10371
[
https://issues.apache.org/jira/browse/FLINK-10369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620616#comment-16620616
]
ASF GitHub Bot commented on FLINK-10369:
TisonKun commented on a change in pull request #6717:
[
https://issues.apache.org/jira/browse/FLINK-10369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620615#comment-16620615
]
ASF GitHub Bot commented on FLINK-10369:
TisonKun commented on a change in pull request #6717:
TisonKun commented on a change in pull request #6717: [FLINK-10369][tests]
Enable YARNITCase to test per job mode deployment
URL: https://github.com/apache/flink/pull/6717#discussion_r218805970
##
File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java
TisonKun commented on a change in pull request #6717: [FLINK-10369][tests]
Enable YARNITCase to test per job mode deployment
URL: https://github.com/apache/flink/pull/6717#discussion_r218803183
##
File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java
[
https://issues.apache.org/jira/browse/FLINK-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-10370:
-
Component/s: Cluster Management
> DistributedCache does not work in job cluster mode.
>
[
https://issues.apache.org/jira/browse/FLINK-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620590#comment-16620590
]
Dawid Wysakowicz commented on FLINK-10370:
--
I have also some additional concerns regarding job
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620586#comment-16620586
]
ASF GitHub Bot commented on FLINK-10358:
tweise commented on issue #6708:
tweise commented on issue #6708: [FLINK-10358][Kinesis-connector] fix NPE in
case millisBehindLatest is null
URL: https://github.com/apache/flink/pull/6708#issuecomment-422805054
Looks like it confirms to the spec (the field is not provided for dynamodb
streams - wouldn't make sense
[
https://issues.apache.org/jira/browse/FLINK-10369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10369:
---
Labels: pull-request-available (was: )
> Enable YARNITCase
> -
>
>
TisonKun edited a comment on issue #6716: [hotfix] [yarn-test] Clean up
inactive test
URL: https://github.com/apache/flink/pull/6716#issuecomment-422799861
Ok, it is just `TestingYarnClusterDescriptor.TestJarFinder` which is a util
class, we can move it out of
TisonKun commented on issue #6716: [hotfix] [yarn-test] Clean up inactive test
URL: https://github.com/apache/flink/pull/6716#issuecomment-422799861
Ok, it is just `TestingYarnClusterDescriptor.TestJarFinder` which is a util
class, we can move it out of `TestingYarnClusterDescriptor`
[
https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620561#comment-16620561
]
Till Rohrmann commented on FLINK-9646:
--
Another instance:
Dawid Wysakowicz created FLINK-10370:
Summary: DistributedCache does not work in job cluster mode.
Key: FLINK-10370
URL: https://issues.apache.org/jira/browse/FLINK-10370
Project: Flink
TisonKun commented on issue #6716: [hotfix] [yarn-test] Clean up inactive test
URL: https://github.com/apache/flink/pull/6716#issuecomment-422799453
@tillrohrmann sure but I notice that it relies on
`TestingYarnClusterDescriptor` which inherited from
`LegacyYarnClusterDescriptor`. I see
[
https://issues.apache.org/jira/browse/FLINK-10369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620553#comment-16620553
]
ASF GitHub Bot commented on FLINK-10369:
tillrohrmann opened a new pull request #6717:
tillrohrmann commented on issue #6716: [hotfix] [yarn-test] Clean up inactive
test
URL: https://github.com/apache/flink/pull/6716#issuecomment-422798581
Thanks for opening this PR @TisonKun. The `YarnITCase` is actually not using
the legacy mode but the Flip-6 code path. Instead of
tillrohrmann opened a new pull request #6717: [FLINK-10369][tests] Enable
YARNITCase to test per job mode deployment
URL: https://github.com/apache/flink/pull/6717
## What is the purpose of the change
Enable YARNITCase to test per job mode deployment.
## Verifying this change
[
https://issues.apache.org/jira/browse/FLINK-10369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-10369:
-
Assignee: Till Rohrmann
> Enable YARNITCase
> -
>
>
Till Rohrmann created FLINK-10369:
-
Summary: Enable YARNITCase
Key: FLINK-10369
URL: https://issues.apache.org/jira/browse/FLINK-10369
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620532#comment-16620532
]
ASF GitHub Bot commented on FLINK-10050:
EugeneYushin commented on issue #6646: [FLINK-10050]
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620530#comment-16620530
]
ASF GitHub Bot commented on FLINK-10355:
lihongliustc commented on issue #6713:
lihongliustc commented on issue #6713: [FLINK-10355][table]the order of the
columns start from 1
URL: https://github.com/apache/flink/pull/6713#issuecomment-422789369
@fhueske Thank you very much.I will continue to work hard to contribute to
the community.
EugeneYushin commented on issue #6646: [FLINK-10050] Support allowedLateness in
CoGroupedStreams
URL: https://github.com/apache/flink/pull/6646#issuecomment-422789390
Nice, CI checks have been passed. I think I have no access to Travis to
relaunch builds (at least, I don't see any button
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620520#comment-16620520
]
ASF GitHub Bot commented on FLINK-10355:
lihongliustc commented on a change in pull request
lihongliustc commented on a change in pull request #6713:
[FLINK-10355][table]the order of the columns start from 1
URL: https://github.com/apache/flink/pull/6713#discussion_r218782806
##
File path:
flink-java/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java
[
https://issues.apache.org/jira/browse/FLINK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620511#comment-16620511
]
陈梓立 commented on FLINK-10320:
-
We have some cases when our customers set parallelism to over 10,000 because
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620506#comment-16620506
]
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 Kafka 2.0.0
URL: https://github.com/apache/flink/pull/6703#issuecomment-422778285
@pnowojski If we don't consider the failed test case, then this PR applies
to both Kafka client 1.0 and kafka client 2.0. Basically it also
[
https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620503#comment-16620503
]
ASF GitHub Bot commented on FLINK-8424:
---
yanghua commented on a change in pull request #6715:
yanghua commented on a change in pull request #6715: FLINK-8424: update
cassandra and driver version to latest
URL: https://github.com/apache/flink/pull/6715#discussion_r218775890
##
File path: flink-connectors/flink-connector-cassandra/pom.xml
##
@@ -37,8 +37,8 @@ under
[
https://issues.apache.org/jira/browse/FLINK-10324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10324.
-
Resolution: Fixed
Fixed via e7ac3ba7dfcb90c21025def2bf4112b108d21afd
> Replace
TisonKun opened a new pull request #6716: [hotfix] [yarn-test] Clean up
inactive test
URL: https://github.com/apache/flink/pull/6716
## What is the purpose of the change
1. YARNITCase is @Ignore
2. YARNHighAvailabilityITCase only run on legacy mode, which is inactive
during
[
https://issues.apache.org/jira/browse/FLINK-10324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620497#comment-16620497
]
ASF GitHub Bot commented on FLINK-10324:
tillrohrmann closed pull request #6681: [FLINK-10324]
tillrohrmann closed pull request #6681: [FLINK-10324] Replace
ZooKeeperStateHandleStore#getAllSortedByNameAndLock by getAllAndLock
URL: https://github.com/apache/flink/pull/6681
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed
Till Rohrmann created FLINK-10368:
-
Summary: 'Kerberized YARN on Docker test' instable
Key: FLINK-10368
URL: https://issues.apache.org/jira/browse/FLINK-10368
Project: Flink
Issue Type: Bug
GJL commented on issue #6667: [hotfix][docs] Fix error typo in
CheckpointedFunction
URL: https://github.com/apache/flink/pull/6667#issuecomment-422770556
@lamber-ken Do you want to address the comments?
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-10332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620483#comment-16620483
]
ASF GitHub Bot commented on FLINK-10332:
NicoK closed pull request #6693: [FLINK-10332][network]
NicoK closed pull request #6693: [FLINK-10332][network] move data notification
out of the synchronized block
URL: https://github.com/apache/flink/pull/6693
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-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620472#comment-16620472
]
ASF GitHub Bot commented on FLINK-8799:
---
yanghua closed pull request #5617: [FLINK-8799][YARN] Make
[
https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620471#comment-16620471
]
ASF GitHub Bot commented on FLINK-8799:
---
yanghua commented on issue #5617: [FLINK-8799][YARN] Make
yanghua commented on issue #5617: [FLINK-8799][YARN] Make
AbstractYarnClusterDescriptor immutable
URL: https://github.com/apache/flink/pull/5617#issuecomment-422764603
@GJL OK, closing this PR.
This is an automated message
yanghua closed pull request #5617: [FLINK-8799][YARN] Make
AbstractYarnClusterDescriptor immutable
URL: https://github.com/apache/flink/pull/5617
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:
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620456#comment-16620456
]
ASF GitHub Bot commented on FLINK-10050:
kl0u commented on issue #6646: [FLINK-10050] Support
kl0u commented on issue #6646: [FLINK-10050] Support allowedLateness in
CoGroupedStreams
URL: https://github.com/apache/flink/pull/6646#issuecomment-422757135
I would recommend to relaunch that specific build and see if it happens
again.
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620450#comment-16620450
]
ASF GitHub Bot commented on FLINK-10050:
EugeneYushin commented on issue #6646: [FLINK-10050]
EugeneYushin commented on issue #6646: [FLINK-10050] Support allowedLateness in
CoGroupedStreams
URL: https://github.com/apache/flink/pull/6646#issuecomment-422754323
I see one build from Travis has been finished with error:
```
10:15:13.087 [ERROR] Failed to execute goal on project
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620439#comment-16620439
]
ASF GitHub Bot commented on FLINK-10355:
fhueske commented on a change in pull request #6713:
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620438#comment-16620438
]
ASF GitHub Bot commented on FLINK-10355:
fhueske commented on a change in pull request #6713:
fhueske commented on a change in pull request #6713: [FLINK-10355][table]the
order of the columns start from 1
URL: https://github.com/apache/flink/pull/6713#discussion_r218750490
##
File path:
flink-java/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java
fhueske commented on a change in pull request #6713: [FLINK-10355][table]the
order of the columns start from 1
URL: https://github.com/apache/flink/pull/6713#discussion_r218750570
##
File path:
flink-java/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java
[
https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620435#comment-16620435
]
ASF GitHub Bot commented on FLINK-10050:
EugeneYushin commented on issue #6646: [FLINK-10050]
[
https://issues.apache.org/jira/browse/FLINK-10331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620434#comment-16620434
]
ASF GitHub Bot commented on FLINK-10331:
NicoK closed pull request #6692: [FLINK-10331][network]
EugeneYushin commented on issue #6646: [FLINK-10050] Support allowedLateness in
CoGroupedStreams
URL: https://github.com/apache/flink/pull/6646#issuecomment-422746729
@kl0u I didn't want to ping you until Travis is finished.
Thanks for quick turnaround
NicoK closed pull request #6692: [FLINK-10331][network] reduce unnecesary
flushing
URL: https://github.com/apache/flink/pull/6692
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
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620432#comment-16620432
]
ASF GitHub Bot commented on FLINK-9061:
---
StephanEwen commented on issue #6604: [FLINK-9061]
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620433#comment-16620433
]
ASF GitHub Bot commented on FLINK-9061:
---
StephanEwen closed pull request #6604: [FLINK-9061]
StephanEwen commented on issue #6604: [FLINK-9061] Optionally add entropy to
checkpoint paths better S3 scalability
URL: https://github.com/apache/flink/pull/6604#issuecomment-422746118
Fixed for 1.6 in a58fa985c4944dd0cf39fa622ec0aa4b35f21f44
For master, I will open a new PR that
StephanEwen closed pull request #6604: [FLINK-9061] Optionally add entropy to
checkpoint paths better S3 scalability
URL: https://github.com/apache/flink/pull/6604
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake
[
https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16620412#comment-16620412
]
ASF GitHub Bot commented on FLINK-8424:
---
bmeriaux commented on issue #6715: FLINK-8424: update
bmeriaux commented on issue #6715: FLINK-8424: update cassandra and driver
version to latest
URL: https://github.com/apache/flink/pull/6715#issuecomment-422742511
i was a little lost on what part to keep and what to remove, is it fine now ?
i saw both kinesis kinesis failed, i'm looking
1 - 100 of 163 matches
Mail list logo
