[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544858#comment-16544858
]
ASF GitHub Bot commented on FLINK-9061:
---
Github user indrc commented on the issue:
Github user indrc commented on the issue:
https://github.com/apache/flink/pull/6302
@StephanEwen Thanks for your comments and feedback, my replies below
1. after talking to @StefanRRichter we decided to bring in this dependency
to use a standard library instead; initially the pr ha
[
https://issues.apache.org/jira/browse/FLINK-9853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544848#comment-16544848
]
ASF GitHub Bot commented on FLINK-9853:
---
Github user xueyumusic commented on a diff
Github user xueyumusic commented on a diff in the pull request:
https://github.com/apache/flink/pull/6337#discussion_r202581145
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala
---
@@ -182,4 +184,6 @@ object Scalar
[
https://issues.apache.org/jira/browse/FLINK-9839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9839:
-
Affects Version/s: 1.6.0
> End-to-end test: Streaming job with SSL
>
[
https://issues.apache.org/jira/browse/FLINK-9839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9839:
-
Fix Version/s: 1.6.0
> End-to-end test: Streaming job with SSL
>
[
https://issues.apache.org/jira/browse/FLINK-9839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9839:
-
Priority: Blocker (was: Major)
> End-to-end test: Streaming job with SSL
> -
[
https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544812#comment-16544812
]
ASF GitHub Bot commented on FLINK-9630:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6336
@ubyyj you can use this command to trigger Travis rebuild :
```
git commit --allow-empty -m ""
```
---
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r202574665
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
---
@@ -0,0 +1,397 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544811#comment-16544811
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user kl0u commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-9853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544807#comment-16544807
]
ASF GitHub Bot commented on FLINK-9853:
---
Github user yanghua commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544808#comment-16544808
]
ASF GitHub Bot commented on FLINK-9853:
---
Github user yanghua commented on a diff in
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6337#discussion_r202573057
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala
---
@@ -182,4 +184,6 @@ object ScalarFun
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6337#discussion_r202572746
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala
---
@@ -400,6 +400,12 @@ trait ImplicitExpressionO
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6321
@StephanEwen, if the original authors of the code had an intention of
writing the code as it is now,
I'll follow your advice and leave it as it is.
---
[
https://issues.apache.org/jira/browse/FLINK-9829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544753#comment-16544753
]
ASF GitHub Bot commented on FLINK-9829:
---
Github user lamber-ken commented on the is
[
https://issues.apache.org/jira/browse/FLINK-9829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544748#comment-16544748
]
ASF GitHub Bot commented on FLINK-9829:
---
Github user lamber-ken commented on the is
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6321
@zentol, @StephanEwen, thank you for explaining the question about
hotfixes. I was not very clear about whether to create a jira or hotfix before.
---
[
https://issues.apache.org/jira/browse/FLINK-9829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544745#comment-16544745
]
ASF GitHub Bot commented on FLINK-9829:
---
Github user lamber-ken commented on a diff
Github user lamber-ken commented on a diff in the pull request:
https://github.com/apache/flink/pull/6321#discussion_r202566500
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigDecSerializer.java
---
@@ -69,17 +69,17 @@ public void serialize(BigDeci
[
https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544722#comment-16544722
]
ASF GitHub Bot commented on FLINK-9630:
---
GitHub user ubyyj reopened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544723#comment-16544723
]
ASF GitHub Bot commented on FLINK-9630:
---
Github user ubyyj commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544721#comment-16544721
]
ASF GitHub Bot commented on FLINK-9630:
---
Github user ubyyj commented on the issue:
Github user ubyyj commented on the issue:
https://github.com/apache/flink/pull/6336
trigger travis build
---
[
https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544720#comment-16544720
]
ASF GitHub Bot commented on FLINK-9630:
---
Github user ubyyj closed the pull request
Github user ubyyj commented on the issue:
https://github.com/apache/flink/pull/6336
unrelavent build failure, close and will reopen again, to trigger travis
build again
---
Github user ubyyj closed the pull request at:
https://github.com/apache/flink/pull/6336
---
GitHub user ubyyj reopened a pull request:
https://github.com/apache/flink/pull/6336
[FLINK-9630] [connector] Kafka09PartitionDiscoverer cause connection â¦
â¦leak on TopicAuthorizationException
**(The sections below can be removed for hotfixes of typos)**
##
[
https://issues.apache.org/jira/browse/FLINK-9751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9751.
---
> Add a RecoverableWriter to the FileSystem abstraction
> ---
[
https://issues.apache.org/jira/browse/FLINK-9751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9751.
-
Resolution: Fixed
Implemented in
e2960949bf84534978cb0be9f1a53cd783b43001
9d238e1a170a96c311b0daf
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544694#comment-16544694
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202556109
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CachingInternalPriorityQueueSet.java
---
@@ -80,13 +82,57 @@ public E peek(
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544693#comment-16544693
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202556091
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -446,8 +485,10 @@ public String toString(
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544692#comment-16544692
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a dif
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r202556032
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
---
@@ -0,0 +1,397 @@
+
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6326
Thanks for the review and for merging. @NicoK has an end-to-end test for
SSL PR already (#6327) which would be great to rebase on top of this change.
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202552616
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/PriorityComparable.java
---
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apach
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202552483
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyExtractorFunction.java
---
@@ -28,9 +28,22 @@
@FunctionalInterface
pu
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544676#comment-16544676
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544670#comment-16544670
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544674#comment-16544674
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202553765
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -342,16 +379,20 @@ private void
restorePar
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544668#comment-16544668
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544669#comment-16544669
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202553524
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CachingInternalPriorityQueueSet.java
---
@@ -80,13 +82,57 @@ public E peek()
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544667#comment-16544667
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544671#comment-16544671
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202553358
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/TieBreakingPriorityComparator.java
---
@@ -85,10 +85,10 @@ public int compare(T o1
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544673#comment-16544673
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544675#comment-16544675
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202552563
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupPartitioner.java
---
@@ -264,6 +265,42 @@ public void writeMappingsInKeyGr
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202553887
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -446,8 +485,10 @@ public String toString()
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202552705
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredBroadcastStateBackendMetaInfo.java
---
@@ -24,37 +24,46 @@
import o
[
https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544672#comment-16544672
]
ASF GitHub Bot commented on FLINK-9489:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202553958
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueueStateSnapshot.java
---
@@ -60,36 +61,35 @@
/**
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6333#discussion_r202552876
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredBroadcastStateBackendMetaInfo.java
---
@@ -63,54 +72,46 @@ public
Regis
[
https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544663#comment-16544663
]
ASF GitHub Bot commented on FLINK-7251:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r202553410
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -584,21 +581,6 @@ private static void registerFactory(Type
[
https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544657#comment-16544657
]
ASF GitHub Bot commented on FLINK-7251:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r202552984
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -584,21 +581,6 @@ private static void registerFactory(Type
Timo Walther created FLINK-9854:
---
Summary: Allow passing multi-line input to SQL Client CLI
Key: FLINK-9854
URL: https://issues.apache.org/jira/browse/FLINK-9854
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544654#comment-16544654
]
ASF GitHub Bot commented on FLINK-8858:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8858.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed in 1.6.0: 695bc56a9e20b9d86eea14a02899b400d32
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6332
---
[
https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-9483.
-
Resolution: Fixed
> "Building Flink" doc doesn't highlight quick build command
>
[
https://issues.apache.org/jira/browse/FLINK-8544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-8544.
-
Resolution: Fixed
Fix Version/s: 1.6.0
> JSONKeyValueDeserializationSchema throws
[
https://issues.apache.org/jira/browse/FLINK-9758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-9758.
-
Resolution: Fixed
Fix Version/s: (was: 1.5.2)
1.6.0
> Conti
[
https://issues.apache.org/jira/browse/FLINK-8731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544632#comment-16544632
]
ASF GitHub Bot commented on FLINK-8731:
---
GitHub user dawidwys opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-8731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8731:
--
Labels: pull-request-available test-stability (was: test-stability)
> TwoInputStreamTaskTest f
GitHub user dawidwys opened a pull request:
https://github.com/apache/flink/pull/6338
[FLINK-8731] Replaced mockito with custom mock in TestInputChannel
Replaced questionable usage if Mockito with custom written mock.
You can merge this pull request into a Git repository by running
[
https://issues.apache.org/jira/browse/FLINK-9758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544631#comment-16544631
]
ASF GitHub Bot commented on FLINK-9758:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544629#comment-16544629
]
ASF GitHub Bot commented on FLINK-8544:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544630#comment-16544630
]
ASF GitHub Bot commented on FLINK-9483:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6109
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6260
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5516
---
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544617#comment-16544617
]
ASF GitHub Bot commented on FLINK-9675:
---
Github user tedyu commented on the issue:
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/6335
From https://travis-ci.org/apache/flink/jobs/404127448 :
```
Failed tests:
BlobServerPutTest.testPutBufferFailsIncomingForJob
Expected: (an instance of java.io.IOException and excepti
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6326
Pushed another commit that rebuilds the generated config docs
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6050
---
[
https://issues.apache.org/jira/browse/FLINK-9404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544611#comment-16544611
]
ASF GitHub Bot commented on FLINK-9404:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544603#comment-16544603
]
ASF GitHub Bot commented on FLINK-9061:
---
Github user StephanEwen commented on the i
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6302
Thanks for this contribution, that's a valuable fix. I have a few thoughts
and suggestions on how we might improve the feature a bit still:
- Can we get id of the `commons-text` depende
[
https://issues.apache.org/jira/browse/FLINK-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544602#comment-16544602
]
ASF GitHub Bot commented on FLINK-9121:
---
Github user Matrix42 commented on a diff i
Github user Matrix42 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5801#discussion_r202548776
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ---
@@ -49,30 +54,45 @@ public YarnClusterDescriptor(
@Ove
[
https://issues.apache.org/jira/browse/FLINK-9829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544599#comment-16544599
]
ASF GitHub Bot commented on FLINK-9829:
---
Github user StephanEwen commented on the i
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6321
Is the issue addressed here a bug?
If not, and if it seems that the original authors of the code had an
intention of writing the code as it is now, I would suggest to leave it as it
is.
---
[
https://issues.apache.org/jira/browse/FLINK-9829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544598#comment-16544598
]
ASF GitHub Bot commented on FLINK-9829:
---
Github user StephanEwen commented on the i
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6321
This would be clearly not a hotfix. As per the pull request template,
contributors should use hotfixes mainly for typos and JavaDoc updates.
---
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544554#comment-16544554
]
ASF GitHub Bot commented on FLINK-9794:
---
Github user jrthe42 commented on the issue
Github user jrthe42 commented on the issue:
https://github.com/apache/flink/pull/6301
Hi @hequn8128, I agree with you that a connection pool is more effective
using connection resource. I didn't choose connection pool because that will
introduce new dependencies, and I'm not sure if t
[
https://issues.apache.org/jira/browse/FLINK-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544549#comment-16544549
]
ASF GitHub Bot commented on FLINK-9841:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6329
@dawidwys can you review this PR?
---
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544544#comment-16544544
]
ASF GitHub Bot commented on FLINK-9675:
---
Github user zhangminglei commented on the
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6335
@tedyu Could you please take a look on this ? Thank you very much.
---
[
https://issues.apache.org/jira/browse/FLINK-9853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9853:
--
Labels: pull-request-available (was: )
> add hex support in table api and sql
> --
[
https://issues.apache.org/jira/browse/FLINK-9853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544542#comment-16544542
]
ASF GitHub Bot commented on FLINK-9853:
---
GitHub user xueyumusic opened a pull reque
GitHub user xueyumusic opened a pull request:
https://github.com/apache/flink/pull/6337
[FLINK-9853][Tabel API & SQL] add HEX support
## What is the purpose of the change
This PR propose to add HEX in table api and sql, the syntax like mysql,
which could take int or string argu
1 - 100 of 124 matches
Mail list logo
