Tzu-Li (Gordon) Tai created FLINK-4821:
--
Summary: Implement rescalable non-partitioned state for Kinesis
Connector
Key: FLINK-4821
URL: https://issues.apache.org/jira/browse/FLINK-4821
Project: F
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2627
I'm merging the PR.
---
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,
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571243#comment-15571243
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2509
@rmetzger @gyfora @koeninger Rebased this on the Kafka 0.10 connector and
some other recent changes. This is ready for review now ;) I'd like to add
tests for this after #2580, because #2580 adds a
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2627
---
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-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571253#comment-15571253
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r83165323
--- 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/2509#discussion_r83165620
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571255#comment-15571255
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4140.
--
Resolution: Fixed
Assignee: (was: Ufuk Celebi)
Fix Version/s: 1.2.0
Fixed as part of
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2604
@rmetzger I think I just wanted to make sure that the
`KafkaTopicPartitionState[]` state in the fetcher wasn't concurrently
accessed, but actually on a second look there shouldn't be any problems wi
[
https://issues.apache.org/jira/browse/FLINK-4753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571319#comment-15571319
]
ASF GitHub Bot commented on FLINK-4753:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571398#comment-15571398
]
Ovidiu Marcu commented on FLINK-4815:
-
hi
I am currently working on a very similar pro
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571405#comment-15571405
]
Philipp von dem Bussche commented on FLINK-2821:
+1 for this feature. I am
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2608
Local Travis passed except for an independent Cassandra test failure
(https://travis-ci.org/uce/flink/builds/167107635). Going to merge this.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571422#comment-15571422
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571423#comment-15571423
]
ASF GitHub Bot commented on FLINK-4717:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2609
Local Travis build passed
(https://travis-ci.org/uce/flink/builds/167108720). I'm going to rebase and
merge this later.
---
If your project is set up for it, you can reply to this email and have your
r
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2518
@skrishnappa I would like to merge this. Could you add the test case to
ensure encryption is turned on and rebase the PR?
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571428#comment-15571428
]
ASF GitHub Bot commented on FLINK-3931:
---
Github user mxm commented on the issue:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83183505
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -60,26 +63,27 @@
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571502#comment-15571502
]
Anton Mushin commented on FLINK-4604:
-
I tried use code like as your code and I got ex
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83184745
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -60,26 +63,27 @@
[
https://issues.apache.org/jira/browse/FLINK-4779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4779:
Priority: Blocker (was: Major)
> Restoring from savepoint fails when BucketingSink has not
[
https://issues.apache.org/jira/browse/FLINK-4725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4725:
Priority: Blocker (was: Major)
> BucketingSink throws NPE while restoring state if basePath
[
https://issues.apache.org/jira/browse/FLINK-4725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4725:
Affects Version/s: 1.2.0
> BucketingSink throws NPE while restoring state if basePath does n
[
https://issues.apache.org/jira/browse/FLINK-4725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4725:
Description:
BucketingSink throws a NullPointerException when attempting to clean up pending
[
https://issues.apache.org/jira/browse/FLINK-4779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4779.
---
Resolution: Duplicate
> Restoring from savepoint fails when BucketingSink has not yet created
Robert Metzger created FLINK-4822:
-
Summary: Ensure that the Kafka 0.8 connector is compatible with
kafka-consumer-groups.sh
Key: FLINK-4822
URL: https://issues.apache.org/jira/browse/FLINK-4822
Proje
[
https://issues.apache.org/jira/browse/FLINK-4822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4822:
--
Description:
The Kafka 0.8 connector is not properly creating all datastructures in
Zookeeper f
GitHub user bjlovegithub opened a pull request:
https://github.com/apache/flink/pull/2629
[FLINK-4391] Provide support for asynchronous operations over streams
PR for [FLIP
12](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65870673)
- Implementation for Async I/O
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571577#comment-15571577
]
ASF GitHub Bot commented on FLINK-4391:
---
GitHub user bjlovegithub opened a pull requ
Sajeev Ramakrishnan created FLINK-4823:
--
Summary: org.apache.flink.types.NullFieldException: Field 0 is
null, but expected to hold a value
Key: FLINK-4823
URL: https://issues.apache.org/jira/browse/FLINK-4823
[
https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571691#comment-15571691
]
Greg Hogan commented on FLINK-4823:
---
Thanks for reporting this. Is there code you could
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2386#discussion_r83201419
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -273,7 +276,7 @@ public void releaseOutputs(
[
https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571741#comment-15571741
]
ASF GitHub Bot commented on FLINK-3660:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571746#comment-15571746
]
Sajeev Ramakrishnan commented on FLINK-4823:
DataSet> vertices
[
https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571752#comment-15571752
]
ASF GitHub Bot commented on FLINK-3660:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2386
Thank you for the review @zentol and @aljoscha.
I addressed your comments and rebased the code to the current master. I'm
currently testing the change again locally. Once that is completed
succe
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571757#comment-15571757
]
Aljoscha Krettek commented on FLINK-2221:
-
+1 for "won't fix" ([~StephanEwen])
>
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-2221.
---
Resolution: Won't Fix
This is the expected behaviour. As mentioned in the discussion.
> Check
Robert Metzger created FLINK-4824:
-
Summary: CliFrontend shows misleading error message when main()
method returns before env.execute()
Key: FLINK-4824
URL: https://issues.apache.org/jira/browse/FLINK-4824
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2386#discussion_r83203023
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -273,7 +276,7 @@ public void releaseOutputs(
[
https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571767#comment-15571767
]
ASF GitHub Bot commented on FLINK-3660:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571815#comment-15571815
]
ASF GitHub Bot commented on FLINK-3660:
---
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/2386#discussion_r83207030
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -273,7 +276,7 @@ public void releaseOutputs(
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571823#comment-15571823
]
Stephan Ewen commented on FLINK-2821:
-
I agree, it would be good to resolve that. It s
[
https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571879#comment-15571879
]
Maximilian Michels commented on FLINK-4824:
---
That was recently changed (before w
[
https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571902#comment-15571902
]
ASF GitHub Bot commented on FLINK-4735:
---
Github user KurtYoung commented on the issu
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/2588
This PR now contains some work from master branch picked by Stephan.
Rebased to the latest flip-6
---
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-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571931#comment-15571931
]
Robert Metzger commented on FLINK-4410:
---
I'll add the CheckpointMetrics to the coord
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-4410:
-
Assignee: Robert Metzger
> Report more information about operator checkpoints
> -
[
https://issues.apache.org/jira/browse/FLINK-4698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-4698:
-
Assignee: Robert Metzger
> Visualize additional checkpoint information
>
[
https://issues.apache.org/jira/browse/FLINK-4697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-4697:
-
Assignee: Robert Metzger
> Gather more detailed checkpoint stats in CheckpointStatsTracke
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/2497
This PR now bases on #2588 , only the last commit is related.
---
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 no
[
https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571922#comment-15571922
]
ASF GitHub Bot commented on FLINK-4339:
---
Github user KurtYoung commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572005#comment-15572005
]
ASF GitHub Bot commented on FLINK-4727:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2585
+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 th
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2604
Okay. I'm sorry that I didn't respond to the JIRA when you opened it.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572008#comment-15572008
]
ASF GitHub Bot commented on FLINK-4753:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572013#comment-15572013
]
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_r83222904
--- 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-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571502#comment-15571502
]
Anton Mushin edited comment on FLINK-4604 at 10/13/16 2:10 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571502#comment-15571502
]
Anton Mushin edited comment on FLINK-4604 at 10/13/16 2:10 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572052#comment-15572052
]
Robert Metzger commented on FLINK-4194:
---
The method {{KinesisDeserializationSchema.i
Timo Walther created FLINK-4825:
---
Summary: Implement a RexExecutor that uses Flink's code generation
Key: FLINK-4825
URL: https://issues.apache.org/jira/browse/FLINK-4825
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-4825:
Description:
The added {{ReduceExpressionRule}} leads to inconsistent behavior. Because some
parts
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2624
Merged to `flip-6`.
---
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
Github user mxm closed the pull request at:
https://github.com/apache/flink/pull/2624
---
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 enabled
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572068#comment-15572068
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572067#comment-15572067
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user mxm closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4791.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Temporarily fixed by disabling the rule in
c7d1a3b8
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572115#comment-15572115
]
Anton Mushin commented on FLINK-4604:
-
Sorry, I will try explain my problem.
I have tw
[
https://issues.apache.org/jira/browse/FLINK-3037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572133#comment-15572133
]
Cody Koeninger commented on FLINK-3037:
---
As a user, I want to be able to start low-v
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572142#comment-15572142
]
Aljoscha Krettek commented on FLINK-4576:
-
Hi,
first off, sorry for the late respo
[
https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572151#comment-15572151
]
Greg Hogan commented on FLINK-4824:
---
{{WordCount}} should be able to convey to {{Cluster
[
https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572160#comment-15572160
]
Greg Hogan commented on FLINK-4823:
---
Adding \{code\} before and after this code block wi
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572174#comment-15572174
]
Maximilian Michels commented on FLINK-2821:
---
Just to add another option:
- Appl
[
https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572274#comment-15572274
]
Maximilian Michels commented on FLINK-4824:
---
I agree that we should differentiat
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2386
I had an offline discussion with @aljoscha about this PR, and we decided to
remove the `isSink` flag from the `AbstractStreamOperator`.
I updated the PR.
---
If your project is set up for it, y
[
https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572276#comment-15572276
]
ASF GitHub Bot commented on FLINK-3660:
---
Github user rmetzger commented on the issue
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2588
Merged to the `flip-6` feature branch in
34fef4752e94b3d0c7afe7a9525799bb651a07b4
---
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-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572286#comment-15572286
]
ASF GitHub Bot commented on FLINK-4735:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2497
Merged into the `flip-6` feature branch in
48c936eeda7b265f32bbf9f14d15f78eae15c06f
---
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-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572293#comment-15572293
]
ASF GitHub Bot commented on FLINK-4339:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-4824:
-
Assignee: Greg Hogan
> CliFrontend shows misleading error message when main() method returns befo
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572347#comment-15572347
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2562
@fhueske I updated the PR. The only thing that is missing now are tests for
the `DataStreamAggregate` class. I will add unit tests tomorrow.
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572364#comment-15572364
]
Maximilian Michels commented on FLINK-2821:
---
Just out of fun, I actually tried t
[
https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-2603.
---
Resolution: Not A Problem
I believe this is due to a configured limit in the size of Akka messages as
[
https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572513#comment-15572513
]
Greg Hogan commented on FLINK-4129:
---
[~vkalavri] what do you think we should do with thi
[
https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4117:
--
Description:
Received the following error when locally running {{mvn verify}}. Searching on
the error i
[
https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4117:
--
Description:
Received the following error when locally running {{mvn verify}}. Searching on
the error i
[
https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-4117.
---
Resolution: Cannot Reproduce
> Wait for CuratorFramework connection to be established
> --
[
https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572633#comment-15572633
]
Greg Hogan commented on FLINK-1890:
---
Do we still want this documented or can we close th
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572639#comment-15572639
]
Philipp von dem Bussche commented on FLINK-2821:
[~mxm] thats awesome ! Th
[
https://issues.apache.org/jira/browse/FLINK-720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572652#comment-15572652
]
Greg Hogan commented on FLINK-720:
--
Are we still looking to add this check?
> Forbid catc
[
https://issues.apache.org/jira/browse/FLINK-787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-787.
--
Resolution: Duplicate
> Custom termination criterion in delta iteration
> ---
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572671#comment-15572671
]
Stephan Ewen commented on FLINK-2821:
-
That's pretty amazing.
[~philipp.bussche] do y
[
https://issues.apache.org/jira/browse/FLINK-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-1936.
---
Resolution: Fixed
> Normalize keys and default values in ConfigConstants.java
> --
1 - 100 of 185 matches
Mail list logo
