[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658865#comment-15658865
]
ASF GitHub Bot commented on FLINK-4449:
---
GitHub user beyond1920 opened a pull request:
GitHub user beyond1920 opened a pull request:
https://github.com/apache/flink/pull/2791
[FLINK-4449] [cluster management] add Heartbeat manager in ResourceManager
with TaskExecutor
This pr aims to add Heartbeat manager in ResourceManager with TaskExecutor.
This pr focused on
[
https://issues.apache.org/jira/browse/FLINK-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658851#comment-15658851
]
ASF GitHub Bot commented on FLINK-4653:
---
Github user beyond1920 closed the pull request at:
Github user beyond1920 closed the pull request at:
https://github.com/apache/flink/pull/2524
---
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-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658797#comment-15658797
]
Robert Metzger commented on FLINK-5013:
---
Thanks a lot for looking into the issue Gordon. Great work!
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658507#comment-15658507
]
ASF GitHub Bot commented on FLINK-4900:
---
Github user EronWright commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658506#comment-15658506
]
ASF GitHub Bot commented on FLINK-4900:
---
Github user EronWright commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658508#comment-15658508
]
ASF GitHub Bot commented on FLINK-4900:
---
Github user EronWright commented on a diff in the pull
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2703#discussion_r87674266
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
---
@@ -601,6 +601,54 @@ else if
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2703#discussion_r87674387
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
---
@@ -601,6 +601,54 @@ else if
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2703#discussion_r87673973
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -489,6 +489,29 @@
*/
public static final
[
https://issues.apache.org/jira/browse/FLINK-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658408#comment-15658408
]
Dan Bress commented on FLINK-1275:
--
I am running Flink in an environment where CPUs are cheap and network
[
https://issues.apache.org/jira/browse/FLINK-4647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-4647:
-
Assignee: Ivan Mushketyk
> Implement BipartiteGraph reader
>
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658348#comment-15658348
]
Dan Bress commented on FLINK-4460:
--
I would like to see WindowedStream make use of this feature for late
[
https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658192#comment-15658192
]
ASF GitHub Bot commented on FLINK-3680:
---
Github user iampeter commented on a diff in the pull
Github user iampeter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2457#discussion_r87659296
--- Diff:
flink-runtime-web/web-dashboard/app/scripts/modules/jobs/jobs.dir.coffee ---
@@ -281,7 +281,8 @@ angular.module('flinkApp')
#
Github user iampeter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2467#discussion_r87658530
--- Diff:
flink-runtime-web/web-dashboard/app/scripts/modules/jobs/jobs.dir.coffee ---
@@ -168,14 +168,15 @@ angular.module('flinkApp')
return
[
https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658180#comment-15658180
]
ASF GitHub Bot commented on FLINK-3719:
---
Github user iampeter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658085#comment-15658085
]
ASF GitHub Bot commented on FLINK-4521:
---
Github user iampeter commented on the issue:
Github user iampeter commented on the issue:
https://github.com/apache/flink/pull/2431
@mushketyk looks good, thanks.
---
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
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2787
I've actually found out the reason for
`HttpConnectionParams.setSoKeepalive` error, noted in the last comment in JIRA.
Cross-posting it here so we don't need to jump around two places:
It
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657832#comment-15657832
]
ASF GitHub Bot commented on FLINK-5013:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657722#comment-15657722
]
ASF GitHub Bot commented on FLINK-5013:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2787
One thought on the `HttpConnectionParams.setSoKeepalive` - we had issues
with Hadoop pulling in a wrong version of that class.
I think we shaded it in Flink's Hadoop dependency, but it might
[
https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657704#comment-15657704
]
Tzu-Li (Gordon) Tai edited comment on FLINK-3123 at 11/11/16 6:18 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657704#comment-15657704
]
Tzu-Li (Gordon) Tai edited comment on FLINK-3123 at 11/11/16 6:18 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657704#comment-15657704
]
Tzu-Li (Gordon) Tai commented on FLINK-3123:
Hi [~juho.autio.r],
{quote}
My use case is
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657432#comment-15657432
]
Anton Solovev edited comment on FLINK-3848 at 11/11/16 5:59 PM:
I have a
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657653#comment-15657653
]
ASF GitHub Bot commented on FLINK-5048:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657652#comment-15657652
]
ASF GitHub Bot commented on FLINK-5048:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657656#comment-15657656
]
ASF GitHub Bot commented on FLINK-5048:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657655#comment-15657655
]
ASF GitHub Bot commented on FLINK-5048:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657657#comment-15657657
]
ASF GitHub Bot commented on FLINK-5048:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657654#comment-15657654
]
ASF GitHub Bot commented on FLINK-5048:
---
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/2789#discussion_r87621040
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2789#discussion_r87625136
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java
---
@@ -0,0
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2789#discussion_r87626228
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2789#discussion_r87624670
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java
---
@@ -0,0
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2789#discussion_r87621534
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java
---
@@ -0,0
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2789#discussion_r87621606
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657432#comment-15657432
]
Anton Solovev commented on FLINK-3848:
--
I have a question about type info, it looks like one int
[
https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657408#comment-15657408
]
ASF GitHub Bot commented on FLINK-4491:
---
GitHub user ddolzan opened a pull request:
GitHub user ddolzan opened a pull request:
https://github.com/apache/flink/pull/2790
[FLINK-4491] Handle index.number_of_shards in the ES connector
Implemented the Index Template and Index Mapping creation.
Number of shards and many other properties can be defined in the Index
Kostas Kloudas created FLINK-5056:
-
Summary: BucketingSink deletes valid data when checkpoint
notification is slow.
Key: FLINK-5056
URL: https://issues.apache.org/jira/browse/FLINK-5056
Project:
[
https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657244#comment-15657244
]
Juho Autio commented on FLINK-3123:
---
Nice one, looking forward to this!
{quote}
If a subscribed
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2785
Okay, if that is the case, then we should probably simply remove the "test
timer sorting" test and note down that this does not give any guarantees on the
order of timers.
@BorisOsipov
[
https://issues.apache.org/jira/browse/FLINK-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657226#comment-15657226
]
ASF GitHub Bot commented on FLINK-5006:
---
Github user StephanEwen commented on the issue:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2789
[FLINK-5048] [Kafka Consumer] Change thread model of FlinkKafkaConsumer to
better handel shutdown/interrupt situations
**NOTE:** Only the second commit is relevant, the first commit only
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657219#comment-15657219
]
ASF GitHub Bot commented on FLINK-5048:
---
GitHub user StephanEwen opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657184#comment-15657184
]
Vijay Srinivasaraghavan commented on FLINK-5055:
Flink security context gets initialized
[
https://issues.apache.org/jira/browse/FLINK-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657138#comment-15657138
]
ASF GitHub Bot commented on FLINK-5006:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2785
@StephanEwen It's used to drive the automatic watermark generation and the
inactivity timer in the `BucketingSink`, but those are cases where the order
doesn't matter.
---
If your project is set
Till Rohrmann created FLINK-5055:
Summary: Security feature crashes JM for certain Hadoop versions
even though using no Kerberos
Key: FLINK-5055
URL: https://issues.apache.org/jira/browse/FLINK-5055
[
https://issues.apache.org/jira/browse/FLINK-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657114#comment-15657114
]
ASF GitHub Bot commented on FLINK-5006:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2785
@aljoscha Okay, if that is the only thing that we use it for, then order is
indeed not important for that service. Are we sure it is not used in other
places?
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657101#comment-15657101
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user gaborhermann commented on the issue:
Github user gaborhermann commented on the issue:
https://github.com/apache/flink/pull/2542
Thank you @thvasilo for your thorough review :)
@mbalassi I think this PR is ready to merge. Could you do a review when you
have some time?
---
If your project is set up for it, you
Github user gaborhermann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2542#discussion_r87588061
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala
---
@@ -675,7 +756,69 @@ object ALS {
[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657084#comment-15657084
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user gaborhermann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657076#comment-15657076
]
ASF GitHub Bot commented on FLINK-5006:
---
Github user aljoscha commented on the issue:
Github user gaborhermann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2542#discussion_r87587473
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala
---
@@ -273,6 +308,14 @@ object ALS {
val
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2785
@StephanEwen I think it's not a problem that these physical, low-level
timers don't fire in order of their timestamp because the ordering of timers is
maintained in the implementation of
[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657073#comment-15657073
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user gaborhermann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5054:
Description:
Aims at integrating the BucketingSink with the rescalable state
abstractions
[
https://issues.apache.org/jira/browse/FLINK-5021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657059#comment-15657059
]
ASF GitHub Bot commented on FLINK-5021:
---
Github user kl0u closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-5021.
-
Resolution: Fixed
> Makes the ContinuousFileReaderOperator rescalable.
>
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/2763
---
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-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657042#comment-15657042
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5013 at 11/11/16 1:15 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657045#comment-15657045
]
ASF GitHub Bot commented on FLINK-5021:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2763
I merged this, thanks for your work! ð
Could you please close this PR and the Jira issue?
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657042#comment-15657042
]
Tzu-Li (Gordon) Tai commented on FLINK-5013:
Update:
I've found the problem with the
Kostas Kloudas created FLINK-5054:
-
Summary: Make the BucketingSink rescalable.
Key: FLINK-5054
URL: https://issues.apache.org/jira/browse/FLINK-5054
Project: Flink
Issue Type: Improvement
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2572
Had another look at the changes, I think it is a very well written test! +1
for merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657012#comment-15657012
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-5002:
Labels: easyfix starter (was: )
> Lack of synchronization in
[
https://issues.apache.org/jira/browse/FLINK-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656919#comment-15656919
]
Stephan Ewen commented on FLINK-5049:
-
Does the test have any specific guard against the state rolling
[
https://issues.apache.org/jira/browse/FLINK-5050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656895#comment-15656895
]
Stephan Ewen commented on FLINK-5050:
-
Do we need the {{hive-exec}} dependency, or can we exclude that
[
https://issues.apache.org/jira/browse/FLINK-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656884#comment-15656884
]
ASF GitHub Bot commented on FLINK-5006:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2785
It's not about timing guarantees here, only about order of running timers.
The problem is that they are sorted by the delay which is affected by
races/stalls, rather than by proper timestamp.
[
https://issues.apache.org/jira/browse/FLINK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656839#comment-15656839
]
ASF GitHub Bot commented on FLINK-4631:
---
Github user chermenin commented on the issue:
Github user chermenin commented on the issue:
https://github.com/apache/flink/pull/2782
I close this PR. Changes will be included into other PR to complete solve
[FLINK-4631](https://issues.apache.org/jira/browse/FLINK-4631) (reopened issue).
---
If your project is set up for it,
Github user chermenin closed the pull request at:
https://github.com/apache/flink/pull/2782
---
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-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656831#comment-15656831
]
Alexander Shoshin commented on FLINK-4541:
--
NOT IN operator does not work with nested queries
[
https://issues.apache.org/jira/browse/FLINK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reopened FLINK-4631:
--
Reopened upon request of [~chermenin].
> NullPointerException during stream task cleanup
>
[
https://issues.apache.org/jira/browse/FLINK-5026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656777#comment-15656777
]
ASF GitHub Bot commented on FLINK-5026:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2788
[FLINK-5026] Rename TimelyFlatMap to Process
This is only renaming, the changed Javadoc probably requires most attention
when reviewing this.
R: @jgrier if you could have a look that
Stefan Richter created FLINK-5053:
-
Summary: Incremental / lightweight snapshots for checkpoints
Key: FLINK-5053
URL: https://issues.apache.org/jira/browse/FLINK-5053
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656730#comment-15656730
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on the issue:
Github user bjlovegithub commented on the issue:
https://github.com/apache/flink/pull/2629
Hi @tillrohrmann . I have updated the code again, adding the Emitter
Thread, using the latest OperatorStateStore, updating the test codes. Thanks
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656726#comment-15656726
]
Alexander Chermenin commented on FLINK-4631:
I think this ticket must be reopened because
Stefan Richter created FLINK-5052:
-
Summary: Changing the maximum parallelism (number of key groups)
of a job
Key: FLINK-5052
URL: https://issues.apache.org/jira/browse/FLINK-5052
Project: Flink
Stefan Richter created FLINK-5051:
-
Summary: Backwards compatibility for serializers in backend state
Key: FLINK-5051
URL: https://issues.apache.org/jira/browse/FLINK-5051
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656605#comment-15656605
]
ASF GitHub Bot commented on FLINK-5016:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2786
+1 for increased timeout.
---
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
Github user chermenin commented on the issue:
https://github.com/apache/flink/pull/2782
1) I researched this question a little. It based on issue
[FLINK-4631](https://issues.apache.org/jira/browse/FLINK-4631) and affect PR
#2709. So, it's more wide issue and all elements of streaming
[
https://issues.apache.org/jira/browse/FLINK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656608#comment-15656608
]
ASF GitHub Bot commented on FLINK-4631:
---
Github user chermenin commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5012.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in
[
https://issues.apache.org/jira/browse/FLINK-5012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-5012:
---
Assignee: Aljoscha Krettek
> Provide Timestamp in TimelyFlatMapFunction
>
[
https://issues.apache.org/jira/browse/FLINK-5012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656596#comment-15656596
]
ASF GitHub Bot commented on FLINK-5012:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2772
Thanks for reviewing @jgrier!
---
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
1 - 100 of 119 matches
Mail list logo
