twalthr commented on a change in pull request #8521: [FLINK-12601][table] Make
the DataStream & DataSet conversion to a Table independent from Calcite
URL: https://github.com/apache/flink/pull/8521#discussion_r289271852
##
File path:
flink-table/flink-table-api-java/src/main/java/o
twalthr commented on a change in pull request #8521: [FLINK-12601][table] Make
the DataStream & DataSet conversion to a Table independent from Calcite
URL: https://github.com/apache/flink/pull/8521#discussion_r289272108
##
File path:
flink-table/flink-table-api-java/src/main/java/o
twalthr commented on a change in pull request #8521: [FLINK-12601][table] Make
the DataStream & DataSet conversion to a Table independent from Calcite
URL: https://github.com/apache/flink/pull/8521#discussion_r289273841
##
File path:
flink-table/flink-table-api-java/src/main/java/o
twalthr commented on a change in pull request #8521: [FLINK-12601][table] Make
the DataStream & DataSet conversion to a Table independent from Calcite
URL: https://github.com/apache/flink/pull/8521#discussion_r289272740
##
File path:
flink-table/flink-table-api-java/src/main/java/o
carp84 commented on a change in pull request #8570: [FLINK-12688] [state] Make
serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289273148
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/state
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289273088
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleDescriptor.java
#
wisgood commented on a change in pull request #8571: [FLINK-12682][connectors]
StringWriter support custom row delimiter
URL: https://github.com/apache/flink/pull/8571#discussion_r289272376
##
File path:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/str
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289272418
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleDescriptor.java
#
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289271987
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java
#
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289271987
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java
#
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289271987
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java
#
danny0405 commented on a change in pull request #8548: [FLINK-6962] [table] Add
create(drop) table SQL DDL
URL: https://github.com/apache/flink/pull/8548#discussion_r289271036
##
File path: flink-table/flink-sql-parser/src/main/resources/META-INF/NOTICE
##
@@ -0,0 +1,15 @@
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289271099
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java
#
danny0405 commented on a change in pull request #8548: [FLINK-6962] [table] Add
create(drop) table SQL DDL
URL: https://github.com/apache/flink/pull/8548#discussion_r289270874
##
File path:
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/SqlProperty.java
###
danny0405 commented on a change in pull request #8548: [FLINK-6962] [table] Add
create(drop) table SQL DDL
URL: https://github.com/apache/flink/pull/8548#discussion_r289270278
##
File path:
flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl
##
@@ -0,0
danny0405 commented on a change in pull request #8548: [FLINK-6962] [table] Add
create(drop) table SQL DDL
URL: https://github.com/apache/flink/pull/8548#discussion_r289269858
##
File path: flink-table/flink-sql-parser/pom.xml
##
@@ -0,0 +1,312 @@
+
+
+http://maven.apache.
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289269558
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java
#
flinkbot commented on issue #8581: [FLINK-12254][table] Update value literals
to new type system
URL: https://github.com/apache/flink/pull/8581#issuecomment-497590727
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
twalthr opened a new pull request #8581: [FLINK-12254][table] Update value
literals to new type system
URL: https://github.com/apache/flink/pull/8581
## What is the purpose of the change
This PR updates `ValueLiteralExpression` and `nullOf` to the new type
system. All existing test
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289266913
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleDescriptor.java
#
[
https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852693#comment-16852693
]
sunjincheng commented on FLINK-10984:
-
The flink-shaded 7.0 already released, and we
sunjincheng121 commented on issue #8225: FLINK-10984]Remove flink-shaded-hadoop
from flink
URL: https://github.com/apache/flink/pull/8225#issuecomment-497587659
The flink-shaded 7.0 already released, I'll rebase the code and let the CI
passed.
-
[
https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852693#comment-16852693
]
sunjincheng edited comment on FLINK-10984 at 5/31/19 6:05 AM:
KurtYoung commented on a change in pull request #8548: [FLINK-6962] [table] Add
create(drop) table SQL DDL
URL: https://github.com/apache/flink/pull/8548#discussion_r289223245
##
File path: flink-table/flink-sql-parser/pom.xml
##
@@ -0,0 +1,312 @@
+
+
+http://maven.apache.
KurtYoung commented on a change in pull request #8548: [FLINK-6962] [table] Add
create(drop) table SQL DDL
URL: https://github.com/apache/flink/pull/8548#discussion_r289265024
##
File path:
flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl
##
@@ -0,0
KurtYoung commented on a change in pull request #8548: [FLINK-6962] [table] Add
create(drop) table SQL DDL
URL: https://github.com/apache/flink/pull/8548#discussion_r289225445
##
File path:
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTable.ja
KurtYoung commented on a change in pull request #8548: [FLINK-6962] [table] Add
create(drop) table SQL DDL
URL: https://github.com/apache/flink/pull/8548#discussion_r289265552
##
File path: flink-table/flink-sql-parser/src/main/resources/META-INF/NOTICE
##
@@ -0,0 +1,15 @@
KurtYoung commented on a change in pull request #8548: [FLINK-6962] [table] Add
create(drop) table SQL DDL
URL: https://github.com/apache/flink/pull/8548#discussion_r289265380
##
File path:
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/SqlProperty.java
###
tzulitai edited a comment on issue #8570: [FLINK-12688] [state] Make serializer
lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497585843
One slight clarification regarding a comment that was mentioned in the
description:
``
tzulitai edited a comment on issue #8570: [FLINK-12688] [state] Make serializer
lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497585843
One slight clarification regarding a comment that was mentioned in the
description:
``
tzulitai commented on issue #8570: [FLINK-12688] [state] Make serializer lazy
initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497585843
One slight clarification regarding a comment that was mentioned in the
description:
```
Th
tzulitai edited a comment on issue #8570: [FLINK-12688] [state] Make serializer
lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497585843
One slight clarification regarding a comment that was mentioned in the
description:
``
liyafan82 commented on issue #8579: [FLINK-12687][Runtime / Operators]
ByteHashSet is always in dense mode
URL: https://github.com/apache/flink/pull/8579#issuecomment-497585646
Hi @JingsongLi, would you please take a look?
Th
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289264560
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java
#
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289264560
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java
#
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289262686
##
File path:
flink-core/src/test/java/org/apache/flink/api/common/sta
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289264163
##
File path:
flink-core/src/test/java/org/apache/flink/api/common/sta
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289262391
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/sta
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289263899
##
File path:
flink-core/src/test/java/org/apache/flink/api/common/sta
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289262323
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/sta
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289262617
##
File path:
flink-core/src/test/java/org/apache/flink/api/common/sta
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289263588
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/sta
bowenli86 commented on issue #8567: [FLINK-12676][table][sql-client] Add
descriptor, validator, and factory of GenericInMemoryCatalog for table
discovery service
URL: https://github.com/apache/flink/pull/8567#issuecomment-497580939
@xuefuz can you take another look?
--
bowenli86 commented on a change in pull request #8522:
[FLINK-12572][hive]Implement HiveInputFormat to read Hive tables
URL: https://github.com/apache/flink/pull/8522#discussion_r289260306
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/conn
bowenli86 commented on a change in pull request #8522:
[FLINK-12572][hive]Implement HiveInputFormat to read Hive tables
URL: https://github.com/apache/flink/pull/8522#discussion_r289260559
##
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/conn
bowenli86 commented on a change in pull request #8522:
[FLINK-12572][hive]Implement HiveInputFormat to read Hive tables
URL: https://github.com/apache/flink/pull/8522#discussion_r289260297
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/conn
bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive]
Implement OutputFormat to write Hive tables
URL: https://github.com/apache/flink/pull/8536#discussion_r289259721
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/conne
bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive]
Implement OutputFormat to write Hive tables
URL: https://github.com/apache/flink/pull/8536#discussion_r289259721
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/conne
[
https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852672#comment-16852672
]
Jasleen Kaur commented on FLINK-5243:
-
[~greghogan] Thanks for your reply. I was plan
tzulitai edited a comment on issue #8570: [FLINK-12688] [state] Make serializer
lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497577479
@flinkbot approve consensus
I'm approving the consensus to fix the problem like thi
tzulitai edited a comment on issue #8570: [FLINK-12688] [state] Make serializer
lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497577479
@flinkbot approve consensus
I'm approving the consensus to fix the problem like thi
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852668#comment-16852668
]
vinoyang commented on FLINK-12683:
--
I think for logging, the good practice is that it s
tzulitai commented on issue #8570: [FLINK-12688] [state] Make serializer lazy
initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497577479
@flinkbot approve consensus
I'm approving the consensus to fix the problem like this, befo
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258274
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4 +42
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258387
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/ta
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258244
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4 +42
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258274
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4 +42
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258121
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/ta
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289257720
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4 +42
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289257545
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4 +42
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258121
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/ta
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289257720
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4 +42
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289257545
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4 +42
[
https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852663#comment-16852663
]
Yu Li commented on FLINK-11987:
---
Regarding the issue mentioned by [~chethanuk], from the p
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852658#comment-16852658
]
Congxian Qiu(klion26) commented on FLINK-12683:
---
In my opinion, the jm log
[
https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852656#comment-16852656
]
Yu Li commented on FLINK-11987:
---
Have created FLINK-12688 to fix the issue from inside {{S
flinkbot commented on issue #8580: [FLINK-12683] Provide task manager location
information for checkpoint coordinator specific log messages
URL: https://github.com/apache/flink/pull/8580#issuecomment-497573926
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbo
Yu Li created FLINK-12688:
-
Summary: Make serializer lazy initialization thread safe in
StateDescriptor
Key: FLINK-12688
URL: https://issues.apache.org/jira/browse/FLINK-12688
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12683:
---
Labels: pull-request-available (was: )
> Provide task manager's location information for ch
yanghua opened a new pull request #8580: [FLINK-12683] Provide task manager
location information for checkpoint coordinator specific log messages
URL: https://github.com/apache/flink/pull/8580
## What is the purpose of the change
*This pull request provides task manager location info
[
https://issues.apache.org/jira/browse/FLINK-12687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12687:
---
Labels: pull-request-available (was: )
> ByteHashSet is always in dense mode
>
flinkbot commented on issue #8579: [FLINK-12687][Runtime / Operators]
ByteHashSet is always in dense mode
URL: https://github.com/apache/flink/pull/8579#issuecomment-497573552
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to revi
liyafan82 opened a new pull request #8579: [FLINK-12687][Runtime / Operators]
ByteHashSet is always in dense mode
URL: https://github.com/apache/flink/pull/8579
## What is the purpose of the change
Improve the performance and code structure for
org.apache.flink.table.runtime
Liya Fan created FLINK-12687:
Summary: ByteHashSet is always in dense mode
Key: FLINK-12687
URL: https://issues.apache.org/jira/browse/FLINK-12687
Project: Flink
Issue Type: Improvement
Biao Liu created FLINK-12686:
Summary: StreamGraph Supports Blink Batch Mode
Key: FLINK-12686
URL: https://issues.apache.org/jira/browse/FLINK-12686
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-12686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-12686:
-
Description: This is a part of merging Blink batch runner. I would like to
improvement the StreamGraph t
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289249491
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/PartitionDescriptor.java
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289249256
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/PartitionDescriptor.java
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289247475
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ProducerDescriptor.java
#
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289247275
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ProducerDescriptor.java
#
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289247275
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ProducerDescriptor.java
#
asfgit closed pull request #8531: [FLINK-12440][python] Add all connector
support align Java Table API.
URL: https://github.com/apache/flink/pull/8531
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/FLINK-12440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-12440.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in master: 836fdfff0db64ff8241f38e8dd362dd50a9d1
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289246143
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java
##
@@
lirui-apache commented on issue #8564: [FLINK-12649][hive] Add a shim layer to
support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#issuecomment-497560367
> For Hive versions, I think for now we can claim support only for versions
like 1.2.1 explicitly. In theory
wisgood commented on a change in pull request #8571: [FLINK-12682][connectors]
StringWriter support custom row delimiter
URL: https://github.com/apache/flink/pull/8571#discussion_r289245475
##
File path:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/str
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289244295
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputGateDeploymentDescriptor.j
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289243434
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleDescriptor.java
##
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289242090
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputGateDeploymentDescriptor.j
sunjincheng121 commented on issue #8531: [FLINK-12440][python] Add all
connector support align Java Table API.
URL: https://github.com/apache/flink/pull/8531#issuecomment-497555012
LGTM. +1 to merged.
@flinkbot approve all
Myasuka commented on a change in pull request #8571: [FLINK-12682][connectors]
StringWriter support custom row delimiter
URL: https://github.com/apache/flink/pull/8571#discussion_r289240462
##
File path:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/str
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852600#comment-16852600
]
vinoyang commented on FLINK-12683:
--
Hi [~klion26] Here is my plan:
Changing these two
zhijiangW commented on a change in pull request #8566: [FLINK-12673][network]
Introduce NetworkEnvironment.getUnreleasedPartitions instead of using
getResultPartitionManager
URL: https://github.com/apache/flink/pull/8566#discussion_r289239909
##
File path:
flink-runtime/src/main/j
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-12683:
-
Summary: Provide task manager's location information for checkpoint
coordinator specific log messages (
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-12683:
-
Summary: Provide task manager's location information for checkpoint
acknowledge log message (was: Provi
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852592#comment-16852592
]
vinoyang commented on FLINK-12683:
--
[~klion26] you are right, thanks, will change this
flinkbot commented on issue #8578: [FLINK-12685] [table-planner-blink] Supports
UNNEST query in blink planner
URL: https://github.com/apache/flink/pull/8578#issuecomment-497551523
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
godfreyhe opened a new pull request #8578: [FLINK-12685] [table-planner-blink]
Supports UNNEST query in blink planner
URL: https://github.com/apache/flink/pull/8578
## What is the purpose of the change
*Supports UNNEST query in blink planner*
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-12685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12685:
---
Labels: pull-request-available (was: )
> Supports UNNEST query in blink planner
> -
klion26 commented on a change in pull request #8573: [FLINK-12670][runtime]
Implement FailureRateRestartBackoffTimeStrategy
URL: https://github.com/apache/flink/pull/8573#discussion_r289237692
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failove
1 - 100 of 241 matches
Mail list logo
