Till Rohrmann created FLINK-4783:
Summary: Allow to register TypeInfoFactories manually
Key: FLINK-4783
URL: https://issues.apache.org/jira/browse/FLINK-4783
Project: Flink
Issue Type: Improv
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2594#discussion_r82562672
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -507,12 +509,18 @@ public void suspendJob(final Throwable
[
https://issues.apache.org/jira/browse/FLINK-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561660#comment-15561660
]
ASF GitHub Bot commented on FLINK-4738:
---
Github user tillrohrmann commented on a dif
Chesnay Schepler created FLINK-4784:
---
Summary: MetricQueryService actor name collision
Key: FLINK-4784
URL: https://issues.apache.org/jira/browse/FLINK-4784
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561665#comment-15561665
]
Timo Walther commented on FLINK-4783:
-
Stephan and I had a discussion about globally a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2594#discussion_r82563195
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateRegistryGateway.java
---
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561670#comment-15561670
]
ASF GitHub Bot commented on FLINK-4738:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561668#comment-15561668
]
ASF GitHub Bot commented on FLINK-4738:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2594#discussion_r82563262
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -127,12 +195,423 @@ public void start() {
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2603
+1 to merge
---
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
[
https://issues.apache.org/jira/browse/FLINK-4745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561681#comment-15561681
]
ASF GitHub Bot commented on FLINK-4745:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2562
Thanks for the update @twalthr.
I'll review #2595 first and continue with this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561690#comment-15561690
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2330
I'll propose to drop the hadoop1 builds on the dev ML.
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561703#comment-15561703
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2605
If no one is opposed to this, I would like to merge this later today...
---
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 pro
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2610
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561707#comment-15561707
]
ASF GitHub Bot commented on FLINK-4764:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561708#comment-15561708
]
ASF GitHub Bot commented on FLINK-4777:
---
Github user asfgit closed the pull request
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2610
Thanks, merged to `release-1.1` and `master`.
---
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
en
[
https://issues.apache.org/jira/browse/FLINK-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561712#comment-15561712
]
ASF GitHub Bot commented on FLINK-4777:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4777.
-
Resolution: Fixed
master: b949d42d9f16fe52126f03a960fdf23ad71e6e63
release-1.1: 7267562bb8
[
https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561732#comment-15561732
]
ASF GitHub Bot commented on FLINK-4450:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2439#discussion_r82567287
--- Diff:
flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java
---
@@ -186,15 +177,15 @@ public void testC
[
https://issues.apache.org/jira/browse/FLINK-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561753#comment-15561753
]
ASF GitHub Bot commented on FLINK-4738:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2594
Thank you for the review @KurtYoung. I've addressed your comments. I would
like to merge this PR soon, since other code changes depend on it.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-4745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561756#comment-15561756
]
ASF GitHub Bot commented on FLINK-4745:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2603
Thanks @fhueske. Will merge...
---
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 w
[
https://issues.apache.org/jira/browse/FLINK-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561763#comment-15561763
]
Timo Walther commented on FLINK-4108:
-
Actually, RowTypeInfo was intended for the Tabl
[
https://issues.apache.org/jira/browse/FLINK-4745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561780#comment-15561780
]
ASF GitHub Bot commented on FLINK-4745:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2603
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4745.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 5e30ba384934b08861a970744db64b5123cfeff8.
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561783#comment-15561783
]
Anton Mushin commented on FLINK-4604:
-
Do you mean check in
{{org.apache.flink.api.ta
Flavio Pompermaier created FLINK-4785:
-
Summary: Flink string parser doesn't handle string fields
containing double quotes
Key: FLINK-4785
URL: https://issues.apache.org/jira/browse/FLINK-4785
Pro
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2604
Why do you want to synchronize on the checkpoint lock when creating the
copy?
The `PeriodicOffsetCommitter` doesn't provide any reliability guarantees
anyways, so synchronizing doesn't add any a
[
https://issues.apache.org/jira/browse/FLINK-4753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561814#comment-15561814
]
ASF GitHub Bot commented on FLINK-4753:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561815#comment-15561815
]
Timo Walther commented on FLINK-4604:
-
Yes, I mean {{matches}}. {{DataSetAggregate}} d
Robert Metzger created FLINK-4786:
-
Summary: BarrierBufferTest test instability
Key: FLINK-4786
URL: https://issues.apache.org/jira/browse/FLINK-4786
Project: Flink
Issue Type: Bug
Affect
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2330
I disabled tests for the hadoop1 profile.
Will build the PR one more time and merge if everything passes.
---
If your project is set up for it, you can reply to this email and have your
reply ap
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561846#comment-15561846
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2541
Code looks good, but the build detected a break in binary compatibility.
Have a look at the Travis logs.
Changing the `createLocalEnvironment` to use an additional parameter with
default
[
https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4785:
-
Issue Type: Improvement (was: Bug)
> Flink string parser doesn't handle string fields containing
[
https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561853#comment-15561853
]
ASF GitHub Bot commented on FLINK-4669:
---
Github user StephanEwen commented on the is
Ufuk Celebi created FLINK-4787:
--
Summary: Add REST API call for cancel-with-savepoints
Key: FLINK-4787
URL: https://issues.apache.org/jira/browse/FLINK-4787
Project: Flink
Issue Type: Improvemen
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2595
Looks good @twalthr.
+1 to merge
---
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
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561915#comment-15561915
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2580#discussion_r82576069
--- 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-4776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4776.
-
Resolution: Done
Done in ed96cb53bfcbe96dd36248839ec4f2bffe60971b
> Move ExecutionGraph initializ
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561914#comment-15561914
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4786.
---
> BarrierBufferTest test instability
> --
>
> Key: FLINK-4
[
https://issues.apache.org/jira/browse/FLINK-4776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4776.
---
> Move ExecutionGraph initialization into a dedicated class
>
[
https://issues.apache.org/jira/browse/FLINK-4786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4786.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fix Version/s: 1.2.0
Fixed in 14e5ecb46c1
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2397
Yes, I'm still planning to merge it. I was sick the last few weeks, that's
why I didn't proceed. I'm hopefully okay now and I'll try to merge your change
today.
Thank you for rebasing it again.
[
https://issues.apache.org/jira/browse/FLINK-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561921#comment-15561921
]
ASF GitHub Bot commented on FLINK-4439:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561907#comment-15561907
]
ASF GitHub Bot commented on FLINK-3656:
---
Github user fhueske commented on the issue:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2580#discussion_r82577343
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@
Florian Koenig created FLINK-4788:
-
Summary: State backend class cannot be loaded, because fully
qualified name converted to lower-case
Key: FLINK-4788
URL: https://issues.apache.org/jira/browse/FLINK-4788
Github user gheo21 commented on the issue:
https://github.com/apache/flink/pull/2397
Hi @rmetzger,
Thanks for the update, np.
---
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 featur
[
https://issues.apache.org/jira/browse/FLINK-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561986#comment-15561986
]
ASF GitHub Bot commented on FLINK-4439:
---
Github user gheo21 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562063#comment-15562063
]
Fabian Hueske commented on FLINK-4781:
--
[~sunjincheng121] Can you check if the featur
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Evgeny Kincharov reassigned FLINK-3133:
---
Assignee: Evgeny Kincharov
> Introduce collect()/coun()/print() methods in DataStream
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2612#discussion_r82590833
--- Diff:
flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java
---
@@ -0,0 +1,106 @@
+package org.apach
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2612#discussion_r82590712
--- Diff:
flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java
---
@@ -0,0 +1,106 @@
+package org.apach
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2612#discussion_r82591567
--- Diff:
flink-batch-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroOutputFormat.java
---
@@ -36,6 +38,8 @@
private final Clas
[
https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562130#comment-15562130
]
ASF GitHub Bot commented on FLINK-4771:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562129#comment-15562129
]
ASF GitHub Bot commented on FLINK-4771:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2612#discussion_r82591316
--- Diff:
flink-batch-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroOutputFormat.java
---
@@ -36,6 +38,8 @@
private final Clas
[
https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562132#comment-15562132
]
ASF GitHub Bot commented on FLINK-4771:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562131#comment-15562131
]
ASF GitHub Bot commented on FLINK-4771:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4788:
Fix Version/s: 1.1.3
1.2.0
> State backend class cannot be loaded, because fully
[
https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562134#comment-15562134
]
Stephan Ewen commented on FLINK-4788:
-
Will look into this...
> State backend class c
[
https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-4788:
---
Assignee: Stephan Ewen
> State backend class cannot be loaded, because fully qualified name c
[
https://issues.apache.org/jira/browse/FLINK-4720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562177#comment-15562177
]
ASF GitHub Bot commented on FLINK-4720:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2577
Thanks for the pr @zentol. Looks good to me! A couple of things I noticed:
- The prefix of the interfaces (`Access*`) could be a bit confusing. What
about these?
- interface: `ExecutionGra
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2477#discussion_r82594396
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/CsvOutputFormatTest.java
---
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562187#comment-15562187
]
ASF GitHub Bot commented on FLINK-4506:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2612#discussion_r82594969
--- Diff:
flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java
---
@@ -0,0 +1,106 @@
+package org.apach
[
https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562188#comment-15562188
]
ASF GitHub Bot commented on FLINK-4771:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562191#comment-15562191
]
Anton Solovev commented on FLINK-4743:
--
Should a new function provide various types l
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2595
Merging
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562201#comment-15562201
]
ASF GitHub Bot commented on FLINK-4778:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2330
Merging
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562203#comment-15562203
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2611
Merging
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562200#comment-15562200
]
ASF GitHub Bot commented on FLINK-3656:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4155:
--
Comment: was deleted
(was: This issue has been resolved with FLINK-4379.)
> Get Kafka producer
[
https://issues.apache.org/jira/browse/FLINK-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562207#comment-15562207
]
Robert Metzger commented on FLINK-4155:
---
This issue has been resolved with FLINK-437
[
https://issues.apache.org/jira/browse/FLINK-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562211#comment-15562211
]
Robert Metzger commented on FLINK-4023:
---
This has been resolved in FLINK-4379.
> Mo
[
https://issues.apache.org/jira/browse/FLINK-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4023.
---
Resolution: Fixed
Assignee: Stefan Richter (was: Tzu-Li (Gordon) Tai)
> Move Kafka cons
[
https://issues.apache.org/jira/browse/FLINK-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562211#comment-15562211
]
Robert Metzger edited comment on FLINK-4023 at 10/10/16 12:48 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562226#comment-15562226
]
Stephan Ewen commented on FLINK-4788:
-
1.1.3 fix in d619f51ac8f922c0cf1d1e789c51410761
[
https://issues.apache.org/jira/browse/FLINK-4720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562237#comment-15562237
]
ASF GitHub Bot commented on FLINK-4720:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2577
I did not want to rename all usages of ExecutionGraph, correct. Otherwise i
would've went with exactly the names you suggested.
I am using the ExecutionConfigSummary (and removed my original
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2545#discussion_r82598976
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -675,38 +673,6 @@ else if (isClassType(t) &&
Tuple.class.is
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2577
>I am using the ExecutionConfigSummary (and removed my original
ArchivedExecutionConfig) when i rebased, so I'm not sure what you mean :/
That's what I meant, I wondered why you didn't use your a
[
https://issues.apache.org/jira/browse/FLINK-4673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562254#comment-15562254
]
ASF GitHub Bot commented on FLINK-4673:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562255#comment-15562255
]
ASF GitHub Bot commented on FLINK-4720:
---
Github user mxm commented on the issue:
Robert Metzger created FLINK-4789:
-
Summary: Avoid Kafka partition discovery on restore and share
consumer instance for discovery and data consumption
Key: FLINK-4789
URL: https://issues.apache.org/jira/browse/FLI
[
https://issues.apache.org/jira/browse/FLINK-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562288#comment-15562288
]
Alexander Alexandrov commented on FLINK-4783:
-
Alright, I guess keeping {{Type
[
https://issues.apache.org/jira/browse/FLINK-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562288#comment-15562288
]
Alexander Alexandrov edited comment on FLINK-4783 at 10/10/16 1:18 PM:
-
1 - 100 of 173 matches
Mail list logo
