[
https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754685#comment-16754685
]
Congxian Qiu commented on FLINK-11352:
--
Hi [~till.rohrmann] Update for
[
https://issues.apache.org/jira/browse/FLINK-11436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-11436.
---
Resolution: Fixed
> Java deserialization failure of the AvroSerializer when used in
[
https://issues.apache.org/jira/browse/FLINK-11436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reopened FLINK-11436:
-
> Java deserialization failure of the AvroSerializer when used in an old
>
[
https://issues.apache.org/jira/browse/FLINK-11436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-11436:
Priority: Blocker (was: Major)
> Java deserialization failure of the
[
https://issues.apache.org/jira/browse/FLINK-11361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu reassigned FLINK-11361:
Assignee: (was: Congxian Qiu)
> Check and port RecoveryITCase to new code base if
asfgit closed pull request #7580: [FLINK-11436] Fix Java deserialization
failure of the AvroSerializer
URL: https://github.com/apache/flink/pull/7580
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-11435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754658#comment-16754658
]
Avi Levi commented on FLINK-11435:
--
[~elevy] as a kafka user you expect that same consumer group will
[
https://issues.apache.org/jira/browse/FLINK-11441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11441:
---
Labels: pull-request-available (was: )
> Remove the schedule mode property from RPDD to
zhijiangW opened a new pull request #7593: [FLINK-11441][network] Remove the
schedule mode property from RPDD to TDD
URL: https://github.com/apache/flink/pull/7593
## What is the purpose of the change
*In `ResultPartitionDeploymentDescriptor` (RPDD) the boolean invariant
[
https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754632#comment-16754632
]
vinoyang commented on FLINK-11202:
--
[~chauncy] see this issue's description.
> Split log file per job
HuangZhenQiu commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r251701493
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754623#comment-16754623
]
chauncy commented on FLINK-11202:
-
can you give link ? [~yanghua]
> Split log file per job
>
eaglewatcherwb commented on issue #7537: [FLINK-11309][core] make
SpillableSubpartition repeatably read to enable
URL: https://github.com/apache/flink/pull/7537#issuecomment-458417919
Hi @aljoscha , would you mind to have a look at this PR? Or anyone else
should I ask to review this?
tzulitai commented on issue #7020: [FLINK-10774] [Kafka] connection leak when
partition discovery is disabled an…
URL: https://github.com/apache/flink/pull/7020#issuecomment-458402620
@tillrohrmann changes in your branch looks good
The tests you added also verifies that the changes
tzulitai commented on issue #7020: [FLINK-10774] [Kafka] connection leak when
partition discovery is disabled an…
URL: https://github.com/apache/flink/pull/7020#issuecomment-458401552
@stevenzwu I've looked at @tillrohrmann's branch which contains the
refactoring, and I think it solves
TisonKun commented on issue #7570: [FLINK-11422] Prefer testing class to mock
StreamTask in AbstractStre…
URL: https://github.com/apache/flink/pull/7570#issuecomment-458400106
travis fails on
```
Submitting job ... 'test_write_as_text'
09:31:13.369 [ERROR] Tests run: 1,
TisonKun commented on issue #6883: [FLINK-10610] [tests] Port slot sharing
cases to new codebase
URL: https://github.com/apache/flink/pull/6883#issuecomment-458399816
ping @tillrohrmann
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-11369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11369:
---
Labels: pull-request-available (was: )
> Check and port ZooKeeperHAJobManagerTest to new
TisonKun opened a new pull request #7592: [FLINK-11369] [tests] Remove invalid
tests ZooKeeperHAJobManagerTest
URL: https://github.com/apache/flink/pull/7592
## What is the purpose of the change
`ZooKeeperHAJobManagerTest` contains only
`testJobGraphReleaseWhenLosingLeadership`,
[
https://issues.apache.org/jira/browse/FLINK-11412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11412:
---
Labels: pull-request-available (was: )
> Remove legacy MesosFlinkResourceManager
>
TisonKun opened a new pull request #7591: [FLINK-11412] [mesos] Remove legacy
MesosFlinkResourceManager
URL: https://github.com/apache/flink/pull/7591
## What is the purpose of the change
Remove legacy `MesosFlinkResourceManager`, which is unused in production
code at all.
[
https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754565#comment-16754565
]
vinoyang commented on FLINK-11202:
--
[~Zentol] [~chauncy] The issue's design document "Flink framework
[
https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11202:
-
Description:
Debugging issues is difficult since Task-/JobManagers create a single log file
in
j2cms commented on issue #7581: blink first commit
URL: https://github.com/apache/flink/pull/7581#issuecomment-458390292
cool
This is an automated message from the Apache Git Service.
To respond to the message, please log on
Aitozi closed pull request #5405: [FLINK-8477][Window]Add api to support user
to skip serval broken window
URL: https://github.com/apache/flink/pull/5405
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-9959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
boshu Zheng reassigned FLINK-9959:
--
Assignee: boshu Zheng
> Add JoinWindowFunction to allow access Window
>
zhijiangW commented on issue #7199: [FLINK-10662][network] Refactor the
ChannelSelector interface for single selected channel
URL: https://github.com/apache/flink/pull/7199#issuecomment-458385764
@pnowojski Thanks for the review again. I already submitted the commit for
addressing latest
[
https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754516#comment-16754516
]
sunjincheng commented on FLINK-11439:
-
Masterpiece starts with a good title [~twalthr] ;)
> INSERT
[
https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754502#comment-16754502
]
Kurt Young commented on FLINK-11439:
Interesting title [~twalthr] :D
> INSERT INTO flink_sql SELECT
[
https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754500#comment-16754500
]
Hequn Cheng commented on FLINK-11439:
-
[~twalthr] A nice title (y)
> INSERT INTO flink_sql SELECT *
[
https://issues.apache.org/jira/browse/FLINK-10718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754491#comment-16754491
]
vinoyang commented on FLINK-10718:
--
Since FLINK-10251 has been merged, I am trying to start this issue.
vinoyang created FLINK-11440:
Summary: AbstractOperatorRestoreTestBase#testMigrationAndRestore
caused IllegalStateException
Key: FLINK-11440
URL: https://issues.apache.org/jira/browse/FLINK-11440
suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn]
Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r251657123
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11411.
Resolution: Fixed
Fix Version/s: 1.8.0
master:
[
https://issues.apache.org/jira/browse/FLINK-11411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11411:
-
Affects Version/s: 1.8.0
> Number of failover regions number ot correctly logged by
>
[
https://issues.apache.org/jira/browse/FLINK-11411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11411:
-
Summary: Number of failover regions number ot correctly logged by
zentol merged pull request #7561: [FLINK-11411][log] show correct failover
region number
URL: https://github.com/apache/flink/pull/7561
This is an automated message from the Apache Git Service.
To respond to the message,
zentol commented on issue #7533: [FLINK-11288][build] Add flink-ml-uber module
URL: https://github.com/apache/flink/pull/7533#issuecomment-458342125
@StephanEwen Do you mean to always have flink-ml be a fat-jar and only
deploy that one? It would certainly _work_. I opted for a new module
zentol commented on a change in pull request #7587: [FLINK-11064] [table] Setup
a new flink-table module structure
URL: https://github.com/apache/flink/pull/7587#discussion_r251629687
##
File path: flink-table/flink-table-dist/pom.xml
##
@@ -0,0 +1,103 @@
+
+
zentol commented on a change in pull request #7587: [FLINK-11064] [table] Setup
a new flink-table module structure
URL: https://github.com/apache/flink/pull/7587#discussion_r251628191
##
File path: flink-table/flink-sql-client/pom.xml
##
@@ -152,7 +161,9 @@ under the
zentol commented on issue #7587: [FLINK-11064] [table] Setup a new flink-table
module structure
URL: https://github.com/apache/flink/pull/7587#issuecomment-458333709
my guess is that it doesn't fit anymore since you also moved the sql-client
to libraries.
zentol merged pull request #7589: [hotfix] [docs] fix typo in batch/example.md
URL: https://github.com/apache/flink/pull/7589
This is an automated message from the Apache Git Service.
To respond to the message, please log on
tillrohrmann commented on issue #7567: [FLINK-11358][tests] Port
LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#issuecomment-458331083
Thanks for the review @azagrebin. I've addressed all your comments.
tillrohrmann commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251624484
##
File path:
tillrohrmann commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251624392
##
File path:
tillrohrmann commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251624205
##
File path:
tillrohrmann commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251624050
##
File path:
tillrohrmann commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251623800
##
File path:
tillrohrmann commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251623506
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-11414.
-
Resolution: Fixed
Fixed via 9fb3025e12a38136fa583110f8f267091c3db19a
> Introduce
tillrohrmann commented on issue #7564: [FLINK-11415] Introduce
JobMasterServiceFactory
URL: https://github.com/apache/flink/pull/7564#issuecomment-458324323
Thanks for the review @azagrebin. I'll rebase and once Travis gives green
light, then I'll merge the PR.
tillrohrmann closed pull request #7563: [FLINK-11414] Introduce
JobMasterService interface
URL: https://github.com/apache/flink/pull/7563
This is an automated message from the Apache Git Service.
To respond to the message,
tweise commented on a change in pull request #7099: [FLINK-10887] [jobmaster]
Add source watermark tracking to the JobMaster
URL: https://github.com/apache/flink/pull/7099#discussion_r251560234
##
File path:
igalshilman opened a new pull request #7590: [FLINK-11329][core] Migrating
CompositeSerializers
URL: https://github.com/apache/flink/pull/7590
## What is the purpose of the change
This PR migrates the following serializers to the new
`TypeSerializerSnapshot` abstraction:
-
zentol commented on issue #7587: [FLINK-11064] [table] Setup a new flink-table
module structure
URL: https://github.com/apache/flink/pull/7587#issuecomment-458276907
flink-table was already run in `libraries` so far.
This is
rmetzger commented on issue #7575: [FLINK-11418][docs] Fix version of bundler
to 1.16.1
URL: https://github.com/apache/flink/pull/7575#issuecomment-458274651
Does this mean you are approving my contribution?
This is an
rmetzger commented on issue #5290: [Flink-8424][Cassandra Connector] upgrade of
cassandra version and driver to latest
URL: https://github.com/apache/flink/pull/5290#issuecomment-458269650
I'm closing this PR. The repository where the PR originates from has been
removed.
rmetzger closed pull request #5290: [Flink-8424][Cassandra Connector] upgrade
of cassandra version and driver to latest
URL: https://github.com/apache/flink/pull/5290
This is an automated message from the Apache Git
stevenzwu commented on issue #7020: [FLINK-10774] [Kafka] connection leak when
partition discovery is disabled an…
URL: https://github.com/apache/flink/pull/7020#issuecomment-458269538
@tillrohrmann I believe in the case of exception from open, `cancel` method
will be called. Regardless,
azagrebin commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251539350
##
File path:
azagrebin commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251440897
##
File path:
azagrebin commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251437510
##
File path:
azagrebin commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251536198
##
File path:
azagrebin commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r251438519
##
File path:
1u0 commented on issue #6976: [FLINK-7155][metrics] Add new metrics reporter to
InfluxDB
URL: https://github.com/apache/flink/pull/6976#issuecomment-458236341
@knaufk, this may be due to some bug in (older) Flink runtime.
I don't see the index value in the resulting name, by running
lamber-ken commented on issue #7571: [FLINK-10724] Refactor failure handling in
check point coordinator
URL: https://github.com/apache/flink/pull/7571#issuecomment-458223164
> @lamber-ken answer your questions:
>
> * yes, now when checkpoint failure we just send a decline
[
https://issues.apache.org/jira/browse/FLINK-11437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754159#comment-16754159
]
Yun Tang commented on FLINK-11437:
--
From the detailed message, I think this is because the task
[
https://issues.apache.org/jira/browse/FLINK-11435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754156#comment-16754156
]
Elias Levy commented on FLINK-11435:
This is expected behavior. Flink manages Kafka offsets itself.
pnowojski commented on a change in pull request #7199: [FLINK-10662][network]
Refactor the ChannelSelector interface for single selected channel
URL: https://github.com/apache/flink/pull/7199#discussion_r251489979
##
File path:
pnowojski commented on a change in pull request #7199: [FLINK-10662][network]
Refactor the ChannelSelector interface for single selected channel
URL: https://github.com/apache/flink/pull/7199#discussion_r251489979
##
File path:
pnowojski commented on a change in pull request #7199: [FLINK-10662][network]
Refactor the ChannelSelector interface for single selected channel
URL: https://github.com/apache/flink/pull/7199#discussion_r251491763
##
File path:
pnowojski commented on a change in pull request #7199: [FLINK-10662][network]
Refactor the ChannelSelector interface for single selected channel
URL: https://github.com/apache/flink/pull/7199#discussion_r251494524
##
File path:
rmetzger commented on issue #5405: [FLINK-8477][Window]Add api to support user
to skip serval broken window
URL: https://github.com/apache/flink/pull/5405#issuecomment-458204507
The underlying JIRA ticket has been closed as "wontfix".
@Aitozi is it okay to close this pull request
rmetzger commented on issue #5501: [FLINK-6053][metrics] Add new
Number-/StringGauge metric types
URL: https://github.com/apache/flink/pull/5501#issuecomment-458203109
@zentol what's the status of this pull request?
This is
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make
access to ExecutionGraph single threaded from JobMaster main thread
URL: https://github.com/apache/flink/pull/7568#discussion_r251491765
##
File path:
tvielgouarin edited a comment on issue #7405: [FLINK-11249]
FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-458186468
Hi @pnowojski,
I have managed to solve the recovery problem for the Kafka Broker. I have
rmetzger commented on issue #5735: [FLINK-9036] [core] Add default values to
State Descriptors via suppliers
URL: https://github.com/apache/flink/pull/5735#issuecomment-458196826
@StephanEwen what's the status of this PR?
itdamo opened a new pull request #7589: [hotfix] [docs] fix typo in
batch/example.md
URL: https://github.com/apache/flink/pull/7589
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through
twalthr edited a comment on issue #7587: [FLINK-11064] [table] Setup a new
flink-table module structure
URL: https://github.com/apache/flink/pull/7587#issuecomment-458195520
@zentol It seems that `flink-table` is too big to be executed in the `misc`
group of Travis. We could add it to
twalthr commented on issue #7587: [FLINK-11064] [table] Setup a new flink-table
module structure
URL: https://github.com/apache/flink/pull/7587#issuecomment-458195520
@zentol It seems that `flink-table` is too big to be executed in the `misc`
group of Travis. We could add it to
rmetzger commented on issue #5896: [FLINK-8286][Security] Fix kerberos security
configuration for YarnTaskExecutor
URL: https://github.com/apache/flink/pull/5896#issuecomment-458193802
@aljoscha @suez1224 This PR appears to be a stale open PR, even though it
seem to contain something
rmetzger commented on issue #5923: [FLINK-9253][network] make the maximum
floating buffers count channel-type independent
URL: https://github.com/apache/flink/pull/5923#issuecomment-458193075
@NicoK what's the status of the pull request?
dawidwys closed pull request #5846: [FLINK-9143] [client] Restart strategy
defined in flink-conf.yaml is ignored
URL: https://github.com/apache/flink/pull/5846
This is an automated message from the Apache Git Service.
To
dawidwys commented on issue #5846: [FLINK-9143] [client] Restart strategy
defined in flink-conf.yaml is ignored
URL: https://github.com/apache/flink/pull/5846#issuecomment-458192429
Fixed in 57872d53c4584faace6dc8e4038ad1f2d068a453
[
https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754094#comment-16754094
]
Jark Wu commented on FLINK-11439:
-
[~twalthr] get you. Interesting title.
> INSERT INTO flink_sql
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make
access to ExecutionGraph single threaded from JobMaster main thread
URL: https://github.com/apache/flink/pull/7568#discussion_r250988031
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754090#comment-16754090
]
Timo Walther commented on FLINK-11439:
--
[~jark] I tried to be creative with the title. If it
[
https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754085#comment-16754085
]
Robert Metzger commented on FLINK-9143:
---
I assume we can close this pull request as it has been
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make
access to ExecutionGraph single threaded from JobMaster main thread
URL: https://github.com/apache/flink/pull/7568#discussion_r251477545
##
File path:
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make
access to ExecutionGraph single threaded from JobMaster main thread
URL: https://github.com/apache/flink/pull/7568#discussion_r251477074
##
File path:
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make
access to ExecutionGraph single threaded from JobMaster main thread
URL: https://github.com/apache/flink/pull/7568#discussion_r251475289
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-11419:
--
Assignee: Edward Rojas
> StreamingFileSink fails to recover after taskmanager
tvielgouarin commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can
not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-458186468
Hi @pnowojski,
I have managed to solve the recovery problem for the Kafka Broker. I have
also
[
https://issues.apache.org/jira/browse/FLINK-11064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754080#comment-16754080
]
xuqianjin commented on FLINK-11064:
---
hi [~twalthr] That's good. I want to be involved.
best
qianjin
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make
access to ExecutionGraph single threaded from JobMaster main thread
URL: https://github.com/apache/flink/pull/7568#discussion_r251473904
##
File path:
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make
access to ExecutionGraph single threaded from JobMaster main thread
URL: https://github.com/apache/flink/pull/7568#discussion_r251471761
##
File path:
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make
access to ExecutionGraph single threaded from JobMaster main thread
URL: https://github.com/apache/flink/pull/7568#discussion_r251471761
##
File path:
EAlexRojas opened a new pull request #7588: [FLINK-11419][filesystem] For
recovery, wait until lease is revoked before truncate file
URL: https://github.com/apache/flink/pull/7588
## What is the purpose of the change
This pull request performs the truncate of the hadoop file only
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make
access to ExecutionGraph single threaded from JobMaster main thread
URL: https://github.com/apache/flink/pull/7568#discussion_r251471309
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11419:
---
Labels: pull-request-available (was: )
> StreamingFileSink fails to recover after
1 - 100 of 177 matches
Mail list logo
