Ufuk Celebi created FLINK-4314:
--
Summary: Test instability in
JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown
Key: FLINK-4314
URL: https://issues.apache.org/jira/browse/FLINK-4314
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409194#comment-15409194
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2231#discussion_r73662520
--- Diff: flink-streaming-connectors/flink-connector-kafka-0.10/pom.xml ---
@@ -0,0 +1,179 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2231
@radekg One thing that's missing is update to the docs. You can find the
Kafka connector documentation at
`flink/docs/apis/streaming/connectors/kafka.md`. We'lll probably only need to
update the
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409192#comment-15409192
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409181#comment-15409181
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2231
Finished first review of the code.
Let me summarize parts of the Kafka 0.10 API that requires us to have a
separate module:
1. `ConsumerRecord` in 0.10 has a new
[
https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4173:
---
Fix Version/s: (was: 1.1.0)
> Replace maven-assembly-plugin by maven-shade-plugin in
[
https://issues.apache.org/jira/browse/FLINK-4265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4265:
---
Fix Version/s: (was: 1.1.0)
> Add a NoOpOperator
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4297:
---
Fix Version/s: (was: 1.1.0)
1.1.1
> Yarn client can't determine fat jar
[
https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409168#comment-15409168
]
ASF GitHub Bot commented on FLINK-4310:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2334
`flink-metrics-core` does not contain any annotations, so the plugin will
never fail here, right?
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-4104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4104:
---
Fix Version/s: (was: 1.1.0)
> Restructure Gelly docs
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4219.
--
Resolution: Fixed
Fix Version/s: (was: 1.1.0)
1.1.1
[
https://issues.apache.org/jira/browse/FLINK-4257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4257:
---
Fix Version/s: (was: 1.1.0)
> Handle delegating algorithm change of class
>
[
https://issues.apache.org/jira/browse/FLINK-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409164#comment-15409164
]
ASF GitHub Bot commented on FLINK-4219:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2253
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4047:
---
Fix Version/s: (was: 1.0.3)
(was: 1.1.0)
> Fix documentation about
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3950:
---
Fix Version/s: (was: 1.1.0)
> Add Meter Metric Type
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-3831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3831:
---
Fix Version/s: (was: 1.1.0)
> flink-streaming-java
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-3833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3833:
---
Fix Version/s: (was: 1.1.0)
> flink-test-utils
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-3832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3832:
---
Fix Version/s: (was: 1.1.0)
> flink-streaming-scala
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-3834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3834:
---
Fix Version/s: (was: 1.1.0)
> flink-statebackend-rocksdb
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-3830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3830:
---
Fix Version/s: (was: 1.1.0)
> flink-scala
> ---
>
> Key: FLINK-3830
>
[
https://issues.apache.org/jira/browse/FLINK-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3827:
---
Fix Version/s: (was: 1.1.0)
> Flink modules include unused dependencies
>
[
https://issues.apache.org/jira/browse/FLINK-3828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3828:
---
Fix Version/s: (was: 1.1.0)
> flink-runtime
> -
>
> Key: FLINK-3828
>
[
https://issues.apache.org/jira/browse/FLINK-3796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3796.
--
Resolution: Fixed
Fixed in d353895ba512a5e30fb08a25643fd93f085e8456 (FLINK-2314)
> FileSourceFunction
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3829:
---
Fix Version/s: (was: 1.1.0)
> flink-java
> --
>
> Key: FLINK-3829
>
[
https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3710:
---
Fix Version/s: (was: 1.1.0)
> ScalaDocs for org.apache.flink.streaming.scala are missing from the
[
https://issues.apache.org/jira/browse/FLINK-4102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4102:
---
Fix Version/s: (was: 1.1.0)
> Test failure with checkpoint barriers
>
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4094:
---
Fix Version/s: (was: 1.1.0)
> Off heap memory deallocation might not properly work
>
[
https://issues.apache.org/jira/browse/FLINK-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3690:
---
Fix Version/s: (was: 1.1.0)
> Create documentation on the new ResourceManager component
>
[
https://issues.apache.org/jira/browse/FLINK-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4039.
--
Resolution: Won't Fix
Fix Version/s: (was: 1.1.0)
> G1 garbage collector only set if no
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2231#discussion_r73656446
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409138#comment-15409138
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409063#comment-15409063
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2231#discussion_r73652372
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15408993#comment-15408993
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2231#discussion_r73648473
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@
Github user gallenvara commented on the issue:
https://github.com/apache/flink/pull/2282
@twalthr PR updated.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes
[
https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15408987#comment-15408987
]
ASF GitHub Bot commented on FLINK-3940:
---
Github user gallenvara commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15408958#comment-15408958
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2231#discussion_r73646737
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
101 - 143 of 143 matches
Mail list logo
