[
https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531460#comment-16531460
]
ASF GitHub Bot commented on FLINK-9666:
---
GitHub user lamber-ken reopened a pull request:
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6230
@tillrohrmann, hi, cc
---
GitHub user lamber-ken reopened a pull request:
https://github.com/apache/flink/pull/6230
[FLINK-9666] short-circuit logic should be used in boolean contexts
Backport of #6212 .
@tillrohrmann, hi, cc
You can merge this pull request into a Git repository by running:
$
Renjie Liu created FLINK-9722:
-
Summary: Add resource tag predicate into slot manager
Key: FLINK-9722
URL: https://issues.apache.org/jira/browse/FLINK-9722
Project: Flink
Issue Type: New Feature
Renjie Liu created FLINK-9725:
-
Summary: Add tag support to standalone cluster manager.
Key: FLINK-9725
URL: https://issues.apache.org/jira/browse/FLINK-9725
Project: Flink
Issue Type: New
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/6228
@sihuazhou @azagrebin thanks for the reviews! I will merge this once my
travis is green.
---
[
https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9636:
-
Fix Version/s: 1.6.0
> Network buffer leaks in requesting a batch of segments during canceling
>
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199814578
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueue.java
---
@@ -0,0 +1,341 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531448#comment-16531448
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531447#comment-16531447
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user StefanRRichter commented on a diff in the pull
GitHub user zjffdu opened a pull request:
https://github.com/apache/flink/pull/6245
FLINK-9718. Add enviroment variable in start-scala-shell.sh to enable
remote debug
## What is the purpose of the change
Add enviroment variable `FLINK_SCALA_SHELL_JAVA_OPTS` in
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199816750
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ *
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199816139
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/KeyGroupPartitionedPriorityQueue.java
---
@@ -0,0 +1,280 @@
+/*
+
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199816552
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9718:
--
Labels: pull-request-available (was: )
> Add enviroment variable in start-scala-shell.sh to
Github user eliaslevy commented on the issue:
https://github.com/apache/flink/pull/6076
@pnowojski what about refactoring the doc into something like
[this](https://docs.google.com/document/d/1b5d-hTdJQsPH3YD0zTB4ZqodinZVHFomKvt41FfUPMc/edit?usp=sharing).
---
Florian Schmidt created FLINK-9728:
--
Summary: Wrong ruby version for building flink docs in docker
container
Key: FLINK-9728
URL: https://issues.apache.org/jira/browse/FLINK-9728
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531492#comment-16531492
]
ASF GitHub Bot commented on FLINK-9636:
---
Github user tillrohrmann commented on a diff in the pull
Github user zsolt-donca commented on the issue:
https://github.com/apache/flink/pull/6206
@tillrohrmann looks good to me. The class `Foo.Bar.Foobar` should trigger
the issue. Thanks for writing the test!
---
[
https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531509#comment-16531509
]
Viktor Vlasov edited comment on FLINK-9643 at 7/3/18 2:56 PM:
--
I've gathered
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531525#comment-16531525
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user StefanRRichter commented on a diff in the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6218
---
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-9444.
-
Resolution: Fixed
Fixed in 1.6.0: c34c7e4127c8947d68e2b960cd84206e59d479b3
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6082
---
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199813559
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueue.java
---
@@ -0,0 +1,341 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531421#comment-16531421
]
ASF GitHub Bot commented on FLINK-9636:
---
Github user tillrohrmann commented on a diff in the pull
Jeff Zhang created FLINK-9718:
-
Summary: Add enviroment variable in start-scala-shell.sh to enable
remote debug
Key: FLINK-9718
URL: https://issues.apache.org/jira/browse/FLINK-9718
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531425#comment-16531425
]
ASF GitHub Bot commented on FLINK-9554:
---
Github user zjffdu commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199813529
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueue.java
---
@@ -0,0 +1,341 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531433#comment-16531433
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531453#comment-16531453
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199817285
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531454#comment-16531454
]
ASF GitHub Bot commented on FLINK-9554:
---
Github user zjffdu commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531456#comment-16531456
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199817513
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ *
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199817158
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ *
Github user zjffdu commented on a diff in the pull request:
https://github.com/apache/flink/pull/6140#discussion_r199817183
--- Diff: flink-scala-shell/start-script/start-scala-shell.sh ---
@@ -19,6 +19,9 @@
# from scala-lang 2.10.4
+# Uncomment the following
Renjie Liu created FLINK-9723:
-
Summary: Add tags support to mesos resource manager
Key: FLINK-9723
URL: https://issues.apache.org/jira/browse/FLINK-9723
Project: Flink
Issue Type: New Feature
Renjie Liu created FLINK-9727:
-
Summary: Allow user to pass resource tag expression in command line
Key: FLINK-9727
URL: https://issues.apache.org/jira/browse/FLINK-9727
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renjie Liu closed FLINK-9671.
-
Resolution: Won't Fix
> Add configuration to enable task manager isolation.
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6238#discussion_r199832400
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
---
@@ -151,7 +151,12 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531509#comment-16531509
]
Viktor Vlasov commented on FLINK-9643:
--
I've gathered statistics (result.csv in attachments or the
[
https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531514#comment-16531514
]
Viktor Vlasov commented on FLINK-9643:
--
[~vinaypatil18] , as I figured out, unfortunately, 1.3.2
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199841799
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531531#comment-16531531
]
Viktor Vlasov commented on FLINK-9643:
--
[~till.rohrmann] , I am afraid that you were right. With
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199806862
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ * Licensed to
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199807071
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ * Licensed to
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199567205
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueueSet.java
---
@@ -0,0 +1,186 @@
+/*
+ * Licensed to the
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199473489
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/InternalPriorityQueue.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199806903
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ * Licensed to
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199566880
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyExtractorFunction.java
---
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199566980
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueue.java
---
@@ -0,0 +1,341 @@
+/*
+ * Licensed to the
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199806997
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ * Licensed to
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199806942
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531391#comment-16531391
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user azagrebin commented on a diff in the pull
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199567420
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOrderedSetStore.java
---
@@ -0,0
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199806702
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java
---
@@ -0,0 +1,452 @@
+/*
+ * Licensed to
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199567167
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueue.java
---
@@ -0,0 +1,341 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531401#comment-16531401
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user azagrebin commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531405#comment-16531405
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user azagrebin commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531392#comment-16531392
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user azagrebin commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531399#comment-16531399
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user azagrebin commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531395#comment-16531395
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user azagrebin commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6238#discussion_r199813070
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
---
@@ -396,4 +398,48 @@ public void go()
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199814790
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueueSet.java
---
@@ -0,0 +1,186 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531430#comment-16531430
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531451#comment-16531451
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531450#comment-16531450
]
ASF GitHub Bot commented on FLINK-9718:
---
GitHub user zjffdu opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531449#comment-16531449
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user StefanRRichter commented on a diff in the pull
Renjie Liu created FLINK-9719:
-
Summary: Mesos should use hostname as default
jobmanager.rpc.address
Key: FLINK-9719
URL: https://issues.apache.org/jira/browse/FLINK-9719
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9693:
Assignee: Till Rohrmann
> Possible memory leak in jobmanager retaining archived
[
https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Vlasov updated FLINK-9643:
-
Attachment: result.csv
> Flink allowing TLS 1.1 in spite of configuring TLS 1.2
>
Renjie Liu created FLINK-9720:
-
Summary: Introduce ResourceTag class for tag support in scheduling
Key: FLINK-9720
URL: https://issues.apache.org/jira/browse/FLINK-9720
Project: Flink
Issue
Renjie Liu created FLINK-9724:
-
Summary: Add tag support to yarn resource manager
Key: FLINK-9724
URL: https://issues.apache.org/jira/browse/FLINK-9724
Project: Flink
Issue Type: New Feature
Renjie Liu created FLINK-9726:
-
Summary: Enable job task manager isolation use tag support
Key: FLINK-9726
URL: https://issues.apache.org/jira/browse/FLINK-9726
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531550#comment-16531550
]
ASF GitHub Bot commented on FLINK-9718:
---
Github user yanghua commented on a diff in the pull
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/6082
In the end it seems that I had to rewrite this whole Avro logic in order to
finally support all types and both specific and generic Avro records. I hope it
is ok that I could not include your
[
https://issues.apache.org/jira/browse/FLINK-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531558#comment-16531558
]
ASF GitHub Bot commented on FLINK-9707:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6243
+1
---
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199860548
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/BatchTableEnvironment.scala
---
@@ -94,11 +95,12 @@ class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199857801
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -433,9 +447,24 @@ abstract class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199860711
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/batch/sql/JavaSqlITCase.java
---
@@ -71,8 +71,10 @@ public void
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199859899
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -77,15 +90,38 @@ class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199855960
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -95,15 +95,17 @@ abstract class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199857602
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -415,6 +416,19 @@ abstract class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199857321
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -145,12 +147,14 @@ abstract class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199857390
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -163,12 +164,14 @@ abstract class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199860145
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -95,12 +131,53 @@ class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199857354
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -300,9 +307,10 @@ abstract class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199860344
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -118,15 +195,19 @@ class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199860044
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -95,12 +131,53 @@ class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199858196
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -55,9 +55,22 @@ class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199857340
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -280,16 +284,19 @@ abstract class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199860444
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/BatchTableEnvironment.scala
---
@@ -53,12 +53,13 @@ class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199860789
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/batch/sql/JavaSqlITCase.java
---
@@ -71,8 +71,10 @@ public void
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199858297
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -77,15 +90,38 @@ class
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6236#discussion_r199857432
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -415,6 +416,19 @@ abstract class
GitHub user snuyanzin opened a pull request:
https://github.com/apache/flink/pull/6246
[hotfix][FLINK-9729][docs][Table API & SQL] Remove duplicate row for %W
## What is the purpose of the change
*This PR removes duplicate line for `%W Weekday name (Sunday .. Saturday)`
[
https://issues.apache.org/jira/browse/FLINK-9729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9729:
--
Labels: pull-request-available (was: )
> Dupplicate lines for "Weekday name (Sunday ..
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6203#discussion_r199867852
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
---
@@ -315,36 +315,61 @@ public JobSubmissionResult
301 - 400 of 483 matches
Mail list logo
