[
https://issues.apache.org/jira/browse/FLINK-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514995#comment-15514995
]
shijinkui commented on FLINK-4661:
--
hi, [~StephanEwen] [~twalthr]
My local nexus proxy is something
[
https://issues.apache.org/jira/browse/FLINK-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui closed FLINK-4661.
Resolution: Won't Fix
> Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT
>
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515022#comment-15515022
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on the issue:
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
Hi @ramkrish86 , CassandraTupleWriteAheadSink extends GenericWriteAheadSink
that deals with the checkpoint mechanism
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-4630:
-
Description:
When source stream get start, listen a provided tcp port, receive stream data
from user
[
https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-4630:
-
Description:
When source stream get start, listen a provided tcp port, receive stream data
from user
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515209#comment-15515209
]
Jark Wu commented on FLINK-4263:
I have no idea how to code generate the values input format. So feel free
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515452#comment-15515452
]
ASF GitHub Bot commented on FLINK-3322:
---
Github user ramkrish86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515504#comment-15515504
]
ASF GitHub Bot commented on FLINK-4666:
---
GitHub user apivovarov opened a pull request:
GitHub user apivovarov opened a pull request:
https://github.com/apache/flink/pull/2538
[FLINK-4666] Make constants to be final in ParameterTool
https://issues.apache.org/jira/browse/FLINK-4666
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515193#comment-15515193
]
shijinkui commented on FLINK-4630:
--
[~StephanEwen]
Though flink already have a SocketTextStreamFunction,
Alexander Pivovarov created FLINK-4665:
--
Summary: Remove boxing/unboxing to parse a primitive
Key: FLINK-4665
URL: https://issues.apache.org/jira/browse/FLINK-4665
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515279#comment-15515279
]
ASF GitHub Bot commented on FLINK-4665:
---
GitHub user apivovarov opened a pull request:
GitHub user apivovarov opened a pull request:
https://github.com/apache/flink/pull/2537
[FLINK-4665] Remove boxing/unboxing to parse a primitive
https://issues.apache.org/jira/browse/FLINK-4665
You can merge this pull request into a Git repository by running:
$ git pull
Alexander Pivovarov created FLINK-4666:
--
Summary: Make constants final in ParameterTool
Key: FLINK-4666
URL: https://issues.apache.org/jira/browse/FLINK-4666
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing resolved FLINK-4537.
--
Resolution: Resolved
> ResourceManager registration with JobManager
>
[
https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing resolved FLINK-4535.
--
Resolution: Resolved
> ResourceManager registration with TaskExecutor
>
[
https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515323#comment-15515323
]
ASF GitHub Bot commented on FLINK-4547:
---
Github user beyond1920 commented on the issue:
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2455
@tillrohrmann , I rebase the PR. 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
[
https://issues.apache.org/jira/browse/FLINK-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Pivovarov updated FLINK-4666:
---
Summary: Make constants to be final in ParameterTool (was: Make constants
final in
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2495
@StephanEwen
Just trying to explain what my intention was. This is particularly to
address the sorters.
Solution
We could create memory allocators inside the batch task corresponding
[
https://issues.apache.org/jira/browse/FLINK-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513420#comment-15513420
]
ASF GitHub Bot commented on FLINK-4662:
---
GitHub user wuchong opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513450#comment-15513450
]
Timo Walther commented on FLINK-4263:
-
I think they don't need to be basic types even though it is
Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/2517
Not all clear.
How should look like `MetricGroup#getMetricIdentifier()`call in this case?
If we use single reporter for other reporters and know their indexes, we
must know name or index where
Github user ex00 closed the pull request at:
https://github.com/apache/flink/pull/2517
---
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-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Mushin updated FLINK-4564:
Comment: was deleted
(was: Not all clear.
How should look like
GitHub user ex00 reopened a pull request:
https://github.com/apache/flink/pull/2517
[FLINK-4564] [metrics] Delimiter should be configured per reporter
Hi
It is my fix FLINK-4564. I want fix this issue, please send me your
comments about this implementation.
I could assign
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512350#comment-15512350
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512351#comment-15512351
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512540#comment-15512540
]
ASF GitHub Bot commented on FLINK-4603:
---
GitHub user StefanRRichter opened a pull request:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2533
Please review @tillrohrmann or @aljoscha
---
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
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2533
[FLINK-4603] Fixes: KeyedStateBackend cannot restore user code classes
This PR fixes [FLINK-4603] and introduces a test to protect better against
future regression.
You can merge this pull
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512553#comment-15512553
]
Stefan Richter commented on FLINK-4603:
---
Currently, we should still keep the UserCodeClassLoader
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512390#comment-15512390
]
Ivan Mushketyk commented on FLINK-4641:
---
Hi [~kervel]
I think the method chaining will allow nested
[
https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512579#comment-15512579
]
ASF GitHub Bot commented on FLINK-4535:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2479
This has been merged to `flip-6`. Could you please close 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
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2451
This has been merged to `flip-6`. Could you please close 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
[
https://issues.apache.org/jira/browse/FLINK-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512578#comment-15512578
]
ASF GitHub Bot commented on FLINK-4537:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512400#comment-15512400
]
ASF GitHub Bot commented on FLINK-3719:
---
Github user mushketyk commented on the issue:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2467
Hi @StephanEwen
All images are coming from this repo:
https://github.com/nathancahill/Split.js
It has a very permissive license:
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512541#comment-15512541
]
ASF GitHub Bot commented on FLINK-4603:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512657#comment-15512657
]
ASF GitHub Bot commented on FLINK-4561:
---
Github user shijinkui commented on the issue:
shijinkui created FLINK-4661:
Summary: Failure to find
org.apache.flink:flink-runtime_2.10:jar:tests
Key: FLINK-4661
URL: https://issues.apache.org/jira/browse/FLINK-4661
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512786#comment-15512786
]
Stephan Ewen commented on FLINK-4650:
-
Am I right in assuming that the TaskManager is not marked as
[
https://issues.apache.org/jira/browse/FLINK-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512844#comment-15512844
]
Stephan Ewen commented on FLINK-4661:
-
What project is throwing that error? The test jar is generated
[
https://issues.apache.org/jira/browse/FLINK-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512915#comment-15512915
]
ASF GitHub Bot commented on FLINK-4544:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2445
Can we move this code out of the TaskManager as a whole, into a metrics
Utility?
We could make it reusable for the JobManager as well, by passing the metric
group where that should be added.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2303
---
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-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512828#comment-15512828
]
Stephan Ewen commented on FLINK-4646:
-
[~greghogan] [~vkalavri] Copying you here. Are these features
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2533
@StephanEwen at least in the RocksDB backend we could remove user code
completely. Right now, the only thing that needs to be serialized is the
TypeSerializer from the ValueDescriptor. It is
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512855#comment-15512855
]
ASF GitHub Bot commented on FLINK-4603:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512893#comment-15512893
]
Stephan Ewen commented on FLINK-4646:
-
Ah, I did not see that. Just thought that it would be good to
[
https://issues.apache.org/jira/browse/FLINK-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512926#comment-15512926
]
ASF GitHub Bot commented on FLINK-4628:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2505
Merging this...
---
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,
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2458
From my side, this is good to merge.
Unless someone objects, I will merge this later today...
---
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-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512934#comment-15512934
]
ASF GitHub Bot commented on FLINK-3719:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512936#comment-15512936
]
ASF GitHub Bot commented on FLINK-4560:
---
Github user StephanEwen commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2330
Hi @nielsbasjes, thanks for fixing and cleaning up the `TableInputFormat`.
This PR is good to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2533
Fix looks good.
Better would probably be to not even have the user code in the checkpoint
at all.
Can we do that?
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4248.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 3507d59f969485dd735487e6bf3eb893b2e3d8ed.
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2533
@StephanEwen we can do that but then we won't have any sanity checks for
the `TypeSerializer` any more. Right now, even the RocksDB backed will
serializer the `TypeSerializer`/`StateDescriptor`
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2533#discussion_r80005604
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -266,18 +265,20 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512773#comment-15512773
]
ASF GitHub Bot commented on FLINK-4603:
---
Github user aljoscha commented on a diff in the pull
Timo Walther created FLINK-4662:
---
Summary: Bump Calcite version up to 1.9
Key: FLINK-4662
URL: https://issues.apache.org/jira/browse/FLINK-4662
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512838#comment-15512838
]
ASF GitHub Bot commented on FLINK-4603:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2533#discussion_r80010321
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -266,18 +265,20 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512922#comment-15512922
]
ASF GitHub Bot commented on FLINK-4580:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512932#comment-15512932
]
ASF GitHub Bot commented on FLINK-3719:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2467
Piotr (who wrote most of the web ui) also wants to leave some comments.
Let's wait for him.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2482
Good point. I think reflect is good, if it does not add too much work.
Keeping the modules separate is nice, I think.
---
If your project is set up for it, you can reply to this email and have
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2467
The license is MIT, so that is fine.
Can you update the LICENSE file with the dependency?
---
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-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512931#comment-15512931
]
ASF GitHub Bot commented on FLINK-4579:
---
Github user StephanEwen commented on the issue:
Swapnil Chougule created FLINK-4663:
---
Summary: Flink JDBCOutputFormat logs wrong WARN message
Key: FLINK-4663
URL: https://issues.apache.org/jira/browse/FLINK-4663
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512604#comment-15512604
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on the issue:
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/2459
hi, @StephanEwen I have an idea in mind, If there are to much tricky bugs,
and follow "don't change it unless it is broken", after two years can you image
the code like? Full of tricky bugs fix.
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512702#comment-15512702
]
ASF GitHub Bot commented on FLINK-4603:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512621#comment-15512621
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 commented on the issue:
Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/2517
Could you explain me how must look API for getting metric identifier?
Now I think about this:
```java
@Test
public void testConfigurableDelimiterForReporter() {
[
https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512709#comment-15512709
]
ASF GitHub Bot commented on FLINK-4248:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-4661:
-
Summary: Failure to find
org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT (was: Failure to
Github user beyond1920 closed the pull request at:
https://github.com/apache/flink/pull/2479
---
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-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512796#comment-15512796
]
ASF GitHub Bot commented on FLINK-4535:
---
Github user beyond1920 closed the pull request at:
Github user beyond1920 closed the pull request at:
https://github.com/apache/flink/pull/2451
---
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-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512795#comment-15512795
]
ASF GitHub Bot commented on FLINK-4537:
---
Github user beyond1920 closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512880#comment-15512880
]
Vasia Kalavri commented on FLINK-4646:
--
Hi [~StephanEwen], thanks! We've discussed this in the parent
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512918#comment-15512918
]
ASF GitHub Bot commented on FLINK-4603:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2533
I see, keeping the serializers for now makes probably sense.
It just seems that there are also user functions in there (like fold, etc)
- those should probably be removed. May mean that we
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2526
Nice!
+1 to merge this
---
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
[
https://issues.apache.org/jira/browse/FLINK-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512941#comment-15512941
]
ASF GitHub Bot commented on FLINK-4544:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2445
that should be doable, yes.
---
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 greghogan commented on the issue:
https://github.com/apache/flink/pull/2527
Would a graph translator simplify the conversion from Long to String? You
can do `graph.run(new TranslateEdgeValues<...>(new StringToLong())` and write a
simple `public class StringToLong
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513996#comment-15513996
]
ASF GitHub Bot commented on FLINK-4624:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2527
I'm not following why specifying the `TypeInformation` is now required with
the change to using `Either`. Is the type system failing to handle this
properly?
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514015#comment-15514015
]
Matt Zimmer commented on FLINK-4660:
[~StephanEwen] We last tested with latest on master as of 9/6.
[
https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514093#comment-15514093
]
Zhenzhong Xu commented on FLINK-4218:
-
I think simply have retries potentially with configurable retry
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2527#discussion_r80109825
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/Summarization.java
---
@@ -226,11 +247,15 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514143#comment-15514143
]
ASF GitHub Bot commented on FLINK-4624:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513945#comment-15513945
]
ASF GitHub Bot commented on FLINK-4624:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15514124#comment-15514124
]
ASF GitHub Bot commented on FLINK-4624:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2527
I'd also like to add a `ToNullValue` translator that would accept any type
and convert to `NullValue`.
---
If your project is set up for it, you can reply to this email and have your
reply appear
1 - 100 of 145 matches
Mail list logo
