aljoscha commented on issue #6784: [FLINK-7811] Add support for Scala 2.12
URL: https://github.com/apache/flink/pull/6784#issuecomment-431645254
Also, we won't merge it like this but have to think about how to integrate
the Scala 2.12 build. This PR only builds Scala 2.12, for testing, with
[
https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658116#comment-16658116
]
ASF GitHub Bot commented on FLINK-7811:
---
aljoscha commented on issue #6784: [FLINK-
[
https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10599:
-
Component/s: Documentation
> Provide documentation for the modern kafka connector
>
[
https://issues.apache.org/jira/browse/FLINK-10609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658166#comment-16658166
]
Till Rohrmann commented on FLINK-10609:
---
This should also apply to the current mas
yanghua opened a new pull request #6889: [FLINK-10599][Documentation] Provide
documentation for the modern kafka connector
URL: https://github.com/apache/flink/pull/6889
## What is the purpose of the change
*This pull request provides documentation for the modern kafka connector*
[
https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658169#comment-16658169
]
ASF GitHub Bot commented on FLINK-10599:
yanghua opened a new pull request #6889
[
https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10599:
---
Labels: pull-request-available (was: )
> Provide documentation for the modern kafka connect
yanghua commented on issue #6889: [FLINK-10599][Documentation] Provide
documentation for the modern kafka connector
URL: https://github.com/apache/flink/pull/6889#issuecomment-431659542
Hi @aljoscha I provided a simple introduction and documentation for the
modern kafka connector. Consider
[
https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658171#comment-16658171
]
ASF GitHub Bot commented on FLINK-10599:
yanghua commented on issue #6889: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658177#comment-16658177
]
vinoyang commented on FLINK-10603:
--
The reason for this issue is due to the increase in
[
https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658177#comment-16658177
]
vinoyang edited comment on FLINK-10603 at 10/21/18 11:33 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658177#comment-16658177
]
vinoyang edited comment on FLINK-10603 at 10/21/18 11:34 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10603:
---
Labels: pull-request-available (was: )
> Reduce kafka test duration
> -
yanghua opened a new pull request #6890: [FLINK-10603] Reduce kafka test
duration
URL: https://github.com/apache/flink/pull/6890
## What is the purpose of the change
*This pull request reduces kafka test duration*
## Brief change log
- *Reduce kafka test duration*
[
https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658180#comment-16658180
]
ASF GitHub Bot commented on FLINK-10603:
yanghua opened a new pull request #6890
Till Rohrmann created FLINK-10622:
-
Summary: Add end-to-end test for time versioned joins
Key: FLINK-10622
URL: https://issues.apache.org/jira/browse/FLINK-10622
Project: Flink
Issue Type: Su
Till Rohrmann created FLINK-10623:
-
Summary: Extend streaming SQL end-to-end test to test
MATCH_RECOGNIZE
Key: FLINK-10623
URL: https://issues.apache.org/jira/browse/FLINK-10623
Project: Flink
Till Rohrmann created FLINK-10624:
-
Summary: Extend SQL client end-to-end to test new KafkaTableSink
Key: FLINK-10624
URL: https://issues.apache.org/jira/browse/FLINK-10624
Project: Flink
Iss
Till Rohrmann created FLINK-10625:
-
Summary: Add MATCH_RECOGNIZE documentation
Key: FLINK-10625
URL: https://issues.apache.org/jira/browse/FLINK-10625
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-10626:
-
Summary: Add documentation for time versioned joins
Key: FLINK-10626
URL: https://issues.apache.org/jira/browse/FLINK-10626
Project: Flink
Issue Type: Sub-
Till Rohrmann created FLINK-10627:
-
Summary: Extend test_streaming_file_sink to test S3 writer
Key: FLINK-10627
URL: https://issues.apache.org/jira/browse/FLINK-10627
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-10627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10627:
--
Description:
We should extend the {{test_streaming_file_sink.sh}} to test the new S3
recovera
Till Rohrmann created FLINK-10628:
-
Summary: Add end-to-end test for REST communication encryption
Key: FLINK-10628
URL: https://issues.apache.org/jira/browse/FLINK-10628
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658231#comment-16658231
]
Benoit MERIAUX commented on FLINK-2485:
---
Hi,
I did a quick search on usage of {code
[
https://issues.apache.org/jira/browse/FLINK-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658251#comment-16658251
]
Henry Saputra commented on FLINK-2485:
--
Agree. Will reduce the importance of this is
[
https://issues.apache.org/jira/browse/FLINK-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra updated FLINK-2485:
-
Priority: Minor (was: Major)
Description:
With potential Oracle will remove Java Unsafe[1
tillrohrmann commented on issue #6876: [FLINK-10251] Handle oversized response
messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#issuecomment-431698563
The problem is that you always try to serialize the result. However, it
should only be serialized if the sender is r
[
https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658356#comment-16658356
]
ASF GitHub Bot commented on FLINK-10251:
tillrohrmann commented on issue #6876:
[
https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658357#comment-16658357
]
Till Rohrmann commented on FLINK-10558:
---
I think in the future we might add a mini
[
https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658358#comment-16658358
]
ASF GitHub Bot commented on FLINK-10527:
tillrohrmann closed pull request #6816:
Till Rohrmann created FLINK-10629:
-
Summary:
FlinkKafkaProducerITCase.testFlinkKafkaProducer10FailTransactionCoordinatorBeforeNotify
failed on Travis
Key: FLINK-10629
URL: https://issues.apache.org/jira/browse/FL
tillrohrmann closed pull request #6816: [FLINK-10527] Cleanup constant
isNewMode in YarnTestBase
URL: https://github.com/apache/flink/pull/6816
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 t
[
https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10527.
---
Resolution: Fixed
Fix Version/s: 1.7.0
Fixed via
https://github.com/apache/flink/com
Till Rohrmann created FLINK-10630:
-
Summary: Update migration tests for Flink 1.6
Key: FLINK-10630
URL: https://issues.apache.org/jira/browse/FLINK-10630
Project: Flink
Issue Type: Task
Till Rohrmann created FLINK-10631:
-
Summary: Update jepsen tests to run with multiple slots
Key: FLINK-10631
URL: https://issues.apache.org/jira/browse/FLINK-10631
Project: Flink
Issue Type:
Till Rohrmann created FLINK-10632:
-
Summary: Run general purpose test job with failures in per-job mode
Key: FLINK-10632
URL: https://issues.apache.org/jira/browse/FLINK-10632
Project: Flink
Till Rohrmann created FLINK-10633:
-
Summary: End-to-end test: Prometheus reporter
Key: FLINK-10633
URL: https://issues.apache.org/jira/browse/FLINK-10633
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-10634:
-
Summary: End-to-end test: Metrics accessible via REST API
Key: FLINK-10634
URL: https://issues.apache.org/jira/browse/FLINK-10634
Project: Flink
Issue Type
Till Rohrmann created FLINK-10635:
-
Summary: End-to-end test: Take & resume from savepoint when using
per-job mode
Key: FLINK-10635
URL: https://issues.apache.org/jira/browse/FLINK-10635
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10624:
Assignee: vinoyang
> Extend SQL client end-to-end to test new KafkaTableSink
> --
[
https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658464#comment-16658464
]
vinoyang commented on FLINK-10624:
--
I created an umbrella issue FLINK-10598 to archive
[
https://issues.apache.org/jira/browse/FLINK-10630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10630:
Assignee: vinoyang
> Update migration tests for Flink 1.6
>
[
https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658470#comment-16658470
]
ASF GitHub Bot commented on FLINK-10603:
yanghua commented on issue #6890: [FLIN
yanghua commented on issue #6890: [FLINK-10603] Reduce kafka test duration
URL: https://github.com/apache/flink/pull/6890#issuecomment-431724328
I don't know why it seems that I can't update the PR and trigger Travis
(China). I don't know how long Github will work, but from the results of m
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10600:
Assignee: vinoyang
> Provide End-to-end test cases for modern Kafka connectors
>
dalongliu created FLINK-10636:
-
Summary: ERROR
org.apache.flink.shaded.curator.org.apache.curator.ConnectionState -
Authentication failed
Key: FLINK-10636
URL: https://issues.apache.org/jira/browse/FLINK-10636
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658496#comment-16658496
]
zhijiang commented on FLINK-10491:
--
[~till.rohrmann], I think it should be covered in F
isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault
tolerant for DataSource…
URL: https://github.com/apache/flink/pull/6684#issuecomment-431734239
Great discussion, thanks everybody.
@wenlong88, the scenario you mention is what i try to fix.
[here](https://
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658517#comment-16658517
]
ASF GitHub Bot commented on FLINK-10205:
isunjin commented on issue #6684: [
isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault
tolerant for DataSource…
URL: https://github.com/apache/flink/pull/6684#issuecomment-431734273
Great discussion, thanks everybody.
@wenlong88, the scenario you mention is what i try to fix.
[here](http
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658516#comment-16658516
]
ASF GitHub Bot commented on FLINK-10205:
isunjin commented on issue #6684: [
isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault
tolerant for DataSource…
URL: https://github.com/apache/flink/pull/6684#issuecomment-431735667
Great discussion, thanks everybody.
@wenlong88, the scenario you mention is what i try to fix.
[here](http
isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault
tolerant for DataSource…
URL: https://github.com/apache/flink/pull/6684#issuecomment-431735693
Great discussion, thanks everybody.
@wenlong88, the scenario you mention is what i try to fix.
[here](http
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658536#comment-16658536
]
ASF GitHub Bot commented on FLINK-10205:
isunjin commented on issue #6684: [
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658535#comment-16658535
]
ASF GitHub Bot commented on FLINK-10205:
isunjin commented on issue #6684: [
[
https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658543#comment-16658543
]
zhijiang edited comment on FLINK-9761 at 10/22/18 3:56 AM:
---
I j
[
https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658543#comment-16658543
]
zhijiang commented on FLINK-9761:
-
I just quickly reviewed the related codes and think th
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737413
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved your comme
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737461
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved your comme
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737435
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved your comme
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658549#comment-16658549
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483: [FL
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658550#comment-16658550
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483: [FL
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737481
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved your comme
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658551#comment-16658551
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483: [FL
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737523
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved your comme
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658552#comment-16658552
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483: [FL
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737558
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved your comme
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737590
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved your comme
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658553#comment-16658553
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483: [FL
HuangZhenQiu closed pull request #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483
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
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658556#comment-16658556
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483: [FL
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737642
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved your comme
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737615
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved your comme
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658558#comment-16658558
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483: [FL
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658557#comment-16658557
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu closed pull request #6483: [F
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658554#comment-16658554
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483: [FL
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658555#comment-16658555
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483: [FL
HuangZhenQiu removed a comment on issue #6483: [FLINK-7243][flink-formats] Add
parquet input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737590
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved yo
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658560#comment-16658560
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu removed a comment on issue #6
HuangZhenQiu removed a comment on issue #6483: [FLINK-7243][flink-formats] Add
parquet input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737481
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved yo
HuangZhenQiu removed a comment on issue #6483: [FLINK-7243][flink-formats] Add
parquet input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737435
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved yo
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658561#comment-16658561
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu removed a comment on issue #6
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658559#comment-16658559
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu removed a comment on issue #6
HuangZhenQiu removed a comment on issue #6483: [FLINK-7243][flink-formats] Add
parquet input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737413
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved yo
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658562#comment-16658562
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu removed a comment on issue #6
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet
input format
URL: https://github.com/apache/flink/pull/6483#issuecomment-431737854
@fhueske
Thanks for your patient review. It is pretty helpful to make the PR more
readable and flawless. Resolved your comme
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658563#comment-16658563
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu commented on issue #6483: [FL
HuangZhenQiu opened a new pull request #6483: [FLINK-7243][flink-formats] Add
parquet input format
URL: https://github.com/apache/flink/pull/6483
## What is the purpose of the change
This pull request is to create a ParquetInputFormat, so that Flink can
process files in Parquet sche
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658564#comment-16658564
]
ASF GitHub Bot commented on FLINK-7243:
---
HuangZhenQiu opened a new pull request #64
zhijiangW opened a new pull request #6891: [FLINK-10606][network][test]
Construct NetworkEnvironment simple for tests
URL: https://github.com/apache/flink/pull/6891
## What is the purpose of the change
*Implement a simple constructor for `NetworkEnvironment`, which can be
widely use
[
https://issues.apache.org/jira/browse/FLINK-10606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658611#comment-16658611
]
ASF GitHub Bot commented on FLINK-10606:
zhijiangW opened a new pull request #68
[
https://issues.apache.org/jira/browse/FLINK-10606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10606:
---
Labels: pull-request-available (was: )
> Construct NetworkEnvironment simple for tests
> --
zhijiangW opened a new pull request #6892: [FLINK-10607][network][test] Unify
to remove duplicated NoOpResultPartitionConsumableNotifier
URL: https://github.com/apache/flink/pull/6892
## What is the purpose of the change
*There are currently existing two same
`NoOpResultPartitionCon
[
https://issues.apache.org/jira/browse/FLINK-10607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10607:
---
Labels: pull-request-available (was: )
> Unify to remove duplicated NoOpResultPartitionCons
[
https://issues.apache.org/jira/browse/FLINK-10607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658662#comment-16658662
]
ASF GitHub Bot commented on FLINK-10607:
zhijiangW opened a new pull request #68
tzulitai commented on a change in pull request #6875: [FLINK-9808] [state
backends] Migrate state when necessary in state backends
URL: https://github.com/apache/flink/pull/6875#discussion_r226911417
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/ap
[
https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658664#comment-16658664
]
ASF GitHub Bot commented on FLINK-9808:
---
tzulitai commented on a change in pull req
[
https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658666#comment-16658666
]
Chesnay Schepler commented on FLINK-10634:
--
I don't believe this test to be nec
tzulitai commented on a change in pull request #6875: [FLINK-9808] [state
backends] Migrate state when necessary in state backends
URL: https://github.com/apache/flink/pull/6875#discussion_r226912089
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/ap
tzulitai commented on a change in pull request #6875: [FLINK-9808] [state
backends] Migrate state when necessary in state backends
URL: https://github.com/apache/flink/pull/6875#discussion_r226912034
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/ap
1 - 100 of 103 matches
Mail list logo
