wuchong commented on a change in pull request #8736: [FLINK-12846][table] Carry
primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294153680
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache/f
sunhaibotb edited a comment on issue #8642: [FLINK-1722][datastream] Enable the
InitializeOnMaster and FinalizeOnMaster interfaces on datastream
URL: https://github.com/apache/flink/pull/8642#issuecomment-502151128
Thank you for reviewing @aljoscha . Because renaming is simple and
`JobMast
[
https://issues.apache.org/jira/browse/FLINK-12406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12406:
---
Description:
After each job finishes, the new {{BLOCKING_PERSISTENT}} result partitions are
generat
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294149556
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache
[
https://issues.apache.org/jira/browse/FLINK-2953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kevinsun reassigned FLINK-2953:
---
Assignee: kevinsun (was: Fabian Hueske)
> Chained sortPartition() calls produce incorrect results i
[
https://issues.apache.org/jira/browse/FLINK-2953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kevinsun reassigned FLINK-2953:
---
Assignee: (was: kevinsun)
> Chained sortPartition() calls produce incorrect results in Scala Dat
klion26 commented on issue #8617: [FLINK-12619][StateBackend]Support
TERMINATE/SUSPEND Job with Checkpoint
URL: https://github.com/apache/flink/pull/8617#issuecomment-502547337
Seems the failed test is related, I'll fix it.
T
[
https://issues.apache.org/jira/browse/FLINK-12850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-12850:
-
Description:
Now in the new type system of table, the default class of time type is
LocalDate a
[
https://issues.apache.org/jira/browse/FLINK-12850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-12850:
-
Summary: Introduce TypeInfo for LocalDate/LocalTime/LocalDateTime (was:
Introduce LocalDate/Loc
gaoyunhaii commented on a change in pull request #8704: [FLINK-12812][runtime]
Set resource profiles for task slots
URL: https://github.com/apache/flink/pull/8704#discussion_r294145802
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.
flinkbot commented on issue #8758: [FLINK-12867] Add insert overwrite grammar
as HIVE dialect
URL: https://github.com/apache/flink/pull/8758#issuecomment-502546321
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
[
https://issues.apache.org/jira/browse/FLINK-12850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12850:
---
Labels: pull-request-available (was: )
> Introduce LocalDate/LocalTime/LocalDateTime TypeIn
[
https://issues.apache.org/jira/browse/FLINK-12867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12867:
---
Labels: pull-request-available (was: )
> Add insert overwrite grammar as HIVE dialect
> ---
flinkbot commented on issue #8757: [FLINK-12850][core] Introduce
LocalDate/LocalTime/LocalDateTime TypeInfo
URL: https://github.com/apache/flink/pull/8757#issuecomment-502546064
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to re
danny0405 opened a new pull request #8758: [FLINK-12867] Add insert overwrite
grammar as HIVE dialect
URL: https://github.com/apache/flink/pull/8758
## What is the purpose of the change
*This pull request add a new grammar insert overwrite as HIVE dialect, this
overwrite can take th
JingsongLi opened a new pull request #8757: [FLINK-12850][core] Introduce
LocalDate/LocalTime/LocalDateTime TypeInfo
URL: https://github.com/apache/flink/pull/8757
## What is the purpose of the change
Now in the new type system of table, the default class of time type is
LocalDa
wangyang0918 commented on issue #8624: [FLINK-10932]Initial flink-kubernetes
module with empty implementation
URL: https://github.com/apache/flink/pull/8624#issuecomment-502544267
Hi, @tianchen92
I think you should remove the `dependencyManagement` and do as the following
steps.
1.
gaoyunhaii commented on a change in pull request #8704: [FLINK-12812][runtime]
Set resource profiles for task slots
URL: https://github.com/apache/flink/pull/8704#discussion_r294143254
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java
##
gaoyunhaii commented on a change in pull request #8704: [FLINK-12812][runtime]
Set resource profiles for task slots
URL: https://github.com/apache/flink/pull/8704#discussion_r294143299
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleEnvironment.jav
Danny Chan created FLINK-12867:
--
Summary: Add insert overwrite grammar as HIVE dialect
Key: FLINK-12867
URL: https://issues.apache.org/jira/browse/FLINK-12867
Project: Flink
Issue Type: Sub-task
wuchong commented on issue #8738: [FLINK-12845][sql-client] Execute multiple
statements in command line…
URL: https://github.com/apache/flink/pull/8738#issuecomment-502543453
Hi @docete , could you add some test to verify the new feature? We should
always add some tests when introduce new
[
https://issues.apache.org/jira/browse/FLINK-12863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865333#comment-16865333
]
Yun Gao commented on FLINK-12863:
-
Hi all, I create a Jira for the state inconsistency b
[
https://issues.apache.org/jira/browse/FLINK-12865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-12865:
Description:
There may be state inconsistency between TM and RM due to race condition and
message loss:
[
https://issues.apache.org/jira/browse/FLINK-12866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865328#comment-16865328
]
TisonKun commented on FLINK-12866:
--
>From its corresponding compile
>stage([https://tr
ifndef-SleePy edited a comment on issue #8721: [FLINK-12823][datastream]
PartitionTransformation supports DataExchan…
URL: https://github.com/apache/flink/pull/8721#issuecomment-502540027
Python module is fine but connectors module failed this time on Travis
checking. It seems a travis rel
ifndef-SleePy edited a comment on issue #8721: [FLINK-12823][datastream]
PartitionTransformation supports DataExchan…
URL: https://github.com/apache/flink/pull/8721#issuecomment-502540027
Python module is fine but connectors module failed this time on Travis
checking. It seems a travis rel
ifndef-SleePy commented on issue #8721: [FLINK-12823][datastream]
PartitionTransformation supports DataExchan…
URL: https://github.com/apache/flink/pull/8721#issuecomment-502540027
Python module is fine but connectors module failed this time on Travis
checking. It seems a travis relevant i
ifndef-SleePy opened a new pull request #8721: [FLINK-12823][datastream]
PartitionTransformation supports DataExchan…
URL: https://github.com/apache/flink/pull/8721
…geMode property
## What is the purpose of the change
* Since `StreamTransformation` would also support batch ru
ifndef-SleePy closed pull request #8721: [FLINK-12823][datastream]
PartitionTransformation supports DataExchan…
URL: https://github.com/apache/flink/pull/8721
This is an automated message from the Apache Git Service.
To resp
wuchong commented on a change in pull request #8736: [FLINK-12846][table] Carry
primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294139723
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/f
Biao Liu created FLINK-12866:
Summary: Connectors module failed on Travis checking
Key: FLINK-12866
URL: https://issues.apache.org/jira/browse/FLINK-12866
Project: Flink
Issue Type: Test
JingsongLi commented on a change in pull request #8689:
[FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString
URL: https://github.com/apache/flink/pull/8689#discussion_r294132999
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table
[
https://issues.apache.org/jira/browse/FLINK-12865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865296#comment-16865296
]
Yun Gao commented on FLINK-12865:
-
I think adding a version to the slot may solves this
[
https://issues.apache.org/jira/browse/FLINK-12865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-12865:
Description:
There may be state inconsistency between TM and RM due to race condition and
message loss:
sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime]
Implement the runtime handling of BoundedOneInput and BoundedMultiInput
URL: https://github.com/apache/flink/pull/8731#discussion_r293741881
##
File path:
flink-streaming-java/src/main/java/org/apache/fl
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294131403
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache
KurtYoung commented on issue #8626: [FLINK-12742] Add insert into partition
grammar as hive dialect
URL: https://github.com/apache/flink/pull/8626#issuecomment-502527618
merged with 4320d8372f93e8fa4d82da06e5e0a0ba310195a2
Th
KurtYoung closed pull request #8626: [FLINK-12742] Add insert into partition
grammar as hive dialect
URL: https://github.com/apache/flink/pull/8626
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-12742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-12742.
--
Resolution: Implemented
merged in 1.9.0: 4320d8372f93e8fa4d82da06e5e0a0ba310195a2
> Add insert into p
klion26 commented on a change in pull request #8750: [FLINK-11606] Translate
the "Distributed Runtime Environment" page in to Chinese
URL: https://github.com/apache/flink/pull/8750#discussion_r294121063
##
File path: docs/concepts/runtime.zh.md
##
@@ -26,102 +26,74 @@ unde
klion26 commented on a change in pull request #8750: [FLINK-11606] Translate
the "Distributed Runtime Environment" page in to Chinese
URL: https://github.com/apache/flink/pull/8750#discussion_r294120960
##
File path: docs/concepts/runtime.zh.md
##
@@ -26,102 +26,74 @@ unde
klion26 commented on a change in pull request #8750: [FLINK-11606] Translate
the "Distributed Runtime Environment" page in to Chinese
URL: https://github.com/apache/flink/pull/8750#discussion_r294122301
##
File path: docs/concepts/runtime.zh.md
##
@@ -26,102 +26,74 @@ unde
klion26 commented on a change in pull request #8750: [FLINK-11606] Translate
the "Distributed Runtime Environment" page in to Chinese
URL: https://github.com/apache/flink/pull/8750#discussion_r294129377
##
File path: docs/concepts/runtime.zh.md
##
@@ -26,102 +26,74 @@ unde
sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime]
Implement the runtime handling of BoundedOneInput and BoundedMultiInput
URL: https://github.com/apache/flink/pull/8731#discussion_r294130413
##
File path:
flink-streaming-java/src/main/java/org/apache/fl
klion26 commented on a change in pull request #8750: [FLINK-11606] Translate
the "Distributed Runtime Environment" page in to Chinese
URL: https://github.com/apache/flink/pull/8750#discussion_r294121434
##
File path: docs/concepts/runtime.zh.md
##
@@ -26,102 +26,74 @@ unde
klion26 commented on a change in pull request #8750: [FLINK-11606] Translate
the "Distributed Runtime Environment" page in to Chinese
URL: https://github.com/apache/flink/pull/8750#discussion_r294129009
##
File path: docs/concepts/runtime.zh.md
##
@@ -26,102 +26,74 @@ unde
klion26 commented on a change in pull request #8750: [FLINK-11606] Translate
the "Distributed Runtime Environment" page in to Chinese
URL: https://github.com/apache/flink/pull/8750#discussion_r294129829
##
File path: docs/concepts/runtime.zh.md
##
@@ -26,102 +26,74 @@ unde
klion26 commented on a change in pull request #8750: [FLINK-11606] Translate
the "Distributed Runtime Environment" page in to Chinese
URL: https://github.com/apache/flink/pull/8750#discussion_r294129669
##
File path: docs/concepts/runtime.zh.md
##
@@ -26,102 +26,74 @@ unde
klion26 commented on a change in pull request #8750: [FLINK-11606] Translate
the "Distributed Runtime Environment" page in to Chinese
URL: https://github.com/apache/flink/pull/8750#discussion_r294121310
##
File path: docs/concepts/runtime.zh.md
##
@@ -26,102 +26,74 @@ unde
godfreyhe commented on a change in pull request #8707: [FLINK-12815]
[table-planner-blink] Supports CatalogManager in blink planner
URL: https://github.com/apache/flink/pull/8707#discussion_r294130078
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flin
sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime]
Implement the runtime handling of BoundedOneInput and BoundedMultiInput
URL: https://github.com/apache/flink/pull/8731#discussion_r294128294
##
File path:
flink-streaming-java/src/main/java/org/apache/fl
[
https://issues.apache.org/jira/browse/FLINK-12406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12406:
---
Labels: pull-request-available (was: )
> Report BLOCKING_PERSISTENT result partition meta b
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-502525621
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the com
Xpray opened a new pull request #8756: [FLINK-12406] [Runtime] Report
BLOCKING_PERSISTENT result partition meta back to client
URL: https://github.com/apache/flink/pull/8756
## What is the purpose of the change
This PR follows FLINK-12405, it reports all result partition locations of
`B
Yun Gao created FLINK-12865:
---
Summary: State inconsistency between RM and TM on the slot status
Key: FLINK-12865
URL: https://issues.apache.org/jira/browse/FLINK-12865
Project: Flink
Issue Type: Bu
sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime]
Implement the runtime handling of BoundedOneInput and BoundedMultiInput
URL: https://github.com/apache/flink/pull/8731#discussion_r294128294
##
File path:
flink-streaming-java/src/main/java/org/apache/fl
godfreyhe commented on a change in pull request #8707: [FLINK-12815]
[table-planner-blink] Supports CatalogManager in blink planner
URL: https://github.com/apache/flink/pull/8707#discussion_r294127605
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flin
Myasuka commented on issue #8686: [FLINK-11869] Make buffer size in checkpoint
stream factory configurable
URL: https://github.com/apache/flink/pull/8686#issuecomment-502523369
CC @tzulitai
This is an automated message from
godfreyhe commented on a change in pull request #8707: [FLINK-12815]
[table-planner-blink] Supports CatalogManager in blink planner
URL: https://github.com/apache/flink/pull/8707#discussion_r294126984
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flin
godfreyhe commented on a change in pull request #8707: [FLINK-12815]
[table-planner-blink] Supports CatalogManager in blink planner
URL: https://github.com/apache/flink/pull/8707#discussion_r294126984
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flin
wuchong commented on a change in pull request #8736: [FLINK-12846][table] Carry
primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294126584
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache/f
wuchong commented on a change in pull request #8736: [FLINK-12846][table] Carry
primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294126242
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/f
[
https://issues.apache.org/jira/browse/FLINK-12857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-12857.
--
Resolution: Implemented
Fix Version/s: 1.9.0
merged in 1.9.0: 9f8f89923e96286275ba3fb259ec450ba
[
https://issues.apache.org/jira/browse/FLINK-12863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865278#comment-16865278
]
shuai.xu edited comment on FLINK-12863 at 6/17/19 3:27 AM:
---
Hi
KurtYoung merged pull request #8748: [FLINK-12857] [table] move
FilterableTableSource into flink-table-common
URL: https://github.com/apache/flink/pull/8748
This is an automated message from the Apache Git Service.
To respon
KurtYoung commented on a change in pull request #8689:
[FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString
URL: https://github.com/apache/flink/pull/8689#discussion_r294125722
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294124528
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache
[
https://issues.apache.org/jira/browse/FLINK-12863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865278#comment-16865278
]
shuai.xu commented on FLINK-12863:
--
Hi [~till.rohrmann], as [~xiaogang.shi] said, we fo
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294120943
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache
wuchong commented on a change in pull request #8736: [FLINK-12846][table] Carry
primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294125156
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/tab
wuchong commented on a change in pull request #8736: [FLINK-12846][table] Carry
primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294125122
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/tab
wuchong commented on a change in pull request #8736: [FLINK-12846][table] Carry
primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294125081
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/tab
[
https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-12852:
Component/s: Runtime / Network
> Deadlock occurs when requiring exclusive buffer for RemoteInputChannel
>
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294120943
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294124528
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache
WeiZhong94 commented on issue #8681: [FLINK-12585][python] Align
Stream/BatchTableEnvironment with JAVA Table API
URL: https://github.com/apache/flink/pull/8681#issuecomment-502518727
@dianfu Thanks for you review again! I have addressed your comments.
-
[
https://issues.apache.org/jira/browse/FLINK-12863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865269#comment-16865269
]
Xiaogang Shi commented on FLINK-12863:
--
Btw, i want to note that the race condition
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294120943
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294118121
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/t
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294117111
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/t
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294121385
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294118265
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/t
godfreyhe commented on a change in pull request #8736: [FLINK-12846][table]
Carry primary key and unique key information in TableSchema
URL: https://github.com/apache/flink/pull/8736#discussion_r294119747
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache
[
https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865268#comment-16865268
]
Tzu-Li (Gordon) Tai commented on FLINK-12653:
-
Thanks for the detailed inves
[
https://issues.apache.org/jira/browse/FLINK-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-12176:
-
Attachment: patch.diff
> Unify JobGraph creation in CliFrontend
> --
[
https://issues.apache.org/jira/browse/FLINK-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865259#comment-16865259
]
TisonKun commented on FLINK-12176:
--
[~till.rohrmann] After a closer look of {{Execution
[
https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-12273:
Assignee: vinoyang
> The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE,
wuchong commented on issue #8712: [FLINK-12819][sql-client] Reuse
TableEnvironment between different SQ…
URL: https://github.com/apache/flink/pull/8712#issuecomment-502513427
Sorry @docete , you are right, transformations will be cleared after
execution.
I will review it again.
-
[
https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-12122:
Fix Version/s: (was: 1.8.1)
1.8.2
> Spread out tasks evenly across all avai
[
https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865244#comment-16865244
]
sunjincheng commented on FLINK-12122:
-
Due to the release of 1.8.1, I change the fix
[
https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-8513:
---
Fix Version/s: (was: 1.8.1)
1.8.2
> Add documentation for connecting to non-AW
[
https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865243#comment-16865243
]
sunjincheng commented on FLINK-8513:
Due to the release of 1.8.1, I change the fix ve
[
https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-12273:
Fix Version/s: (was: 1.8.1)
1.8.2
> The default value of CheckpointRetentio
[
https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865242#comment-16865242
]
sunjincheng commented on FLINK-12273:
-
Due to the release of 1.8.1, I change the fix
[
https://issues.apache.org/jira/browse/FLINK-12578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-12578:
Fix Version/s: (was: 1.8.1)
1.8.2
> Use secure URLs for Maven repositories
[
https://issues.apache.org/jira/browse/FLINK-12578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865241#comment-16865241
]
sunjincheng commented on FLINK-12578:
-
Due to the release of 1.8.1, I change the fix
[
https://issues.apache.org/jira/browse/FLINK-11958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865240#comment-16865240
]
sunjincheng commented on FLINK-11958:
-
Due to the release of 1.8.1, I change the fi
[
https://issues.apache.org/jira/browse/FLINK-12863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865239#comment-16865239
]
Xiaogang Shi commented on FLINK-12863:
--
I think a similar problem happens in the he
JingsongLi commented on a change in pull request #8689:
[FLINK-12802][table-runtime-blink] Reducing the Code of BinaryString
URL: https://github.com/apache/flink/pull/8689#discussion_r294118537
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table
[
https://issues.apache.org/jira/browse/FLINK-11958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11958:
Fix Version/s: (was: 1.8.1)
1.8.2
> flink on windows yarn deploy failed
> -
1 - 100 of 158 matches
Mail list logo
