[
https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-10344:
-
Attachment: (was: Tornado.pdf)
> Rethink SubmittedJobGraphListener
>
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623270#comment-16623270
]
ASF GitHub Bot commented on FLINK-9891:
---
azagrebin commented on a change in pull request #6718:
azagrebin commented on a change in pull request #6718: [FLINK-9891] Add
optional hook to shutdown cluster if a session was created in per-job mode in
attached mode
URL: https://github.com/apache/flink/pull/6718#discussion_r219421119
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623266#comment-16623266
]
Andrey Zagrebin commented on FLINK-10312:
-
PR suggests the following embedding of server side
[
https://issues.apache.org/jira/browse/FLINK-10376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623265#comment-16623265
]
ASF GitHub Bot commented on FLINK-10376:
TisonKun commented on issue #6721: [FLINK-10376]
TisonKun commented on issue #6721: [FLINK-10376] [tests] Replace
mkdirTolerateExisting by thread safe Files#createDirectories
URL: https://github.com/apache/flink/pull/6721#issuecomment-423456515
travis gives green and the unstable one is theoretically hardened.
@tillrohrmann
[
https://issues.apache.org/jira/browse/FLINK-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623264#comment-16623264
]
ASF GitHub Bot commented on FLINK-10255:
tillrohrmann commented on issue #6678: [FLINK-10255]
tillrohrmann commented on issue #6678: [FLINK-10255] Only react to
onAddedJobGraph signal when being leader
URL: https://github.com/apache/flink/pull/6678#issuecomment-423455756
I think it should not be possible to have two async recovery operations
ongoing since either of them will have
[
https://issues.apache.org/jira/browse/FLINK-10312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10312:
---
Labels: pull-request-available (was: )
> Wrong / missing exception when submitting job
>
[
https://issues.apache.org/jira/browse/FLINK-10312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623261#comment-16623261
]
ASF GitHub Bot commented on FLINK-10312:
azagrebin opened a new pull request #6731:
azagrebin opened a new pull request #6731: [FLINK-10312] Propagate exception
from server to client in REST API
URL: https://github.com/apache/flink/pull/6731
## What is the purpose of the change
If exception currently happens on the server side in REST API handlers, the
client side
[
https://issues.apache.org/jira/browse/FLINK-10371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623256#comment-16623256
]
ASF GitHub Bot commented on FLINK-10371:
tillrohrmann commented on a change in pull request
[
https://issues.apache.org/jira/browse/FLINK-10371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623254#comment-16623254
]
ASF GitHub Bot commented on FLINK-10371:
tillrohrmann commented on a change in pull request
[
https://issues.apache.org/jira/browse/FLINK-10371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623258#comment-16623258
]
ASF GitHub Bot commented on FLINK-10371:
tillrohrmann commented on a change in pull request
[
https://issues.apache.org/jira/browse/FLINK-10371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623255#comment-16623255
]
ASF GitHub Bot commented on FLINK-10371:
tillrohrmann commented on a change in pull request
[
https://issues.apache.org/jira/browse/FLINK-10371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623257#comment-16623257
]
ASF GitHub Bot commented on FLINK-10371:
tillrohrmann commented on a change in pull request
tillrohrmann commented on a change in pull request #6727: [FLINK-10371] Allow
to enable SSL mutual authentication on REST endpoints by configuration
URL: https://github.com/apache/flink/pull/6727#discussion_r219417270
##
File path:
tillrohrmann commented on a change in pull request #6727: [FLINK-10371] Allow
to enable SSL mutual authentication on REST endpoints by configuration
URL: https://github.com/apache/flink/pull/6727#discussion_r219416570
##
File path:
tillrohrmann commented on a change in pull request #6727: [FLINK-10371] Allow
to enable SSL mutual authentication on REST endpoints by configuration
URL: https://github.com/apache/flink/pull/6727#discussion_r219417533
##
File path:
tillrohrmann commented on a change in pull request #6727: [FLINK-10371] Allow
to enable SSL mutual authentication on REST endpoints by configuration
URL: https://github.com/apache/flink/pull/6727#discussion_r219416411
##
File path:
tillrohrmann commented on a change in pull request #6727: [FLINK-10371] Allow
to enable SSL mutual authentication on REST endpoints by configuration
URL: https://github.com/apache/flink/pull/6727#discussion_r219416858
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623253#comment-16623253
]
ASF GitHub Bot commented on FLINK-10074:
yanghua commented on issue #6567: [FLINK-10074]
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-423453821
hi @tillrohrmann what do you think about the latest implementation?
[
https://issues.apache.org/jira/browse/FLINK-10371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623236#comment-16623236
]
ASF GitHub Bot commented on FLINK-10371:
tillrohrmann commented on issue #6727: [FLINK-10371]
tillrohrmann commented on issue #6727: [FLINK-10371] Allow to enable SSL mutual
authentication on REST endpoints by configuration
URL: https://github.com/apache/flink/pull/6727#issuecomment-423449469
Thanks for your contribution @kleingeist. The documentation needs to be
updated in order
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623219#comment-16623219
]
ASF GitHub Bot commented on FLINK-9713:
---
pnowojski edited a comment on issue #6299:
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623218#comment-16623218
]
ASF GitHub Bot commented on FLINK-9713:
---
pnowojski commented on issue #6299:
pnowojski edited a comment on issue #6299: [FLINK-9713][table][sql] Support
processing time versioned joins
URL: https://github.com/apache/flink/pull/6299#issuecomment-423448194
Thanks for the review @twalthr :) I'm pushing latest update (already
squashed). Will merge it once it's green.
pnowojski commented on issue #6299: [FLINK-9713][table][sql] Support processing
time versioned joins
URL: https://github.com/apache/flink/pull/6299#issuecomment-423448194
Thanks for the review @twalthr :) I'm pushing latest update. Will merge it
once it's green.
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623217#comment-16623217
]
ASF GitHub Bot commented on FLINK-9713:
---
pnowojski commented on a change in pull request #6299:
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623216#comment-16623216
]
ASF GitHub Bot commented on FLINK-9713:
---
pnowojski commented on a change in pull request #6299:
pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql]
Support processing time versioned joins
URL: https://github.com/apache/flink/pull/6299#discussion_r219411672
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reopened FLINK-7942:
--
> NPE when apply FilterJoinRule
> -
>
> Key:
pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql]
Support processing time versioned joins
URL: https://github.com/apache/flink/pull/6299#discussion_r219411313
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623213#comment-16623213
]
ASF GitHub Bot commented on FLINK-9713:
---
pnowojski commented on a change in pull request #6299:
pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql]
Support processing time versioned joins
URL: https://github.com/apache/flink/pull/6299#discussion_r219410591
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623209#comment-16623209
]
Till Rohrmann commented on FLINK-9235:
--
What's the status of this issue [~suez1224] and [~aljoscha]?
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623207#comment-16623207
]
ASF GitHub Bot commented on FLINK-9567:
---
asfgit closed pull request #6669:
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623198#comment-16623198
]
ASF GitHub Bot commented on FLINK-9713:
---
twalthr commented on a change in pull request #6299:
asfgit closed pull request #6669: [FLINK-9567][runtime][yarn] Fix the yarn
container over allocation in…
URL: https://github.com/apache/flink/pull/6669
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
asfgit closed pull request #6719: [FLINK-10375] Add wrapped exception as cause
in ExceptionInChainedStubException
URL: https://github.com/apache/flink/pull/6719
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
[
https://issues.apache.org/jira/browse/FLINK-10260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623206#comment-16623206
]
ASF GitHub Bot commented on FLINK-10260:
asfgit closed pull request #6720: [FLINK-10260] Change
asfgit closed pull request #6720: [FLINK-10260] Change log level to debug in
ResourceManager in case of TaskExecutor reconnect
URL: https://github.com/apache/flink/pull/6720
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below
[
https://issues.apache.org/jira/browse/FLINK-10375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623205#comment-16623205
]
ASF GitHub Bot commented on FLINK-10375:
asfgit closed pull request #6719: [FLINK-10375] Add
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623203#comment-16623203
]
ASF GitHub Bot commented on FLINK-9713:
---
twalthr commented on issue #6299: [FLINK-9713][table][sql]
twalthr commented on issue #6299: [FLINK-9713][table][sql] Support processing
time versioned joins
URL: https://github.com/apache/flink/pull/6299#issuecomment-423443446
Thank you @pnowojski. I added my last 4 comments. Feel free to merge this PR
after you addressed them. +1 from my side.
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623199#comment-16623199
]
ASF GitHub Bot commented on FLINK-9713:
---
twalthr commented on a change in pull request #6299:
[
https://issues.apache.org/jira/browse/FLINK-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623196#comment-16623196
]
陈梓立 edited comment on FLINK-10385 at 9/21/18 7:36 AM:
--
Maybe a waiting utils based
twalthr commented on a change in pull request #6299: [FLINK-9713][table][sql]
Support processing time versioned joins
URL: https://github.com/apache/flink/pull/6299#discussion_r219407507
##
File path:
twalthr commented on a change in pull request #6299: [FLINK-9713][table][sql]
Support processing time versioned joins
URL: https://github.com/apache/flink/pull/6299#discussion_r219407109
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623196#comment-16623196
]
陈梓立 commented on FLINK-10385:
-
Maybe a waiting utils based on {{sleep}} and test would lose state changes
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623195#comment-16623195
]
ASF GitHub Bot commented on FLINK-10247:
Clark closed pull request #6676:
Clark closed pull request #6676: [FLINK-10247][Metrics] Run
MetricQueryService in separate thread pool
URL: https://github.com/apache/flink/pull/6676
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
[
https://issues.apache.org/jira/browse/FLINK-10263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623191#comment-16623191
]
ASF GitHub Bot commented on FLINK-10263:
dawidwys commented on a change in pull request #6725:
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623190#comment-16623190
]
ASF GitHub Bot commented on FLINK-9713:
---
twalthr commented on a change in pull request #6299:
twalthr commented on a change in pull request #6299: [FLINK-9713][table][sql]
Support processing time versioned joins
URL: https://github.com/apache/flink/pull/6299#discussion_r219405006
##
File path:
dawidwys commented on a change in pull request #6725: [FLINK-10263]
[sql-client] Fix classloader issues in SQL Client
URL: https://github.com/apache/flink/pull/6725#discussion_r219405018
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623173#comment-16623173
]
ASF GitHub Bot commented on FLINK-10386:
TisonKun edited a comment on issue #6729: [FLINK-10386]
[
https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623171#comment-16623171
]
ASF GitHub Bot commented on FLINK-10386:
TisonKun commented on issue #6729: [FLINK-10386]
TisonKun edited a comment on issue #6729: [FLINK-10386] [taskmanager] Remove
legacy class TaskExecutionStateListener
URL: https://github.com/apache/flink/pull/6729#issuecomment-423436864
Travis fails on `TaskTest` because it is based on legacy code base.
Temporarily hack to refine it.
TisonKun commented on issue #6729: [FLINK-10386] [taskmanager] Remove legacy
class TaskExecutionStateListener
URL: https://github.com/apache/flink/pull/6729#issuecomment-423436864
Travis fails on `TaskTest` because it is based on legacy code base.
Temporarily hack to refine it.
Note
[
https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10384:
---
Labels: pull-request-available (was: )
> Add Sinh math function supported in Table API and
[
https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623156#comment-16623156
]
ASF GitHub Bot commented on FLINK-10384:
yanghua opened a new pull request #6730: [FLINK-10384]
yanghua opened a new pull request #6730: [FLINK-10384] Add Sinh math function
supported in Table API and SQL
URL: https://github.com/apache/flink/pull/6730
## What is the purpose of the change
*This pull request adds Sinh math function supported in Table API and SQL*
##
[
https://issues.apache.org/jira/browse/FLINK-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623153#comment-16623153
]
zhijiang commented on FLINK-10339:
--
Hey [~NicoK] [~pnowojski], do you think we should make
[
https://issues.apache.org/jira/browse/FLINK-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623132#comment-16623132
]
ASF GitHub Bot commented on FLINK-10380:
satybald commented on issue #6724: [FLINK-10380] Add
satybald commented on issue #6724: [FLINK-10380] Add precondition for
assignToKeyGroup method
URL: https://github.com/apache/flink/pull/6724#issuecomment-423427348
@StephanEwen agree, try expression doesn't incur any performance penalties.
Another option that doesn't affect performance is
[
https://issues.apache.org/jira/browse/FLINK-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623107#comment-16623107
]
ASF GitHub Bot commented on FLINK-10380:
satybald removed a comment on issue #6724:
satybald commented on issue #6724: [FLINK-10380] Add precondition for
assignToKeyGroup method
URL: https://github.com/apache/flink/pull/6724#issuecomment-423422608
another option would be to add try/catch statement for NPE. Try statement
doesn't incur any performance issue unless an
satybald removed a comment on issue #6724: [FLINK-10380] Add precondition for
assignToKeyGroup method
URL: https://github.com/apache/flink/pull/6724#issuecomment-423422608
another option would be to add try/catch statement for NPE. Try statement
doesn't incur any performance issue unless
[
https://issues.apache.org/jira/browse/FLINK-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623106#comment-16623106
]
ASF GitHub Bot commented on FLINK-10380:
satybald commented on issue #6724: [FLINK-10380] Add
101 - 171 of 171 matches
Mail list logo
