[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525007#comment-16525007
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user xccui commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/6090#discussion_r198482931
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/UDFDescriptor.java
---
@@ -0,0 +1,153 @@
+/*
+ *
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/6090
Hi @twalthr, sorry for the delay. I've been quite busy with my graduation
these weeks. Everything's finished now and I'll put these tasks back on track.
---
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525103#comment-16525103
]
ASF GitHub Bot commented on FLINK-9444:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9444:
--
Labels: patch pull-request-available (was: patch)
> KafkaAvroTableSource failed to work for
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5410
---
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525156#comment-16525156
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524984#comment-16524984
]
ASF GitHub Bot commented on FLINK-9593:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524986#comment-16524986
]
ASF GitHub Bot commented on FLINK-9593:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9593:
--
Labels: pull-request-available (was: )
> Unify AfterMatch semantics with SQL MATCH_RECOGNIZE
[
https://issues.apache.org/jira/browse/FLINK-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524983#comment-16524983
]
ASF GitHub Bot commented on FLINK-9593:
---
Github user kl0u commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/6090#discussion_r198485307
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/PrimitiveTypeDescriptor.scala
---
@@ -0,0 +1,56 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525024#comment-16525024
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524989#comment-16524989
]
Till Rohrmann commented on FLINK-9662:
--
This is correct [~gzm55]. I think that this is quite easy to
[
https://issues.apache.org/jira/browse/FLINK-9474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9474:
--
Summary: Add runtime support of distinct filter using ElasticBloomFilter
(was: Introduce an
Yazdan Shirvany created FLINK-9679:
--
Summary: Implement AvroSerializationSchema
Key: FLINK-9679
URL: https://issues.apache.org/jira/browse/FLINK-9679
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9647:
-
Summary: Files uploaded to blobservice during job submission aren't removed
on failure (was:
[
https://issues.apache.org/jira/browse/FLINK-9647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9647:
Description:
During the job-submission clients upload jars, and in 1.6+ also distributed
[
https://issues.apache.org/jira/browse/FLINK-9647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9647:
Description:
During the job-submission clients upload jars, and in 1.6+ also distributed
[
https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525031#comment-16525031
]
Sergey Nuyanzin commented on FLINK-4542:
Hello [~twalthr]. Thank you for your comment
yes Calcite
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525033#comment-16525033
]
ASF GitHub Bot commented on FLINK-9634:
---
Github user tillrohrmann closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9634.
Resolution: Fixed
Fixed via
1.6.0: d5919d9c1d4054dbfa182e482e082940b4e2f24d
1.5.1:
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/6208
---
[
https://issues.apache.org/jira/browse/FLINK-9474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9474:
--
Description: We can implement an approximate version of "distinct filter"
base on the "Elastic Bloom
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525151#comment-16525151
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user medcv commented on the issue:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6171#discussion_r198472975
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java
---
@@ -79,18 +98,18 @@ public boolean equals(Object o) {
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6171#discussion_r198472927
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java
---
@@ -79,18 +98,18 @@ public boolean equals(Object o) {
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6171#discussion_r198474417
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -330,77 +328,85 @@ private boolean isStateTimedOut(final
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6171#discussion_r198473426
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,155 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524982#comment-16524982
]
ASF GitHub Bot commented on FLINK-9593:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524985#comment-16524985
]
ASF GitHub Bot commented on FLINK-9593:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6171#discussion_r198473858
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -330,77 +328,85 @@ private boolean isStateTimedOut(final
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/6218
[FLINK-9444] [formats] Add full SQL support for Avro formats
## What is the purpose of the change
This PR adds full support of Apache Avro records for the Table API & SQL.
It adds
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. However,
users
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. Users want
to do
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6083
@tillrohrmann make sense.
I created this ticket https://issues.apache.org/jira/browse/FLINK-9679 for
implementing `AvroSerializationConfluentSchema`. I will make a PR for it
shortly.
Mean
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8468.
--
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-9677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525223#comment-16525223
]
ASF GitHub Bot commented on FLINK-9677:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525242#comment-16525242
]
Sergey Nuyanzin commented on FLINK-4542:
You are right, just pushed test in
Chesnay Schepler created FLINK-9680:
---
Summary: Reduce heartbeat timeout for E2E tests
Key: FLINK-9680
URL: https://issues.apache.org/jira/browse/FLINK-9680
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-9524.
Resolution: Fixed
Fix Version/s: 1.5.1
1.4.3
1.6.0
[
https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525207#comment-16525207
]
Timo Walther commented on FLINK-4542:
-
I checked out your branch but I could not find the failing
[
https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525322#comment-16525322
]
ASF GitHub Bot commented on FLINK-9524:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525323#comment-16525323
]
ASF GitHub Bot commented on FLINK-9524:
---
Github user asfgit closed the pull request at:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/6180
Thanks for the update @yzandrew.
Merging
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6180
---
[
https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525331#comment-16525331
]
Elias Levy commented on FLINK-9662:
---
I like the direction of this. And as I mentioned in the other
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6217
merging.
---
GitHub user elbaulp opened a pull request:
https://github.com/apache/flink/pull/6219
[hotfix] Fixed typo in docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/elbaulp/flink patch-1
Alternatively you can review and apply these
Hequn Cheng created FLINK-9681:
--
Summary: Make sure minRetentionTime not equal to maxRetentionTime
Key: FLINK-9681
URL: https://issues.apache.org/jira/browse/FLINK-9681
Project: Flink
Issue
Elias Levy created FLINK-9682:
-
Summary: Add setDescription to execution environment and display
it in the UI
Key: FLINK-9682
URL: https://issues.apache.org/jira/browse/FLINK-9682
Project: Flink
Ethan Li created FLINK-9683:
---
Summary: inconsistent behaviors when setting
historyserver.archive.fs.dir
Key: FLINK-9683
URL: https://issues.apache.org/jira/browse/FLINK-9683
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525505#comment-16525505
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6083
@tillrohrmann PR has been updated!
I had to do some changes:
- map `User` object to `String` in `TestAvroConsumerConfluent` class
- use `read_messages_from_kafka` instead of
Github user etiennecarriere commented on the issue:
https://github.com/apache/flink/pull/6149
Hi @pnowojski,
Unfortunately, this patch is not working because :
* The implementation of FileSystem is using a temporary file to store it
** s3 : it is mandatory to know
[
https://issues.apache.org/jira/browse/FLINK-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525534#comment-16525534
]
ASF GitHub Bot commented on FLINK-9560:
---
Github user etiennecarriere commented on the issue:
Ethan Li created FLINK-9684:
---
Summary: HistoryServerArchiveFetcher not working properly with
secure hdfs cluster
Key: FLINK-9684
URL: https://issues.apache.org/jira/browse/FLINK-9684
Project: Flink
Ethan Li created FLINK-9685:
---
Summary: Flink should support hostname-substitution for
security.kerberos.login.principal
Key: FLINK-9685
URL: https://issues.apache.org/jira/browse/FLINK-9685
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525650#comment-16525650
]
Ying Xu commented on FLINK-4582:
Hi:
[~tzulitai] [~mingdaoy]
I'm following up on this JIRA as we
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524974#comment-16524974
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8468:
Assignee: Ph.Duveau
> Make the connector to take advantage of AMQP features (routing key,
[
https://issues.apache.org/jira/browse/FLINK-9665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525017#comment-16525017
]
ASF GitHub Bot commented on FLINK-9665:
---
Github user jelmerk commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525020#comment-16525020
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user xccui commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/6090#discussion_r198484614
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
---
@@ -187,6 +206,7 @@ private
Github user jelmerk commented on a diff in the pull request:
https://github.com/apache/flink/pull/6211#discussion_r198484545
--- Diff:
flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTest.java
---
@@ -159,6 +162,27 @@
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525030#comment-16525030
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user xccui commented on the issue:
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r198677754
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala
---
@@ -16,21 +16,18 @@
*
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525757#comment-16525757
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff in the pull
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r198677762
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala
---
@@ -16,21 +16,18 @@
*
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525755#comment-16525755
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525753#comment-16525753
]
Shuyi Chen commented on FLINK-6962:
---
Hi [~shenyufeng], I am finalizing the DDL design doc and should
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r198677922
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala
---
@@ -16,21 +16,18 @@
*
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525761#comment-16525761
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525764#comment-16525764
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff in the pull
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r198678147
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/connector/TableSinkFactoryServiceTest.scala
---
@@ -0,0 +1,84 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-9543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525692#comment-16525692
]
ASF GitHub Bot commented on FLINK-9543:
---
Github user lamber-ken commented on the issue:
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6195
@zentol , cc.
---
[
https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525694#comment-16525694
]
ASF GitHub Bot commented on FLINK-9666:
---
Github user lamber-ken commented on the issue:
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6212
hi, @StephanEwen, @tillrohrmann cc.
---
[
https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9643:
-
Affects Version/s: (was: 1.6.0)
(was: 1.4.2)
[
https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524861#comment-16524861
]
Till Rohrmann commented on FLINK-9643:
--
I did not test it and assumed that it would also be a
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524850#comment-16524850
]
zhangminglei edited comment on FLINK-9675 at 6/27/18 10:09 AM:
---
+1,
There
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r198439148
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateVisibility.java
---
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-9674:
---
Assignee: Chesnay Schepler
> Remove 65s sleep in QueryableState E2E test
>
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524863#comment-16524863
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524864#comment-16524864
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff in the pull
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r198439894
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524871#comment-16524871
]
James Z.M. Gao commented on FLINK-9662:
---
[~till.rohrmann]
In a tagged scheduling system, when one
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524873#comment-16524873
]
zhijiang commented on FLINK-9676:
-
[~NicoK], I think this is a bug in credit-based mode.
> Deadlock
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524908#comment-16524908
]
ASF GitHub Bot commented on FLINK-9634:
---
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/6208#discussion_r198453459
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/LocationPreferenceSchedulingStrategy.java
---
@@ -0,0 +1,119 @@
[
https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524641#comment-16524641
]
yinhua.dai commented on FLINK-9565:
---
[~fhueske] [~twalthr]
So there are two options:
#1. using
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524649#comment-16524649
]
Gary Yao commented on FLINK-4534:
-
Is this really needed? Flink callbacks are generally not invoked
[
https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524647#comment-16524647
]
Gary Yao commented on FLINK-9649:
-
[~lishim] In FLIP-6 mode, resources are allocated dynamically:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6208#discussion_r198421923
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulingStrategy.java
---
@@ -0,0 +1,60 @@
+/*
+ *
1 - 100 of 208 matches
Mail list logo
