Piotr Nowojski created FLINK-9717:
-
Summary: Flush state of one side of the join if other side is
bounded
Key: FLINK-9717
URL: https://issues.apache.org/jira/browse/FLINK-9717
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-9712:
-
Assignee: Piotr Nowojski
> Support enrichment joins in Flink SQL/Table API
> ---
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-9713:
-
Assignee: Piotr Nowojski
> Support versioned joins in planning phase
> -
Github user zjffdu commented on a diff in the pull request:
https://github.com/apache/flink/pull/6140#discussion_r199750956
--- Diff:
flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala ---
@@ -255,14 +257,25 @@ object FlinkShell {
yarnConfig.queue
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6242
-1
The PR description is outdated, the CLI only lists jobs in non-terminal
states as running, i.e. CANCELED, FAILED and FINISHED jobs are not included.
For all intents and purposes this is th
[
https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531142#comment-16531142
]
ASF GitHub Bot commented on FLINK-9711:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531138#comment-16531138
]
ASF GitHub Bot commented on FLINK-9554:
---
Github user zjffdu commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9674.
---
Resolution: Fixed
Fix Version/s: 1.6.0
master: 41277f6b7447f3542e439b7ae82b99be862df7c
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9674:
Affects Version/s: (was: 1.5.0)
> Remove 65s sleep in QueryableState E2E test
> ---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5899
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5297
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6025
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6216
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5901
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6211
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5888
---
[
https://issues.apache.org/jira/browse/FLINK-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9235:
--
Labels: pull-request-available (was: )
> Add Integration test for Flink-Yarn-Kerberos integrat
[
https://issues.apache.org/jira/browse/FLINK-9665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531147#comment-16531147
]
ASF GitHub Bot commented on FLINK-9665:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531148#comment-16531148
]
ASF GitHub Bot commented on FLINK-9194:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531149#comment-16531149
]
ASF GitHub Bot commented on FLINK-9674:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531150#comment-16531150
]
ASF GitHub Bot commented on FLINK-9235:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9194:
--
Labels: flip-6 pull-request-available (was: flip-6)
> Finished jobs are not archived to Histor
[
https://issues.apache.org/jira/browse/FLINK-8434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531146#comment-16531146
]
ASF GitHub Bot commented on FLINK-8434:
---
Github user asfgit closed the pull request
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6140#discussion_r199752165
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java ---
@@ -166,6 +166,10 @@ public Configuration getConfiguration() {
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531151#comment-16531151
]
ASF GitHub Bot commented on FLINK-9554:
---
Github user zentol commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9707:
-
Description:
The {{LocalFileSystem}} does not support concurrent directory creations. The
conseq
Github user azagrebin commented on the issue:
https://github.com/apache/flink/pull/6196
@StefanRRichter
I added more precomputed fields to `CompositeSerializer` constructor and
included `TtlStateFactory` in TTL tests.
---
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531159#comment-16531159
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user azagrebin commented on the iss
Github user satybald commented on the issue:
https://github.com/apache/flink/pull/6242
I'd agree with you that CREATED, RESTARTING and RUNNING is part of the
definition of the running job.
However, CLI does include CANCELED jobs as RUNNING one if --running options
is provide
[
https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531165#comment-16531165
]
ASF GitHub Bot commented on FLINK-9711:
---
Github user satybald commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531171#comment-16531171
]
ASF GitHub Bot commented on FLINK-9711:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6242
I take it that happens in 1.5.0? If so, this was already fixed for master
and 1.5.1.
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6242
see https://issues.apache.org/jira/browse/FLINK-9398
---
[
https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531172#comment-16531172
]
Fabian Hueske commented on FLINK-9717:
--
There is another aspect to consider when imp
[
https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531174#comment-16531174
]
ASF GitHub Bot commented on FLINK-9711:
---
Github user zentol commented on the issue:
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199758405
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -17,154 +17,338 @@
packag
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531176#comment-16531176
]
ASF GitHub Bot commented on FLINK-9444:
---
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/6218#discussion_r199759148
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -17,154 +17,338 @@
packag
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531177#comment-16531177
]
ASF GitHub Bot commented on FLINK-9444:
---
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/6218#discussion_r199759847
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -17,154 +17,338 @@
packag
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531178#comment-16531178
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user twalthr commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6140#discussion_r199760506
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java ---
@@ -166,6 +166,10 @@ public Configuration getConfiguration() {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6140#discussion_r199760246
--- Diff: flink-scala-shell/start-script/start-scala-shell.sh ---
@@ -19,6 +19,9 @@
# from scala-lang 2.10.4
+# Uncomment the following li
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531182#comment-16531182
]
ASF GitHub Bot commented on FLINK-9554:
---
Github user zentol commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531181#comment-16531181
]
ASF GitHub Bot commented on FLINK-9554:
---
Github user zentol commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199761646
--- Diff:
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverterTest.java
---
@@ -0,0 +1,71 @@
+/*
+ * L
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6084#discussion_r199761621
--- Diff: docs/quickstart/java_api_quickstart.md ---
@@ -111,7 +111,7 @@ In IntelliJ IDEA recommended way to change JVM options
is from the `Help | Edit
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531189#comment-16531189
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531190#comment-16531190
]
ASF GitHub Bot commented on FLINK-8654:
---
Github user zentol commented on a diff in
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6047
---
[
https://issues.apache.org/jira/browse/FLINK-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8654:
Affects Version/s: 1.6.0
1.4.2
> Extend quickstart docs on how to su
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6084
---
[
https://issues.apache.org/jira/browse/FLINK-8160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8160:
--
Labels: pull-request-available (was: )
> Extend OperatorHarness to expose metrics
> --
[
https://issues.apache.org/jira/browse/FLINK-8160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531194#comment-16531194
]
ASF GitHub Bot commented on FLINK-8160:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531193#comment-16531193
]
ASF GitHub Bot commented on FLINK-8654:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8654.
---
Resolution: Fixed
Fix Version/s: 1.5.1
1.4.3
1.6.
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/6243
[FLINK-9707] Support concurrent directory creations in LocalFileSystem
## What is the purpose of the change
Support concurrent directory creations by accepting directories which have
b
[
https://issues.apache.org/jira/browse/FLINK-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9707:
--
Labels: pull-request-available (was: )
> LocalFileSystem does not support concurrent directory
[
https://issues.apache.org/jira/browse/FLINK-9707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531233#comment-16531233
]
ASF GitHub Bot commented on FLINK-9707:
---
GitHub user tillrohrmann opened a pull req
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/6201
I agree with @fhueske. Let's do the `from-source` in a follow-up issue. I
will open a PR soon for FLINK-8558 which separates connector and format. For
this I also introduced a method `KafkaTableSourc
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531237#comment-16531237
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user twalthr commented on the issue
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6102#discussion_r199776329
--- Diff: tools/check_dependency_convergence.sh ---
@@ -0,0 +1,67 @@
+#!/usr/bin/env bash
+###
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/6244
[FLINK-9622] Do not swallow exceptions in FileUtils#copy
## What is the purpose of the change
This commit lets `IOExceptions` originating from `FileUtil#copy` bubble up
instead of swal
[
https://issues.apache.org/jira/browse/FLINK-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531240#comment-16531240
]
ASF GitHub Bot commented on FLINK-9622:
---
GitHub user tillrohrmann opened a pull req
[
https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531239#comment-16531239
]
ASF GitHub Bot commented on FLINK-9091:
---
Github user zentol commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9622:
--
Labels: pull-request-available (was: )
> DistributedCacheDfsTest failed on travis
> --
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6102#discussion_r199776816
--- Diff: tools/check_dependency_convergence.sh ---
@@ -0,0 +1,67 @@
+#!/usr/bin/env bash
+###
[
https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531242#comment-16531242
]
ASF GitHub Bot commented on FLINK-9091:
---
Github user zentol commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-9578.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed in 1.6.0: 19040a632c66af64d49707cdf07adb25af0
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6160
---
[
https://issues.apache.org/jira/browse/FLINK-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531249#comment-16531249
]
ASF GitHub Bot commented on FLINK-9578:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9578:
--
Labels: pull-request-available (was: )
> Allow to define an auto watermark interval in SQL Cli
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199778602
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -148,25 +148,26 @@ public AvroRowD
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199780249
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -17,154 +17,338 @@
pack
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531252#comment-16531252
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user pnowojski commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531251#comment-16531251
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user pnowojski commented on a diff
Github user satybald closed the pull request at:
https://github.com/apache/flink/pull/6242
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6203#discussion_r199780490
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java
---
@@ -79,6 +79,7 @@ protected void respondToRequ
Github user satybald commented on the issue:
https://github.com/apache/flink/pull/6242
yep, it's flink 1.5.0. I'm closing PR then.
---
[
https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531255#comment-16531255
]
ASF GitHub Bot commented on FLINK-9711:
---
Github user satybald closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531254#comment-16531254
]
ASF GitHub Bot commented on FLINK-9711:
---
Github user satybald commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531256#comment-16531256
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6203#discussion_r199780706
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java
---
@@ -105,7 +106,8 @@ protected void respondToRe
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531258#comment-16531258
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user tillrohrmann commented on a di
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199780422
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -201,71 +202,69 @@ private Object
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199781443
--- Diff:
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverterTest.java
---
@@ -0,0 +1,71 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531263#comment-16531263
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user pnowojski commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531264#comment-16531264
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user pnowojski commented on a diff
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r199782303
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java
---
@@ -0,0 +1,275 @@
+/*
+ * Licensed to t
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/6206
@zsolt-donca I actually added some test to my branch
https://github.com/tillrohrmann/flink/commits/FLINK-9654. If this should cover
your fix, then I could merge your PR with this test. What do y
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6218#discussion_r199782571
--- Diff: flink-formats/flink-avro/pom.xml ---
@@ -51,6 +51,17 @@ under the License.
+
+
[
https://issues.apache.org/jira/browse/FLINK-9654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531266#comment-16531266
]
ASF GitHub Bot commented on FLINK-9654:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531265#comment-16531265
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user StefanRRichter commented on a
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531269#comment-16531269
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user pnowojski commented on a diff
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r199782860
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java
---
@@ -0,0 +1,275 @@
+/*
+ * Licensed to t
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r199783102
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala
---
@@ -1029,6 +1029,29 @@ object temporalOverlaps
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531270#comment-16531270
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user StefanRRichter commented on a
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531274#comment-16531274
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user twalthr commented on a diff in
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r199783587
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java
---
@@ -0,0 +1,275 @@
+/*
+ * Licensed to t
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6222#discussion_r199783421
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java
---
@@ -66,6 +67,9 @@ public JobSubmitHandler(
101 - 200 of 495 matches
Mail list logo