danny0405 commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301445349
##
File path:
danny0405 commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301445439
##
File path: flink-table/flink-table-planner/pom.xml
##
@@ -88,26 +88,26 @@
danny0405 commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301445282
##
File path:
ye-lun commented on a change in pull request #8995:
[FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese
URL: https://github.com/apache/flink/pull/8995#discussion_r301445869
##
File path: docs/dev/parallel.zh.md
##
@@ -22,29 +22,20 @@ specific language
[
https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-13163:
--
Component/s: (was: Runtime / Configuration)
> Default value of slot.request.timeout is
[
https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-13163:
--
Issue Type: Improvement (was: Bug)
> Default value of slot.request.timeout is too small for
[
https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-13163:
--
Fix Version/s: 1.9.0
> Default value of slot.request.timeout is too small for batch job
>
[
https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881035#comment-16881035
]
Till Rohrmann commented on FLINK-13163:
---
Thanks for opening this issue [~zjffdu]. You are right
danny0405 commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301447999
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-13101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-13101.
Resolution: Implemented
Added on master in
5e27744c94c59f2bcc661b3f94f311221c021773
>
[
https://issues.apache.org/jira/browse/FLINK-13098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-13098.
Resolution: Implemented
Added on master in
47d7eaa67f837d51bf0600b2d2d6d0f4202b6c0a
>
aljoscha commented on issue #8985: [FLINK-13101][datastream] Introduce
blockingConnectionsBetweenChains property of StreamGraph
URL: https://github.com/apache/flink/pull/8985#issuecomment-509538351
Merged.
This is an
aljoscha closed pull request #8985: [FLINK-13101][datastream] Introduce
blockingConnectionsBetweenChains property of StreamGraph
URL: https://github.com/apache/flink/pull/8985
This is an automated message from the Apache
danny0405 commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301450484
##
File path:
xuchao0903 commented on issue #9005: FLINK-13130 Refactor
AbstractYarnClusterDescriptor to avoid code duplication
URL: https://github.com/apache/flink/pull/9005#issuecomment-509545158
Thank you for your comment, wangyang.
[
https://issues.apache.org/jira/browse/FLINK-13123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-13123:
-
Description:
Currently, the REST API and CLI around stopping and cancelling jobs are
knaufk opened a new pull request #9030: [FLINK-13123] Align Stop/Cancel
Commands in CLI and REST Interface and Improve Documentation
URL: https://github.com/apache/flink/pull/9030
## What is the purpose of the change
Currently, the REST API and CLI around stopping and cancelling
xuchao0903 edited a comment on issue #9005: FLINK-13130 Refactor
AbstractYarnClusterDescriptor to avoid code duplication
URL: https://github.com/apache/flink/pull/9005#issuecomment-509545158
Thank you for your comment, Myasuka and wangyang.
[
https://issues.apache.org/jira/browse/FLINK-13123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13123:
---
Labels: pull-request-available (was: )
> Align Stop/Cancel Commands in CLI and REST
ifndef-SleePy closed pull request #8982: [FLINK-13098][datastream] Add a new
type UNDEFINED of shuffle mode
URL: https://github.com/apache/flink/pull/8982
This is an automated message from the Apache Git Service.
To respond
Till Rohrmann created FLINK-13165:
-
Summary: Complete requested slots in request order
Key: FLINK-13165
URL: https://issues.apache.org/jira/browse/FLINK-13165
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-13155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880910#comment-16880910
]
Zhenghua Gao edited comment on FLINK-13155 at 7/9/19 8:44 AM:
--
FLINK-12024
flinkbot commented on issue #9028: [hotfix][python] Update the package name
from pyflink to apache-flink
URL: https://github.com/apache/flink/pull/9028#issuecomment-509550750
CI report for commit 3be73a6114eef6b5858596964068d3837f4d0409: SUCCESS
[
https://issues.apache.org/jira/browse/FLINK-13155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881059#comment-16881059
]
Zhenghua Gao commented on FLINK-13155:
--
Find another issue: flink-sql-client jar missed
zjuwangg opened a new pull request #9032: [FLINK-13160]HiveTaleSource should
implement PartitionableTableSource
URL: https://github.com/apache/flink/pull/9032
## What is the purpose of the change
* implement PartitionableTableSource for HiveTaleSource to support partition
pruning*
[
https://issues.apache.org/jira/browse/FLINK-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13160:
---
Labels: pull-request-available (was: )
> HiveTaleSource should implment
[
https://issues.apache.org/jira/browse/FLINK-13124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-13124:
-
Description:
When running the {{StateMachineExample}} (with the universal Kafka
[
https://issues.apache.org/jira/browse/FLINK-13124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-13124:
-
Description:
When running the {{StateMachineExample}} (with the universal Kafka
klion26 commented on a change in pull request #8995:
[FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese
URL: https://github.com/apache/flink/pull/8995#discussion_r301482473
##
File path: docs/dev/parallel.zh.md
##
@@ -80,17 +71,11 @@ env.execute("Word
klion26 commented on a change in pull request #8995:
[FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese
URL: https://github.com/apache/flink/pull/8995#discussion_r301481947
##
File path: docs/dev/parallel.zh.md
##
@@ -22,29 +22,20 @@ specific language
[
https://issues.apache.org/jira/browse/FLINK-13124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-13124:
-
Description:
When running the {{StateMachineExample}} (with the universal Kafka
[
https://issues.apache.org/jira/browse/FLINK-13167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luo Gen updated FLINK-13167:
Description:
Import/export a trained model is an important part in machine learning
lifecycle,
[
https://issues.apache.org/jira/browse/FLINK-13124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881098#comment-16881098
]
Kostas Kloudas commented on FLINK-13124:
Thanks for all the runs [~knaufk]. I think I know now
flinkbot commented on issue #9033: [FLINK-13167] Introduce FlinkML
import/export framework
URL: https://github.com/apache/flink/pull/9033#issuecomment-509574448
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
ye-lun commented on a change in pull request #8995:
[FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese
URL: https://github.com/apache/flink/pull/8995#discussion_r301495755
##
File path: docs/dev/parallel.zh.md
##
@@ -22,29 +22,20 @@ specific language
[
https://issues.apache.org/jira/browse/FLINK-13167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13167:
---
Labels: pull-request-available (was: )
> Introduce FlinkML import/export framework
>
[
https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13063:
---
Labels: pull-request-available (was: )
> AsyncWaitOperator shouldn't be releasing
StefanRRichter opened a new pull request #9034: [FLINK-13063] Temporary fix for
AsyncWaitOperator consistency problems.
URL: https://github.com/apache/flink/pull/9034
## What is the purpose of the change
This PR is a temporary fix for the consistency problems with the
godfrey he created FLINK-13168:
--
Summary: clarify isBatch/isStreaming/isBounded flag in flink
planner and blink planner
Key: FLINK-13168
URL: https://issues.apache.org/jira/browse/FLINK-13168
Project:
ye-lun commented on a change in pull request #8995:
[FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese
URL: https://github.com/apache/flink/pull/8995#discussion_r301502631
##
File path: docs/dev/parallel.zh.md
##
@@ -80,17 +71,11 @@ env.execute("Word
[
https://issues.apache.org/jira/browse/FLINK-13019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-13019:
Summary: IT test for fine-grained recovery (user code failures) (was: IT
test for
wuchong commented on a change in pull request #8995:
[FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese
URL: https://github.com/apache/flink/pull/8995#discussion_r301503461
##
File path: docs/dev/parallel.zh.md
##
@@ -22,29 +22,20 @@ specific language
StephanEwen commented on issue #8740: [FLINK-12763][runtime] Fail job
immediately if tasks’ resource needs can not be satisfied.
URL: https://github.com/apache/flink/pull/8740#issuecomment-509583218
Looks good overall. And thanks for splitting this into finer grained commits
for the
StephanEwen edited a comment on issue #8740: [FLINK-12763][runtime] Fail job
immediately if tasks’ resource needs can not be satisfied.
URL: https://github.com/apache/flink/pull/8740#issuecomment-509583218
Looks good overall. And thanks for splitting this into finer grained commits
for
flinkbot commented on issue #8964: [FLINK-13067][docs] Fix broken links to
contributing docs
URL: https://github.com/apache/flink/pull/8964#issuecomment-509584577
CI report for commit f37d146ddc4745ca806c4c283eba837c117bc891: FAILURE
pnowojski commented on a change in pull request #8742: [FLINK-11879] Add
validators for the uses of InputSelectable, BoundedOneInput and
BoundedMultiInput
URL: https://github.com/apache/flink/pull/8742#discussion_r301507241
##
File path:
zjuwangg commented on issue #9032: [FLINK-13160]HiveTaleSource should implement
PartitionableTableSource
URL: https://github.com/apache/flink/pull/9032#issuecomment-509585731
cc @bowenli86 @xuefuz @lirui-apache
Travis-CLI [link ](https://travis-ci.com/zjuwangg/flink/builds/118411999)
godfreyhe opened a new pull request #9035: [FLINK-13168] [table] clarify
isBatch/isStreaming/isBounded flag in flink planner and blink planner
URL: https://github.com/apache/flink/pull/9035
## What is the purpose of the change
*clarify isBatch/isStreaming/isBounded flag in
flinkbot commented on issue #9035: [FLINK-13168] [table] clarify
isBatch/isStreaming/isBounded flag in flink planner and blink planner
URL: https://github.com/apache/flink/pull/9035#issuecomment-509586459
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
godfreyhe commented on issue #9035: [FLINK-13168] [table] clarify
isBatch/isStreaming/isBounded flag in flink planner and blink planner
URL: https://github.com/apache/flink/pull/9035#issuecomment-509586452
cc @KurtYoung @twalthr @dawidwys
[
https://issues.apache.org/jira/browse/FLINK-13168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13168:
---
Labels: pull-request-available (was: )
> clarify isBatch/isStreaming/isBounded flag in
xintongsong commented on issue #8740: [FLINK-12763][runtime] Fail job
immediately if tasks’ resource needs can not be satisfied.
URL: https://github.com/apache/flink/pull/8740#issuecomment-509587077
Thank you for the review, @StephanEwen.
I don't think this is a bug. If the required
JingsongLi opened a new pull request #9036: [FLINK-13112][table-planner-blink]
Support LocalZonedTimestampType in blink
URL: https://github.com/apache/flink/pull/9036
## What is the purpose of the change
Now we just support TimestampType, it is without time zone.
We need
[
https://issues.apache.org/jira/browse/FLINK-13112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13112:
---
Labels: pull-request-available (was: )
> Support LocalZonedTimestampType in blink
>
pnowojski commented on a change in pull request #9034: [FLINK-13063] Temporary
fix for AsyncWaitOperator consistency problems.
URL: https://github.com/apache/flink/pull/9034#discussion_r301512883
##
File path:
flinkbot commented on issue #9036: [FLINK-13112][table-planner-blink] Support
LocalZonedTimestampType in blink
URL: https://github.com/apache/flink/pull/9036#issuecomment-509588316
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881129#comment-16881129
]
Yingjie Cao commented on FLINK-13100:
-
The deadlock problem of spillable subpartition has been
StefanRRichter commented on a change in pull request #9034: [FLINK-13063]
Temporary fix for AsyncWaitOperator consistency problems.
URL: https://github.com/apache/flink/pull/9034#discussion_r301520850
##
File path:
flinkbot commented on issue #8756: [FLINK-12406] [Runtime] Report
BLOCKING_PERSISTENT result partition meta back to client
URL: https://github.com/apache/flink/pull/8756#issuecomment-509593017
CI report for commit bd59e50f39211665ce6dc16e0ba6643dcb8ccc0d: FAILURE
ye-lun commented on a change in pull request #8995:
[FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese
URL: https://github.com/apache/flink/pull/8995#discussion_r301525333
##
File path: docs/dev/parallel.zh.md
##
@@ -22,29 +22,20 @@ specific language
lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build
to Travis
URL: https://github.com/apache/flink/pull/8911#issuecomment-509596454
Updated to move the build to cron job. This build on my own repo verifies
it's working properly,
flinkbot commented on issue #9027: [FLINK-13161][table-blink-runtime]numBuckets
calculate wrong in BinaryHashBucketArea
URL: https://github.com/apache/flink/pull/9027#issuecomment-509597728
CI report for commit 43527e1d5c4bba23569e3b7d908ab93c6bb9a59e: SUCCESS
xintongsong edited a comment on issue #8740: [FLINK-12763][runtime] Fail job
immediately if tasks’ resource needs can not be satisfied.
URL: https://github.com/apache/flink/pull/8740#issuecomment-509587077
Thank you for the review, @StephanEwen.
I don't think this is a bug. If the
xintongsong edited a comment on issue #8740: [FLINK-12763][runtime] Fail job
immediately if tasks’ resource needs can not be satisfied.
URL: https://github.com/apache/flink/pull/8740#issuecomment-509587077
Thank you for the review, @StephanEwen.
I don't think this is a bug. If the
StefanRRichter merged pull request #8613: [FLINK-12730][Runtime / Coordination]
Combine BitSet implementations in flink-runtime
URL: https://github.com/apache/flink/pull/8613
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-12730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-12730.
--
Resolution: Implemented
Merged in:
master: 14c4b23
> Combine BitSet implementations in
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881029#comment-16881029
]
zhijiang commented on FLINK-13100:
--
Yes, the ITCase is also necessary and I think it should already
danny0405 commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301447088
##
File path:
danny0405 commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301447434
##
File path:
Myasuka commented on issue #8964: [FLINK-13067][docs] Fix broken links to
contributing docs
URL: https://github.com/apache/flink/pull/8964#issuecomment-509536391
@StephanEwen I noticed `flink-libraries/flink-ml` have been removed, shall I
rebase latest code again for this PR?
flinkbot commented on issue #8987: [FLINK-13090][hive] Test Hive connector with
hive runner
URL: https://github.com/apache/flink/pull/8987#issuecomment-509536632
CI report for commit c0939e07ad5c7c5aef85a811f30bb7150a4a471d: SUCCESS
[
https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-13163:
--
Summary: Support execution of batch jobs with fewer slots than requested
(was: Default value
azagrebin commented on issue #8988: [FLINK-12736][coordination] Release
TaskExecutor in SlotManager if no slot allocations after partition check
URL: https://github.com/apache/flink/pull/8988#issuecomment-509538110
Thanks for the review @tillrohrmann, I addressed the comments
flinkbot commented on issue #9029: [FLINK-13118][jdbc] Introduce JDBC table
factory and bridge JDBC table source with streaming table source
URL: https://github.com/apache/flink/pull/9029#issuecomment-509538104
Thanks a lot for your contribution to the Apache Flink project. I'm the
[
https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-13163:
--
Description:
Flink should be able to execute batch jobs with fewer slots than requested in a
[
https://issues.apache.org/jira/browse/FLINK-13155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13155:
---
Labels: pull-request-available test-stability (was: test-stability)
> SQL Client
flinkbot commented on issue #9031: [FLINK-13155][hotfix][e2e] fix SQL Client
end-to-end test
URL: https://github.com/apache/flink/pull/9031#issuecomment-509548839
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
docete opened a new pull request #9031: [FLINK-13155][hotfix][e2e] fix SQL
Client end-to-end test
URL: https://github.com/apache/flink/pull/9031
## What is the purpose of the change
Fix SQL Client e2e test
## Brief change log
Fix SQL Client e2e test
## Verifying
ifndef-SleePy commented on issue #8982: [FLINK-13098][datastream] Add a new
type UNDEFINED of shuffle mode
URL: https://github.com/apache/flink/pull/8982#issuecomment-509549957
This PR is merged through https://github.com/apache/flink/pull/8985. So
close it.
Till Rohrmann created FLINK-13166:
-
Summary: Support batch slot requests
Key: FLINK-13166
URL: https://issues.apache.org/jira/browse/FLINK-13166
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-13124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-13124:
-
Description:
When running the {{StateMachineExample}} (with the universal Kafka
[
https://issues.apache.org/jira/browse/FLINK-13124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-13124:
-
Description:
When running the {{StateMachineExample}} (with the universal Kafka
flinkbot commented on issue #9032: [FLINK-13160]HiveTaleSource should implement
PartitionableTableSource
URL: https://github.com/apache/flink/pull/9032#issuecomment-509558538
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
gyfora commented on issue #8410: [FLINK-11159] Allow configuration whether to
fall back to savepoints for restore
URL: https://github.com/apache/flink/pull/8410#issuecomment-509561771
@StephanEwen @zentol I agree with most comments, and as far as the logging,
exception handling goes it
KurtYoung commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301484630
##
File path:
KurtYoung commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301461918
##
File path:
KurtYoung commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301482814
##
File path:
KurtYoung commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301462925
##
File path:
KurtYoung commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301487778
##
File path:
KurtYoung commented on a change in pull request #8844:
[FLINK-12951][table-planner] Add logic to bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#discussion_r301466632
##
File path:
Luo Gen created FLINK-13167:
---
Summary: Introduce FlinkML import/export framework
Key: FLINK-13167
URL: https://issues.apache.org/jira/browse/FLINK-13167
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-13167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luo Gen updated FLINK-13167:
Description:
Import/export a trained model is an important part in machine learning
lifecycle,
flinkbot commented on issue #8957: [hotfix][docs] fix broken links
URL: https://github.com/apache/flink/pull/8957#issuecomment-509573302
CI report for commit 2815bb5aa808f2d9bd56d037afa85824753f436b: FAILURE
[Build](https://travis-ci.com/flink-ci/flink/builds/118398271)
lombarde commented on issue #8914: [FLINK-12929] Pass TypeInformation in
addSource
URL: https://github.com/apache/flink/pull/8914#issuecomment-509575538
> @lombarde Are you interested in picking this up, following @aljoscha's
suggestion?
We updated our code following your
flinkbot commented on issue #9034: [FLINK-13063] Temporary fix for
AsyncWaitOperator consistency problems.
URL: https://github.com/apache/flink/pull/9034#issuecomment-509577195
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
[
https://issues.apache.org/jira/browse/FLINK-13168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-13168:
---
Description:
in blink planner & flink planner, there are many {{isBatch}} and
{{isStreaming}}
1u0 commented on a change in pull request #8742: [FLINK-11879] Add validators
for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput
URL: https://github.com/apache/flink/pull/8742#discussion_r301503188
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-13019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin closed FLINK-13019.
---
Resolution: Done
> IT test for fine-grained recovery (user code failures)
>
[
https://issues.apache.org/jira/browse/FLINK-13168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-13168:
---
Description:
in blink planner & flink planner, there are many {{isBatch}} and
{{isStreaming}}
1u0 commented on a change in pull request #8742: [FLINK-11879] Add validators
for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput
URL: https://github.com/apache/flink/pull/8742#discussion_r301487379
##
File path:
1 - 100 of 554 matches
Mail list logo
