[
https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639321#comment-16639321
]
ASF GitHub Bot commented on FLINK-10386:
TisonKun edited a comment on issue #672
TisonKun edited a comment on issue #6729: [FLINK-10386] [taskmanager] Remove
legacy class TaskExecutionStateListener
URL: https://github.com/apache/flink/pull/6729#issuecomment-427071700
All "Why are we removing these assertions?" is as you say, we do not send
those state updates via `Task
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639198#comment-16639198
]
ASF GitHub Bot commented on FLINK-10247:
Clark commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639189#comment-16639189
]
ASF GitHub Bot commented on FLINK-10247:
Clark commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639197#comment-16639197
]
ASF GitHub Bot commented on FLINK-10247:
Clark commented on a change in pull
Clark commented on a change in pull request #6759: [FLINK-10247][Metrics]
Run MetricQueryService in a dedicated actor system
URL: https://github.com/apache/flink/pull/6759#discussion_r222880990
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/Task
Clark commented on a change in pull request #6759: [FLINK-10247][Metrics]
Run MetricQueryService in a dedicated actor system
URL: https://github.com/apache/flink/pull/6759#discussion_r222880965
##
File path:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.s
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639193#comment-16639193
]
ASF GitHub Bot commented on FLINK-10247:
Clark commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639190#comment-16639190
]
ASF GitHub Bot commented on FLINK-10247:
Clark commented on a change in pull
Clark commented on a change in pull request #6759: [FLINK-10247][Metrics]
Run MetricQueryService in a dedicated actor system
URL: https://github.com/apache/flink/pull/6759#discussion_r222880749
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/Cluste
Clark commented on a change in pull request #6759: [FLINK-10247][Metrics]
Run MetricQueryService in a dedicated actor system
URL: https://github.com/apache/flink/pull/6759#discussion_r222880719
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/Cluste
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639192#comment-16639192
]
ASF GitHub Bot commented on FLINK-10247:
Clark commented on a change in pull
Clark commented on a change in pull request #6759: [FLINK-10247][Metrics]
Run MetricQueryService in a dedicated actor system
URL: https://github.com/apache/flink/pull/6759#discussion_r222880652
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/Task
Clark commented on a change in pull request #6759: [FLINK-10247][Metrics]
Run MetricQueryService in a dedicated actor system
URL: https://github.com/apache/flink/pull/6759#discussion_r222880596
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/HighAvailabili
[
https://issues.apache.org/jira/browse/FLINK-10487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639182#comment-16639182
]
ASF GitHub Bot commented on FLINK-10487:
hequn8128 commented on issue #6790: [FL
hequn8128 commented on issue #6790: [FLINK-10487] [table] fix invalid Flink SQL
example and add runnable SQL example for Java API
URL: https://github.com/apache/flink/pull/6790#issuecomment-427227713
@bowenli86 thanks for the update. LSGTM.
[
https://issues.apache.org/jira/browse/FLINK-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639056#comment-16639056
]
ASF GitHub Bot commented on FLINK-10316:
diego-carvallo-tx commented on a change
diego-carvallo-tx commented on a change in pull request #6789:
[FLINK-10316][kinesis] bug was preventing FlinkKinesisProducer to connect to
Kinesalite
URL: https://github.com/apache/flink/pull/6789#discussion_r222859878
##
File path:
flink-connectors/flink-connector-kinesis/src/ma
[
https://issues.apache.org/jira/browse/FLINK-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639026#comment-16639026
]
Diego Carvallo commented on FLINK-9544:
---
I am using the Scala sdk version 1.6.0 and
[
https://issues.apache.org/jira/browse/FLINK-10487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16639016#comment-16639016
]
ASF GitHub Bot commented on FLINK-10487:
bowenli86 commented on issue #6790: [FL
bowenli86 commented on issue #6790: [FLINK-10487] [table] fix invalid Flink SQL
example and add runnable SQL example for Java API
URL: https://github.com/apache/flink/pull/6790#issuecomment-427198159
@hequn8128 @fhueske Thanks for your review. I've updated code accordingly
[
https://issues.apache.org/jira/browse/FLINK-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10494:
---
Labels: pull-request-available (was: )
> Rename 'JobManager' to 'JobMaster' for some classe
[
https://issues.apache.org/jira/browse/FLINK-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638954#comment-16638954
]
ASF GitHub Bot commented on FLINK-9932:
---
isunjin commented on a change in pull requ
[
https://issues.apache.org/jira/browse/FLINK-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638969#comment-16638969
]
ASF GitHub Bot commented on FLINK-10494:
isunjin opened a new pull request #6794
isunjin opened a new pull request #6794: [FLINK-10494] [Job Manager] Rename
'JobManager' to 'JobMaster' for some classes in JobMaster folder
URL: https://github.com/apache/flink/pull/6794
## What is the purpose of the change
* this pull request is a code renaming, no logic change
[
https://issues.apache.org/jira/browse/FLINK-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638946#comment-16638946
]
ASF GitHub Bot commented on FLINK-9932:
---
isunjin commented on a change in pull requ
isunjin commented on a change in pull request #6780: [FLINK-9932] [runtime] fix
slot leak when task executor offer slot to job master timeout
URL: https://github.com/apache/flink/pull/6780#discussion_r222842321
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/task
isunjin commented on a change in pull request #6780: [FLINK-9932] [runtime] fix
slot leak when task executor offer slot to job master timeout
URL: https://github.com/apache/flink/pull/6780#discussion_r222842321
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/task
[
https://issues.apache.org/jira/browse/FLINK-10392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638905#comment-16638905
]
JIN SUN commented on FLINK-10392:
-
Sounds good, i will try my best. :)
> Remove legacy
[
https://issues.apache.org/jira/browse/FLINK-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10494:
Summary: Rename 'JobManager' to 'JobMaster' for some classes in JobMaster
folder (was: Rename 'JobManager
JIN SUN created FLINK-10494:
---
Summary: Rename 'JobManager' to J'obMaster' for some classes in
JobMaster folder
Key: FLINK-10494
URL: https://issues.apache.org/jira/browse/FLINK-10494
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638834#comment-16638834
]
Elias Levy commented on FLINK-10493:
This issue was noted [~tzulitai] back in June 2
[
https://issues.apache.org/jira/browse/FLINK-10459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Georgii Gobozov closed FLINK-10459.
---
> Flink cluster does not work properly in kubernetes
> -
[
https://issues.apache.org/jira/browse/FLINK-10459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638825#comment-16638825
]
Georgii Gobozov commented on FLINK-10459:
-
[~till.rohrmann] thanks, it works now
[
https://issues.apache.org/jira/browse/FLINK-10459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Georgii Gobozov resolved FLINK-10459.
-
Resolution: Fixed
> Flink cluster does not work properly in kubernetes
> ---
Elias Levy created FLINK-10493:
--
Summary: Macro generated CaseClassSerializer considered harmful
Key: FLINK-10493
URL: https://issues.apache.org/jira/browse/FLINK-10493
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-10483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy closed FLINK-10483.
--
Resolution: Invalid
> Can't restore from a savepoint even with Allow Non Restored State enabled
>
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638763#comment-16638763
]
ASF GitHub Bot commented on FLINK-9083:
---
jparkie commented on issue #6782: [FLINK-9
jparkie commented on issue #6782: [FLINK-9083][Cassandra Connector] Add async
backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#issuecomment-427147368
I think post 3.0.4 the driver doesn’t block on executeAsync() when the
internal queues are full. I
[
https://issues.apache.org/jira/browse/FLINK-10484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638756#comment-16638756
]
Jamie Grier edited comment on FLINK-10484 at 10/4/18 7:46 PM:
[
https://issues.apache.org/jira/browse/FLINK-10484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638756#comment-16638756
]
Jamie Grier commented on FLINK-10484:
-
Cool. We should definitely backport [FLINK-1
[
https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638747#comment-16638747
]
Thomas Wozniakowski commented on FLINK-10475:
-
Sure - I can update the docs.
[
https://issues.apache.org/jira/browse/FLINK-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638702#comment-16638702
]
ASF GitHub Bot commented on FLINK-10289:
isunjin commented on issue #6739: [FLIN
isunjin commented on issue #6739: [FLINK-10289] [JobManager] Classify
Exceptions to different category for apply different failover strategy
URL: https://github.com/apache/flink/pull/6739#issuecomment-427133050
@StefanRRichter Thanks for review and you make a very good point, but
annotatio
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638668#comment-16638668
]
ASF GitHub Bot commented on FLINK-9083:
---
bmeriaux commented on issue #6782: [FLINK-
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638685#comment-16638685
]
ASF GitHub Bot commented on FLINK-10205:
isunjin commented on issue #6684: [
isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault
tolerant for DataSource…
URL: https://github.com/apache/flink/pull/6684#issuecomment-427127694
@StefanRRichter thanks for comments
- for the inconsistent issue,
[this](https://github.com/isunjin/flink/commit
bmeriaux commented on issue #6782: [FLINK-9083][Cassandra Connector] Add async
backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#issuecomment-427124744
Nice work ! i ask my self if it should be push down to the driver or not ?
--
[
https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638644#comment-16638644
]
ASF GitHub Bot commented on FLINK-8424:
---
bmeriaux commented on issue #6715: [FLINK-
bmeriaux commented on issue #6715: [FLINK-8424] update cassandra and driver
version to latest
URL: https://github.com/apache/flink/pull/6715#issuecomment-427121123
Hi, do you have any idea when this will be merged ? 1.6.2 ? or 1.7.0 ?
---
[
https://issues.apache.org/jira/browse/FLINK-10392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638600#comment-16638600
]
tison commented on FLINK-10392:
---
[~isunjin] Previously I made a similar proposal but now
markcho opened a new pull request #6793: [hotfix] [docs] Update cluster setup
docs to reflect the new syntax of jobmanager.sh script.
URL: https://github.com/apache/flink/pull/6793
[docs] Update cluster setup docs to reflect the new syntax of jobmanager.sh
script.
jobmanager.sh scri
[
https://issues.apache.org/jira/browse/FLINK-10392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638539#comment-16638539
]
JIN SUN commented on FLINK-10392:
-
+1, can we also do the refactor by move the code to a
[
https://issues.apache.org/jira/browse/FLINK-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638496#comment-16638496
]
ASF GitHub Bot commented on FLINK-10289:
StefanRRichter commented on issue #6739
StefanRRichter commented on issue #6739: [FLINK-10289] [JobManager] Classify
Exceptions to different category for apply different failover strategy
URL: https://github.com/apache/flink/pull/6739#issuecomment-427087088
@isunjin I also like the general idea, but not so much the current
imple
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638449#comment-16638449
]
ASF GitHub Bot commented on FLINK-10205:
StefanRRichter commented on issue #6684
[
https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638448#comment-16638448
]
ASF GitHub Bot commented on FLINK-10386:
TisonKun commented on a change in pull
TisonKun commented on a change in pull request #6729: [FLINK-10386]
[taskmanager] Remove legacy class TaskExecutionStateListener
URL: https://github.com/apache/flink/pull/6729#discussion_r222733909
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/
[
https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638391#comment-16638391
]
ASF GitHub Bot commented on FLINK-10386:
TisonKun commented on a change in pull
TisonKun edited a comment on issue #6729: [FLINK-10386] [taskmanager] Remove
legacy class TaskExecutionStateListener
URL: https://github.com/apache/flink/pull/6729#issuecomment-427071700
All "Why are we removing these assertions?" is as you say, we do not send
those state updates via `Task
[
https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638426#comment-16638426
]
ASF GitHub Bot commented on FLINK-10386:
TisonKun edited a comment on issue #672
[
https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638424#comment-16638424
]
ASF GitHub Bot commented on FLINK-10386:
TisonKun commented on issue #6729: [FLI
TisonKun commented on issue #6729: [FLINK-10386] [taskmanager] Remove legacy
class TaskExecutionStateListener
URL: https://github.com/apache/flink/pull/6729#issuecomment-427071700
All "Why are we removing these assertions?" is as you say, we do not send
those state updates via `TaskManager
[
https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638401#comment-16638401
]
ASF GitHub Bot commented on FLINK-10386:
TisonKun commented on issue #6729: [FLI
TisonKun commented on issue #6729: [FLINK-10386] [taskmanager] Remove legacy
class TaskExecutionStateListener
URL: https://github.com/apache/flink/pull/6729#issuecomment-427068734
@tillrohrmann currently our production codes never deal with the message
send by `notifyObservers`, because th
TisonKun commented on a change in pull request #6729: [FLINK-10386]
[taskmanager] Remove legacy class TaskExecutionStateListener
URL: https://github.com/apache/flink/pull/6729#discussion_r222721494
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/
[
https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638389#comment-16638389
]
ASF GitHub Bot commented on FLINK-10386:
TisonKun commented on a change in pull
TisonKun commented on a change in pull request #6729: [FLINK-10386]
[taskmanager] Remove legacy class TaskExecutionStateListener
URL: https://github.com/apache/flink/pull/6729#discussion_r222721303
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/
[
https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638386#comment-16638386
]
ASF GitHub Bot commented on FLINK-10386:
TisonKun commented on a change in pull
TisonKun commented on a change in pull request #6729: [FLINK-10386]
[taskmanager] Remove legacy class TaskExecutionStateListener
URL: https://github.com/apache/flink/pull/6729#discussion_r222720265
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/
[
https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638378#comment-16638378
]
Yun Gao commented on FLINK-10469:
-
I commented on the pull request, but it seems that th
[
https://issues.apache.org/jira/browse/FLINK-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638284#comment-16638284
]
ASF GitHub Bot commented on FLINK-10316:
tweise commented on a change in pull re
tweise commented on a change in pull request #6789: [FLINK-10316][kinesis] bug
was preventing FlinkKinesisProducer to connect to Kinesalite
URL: https://github.com/apache/flink/pull/6789#discussion_r222691000
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/
[
https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638273#comment-16638273
]
ASF GitHub Bot commented on FLINK-10008:
Xpray commented on issue #6465: [FLINK-
Xpray commented on issue #6465: [FLINK-10008] [table] Improve the LOG function
in Table to support bases less than 1
URL: https://github.com/apache/flink/pull/6465#issuecomment-427033176
It's strange that I rebase the master and modified the sql.md, but it always
shows a conflict.
---
[
https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638251#comment-16638251
]
ASF GitHub Bot commented on FLINK-9997:
---
Xpray commented on a change in pull reques
[
https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638253#comment-16638253
]
ASF GitHub Bot commented on FLINK-9997:
---
Xpray commented on a change in pull reques
Xpray commented on a change in pull request #6455: [FLINK-9997] [table] Improve
Expression Reduce
URL: https://github.com/apache/flink/pull/6455#discussion_r222677511
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/ExpressionReductionRulesTest.s
Xpray commented on a change in pull request #6455: [FLINK-9997] [table] Improve
Expression Reduce
URL: https://github.com/apache/flink/pull/6455#discussion_r222677293
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/FlinkRuleSets.scala
###
[
https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638249#comment-16638249
]
ASF GitHub Bot commented on FLINK-9997:
---
Xpray commented on a change in pull reques
Xpray commented on a change in pull request #6455: [FLINK-9997] [table] Improve
Expression Reduce
URL: https://github.com/apache/flink/pull/6455#discussion_r222677089
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
##
Piotr Nowojski created FLINK-10491:
--
Summary: Deadlock during spilling data in SpillableSubpartition
Key: FLINK-10491
URL: https://issues.apache.org/jira/browse/FLINK-10491
Project: Flink
I
Tzu-Li (Gordon) Tai created FLINK-10492:
---
Summary: Document generic support for configuring AwsKinesisClient
in the Kinesis Consumer
Key: FLINK-10492
URL: https://issues.apache.org/jira/browse/FLINK-10492
[
https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-10491:
---
Priority: Critical (was: Major)
> Deadlock during spilling data in SpillableSubpartition
>
[
https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638144#comment-16638144
]
ASF GitHub Bot commented on FLINK-10309:
GJL commented on issue #6785: [FLINK-10
[
https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-10354.
--
Resolution: Fixed
Fix Version/s: 1.5.5
1.6.2
Fixed in master
[
https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-8880:
Assignee: (was: Rong Rong)
> Validate configurations for SQL Client
>
[
https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638159#comment-16638159
]
Rong Rong commented on FLINK-8880:
--
[~twalthr] yes aboslutely. please go ahead.
> Vali
GJL commented on issue #6785: [FLINK-10309][rest] Before shutting down cluster,
wait for asynchronous operations
URL: https://github.com/apache/flink/pull/6785#issuecomment-426998950
There are some test failures that I have to look into.
[
https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638121#comment-16638121
]
Yun Gao commented on FLINK-10469:
-
[~NicoK] [~pnowojski] Sorry for responding later. I f
[
https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10474:
---
Labels: pull-request-available (was: )
> Don't translate IN to JOIN with VALUES for streami
[
https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638101#comment-16638101
]
ASF GitHub Bot commented on FLINK-10474:
hequn8128 opened a new pull request #67
hequn8128 opened a new pull request #6792: [FLINK-10474][table] Don't translate
IN/NOT_IN to JOIN with VALUES
URL: https://github.com/apache/flink/pull/6792
## What is the purpose of the change
IN clauses are translated to JOIN with VALUES if the number of elements in
the IN cla
[
https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-9422:
-
Summary: Dedicated DISTINCT operator for streaming tables with time
attributes (was: Dedicated o
[
https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638099#comment-16638099
]
ASF GitHub Bot commented on FLINK-10354:
dawidwys closed pull request #6704: [FL
[
https://issues.apache.org/jira/browse/FLINK-10488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-10488.
-
Resolution: Duplicate
Duplicate of FLINK-9422
> Add DISTINCT operator for streaming tables that
dawidwys closed pull request #6704: [FLINK-10354] Revert "[FLINK-6328] [chkPts]
Don't add savepoints to CompletedCheckpointStore"
URL: https://github.com/apache/flink/pull/6704
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-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638073#comment-16638073
]
ASF GitHub Bot commented on FLINK-10470:
pnowojski commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638097#comment-16638097
]
Fabian Hueske commented on FLINK-10488:
---
Yes, thanks for noticing!
> Add DISTINCT
[
https://issues.apache.org/jira/browse/FLINK-8594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-8594:
---
Summary: Add a dedicated DISTINCT operator to always produce append sreams
(was: Make producesUpdate
1 - 100 of 176 matches
Mail list logo
