GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/2916
[FLINK-4523] [kinesis] Allow Kinesis Consumer to start from specific
timestamp / Date
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tony81
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711248#comment-15711248
]
ASF GitHub Bot commented on FLINK-4523:
---
GitHub user tony810430 opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711289#comment-15711289
]
ASF GitHub Bot commented on FLINK-5023:
---
Github user shixiaogang commented on the is
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/2768
I rebased the branch to resolve the conflicts with the master branch.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your proje
shijinkui created FLINK-5217:
Summary: Deprecated interface Checkpointed make clear suggestion
Key: FLINK-5217
URL: https://issues.apache.org/jira/browse/FLINK-5217
Project: Flink
Issue Type: Imp
[
https://issues.apache.org/jira/browse/FLINK-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711460#comment-15711460
]
shijinkui commented on FLINK-5217:
--
hi, [~StephanEwen] , can you complete this?
> Depre
[
https://issues.apache.org/jira/browse/FLINK-5194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5194.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
Fixed 8228ac6 (master), ffe6b6b (
[
https://issues.apache.org/jira/browse/FLINK-5201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5201.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
Fixed in dc5650a (master), c8ade6
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90410106
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90408543
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
---
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711500#comment-15711500
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5198.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
Fixed in dc7d8ec (master), ee478f
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711504#comment-15711504
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5196.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
Fixed in 67bd827 (master), 7b9a44
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711503#comment-15711503
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711499#comment-15711499
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711501#comment-15711501
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90410148
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90411159
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90410957
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711502#comment-15711502
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90411420
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerTest.java
---
@
[
https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4574:
--
Assignee: Wei-Che Wei
> Strengthen fetch interval implementation in Kinesis consumer
>
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711498#comment-15711498
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90410691
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90410520
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@ -230
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711497#comment-15711497
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5199.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
Fixed in f91dd9f (master), 8d949c
[
https://issues.apache.org/jira/browse/FLINK-5207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5207.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
Fixed in bf859e7 (master), 28e44e
[
https://issues.apache.org/jira/browse/FLINK-5192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5192.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
Fixed in 7d66aae (master), 357b93
[
https://issues.apache.org/jira/browse/FLINK-4330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711574#comment-15711574
]
Anton Mushin commented on FLINK-4330:
-
Hi everyone.
Components name in this issue conf
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711579#comment-15711579
]
Fabian Hueske commented on FLINK-5185:
--
Hi [~ykt836], you are right, I did not consid
Github user tony810430 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90420204
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerTest.java
---
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711587#comment-15711587
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tony810430 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711592#comment-15711592
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tony810430 commented on a diff
Github user tony810430 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90420632
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@ -2
Github user tony810430 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90420737
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711598#comment-15711598
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tony810430 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711605#comment-15711605
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tony810430 commented on a diff
Github user tony810430 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90420855
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711604#comment-15711604
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tony810430 commented on a diff
Github user tony810430 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90420861
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
-
[
https://issues.apache.org/jira/browse/FLINK-5173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711620#comment-15711620
]
Aljoscha Krettek commented on FLINK-5173:
-
Done in 6377ef00feb0244276d6f409baa4611
[
https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711641#comment-15711641
]
ASF GitHub Bot commented on FLINK-5091:
---
Github user Makman2 commented on a diff in
Github user Makman2 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2915#discussion_r90423588
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java
---
@@ -39,12 +39,31 @@
public static final String F
[
https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711644#comment-15711644
]
ASF GitHub Bot commented on FLINK-5091:
---
Github user Makman2 commented on a diff in
Github user Makman2 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2915#discussion_r90423889
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -1372,6 +1381,12 @@
/** The environment variable name wh
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711681#comment-15711681
]
Ufuk Celebi commented on FLINK-3160:
OK, there was some confusion on my side, because
Stephan Ewen created FLINK-5218:
---
Summary: Eagerly close checkpoint streams on cancellation
Key: FLINK-5218
URL: https://issues.apache.org/jira/browse/FLINK-5218
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-5219:
--
Summary: Add non-grouped session windows for batch tables
Key: FLINK-5219
URL: https://issues.apache.org/jira/browse/FLINK-5219
Project: Flink
Issue Type: Sub-ta
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711763#comment-15711763
]
Aljoscha Krettek commented on FLINK-5218:
-
This seems to be a duplicate of FLINK-5
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2905
Thanks for the patch!
Is there another place where the client now gets shut down properly?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
[
https://issues.apache.org/jira/browse/FLINK-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711919#comment-15711919
]
ASF GitHub Bot commented on FLINK-5190:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711938#comment-15711938
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711935#comment-15711935
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711943#comment-15711943
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711944#comment-15711944
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711937#comment-15711937
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711941#comment-15711941
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711939#comment-15711939
]
ASF GitHub Bot commented on FLINK-4469:
---
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/2653#discussion_r90036667
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/CodeGenerator.scala
---
@@ -753,8 +777,9 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711931#comment-15711931
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711942#comment-15711942
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711932#comment-15711932
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711940#comment-15711940
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711936#comment-15711936
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711933#comment-15711933
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711934#comment-15711934
]
ASF GitHub Bot commented on FLINK-4469:
---
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/2653#discussion_r90425776
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/FlinkCorrelate.scala
---
@@ -0,0 +1,152 @@
+/*
+ * License
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90421294
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/FlinkCorrelate.scala
---
@@ -0,0 +1,152 @@
+/*
+ * License
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90419246
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/TableFunction.scala
---
@@ -0,0 +1,121 @@
+/*
+ * Licensed
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90059865
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala
---
@@ -411,22 +416,31 @@ case class Join(
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90034800
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/CodeGenerator.scala
---
@@ -334,18 +337,33 @@ class CodeGenerator(
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90033099
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/TableFunctionCall.scala
---
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90029320
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/BatchTableEnvironment.scala
---
@@ -139,4 +140,15 @@ class BatchTableEn
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90442225
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -451,6 +452,28 @@ object Expression
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90029283
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/StreamTableEnvironment.scala
---
@@ -142,4 +143,14 @@ class StreamTable
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90426441
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/FlinkCorrelate.scala
---
@@ -0,0 +1,152 @@
+/*
+ * License
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90038389
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/CodeGenerator.scala
---
@@ -1332,16 +1360,17 @@ class CodeGenerator(
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90050627
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/SqlFunctionUtils.scala
---
@@ -28,14 +28,14 @@ import org.apach
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r90052039
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/TableFunctionCallGen.scala
---
@@ -0,0 +1,78 @@
+/*
+ *
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2811
Thanks for the update @AlexanderShoshin.
PR is good to merge!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2910#discussion_r90446364
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -505,37 +507,31 @@ class JobManager(
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711981#comment-15711981
]
ASF GitHub Bot commented on FLINK-5193:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711988#comment-15711988
]
Stephan Ewen commented on FLINK-5218:
-
True, will close one of the issues.
> Eagerly
[
https://issues.apache.org/jira/browse/FLINK-5215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5215.
---
Resolution: Duplicate
Duplicated by FLINK-5218
Closed in favor of the newer issue (which is already r
[
https://issues.apache.org/jira/browse/FLINK-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711997#comment-15711997
]
Stephan Ewen commented on FLINK-5217:
-
Agreed, this should add a comment to refer to t
[
https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712013#comment-15712013
]
ASF GitHub Bot commented on FLINK-3921:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2901
Hi @greghogan, thanks for working on this. The changes look good.
However, I think we need to propagate the configured charset also to the
`DelimitedInputFormat`. `DelimitedInputFormat` splits th
[
https://issues.apache.org/jira/browse/FLINK-5159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711967#comment-15711967
]
ASF GitHub Bot commented on FLINK-5159:
---
Github user fhueske commented on the issue:
Github user ddolzan closed the pull request at:
https://github.com/apache/flink/pull/2790
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is ena
Github user ddolzan commented on the issue:
https://github.com/apache/flink/pull/2790
Index template and index mapping creation/configuration will be kept
outside of flink.
An example on how to do it can be found on
https://github.com/okkam-it/flink-examples.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712047#comment-15712047
]
ASF GitHub Bot commented on FLINK-4491:
---
Github user ddolzan closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712048#comment-15712048
]
ASF GitHub Bot commented on FLINK-4491:
---
Github user ddolzan commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2842
@vasia You are right. The `TypeExtractor` doesn't support functions with
more than 2 inputs. That has never been required so far as the runtime
operators always have two inputs. You could open an iss
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712056#comment-15712056
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712061#comment-15712061
]
ASF GitHub Bot commented on FLINK-4491:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2790
Thank you @ddolzan
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, o
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2762
Hi @mushketyk, do you plan to continue with this PR?
Thanks, Fabian
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your pr
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712083#comment-15712083
]
Kurt Young commented on FLINK-5185:
---
Hi [~fhueske], you are right about the schema thing
1 - 100 of 211 matches
Mail list logo
